stable version

Author: vfssantos

.gitignore

@@ -11,7 +11,7 @@ coverage
 dist
 
 # Deno logs
-logs
+logs/
 
 # .env file
 .env
@@ -21,7 +21,7 @@ data
 cache
 
 # Deno lock file
-lock.json
+deno-lock.json
 
 # Deno dependencies
 deps
@@ -33,4 +33,10 @@ deps
 test-migrations.js
 
 # passwords
-passwords.txt
+passwords.txt
+
+# Cursor rules
+.cursorrules
+
+# test-data
+test-data

deno.json

@@ -1,8 +1,8 @@
 {
     "tasks": {
-        "start": "DENO_DIR=./data/local/cache/.deno ENV=production deno run -A --importmap=deno.json --reload=http://localhost --no-lock --unstable-sloppy-imports  --no-prompt --unstable https://raw.githubusercontent.com/AxionCompany/functions/develop/main.ts",
-        "dev": "DENO_DIR=./data/local/cache/.deno ENV=development WATCH=true deno run --importmap=deno.json --reload=http://localhost,https://raw.githubusercontent.com/AxionCompany/functions/develop -A --no-lock --unstable-sloppy-imports  --no-prompt --unstable https://raw.githubusercontent.com/AxionCompany/functions/develop/main.ts",
-        "dev:local": "DENO_DIR=./data/local/cache/.deno ENV=development WATCH=true deno run --importmap=deno.json --reload=http://localhost  -A --no-lock --unstable-sloppy-imports  --no-prompt --unstable http://localhost:9000"
+        "start": "DENO_DIR=./data/local/cache/.deno ENV=production deno run -A --importmap=deno.json --reload=http://http://local@localhost:8000 --no-lock --unstable-sloppy-imports  --no-prompt --unstable https://raw.githubusercontent.com/AxionCompany/functions/develop/main.ts",
+        "dev": "DENO_DIR=./data/local/cache/.deno ENV=development WATCH=true deno run --importmap=deno.json --reload=http://local@localhost:8000,https://raw.githubusercontent.com/AxionCompany/functions/release -A --no-lock --unstable-sloppy-imports  --no-prompt --unstable https://raw.githubusercontent.com/AxionCompany/functions/release/main.ts",
+        "dev:local": "DENO_DIR=./data/local/cache/.deno ENV=development WATCH=true deno run --importmap=deno.json --reload=http://local@localhost:9000  -A --no-lock --unstable-sloppy-imports  --no-prompt --unstable http://localhost:9000"
     },
     "imports": {
         "axion-components/": "http://AxionCompany--axions-web--main:{{GIT_API_KEY}}@localhost:9000/src/components/",

deno.lock

@@ -0,0 +1,51 @@
+// Function to make one round of parallel requests
+async function makeRequests(round) {
+    const url = "http://localhost:8001/api/agents/functionCall";
+    const data = {
+      copilotzId: 1,
+      input: "sim, por favor",
+      user: {
+        id: "user123",
+        name: "John Doe"
+      },
+      thread: {
+        extId: "thread456"
+      }
+    };
+  
+    const headers = {
+      "Content-Type": "application/json"
+    };
+  
+    // Array of parallel fetch requests
+    const requests = Array.from({ length: 5 }, () =>
+      fetch(url, {
+        method: "POST",
+        headers,
+        body: JSON.stringify(data)
+      })
+    );
+  
+    // Execute all requests in parallel
+    console.log(`Starting round ${round}`);
+    const responses = await Promise.all(requests);
+  
+    // Log response status for each request
+    responses.forEach((response, i) => {
+      console.log(`Request ${i + 1} in round ${round}: Status ${response.status}`);
+    });
+  }
+  
+  // Function to make Y rounds with X seconds interval
+  async function makeRounds(x, y) {
+    for (let i = 0; i < y; i++) {
+      await makeRequests(i + 1);
+      if (i < y - 1) {
+        console.log(`Waiting for ${x} seconds before next round...`);
+        await new Promise(resolve => setTimeout(resolve, x * 1000)); // Wait for X seconds
+      }
+    }
+  }
+  
+  // Usage: X = interval in seconds, Y = number of rounds
+  makeRounds(3, 2);

load-test.js

@@ -0,0 +1,21 @@
+const getConfig = async (req) => {
+
+    const { models,  resources } = getConfig;
+
+    const { copilotz } = resources;
+
+    // Get the Copilotz's configuration
+    const configsArr = await models.configs.find({ owner: copilotz._id, type: 'copilotz' });
+
+    // Convert the configuration array to an object
+    const config = configsArr.reduce((obj, c) => {
+        obj[c.name] = c.value;
+        return obj;
+    }, {});
+
+    getConfig.resources.config = config;
+    
+    return req;
+}
+
+export default getConfig;

src/api/_middlewares/getConfig.js

@@ -0,0 +1,45 @@
+
+const getCopilotz = async (req) => {
+
+    const { extId, copilotzId, channel } = req.params;
+    const { models } = getCopilotz;
+
+    let copilotzDoc;
+
+    if (copilotzId || extId) {
+
+        if (copilotzId) {
+            // Firts, try to find the Copilotz by its id
+            copilotzDoc = await models.copilotz.findOne({
+                _id: copilotzId,
+            });
+        }
+        // If not found, try to find the Copilotz by its external id
+        else if (extId) {
+            const mapper = await models.mappings.findOne({
+                extId,
+                resource: 'copilotz',
+                type: channel,
+            }, { populate: ['copilotz'] });
+
+            copilotzDoc = mapper.copilotz
+        };
+
+        // If no Copilotz found, return an error
+        if (!copilotzDoc) {
+            throw { status: 404, message: 'Copilotz not found' };
+        }
+
+        const actions = await Promise.all(copilotzDoc?.actions?.map(async (action) => {
+            return await models.actions.findOne({ _id: action });
+        }) || []);
+
+        copilotzDoc.actions = actions;
+
+        getCopilotz.resources.copilotz = copilotzDoc;
+
+        return req;
+    }
+}
+
+export default getCopilotz;

src/api/_middlewares/getCopilotz.js

@@ -0,0 +1,23 @@
+
+const getJob = async (req) => {
+    const { resources, models } = getJob;
+
+    const { copilotz } = resources;
+
+    if (!copilotz.job) return;
+
+    const job = await models.jobs.findOne({ _id: copilotz.job }, { populate: ['actions'] });
+
+
+    const workflow = await models.workflows.findOne({ _id: job.defaultWorkflow }, { populate: ['steps'] });
+
+    job.defaultWorkflow = workflow;
+
+    copilotz.job = job;
+
+    getJob.resources.copilotz = copilotz;
+
+    return req;
+}
+
+export default getJob;

src/api/_middlewares/getJob.js

@@ -0,0 +1,24 @@
+const getSubscription = async (req) => {
+
+    const { models, payments } = getSubscription;
+
+    const { resources } = getSubscription;
+
+    const { user, copilotz } = resources;
+
+    const subscriptionDoc = await models.subscriptions.findOne(
+        { user: user?._id, copilotz: copilotz?._id }
+    );
+
+    if (!subscriptionDoc || !payments[subscriptionDoc?.paymentProvider]) return;
+
+    const subscriptionData = await payments[subscriptionDoc.paymentProvider].subscriptions.get(
+        { subscriptionId: subscriptionDoc.subscriptionId }
+    );
+
+    getSubscription.resources.subscription = subscriptionData;
+
+    return req;
+}
+
+export default getSubscription;

src/api/_middlewares/getSubscription.js

@@ -0,0 +1,35 @@
+const getUsers = async (req) => {
+
+    const { models } = getUsers;
+
+    if (!req?.params.user.name) return;
+
+    let usersPhonePromise, usersEmailPromise;
+    if (req.params?.user?.phone) {
+        usersPhonePromise = models.users.findOne({ phone: req.params?.user?.phone });
+    }
+    if (req.params?.user?.email) {
+        usersEmailPromise = models.users.findOne({ email: req.params?.user?.email });
+    }
+
+    const usersResolved = await Promise.all([usersPhonePromise, usersEmailPromise]);
+    let user = usersResolved[0] || usersResolved[1];
+
+    if (!user) {
+
+        user = await models.users.create({
+            phone: req.params?.user?.phone,
+            email: req.params?.user?.email,
+            name: req.params?.user?.name || 'Guest',
+            context: req.params?.user?.context || {},
+        });
+
+    }
+
+    getUsers.resources.user = user;
+
+    return req;
+
+}
+
+export default getUsers;

src/api/_middlewares/getUser.js

@@ -0,0 +1,7 @@
+export { default as getUser } from './getUser.js';
+export { default as getCopilotz } from './getCopilotz.js';
+export { default as getConfig } from './getConfig.js';
+export { default as getJob } from './getJob.js';
+export { default as getSubscription } from './getSubscription.js';
+
+

src/api/_middlewares/main.js

@@ -63,17 +63,15 @@ const ParseOpenApiSpec = ({ spec, module: request }) => {
       // Combine all the parts
       const spec = `(${summary}):${formattedArgs}->${responses["200"].description}`;
 
-      const request = ({ _user, ...params }) => (
+      actions[operationId] = ({ _user, ...params }) => request(
         new URL(path, baseUrl).href,
         {
           method,
           headers: request?.globals?.headers,
-          data: { ...validate(schema.body, { ...request?.globals?.body, ...params }), _user },
+          body: { ...validate(schema.body, { ...request?.globals?.body, ...params }), _user },
           query: validate(schema.query, { ...request?.globals?.query, ...params }),
         }
       );
-
-      actions[operationId] = request;
       actions[operationId].spec = spec;
     }
   }