fix: rm unnedded calls, wss tidy

zetxx · Apr 5, 2024 · ccafb6a · ccafb6a
1 parent 8d9faa5
commit ccafb6a
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 22 deletions.
diff --git a/lib/loader.js b/lib/loader.js
@@ -46,21 +46,20 @@ module.exports = () => {
                 .reduce((prev, curr) => {
                     const ln = layerProps(curr, createConfig, Config);
                     console.log(`Add Layer: ${ln.layerName} for namespace ${ln.namespace}`);
-                    const comp = curr({
+                    return curr({
                         prev,
                         config: ln.config,
                         wires,
                         list: methodsList,
                         allMethods
                     });
-                    return () => comp;
                 },
-                () => Methods({
+                Methods({
                     wires,
                     list: methodsList,
                     config: layerProps(Methods, createConfig, Config).config
                 }));
-            const comp = new (Component());
+            const comp = new Component();
             components.push(comp);
             return api;
         },

diff --git a/lib/logger.js b/lib/logger.js
@@ -14,11 +14,9 @@ log4js.configure({
 const loggers = new Map();
 const Logger = ({
     prev,
-    config,
-    wires,
-    list
+    config
 }) => {
-    class logger extends prev({wires, list, config}) {
+    class logger extends prev {
         log(level, ...rest) {
             let l = loggers.get(this.namespace);
             if (!l) {

diff --git a/lib/sql.js b/lib/sql.js
@@ -4,11 +4,9 @@ const exposeMethods = require('expose-sql-methods/lib/postgres');
 
 const Sql = ({
     prev,
-    config,
-    wires,
-    list
+    config
 }) => {
-    class sql extends prev({wires, list}) {
+    class sql extends prev {
         async init() {
             this.log('info', 'Sql', 'Init');
             await migration({

diff --git a/lib/wss.js b/lib/wss.js
@@ -33,11 +33,9 @@ const dumpingComm = (fn) => {
 };
 const Wss = ({
     prev,
-    config,
-    wires,
-    list
+    config
 }) => {
-    class wss extends prev({wires, list}) {
+    class wss extends prev {
         constructor() {
             super();
             this.server = undefined;
@@ -65,7 +63,7 @@ const Wss = ({
         }
         async init() {
             this.log('info', 'Wss', 'Init');
-            await this.connect();
+            await this.initWssServer();
             this.add({name: this.namespace + '.write', fn: async(message) => {
                 try {
                     if (!message.id) {
@@ -266,11 +264,15 @@ const Wss = ({
             this.refreshConnection(id);
             return this.connections.get(id)?.connection;
         }
-        async connect() {
+        async initWssServer() {
             return await (new Promise((resolve, reject) => {
                 this.server = new WebSocketServer({
                     port: config.port
                 });
+                this.server.on('error', (error) => {
+                    this.log('error', 'Wss', error);
+                    reject(error);
+                });
                 this.server.on('connection', async(wsClient, req) => {
                     const connectionId = uuidv4();
                     try {
@@ -296,10 +298,6 @@ const Wss = ({
                         wsClient.close();
                     }
                 });
-                this.server.on('error', (error) => {
-                    this.log('error', 'Wss', error);
-                    reject(error);
-                });
                 this.server.on('listening', () => {
                     this.log('info', 'Wss', 'Listening', this.server.address());
                     resolve();