WIP: Improve Thread pool invokation syntax

lib/application.js

@@ -195,7 +195,7 @@ class Application extends events.EventEmitter {
     return this.static.get(fileName);
   }
 
-  async invoke({ method, args, exclusive = false }) {
+  async invoke({ method, exclusive = false, args }) {
     const { port1: port, port2 } = new MessageChannel();
     const data = { method, args };
     const msg = { type: 'invoke', name: 'request', exclusive, data, port };

lib/cache.js

@@ -6,6 +6,7 @@ const fsp = require('fs').promises;
 class Cache {
   constructor(place, application) {
     this.path = application.absolute(place);
+    this.place = place;
     this.application = application;
   }
 

lib/modules.js

@@ -25,8 +25,10 @@ class Modules extends Cache {
     }, timeout);
   }
 
-  set(relPath, iface) {
+  set(relPath, exports) {
     const names = parsePath(relPath);
+    const method = [this.place, ...names].join('.');
+    const iface = this.wrapIface(method, exports);
     let level = this.tree;
     const last = names.length - 1;
     for (let depth = 0; depth <= last; depth++) {
@@ -44,8 +46,8 @@ class Modules extends Cache {
       if (next === undefined) next = { parent: level };
       level[name] = next;
       if (depth === 1 && name === 'start') {
-        if (iface.constructor.name === 'AsyncFunction') {
-          this.application.starts.push(iface);
+        if (exports.constructor.name === 'AsyncFunction') {
+          this.application.starts.push(exports);
         } else {
           const msg = `${relPath} expected to be async function`;
           this.application.console.error(msg);
@@ -73,6 +75,28 @@ class Modules extends Cache {
       }
     }
   }
+
+  wrapIface(method, iface) {
+    if (iface.constructor.name === 'AsyncFunction') {
+      const { invoke } = this.application;
+      return (args) => ({
+        handler: iface,
+        args,
+        then(resolve, reject) {
+          return this.handler(this.args).then(resolve, reject);
+        },
+        catch(reject) {
+          return this.handler(this.args).then(null, reject);
+        },
+        inThread({ exclusive = false }) {
+          this.handler = invoke;
+          this.args = { method, exclusive, args };
+          return this;
+        },
+      });
+    }
+    return iface;
+  }
 }
 
 module.exports = { Modules };

lib/worker.js

@@ -24,6 +24,7 @@ const application = require('./application.js');
     home,
   });
   const { console } = logger;
+  logger.addListener('error', (err) => console.error(err));
   Object.assign(application, { config, logger, console });
 
   const logError = async (err) => {