Client tests

application/api/example.1/getClientInfo.js

@@ -3,7 +3,9 @@
   method: async () => {
     const { uuid, session, client } = context;
     const { ip } = client;
-    const { token, accountId } = session;
-    return { result: { ip, token, accountId, uuid } };
+    const { token } = session;
+    const accountId = session.state.accountId;
+    const result = { ip, token, accountId, uuid };
+    return { result };
   },
 });

application/api/example.1/hook.js

@@ -2,6 +2,6 @@
   router({ method, args, verb, headers }) {
     const ip = context.client.ip;
     console.log({ method, args, ip, verb, headers });
-    return {success:true, method, args, ip, verb, headers };
+    return { success: true, method, args, ip, verb, headers };
   },
 });

application/api/example.1/redisGet.js

@@ -1,7 +1,7 @@
 ({
   access: 'public',
   method: async ({ key }) => {
-    const result = await lib.redis.get(key);
+    const result = await db.redis.get(key);
     return { result };
   },
 });

application/api/example.1/redisSet.js

@@ -1,7 +1,7 @@
 ({
   access: 'public',
   method: async ({ key, value }) => {
-    const result = await lib.redis.set(key, value);
+    const result = await db.redis.set(key, value);
     return { result };
   },
 });

application/api/example.1/uploadFile.js

@@ -5,5 +5,5 @@ async ({ name, data }) => {
   if (filePath.startsWith(tmpPath)) {
     await node.fsp.writeFile(filePath, buffer);
   }
-  return { uploaded: data.length };
+  return { uploaded: data.data.length };
 };

application/api/files.1/upload.js

@@ -1,5 +1,13 @@
 async ({ streamId, name }) => {
   const filePath = `./application/resources/${name}`;
+  let exist = false;
+  try {
+    await node.fsp.access(filePath);
+    exist = true;
+  } catch (err) {
+    console.error(err);
+  }
+  if (exist) return { result: `File ${name} already exist on server` };
   // Get incoming stream by streamId sent from client
   const readable = context.client.getStream(streamId);
   // Create nodejs stream to write file on server

application/api/hook.1.js

@@ -2,6 +2,6 @@
   router({ method, args, verb, headers }) {
     const ip = context.client.ip;
     console.log({ method, args, ip, verb, headers });
-    return {};
+    return { success: true, args };
   },
 });

application/db/redis/get.js

@@ -1,7 +1 @@
-(key) =>
-  new Promise((resolve, reject) => {
-    lib.redis.client.get(key, (err, result) => {
-      if (err) reject(err);
-      else resolve(result);
-    });
-  });
+(key) => db.redis.client.get(key);

application/db/redis/set.js

@@ -1,7 +1 @@
-(key, value) =>
-  new Promise((resolve, reject) => {
-    lib.redis.client.set(key, value, (err, result) => {
-      if (err) reject(err);
-      else resolve(result);
-    });
-  });
+async (key, value) => db.redis.client.set(key, value);

application/db/redis/start.js

@@ -10,5 +10,5 @@ async () => {
     }
     client.quit();
   });
-  //await client.connect();
+  await client.connect();
 };

application/lib/task1/start.js

@@ -1,13 +1,13 @@
 async () => {
   if (application.worker.id === 'W1') {
-    setTimeout(async () => {
-      const res = await application.scheduler.add({
-        name: 'name',
-        every: 'Sep 10th 10s',
-        args: { i: 2 },
-        run: 'lib.task1.f1',
-      });
-      console.log('Add task', res);
-    }, 1000);
+    // setTimeout(async () => {
+    //   const res = await application.scheduler.add({
+    //     name: 'name',
+    //     every: 'Sep 10th 10s',
+    //     args: { i: 2 },
+    //     run: 'lib.task1.f1',
+    //   });
+    //   console.log('Add task', res);
+    // }, 1000);
   }
 };

docker-compose.yml

@@ -33,6 +33,12 @@ services:
       - 127.0.0.1:5432:5432
     restart: always
 
+  redis-example:
+    image: redis:alpine
+    container_name: redis-example
+    ports:
+      - 127.0.0.1:6379:6379
+    restart: always
 networks:
   default:
     name: api-example-network