streamline + refactor

Author: tysonrm

src/domain/datasource-factory.js

@@ -90,9 +90,9 @@ const DsCoreExtensions = superclass =>
       return new Transform({
         objectMode: true,
 
-        transform (chunk, _encoding, callback) {
+        transform (chunk, _encoding, next) {
           this.push(ModelFactory.loadModel(broker, ctx, chunk, ctx.name))
-          callback()
+          next()
         }
       })
     }
@@ -101,7 +101,7 @@ const DsCoreExtensions = superclass =>
       if (options?.writable)
         return isMainThread
           ? super.list(options)
-          : super.list({ ...options, transfrom: this.transform() })
+          : super.list({ ...options, transform: this.transform() })
 
       const arr = await super.list(options)
 

src/domain/make-ports.js

@@ -190,9 +190,12 @@ export default function makePorts (ports, adapters, broker, datasource) {
       const disabled = portConf.disabled || !adapters[port]
 
       // Listen for event that will invoke this port
-      const rememberPort = disabled
-        ? false
-        : addPortListener(portName, portConf, broker, datasource)
+      const rememberPort = addPortListener(
+        portName,
+        portConf,
+        broker,
+        datasource
+      )
 
       /**
        *
@@ -223,7 +226,7 @@ export default function makePorts (ports, adapters, broker, datasource) {
         }
 
         try {
-          // call the inbound or oubound adapter and wait
+          // call the inbound or oubound adapte
           const result = await adapters[port]({ model: this, port, args })
 
           // Stop the timer