@bettercorp/service-base - npm Package Compare versions

Comparing version 8.5.47 to 8.5.50

development/tsconfig.json

@@ -7,3 +7,3 @@ {
     },
-    "module": "commonjs",
+    "module": "CommonJS",
     "noImplicitAny": true,
@@ -18,4 +18,4 @@ "removeComments": true,
     "strict": true,
-    "target": "es2021",
-    "lib": ["es2021"],
+    "target": "es2022",
+    "lib": ["es2022"],
     "declaration": true,
@@ -27,3 +27,3 @@ "emitDecoratorMetadata": true,
     "forceConsistentCasingInFileNames": true,
-    "moduleResolution": "node"
+    "moduleResolution": "Node"
   },
@@ -30,0 +30,0 @@ "linterOptions": {

lib/base/base.js

@@ -6,5 +6,8 @@ "use strict";
 class MainBase {
+    appId = "tbd";
+    mode = "development";
+    cwd;
+    pluginCwd;
+    pluginName;
     constructor(config) {
-        this.appId = "tbd";
-        this.mode = "development";
         this.appId = config.appId;
@@ -26,2 +29,3 @@ this.mode = config.mode;
 class BaseWithConfig extends Base {
+    config;
     constructor(config) {
@@ -34,2 +38,3 @@ super(config);
 class BaseWithLogging extends Base {
+    log;
     constructor(config) {
@@ -42,2 +47,4 @@ super(config);
 class BaseWithLoggingAndConfig extends BaseWithConfig {
+    log;
+    createNewLogger;
     constructor(config) {
@@ -44,0 +51,0 @@ super(config);

lib/base/functions.d.ts

@@ -5,4 +5,5 @@ type SmartFunctionCallFunc = {
 };
+export declare function SmartFunctionCallThroughAsync<T extends SmartFunctionCallFunc>(context: any, input: T | undefined, ...params: Parameters<T>): Promise<ReturnType<T> | void> | ReturnType<T> | void;
 export declare function SmartFunctionCallAsync<T extends SmartFunctionCallFunc>(context: any, input: T | undefined, ...params: Parameters<T>): Promise<ReturnType<T> | void>;
 export declare function SmartFunctionCallSync<T extends SmartFunctionCallFunc>(context: any, input: T | undefined, ...params: Parameters<T>): ReturnType<T> | void;
 export {};

lib/base/functions.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.SmartFunctionCallSync = exports.SmartFunctionCallAsync = void 0;
+exports.SmartFunctionCallSync = exports.SmartFunctionCallAsync = exports.SmartFunctionCallThroughAsync = void 0;
 const index_1 = require("./index");
+function SmartFunctionCallThroughAsync(context, input, ...params) {
+    if (typeof input !== "function")
+        return;
+    if (typeof context !== "object")
+        throw new index_1.BSBError("INCORRECT_REFERENCE", "SmartFunctionCallThroughAsync: context is not an object");
+    return input.call(context, ...params);
+}
+exports.SmartFunctionCallThroughAsync = SmartFunctionCallThroughAsync;
 async function SmartFunctionCallAsync(context, input, ...params) {
@@ -6,0 +14,0 @@ if (typeof input !== "function")

lib/base/pluginConfig.js

@@ -10,6 +10,3 @@ "use strict";
 class BSBPluginConfigRef extends BSBPluginConfig {
-    constructor() {
-        super(...arguments);
-        this.validationSchema = {};
-    }
+    validationSchema = {};
     migrate(toVersion, fromVersion, fromConfig) {
@@ -16,0 +13,0 @@ throw (0, index_1.BSB_ERROR_METHOD_NOT_IMPLEMENTED)("BSBPluginConfigRef", "migrate");

lib/base/PluginEvents.js

@@ -8,2 +8,4 @@ "use strict";
 class PluginEvents {
+    events;
+    service;
     constructor(mode, events, context) {
@@ -64,13 +66,10 @@ this.events = events;
 class BSBPluginEventsRef extends BSBPluginEvents {
-    constructor() {
-        super(...arguments);
-        this.onEvents = {};
-        this.emitEvents = {};
-        this.onReturnableEvents = {};
-        this.emitReturnableEvents = {};
-        this.onBroadcast = {};
-        this.emitBroadcast = {};
-    }
+    onEvents = {};
+    emitEvents = {};
+    onReturnableEvents = {};
+    emitReturnableEvents = {};
+    onBroadcast = {};
+    emitBroadcast = {};
 }
 exports.BSBPluginEventsRef = BSBPluginEventsRef;
 //# sourceMappingURL=PluginEvents.js.map

lib/base/PluginLogger.js

@@ -5,4 +5,6 @@ "use strict";
 class PluginLogger {
+    logging;
+    pluginName;
+    canDebug = false;
     constructor(mode, plugin, logging) {
-        this.canDebug = false;
         this.logging = logging;
@@ -9,0 +11,0 @@ this.pluginName = plugin;

lib/base/service.js

@@ -6,6 +6,7 @@ "use strict";
 class BSBService extends index_1.BaseWithLoggingAndConfig {
+    _virtual_internal_events = {};
+    events;
+    _clients = [];
     constructor(config) {
         super(config);
-        this._virtual_internal_events = {};
-        this._clients = [];
         this.events = new index_1.PluginEvents(config.mode, config.sbEvents, this);
@@ -16,5 +17,9 @@ }
 class BSBServiceRef extends BSBService {
+    methods = {};
+    initBeforePlugins;
+    initAfterPlugins;
+    runBeforePlugins;
+    runAfterPlugins;
     constructor(config) {
         super(config);
-        this.methods = {};
     }
@@ -21,0 +26,0 @@ }

lib/base/serviceClient.d.ts

@@ -7,3 +7,3 @@ import { IPluginLogger, DynamicallyReferencedMethodCallable } from "../interfaces";
     protected readonly events: PluginEvents<Service["_virtual_internal_events"]["emitEvents"], Service["_virtual_internal_events"]["onEvents"], Service["_virtual_internal_events"]["emitReturnableEvents"], Service["_virtual_internal_events"]["onReturnableEvents"], Service["_virtual_internal_events"]["emitBroadcast"], Service["_virtual_internal_events"]["onBroadcast"]>;
-    callMethod<TA extends string>(...args: DynamicallyReferencedMethodCallable<DynamicallyReferencedMethodType<Service["methods"]>, TA>): DynamicallyReferencedMethodCallable<DynamicallyReferencedMethodType<Service["methods"]>, TA, false>;
+    callMethod<TA extends keyof Service["methods"]>(...args: DynamicallyReferencedMethodCallable<DynamicallyReferencedMethodType<Service["methods"]>, TA>): DynamicallyReferencedMethodCallable<DynamicallyReferencedMethodType<Service["methods"]>, TA, false>;
     constructor(context: BSBService);
@@ -10,0 +10,0 @@ abstract readonly pluginName: string;

lib/base/serviceClient.js

@@ -6,2 +6,4 @@ "use strict";
 class BSBServiceClient {
+    log;
+    events;
     callMethod(...args) {
@@ -18,6 +20,7 @@ throw new index_1.BSBError("The plugin {plugin} is not enabled so you cannot call methods from it", {
 class BSBServiceClientRef extends BSBServiceClient {
-    constructor() {
-        super(...arguments);
-        this.pluginName = "";
-    }
+    pluginName = "";
+    initBeforePlugins;
+    initAfterPlugins;
+    runBeforePlugins;
+    runAfterPlugins;
     dispose() {
@@ -24,0 +27,0 @@ throw new Error("Method not implemented.");

lib/client.js

@@ -8,4 +8,7 @@ "use strict";
 class SBClient {
+    serviceBase;
+    client;
+    useDefaultConfigPlugin;
+    configSetup = false;
     constructor(useDefaultConfigPlugin = false) {
-        this.configSetup = false;
         this.useDefaultConfigPlugin = useDefaultConfigPlugin;
@@ -32,2 +35,7 @@ const CWD = process.env.APP_DIR || process.cwd();
 class FakeServiceClient extends base_1.BSBService {
+    initBeforePlugins;
+    initAfterPlugins;
+    runBeforePlugins;
+    runAfterPlugins;
+    methods = {};
     init() {
@@ -41,3 +49,2 @@ throw new Error("Method not implemented.");
         super(config);
-        this.methods = {};
     }
@@ -44,0 +51,0 @@ }

lib/interfaces/events.d.ts

 import { DynamicallyReferencedMethodBase } from "@bettercorp/tools/lib/Interfaces";
-export type DynamicallyReferencedMethodCallable<Interface extends DynamicallyReferencedMethodBase, Method extends keyof Interface, ArgsReference extends boolean = true> = ArgsReference extends true ? Interface[Method] extends (...a: infer Arguments) => infer Return ? [event: Method, ...a: Arguments] : [event: Method, noMatchingEvent: never] : Interface[Method] extends (...a: infer Arguments) => infer Return ? Return extends Promise<unknown> ? Return : Promise<Return> : Promise<never>;
+export type DynamicallyReferencedMethodCallable<Interface extends DynamicallyReferencedMethodBase, Method extends keyof Interface, ArgsReference extends boolean = true> = ArgsReference extends true ? Interface[Method] extends (...a: infer Arguments) => infer Return ? [event: Method, ...a: Arguments] : [event: Method, noMatchingEvent: never] : Interface[Method] extends (...a: infer Arguments) => infer Return ? Return : Promise<never>;
 export type DynamicallyReferencedMethodOnIEvents<Interface extends DynamicallyReferencedMethodBase, Method extends keyof Interface, hasReturnable extends boolean = false> = Interface[Method] extends (...a: infer Arguments) => infer Return ? [
@@ -4,0 +4,0 @@ event: Method,

lib/plugins/config-default/plugin.js

@@ -117,5 +117,7 @@ "use strict";
     }
+    _appConfig;
+    _secConfigFilePath;
+    _deploymentProfile = "default";
     constructor(config) {
         super(config);
-        this._deploymentProfile = "default";
         this._secConfigFilePath = path.join(this.cwd, "./sec-config.yaml");
@@ -122,0 +124,0 @@ }

lib/plugins/events-default/events/broadcast.js

@@ -6,2 +6,3 @@ "use strict";
 class broadcast extends events_1.EventEmitter {
+    log;
     constructor(log) {
@@ -8,0 +9,0 @@ super();

lib/plugins/events-default/events/emit.js

@@ -7,2 +7,4 @@ "use strict";
 class emit extends events_1.EventEmitter {
+    log;
+    _lastReceivedMessageIds = [];
     set lastReceivedMessageIds(value) {
@@ -16,3 +18,2 @@ if (this._lastReceivedMessageIds.length > 50) {
         super();
-        this._lastReceivedMessageIds = [];
         this.log = log;
@@ -19,0 +20,0 @@ }

lib/plugins/events-default/events/emitAndReturn.js

@@ -6,2 +6,3 @@ "use strict";
 class emitAndReturn extends events_1.EventEmitter {
+    log;
     constructor(log) {
@@ -8,0 +9,0 @@ super();

lib/plugins/events-default/events/emitStreamAndReceiveStream.js

@@ -7,5 +7,6 @@ "use strict";
 class emitStreamAndReceiveStream extends events_1.EventEmitter {
+    staticCommsTimeout = 1000;
+    log;
     constructor(log) {
         super();
-        this.staticCommsTimeout = 1000;
         this.log = log;
@@ -12,0 +13,0 @@ }

lib/plugins/events-default/plugin.js

@@ -7,2 +7,6 @@ "use strict";
 class Plugin extends __1.BSBEvents {
+    broadcast;
+    emit;
+    ear;
+    eas;
     constructor(config) {
@@ -9,0 +13,0 @@ super(config);

lib/plugins/logging-default/plugin.js

@@ -15,6 +15,7 @@ "use strict";
 class Plugin extends __1.BSBLogging {
+    _mockedConsole;
+    _mockConsole = false;
+    logFormatter = new __1.LogFormatter();
     constructor(config, mockConsole) {
         super(config);
-        this._mockConsole = false;
-        this.logFormatter = new __1.LogFormatter();
         this._mockedConsole = mockConsole;
@@ -21,0 +22,0 @@ if (this._mockedConsole !== undefined)

lib/serviceBase/config.js

@@ -9,5 +9,10 @@ "use strict";
 class SBConfig {
+    mode = "development";
+    appId;
+    cwd;
+    sbPlugins;
+    sbLogging;
+    log;
+    configPlugin;
     constructor(appId, mode, cwd, sbLogging, sbPlugins) {
-        this.mode = "development";
-        this.configPluginName = "config-default";
         this.appId = appId;
@@ -46,2 +51,4 @@ this.mode = mode;
     }
+    configPackage;
+    configPluginName = "config-default";
     async setConfigPlugin(reference) {
@@ -48,0 +55,0 @@ this.configPlugin = new reference.plugin({

lib/serviceBase/events.js

@@ -12,5 +12,9 @@ "use strict";
 class SBEvents {
+    events = [];
+    mode = "development";
+    appId;
+    cwd;
+    sbPlugins;
+    log;
     constructor(appId, mode, cwd, sbPlugins, sbLogging) {
-        this.events = [];
-        this.mode = "development";
         this.appId = appId;
@@ -17,0 +21,0 @@ this.mode = mode;

lib/serviceBase/logging.js

@@ -9,6 +9,10 @@ "use strict";
 class SBLogging {
+    loggers = [];
+    logBus = new stream_1.EventEmitter();
+    mode = "development";
+    appId;
+    cwd;
+    sbPlugins;
+    log;
     constructor(appId, mode, cwd, sbPlugins) {
-        this.loggers = [];
-        this.logBus = new stream_1.EventEmitter();
-        this.mode = "development";
         this.appId = appId;
@@ -15,0 +19,0 @@ this.mode = mode;

lib/serviceBase/plugins.js

@@ -31,2 +31,5 @@ "use strict";
 class SBPlugins {
+    cwd;
+    pluginDir;
+    devMode;
     constructor(cwd, devMode) {
@@ -33,0 +36,0 @@ this.cwd = cwd;

lib/serviceBase/serviceBase.js

@@ -23,2 +23,16 @@ "use strict";
 class ServiceBase {
+    mode = "development";
+    _CORE_PLUGIN_NAME = "core";
+    _appId;
+    logging;
+    plugins;
+    config;
+    events;
+    log;
+    services;
+    cwd;
+    _keeps = {
+        BSB: process.hrtime(),
+    };
+    _heartbeat;
     _startKeep(stepName) {
@@ -40,8 +54,2 @@ if (this.log !== undefined)
     constructor(debug = true, live = false, cwd, config = __1.SBConfig, plugins = __1.SBPlugins, logging = __1.SBLogging, events = __1.SBEvents, services = __1.SBServices) {
-        this.mode = "development";
-        this._CORE_PLUGIN_NAME = "core";
-        this._keeps = {
-            BSB: process.hrtime(),
-        };
-        this._disposing = false;
         this._startKeep(exports.BOOT_STAT_KEYS.SELF);
@@ -107,2 +115,3 @@ this.cwd = cwd;
     }
+    _disposing = false;
     async dispose(eCode = 0, reason, extraData) {
@@ -109,0 +118,0 @@ console.error(reason, extraData);

lib/serviceBase/services.js

@@ -7,43 +7,9 @@ "use strict";
 class SBServices {
+    _activeServices = [];
+    mode = "development";
+    appId;
+    cwd;
+    sbPlugins;
+    log;
     constructor(appId, mode, cwd, sbPlugins, sbLogging) {
-        this._activeServices = [];
-        this.mode = "development";
-        this.setupPluginClient = async (sbConfig, sbLogging, sbEvents, context, clientContext) => {
-            const contextPlugin = await sbConfig.getServicePluginDefinition(clientContext.pluginName);
-            clientContext._pluginName = clientContext.pluginName;
-            clientContext.pluginName = contextPlugin.name;
-            clientContext.pluginEnabled = contextPlugin.enabled;
-            clientContext.log = new __1.PluginLogger(this.mode, contextPlugin.name, sbLogging);
-            clientContext.events = new __1.PluginEvents(this.mode, sbEvents, clientContext);
-            context.initBeforePlugins = (context.initBeforePlugins ?? []).concat(clientContext.initBeforePlugins ?? []);
-            context.initAfterPlugins = (context.initAfterPlugins ?? []).concat(clientContext.initAfterPlugins ?? []);
-            context.runBeforePlugins = (context.runBeforePlugins ?? []).concat(clientContext.runBeforePlugins ?? []);
-            context.runAfterPlugins = (context.runAfterPlugins ?? []).concat(clientContext.runAfterPlugins ?? []);
-        };
-        this.initPluginClient = async (sbConfig, clientContext) => {
-            const contextPlugin = await sbConfig.getServicePluginDefinition(clientContext._pluginName);
-            if (contextPlugin.enabled) {
-                const referencedServiceContext = this._activeServices.find((x) => x.pluginName === contextPlugin.name);
-                if (referencedServiceContext === undefined) {
-                    throw new __1.BSBError("The plugin {plugin} is not enabled so you cannot call methods from it", {
-                        plugin: contextPlugin.name,
-                    });
-                }
-                if (referencedServiceContext.methods === null) {
-                    throw new __1.BSBError("The plugin {plugin} does not have any callable methods", {
-                        plugin: contextPlugin.name,
-                    });
-                }
-                clientContext.callMethod = async (method, ...args) => {
-                    if (referencedServiceContext.methods[method] === undefined) {
-                        throw new __1.BSBError("The plugin {plugin} does not have a method called {method}", {
-                            plugin: contextPlugin.name,
-                            method,
-                        });
-                    }
-                    return (0, __1.SmartFunctionCallAsync)(referencedServiceContext, referencedServiceContext.methods[method], ...args);
-                };
-            }
-            await (0, __1.SmartFunctionCallSync)(clientContext, clientContext.init);
-        };
         this.appId = appId;
@@ -78,2 +44,14 @@ this.mode = mode;
     }
+    setupPluginClient = async (sbConfig, sbLogging, sbEvents, context, clientContext) => {
+        const contextPlugin = await sbConfig.getServicePluginDefinition(clientContext.pluginName);
+        clientContext._pluginName = clientContext.pluginName;
+        clientContext.pluginName = contextPlugin.name;
+        clientContext.pluginEnabled = contextPlugin.enabled;
+        clientContext.log = new __1.PluginLogger(this.mode, contextPlugin.name, sbLogging);
+        clientContext.events = new __1.PluginEvents(this.mode, sbEvents, clientContext);
+        context.initBeforePlugins = (context.initBeforePlugins ?? []).concat(clientContext.initBeforePlugins ?? []);
+        context.initAfterPlugins = (context.initAfterPlugins ?? []).concat(clientContext.initAfterPlugins ?? []);
+        context.runBeforePlugins = (context.runBeforePlugins ?? []).concat(clientContext.runBeforePlugins ?? []);
+        context.runAfterPlugins = (context.runAfterPlugins ?? []).concat(clientContext.runAfterPlugins ?? []);
+    };
     async mapServicePlugins(sbConfig, referencedPluginName, ...sourcePluginsList) {
@@ -165,2 +143,28 @@ const outlist = [];
     }
+    initPluginClient = async (sbConfig, clientContext) => {
+        const contextPlugin = await sbConfig.getServicePluginDefinition(clientContext._pluginName);
+        if (contextPlugin.enabled) {
+            const referencedServiceContext = this._activeServices.find((x) => x.pluginName === contextPlugin.name);
+            if (referencedServiceContext === undefined) {
+                throw new __1.BSBError("The plugin {plugin} is not enabled so you cannot call methods from it", {
+                    plugin: contextPlugin.name,
+                });
+            }
+            if (referencedServiceContext.methods === null) {
+                throw new __1.BSBError("The plugin {plugin} does not have any callable methods", {
+                    plugin: contextPlugin.name,
+                });
+            }
+            clientContext.callMethod = (method, ...args) => {
+                if (referencedServiceContext.methods[method] === undefined) {
+                    throw new __1.BSBError("The plugin {plugin} does not have a method called {method}", {
+                        plugin: contextPlugin.name,
+                        method,
+                    });
+                }
+                return (0, __1.SmartFunctionCallThroughAsync)(referencedServiceContext, referencedServiceContext.methods[method], ...args);
+            };
+        }
+        await (0, __1.SmartFunctionCallSync)(clientContext, clientContext.init);
+    };
     async init(sbConfig) {
@@ -167,0 +171,0 @@ this.log.info("Init all services");

lib/tests/sb/plugins/events/broadcast.js

 "use strict";
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
 };
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.broadcast = void 0;
-const assert_1 = __importDefault(require("assert"));
+const assert = __importStar(require("assert"));
 const crypto_1 = require("crypto");
@@ -30,6 +50,6 @@ const __1 = require("../../../..");
                     if (receiveCounter === 2)
-                        return assert_1.default.ok(receiveCounter);
+                        return assert.ok(receiveCounter);
                     if (receiveCounter === 0)
-                        return assert_1.default.fail("Event not received");
-                    assert_1.default.fail("Received " + receiveCounter + " events");
+                        return assert.fail("Event not received");
+                    assert.fail("Received " + receiveCounter + " events");
                 }, maxTimeoutToExpectAResponse);
@@ -48,7 +68,7 @@ await emitter.onBroadcast(thisPlugin, thisEvent, async () => {
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisPlugin, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.ok(data[0]);
+                    assert.ok(data[0]);
                 });
@@ -61,7 +81,7 @@ await emitter.emitBroadcast(thisPlugin, thisEvent, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisCaller, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.ok(data[0]);
+                    assert.ok(data[0]);
                 });
@@ -74,10 +94,10 @@ await emitter.emitBroadcast(thisCaller, thisEvent, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisCaller, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.deepEqual(data[0], 0);
-                    assert_1.default.deepEqual(data[1], 1);
-                    assert_1.default.deepEqual(data[2], 2);
-                    assert_1.default.deepEqual(data[3], 3);
+                    assert.deepEqual(data[0], 0);
+                    assert.deepEqual(data[1], 1);
+                    assert.deepEqual(data[2], 2);
+                    assert.deepEqual(data[3], 3);
                 });
@@ -91,7 +111,7 @@ await emitter.emitBroadcast(thisCaller, thisEvent, [0, 1, 2, 3]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisPlugin, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("Event received");
+                    assert.fail("Event received");
                 });
@@ -105,7 +125,7 @@ await emitter.emitBroadcast(thisPlugin, thisEvent2, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisCaller, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("Event received");
+                    assert.fail("Event received");
                 });
@@ -121,7 +141,7 @@ await emitter.emitBroadcast(thisCaller, thisEvent2, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisPlugin, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.deepEqual(data[0], emitData);
+                    assert.deepEqual(data[0], emitData);
                 });
@@ -134,7 +154,7 @@ await emitter.emitBroadcast(thisPlugin, thisEvent, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisCaller, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.deepEqual(data[0], emitData);
+                    assert.deepEqual(data[0], emitData);
                 });
@@ -148,7 +168,7 @@ await emitter.emitBroadcast(thisCaller, thisEvent, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisPlugin, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("Event received");
+                    assert.fail("Event received");
                 });
@@ -162,7 +182,7 @@ await emitter.emitBroadcast(thisPlugin, thisEvent2, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onBroadcast(thisCaller, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("Event received");
+                    assert.fail("Event received");
                 });
@@ -219,7 +239,7 @@ await emitter.emitBroadcast(thisCaller, thisEvent2, [emitData]);
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received");
+                        assert.fail("Event not received");
                     }, maxTimeoutToExpectAResponse);
                     await emitter.onBroadcast(thisPlugin, thisEvent, async (data) => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.deepEqual(data[0], typeToTest.data);
+                        assert.deepEqual(data[0], typeToTest.data);
                     });
@@ -232,7 +252,7 @@ await emitter.emitBroadcast(thisPlugin, thisEvent, [typeToTest.data]);
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received");
+                        assert.fail("Event not received");
                     }, maxTimeoutToExpectAResponse);
                     await emitter.onBroadcast(thisCaller, thisEvent, async (data) => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.deepEqual(data[0], typeToTest.data);
+                        assert.deepEqual(data[0], typeToTest.data);
                     });
@@ -246,7 +266,7 @@ await emitter.emitBroadcast(thisCaller, thisEvent, [typeToTest.data]);
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.ok(true);
+                        assert.ok(true);
                     }, maxTimeoutToExpectAResponse);
                     await emitter.onBroadcast(thisPlugin, thisEvent, async () => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("Event received");
+                        assert.fail("Event received");
                     });
@@ -262,7 +282,7 @@ await emitter.emitBroadcast(thisPlugin, thisEvent2, [
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.ok(true);
+                        assert.ok(true);
                     }, maxTimeoutToExpectAResponse);
                     await emitter.onBroadcast(thisCaller, thisEvent, async () => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("Event received");
+                        assert.fail("Event received");
                     });
@@ -269,0 +289,0 @@ await emitter.emitBroadcast(thisCaller, thisEvent2, [

lib/tests/sb/plugins/events/emit.js

 "use strict";
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
 };
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.emit = void 0;
-const assert_1 = __importDefault(require("assert"));
+const assert = __importStar(require("assert"));
 const crypto_1 = require("crypto");
@@ -30,6 +50,6 @@ const __1 = require("../../../..");
                     if (receiveCounter === 1)
-                        return assert_1.default.ok(receiveCounter);
+                        return assert.ok(receiveCounter);
                     if (receiveCounter === 0)
-                        return assert_1.default.fail("Event not received");
-                    assert_1.default.fail("Received " + receiveCounter + " events");
+                        return assert.fail("Event not received");
+                    assert.fail("Received " + receiveCounter + " events");
                 }, maxTimeoutToExpectAResponse);
@@ -48,7 +68,7 @@ await emitter.onEvent(thisPlugin, thisEvent, async () => {
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisPlugin, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.ok(data[0]);
+                    assert.ok(data[0]);
                 });
@@ -61,7 +81,7 @@ await emitter.emitEvent(thisPlugin, thisEvent, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisCaller, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.ok(data[0]);
+                    assert.ok(data[0]);
                 });
@@ -74,10 +94,10 @@ await emitter.emitEvent(thisCaller, thisEvent, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisCaller, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.deepEqual(data[0], 0);
-                    assert_1.default.deepEqual(data[1], 1);
-                    assert_1.default.deepEqual(data[2], 2);
-                    assert_1.default.deepEqual(data[3], 3);
+                    assert.deepEqual(data[0], 0);
+                    assert.deepEqual(data[1], 1);
+                    assert.deepEqual(data[2], 2);
+                    assert.deepEqual(data[3], 3);
                 });
@@ -91,7 +111,7 @@ await emitter.emitEvent(thisCaller, thisEvent, [0, 1, 2, 3]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisPlugin, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("Event received");
+                    assert.fail("Event received");
                 });
@@ -105,7 +125,7 @@ await emitter.emitEvent(thisPlugin, thisEvent2, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisCaller, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("Event received");
+                    assert.fail("Event received");
                 });
@@ -121,7 +141,7 @@ await emitter.emitEvent(thisCaller, thisEvent2, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisPlugin, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.deepEqual(data[0], emitData);
+                    assert.deepEqual(data[0], emitData);
                 });
@@ -134,7 +154,7 @@ await emitter.emitEvent(thisPlugin, thisEvent, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisCaller, thisEvent, async (data) => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.deepEqual(data[0], emitData);
+                    assert.deepEqual(data[0], emitData);
                 });
@@ -148,7 +168,7 @@ await emitter.emitEvent(thisCaller, thisEvent, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisPlugin, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("Event received");
+                    assert.fail("Event received");
                 });
@@ -162,7 +182,7 @@ await emitter.emitEvent(thisPlugin, thisEvent2, [emitData]);
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, maxTimeoutToExpectAResponse);
                 await emitter.onEvent(thisCaller, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("Event received");
+                    assert.fail("Event received");
                 });
@@ -219,7 +239,7 @@ await emitter.emitEvent(thisCaller, thisEvent2, [emitData]);
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received");
+                        assert.fail("Event not received");
                     }, maxTimeoutToExpectAResponse);
                     await emitter.onEvent(thisPlugin, thisEvent, async (data) => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.deepEqual(data[0], typeToTest.data);
+                        assert.deepEqual(data[0], typeToTest.data);
                     });
@@ -232,7 +252,7 @@ await emitter.emitEvent(thisPlugin, thisEvent, [typeToTest.data]);
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received");
+                        assert.fail("Event not received");
                     }, maxTimeoutToExpectAResponse);
                     await emitter.onEvent(thisCaller, thisEvent, async (data) => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.deepEqual(data[0], typeToTest.data);
+                        assert.deepEqual(data[0], typeToTest.data);
                     });
@@ -246,7 +266,7 @@ await emitter.emitEvent(thisCaller, thisEvent, [typeToTest.data]);
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.ok(true);
+                        assert.ok(true);
                     }, maxTimeoutToExpectAResponse);
                     await emitter.onEvent(thisPlugin, thisEvent, async () => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("Event received");
+                        assert.fail("Event received");
                     });
@@ -260,7 +280,7 @@ await emitter.emitEvent(thisPlugin, thisEvent2, [typeToTest.data]);
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.ok(true);
+                        assert.ok(true);
                     }, maxTimeoutToExpectAResponse);
                     await emitter.onEvent(thisCaller, thisEvent, async () => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("Event received");
+                        assert.fail("Event received");
                     });
@@ -267,0 +287,0 @@ await emitter.emitEvent(thisCaller, thisEvent2, [typeToTest.data]);

lib/tests/sb/plugins/events/emitAndReturn.js

 "use strict";
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
 };
@@ -8,3 +28,3 @@ Object.defineProperty(exports, "__esModule", { value: true });
 const __1 = require("../../../..");
-const assert_1 = __importDefault(require("assert"));
+const assert = __importStar(require("assert"));
 const crypto_1 = require("crypto");
@@ -29,3 +49,3 @@ const randomName = () => (0, crypto_1.randomUUID)();
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, timermaxTimeoutToExpectAResponse);
@@ -35,3 +55,3 @@ await emitter.onReturnableEvent(thisPlugin, thisEvent, async () => {
                         console.log("Received onEvent");
-                        assert_1.default.ok(true, "Received onEvent");
+                        assert.ok(true, "Received onEvent");
                     }, 1);
@@ -44,3 +64,3 @@ return emitData2;
                 clearTimeout(emitTimeout);
-                assert_1.default.ok(true, "Received Response");
+                assert.ok(true, "Received Response");
             });
@@ -51,6 +71,6 @@ it("should be able to emit to events with self", async () => {
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, timermaxTimeoutToExpectAResponse);
                 await emitter.onReturnableEvent(thisCaller, thisEvent, async () => {
-                    assert_1.default.ok(true, "Received onEvent");
+                    assert.ok(true, "Received onEvent");
                     return emitData2;
@@ -60,3 +80,3 @@ });
                 clearTimeout(emitTimeout);
-                assert_1.default.ok(true, "Received Response");
+                assert.ok(true, "Received Response");
             });
@@ -68,6 +88,6 @@ it("should not be able to emit to other events with plugin name defined", async () => {
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, timermaxTimeoutToExpectAResponse);
                 await emitter.onReturnableEvent(thisPlugin, thisEvent, () => {
-                    assert_1.default.fail("EEAR MSG Received");
+                    assert.fail("EEAR MSG Received");
                 });
@@ -77,7 +97,7 @@ try {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("EEAR Returned");
+                    assert.fail("EEAR Returned");
                 }
                 catch (exc) {
                     clearTimeout(emitTimeout);
-                    assert_1.default.ok("Timeout of EEAR");
+                    assert.ok("Timeout of EEAR");
                 }
@@ -90,6 +110,6 @@ });
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.ok(true);
+                    assert.ok(true);
                 }, timermaxTimeoutToExpectAResponse);
                 await emitter.onReturnableEvent(thisCaller, thisEvent, () => {
-                    assert_1.default.fail("EEAR MSG Received");
+                    assert.fail("EEAR MSG Received");
                 });
@@ -99,7 +119,7 @@ try {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("EEAR Returned");
+                    assert.fail("EEAR Returned");
                 }
                 catch (exc) {
                     clearTimeout(emitTimeout);
-                    assert_1.default.ok("Timeout of EEAR");
+                    assert.ok("Timeout of EEAR");
                 }
@@ -111,3 +131,3 @@ });
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, timermaxTimeoutToExpectAResponse);
@@ -118,7 +138,7 @@ await emitter.onReturnableEvent(thisCaller, thisEvent, async () => { });
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("EEAR Returned");
+                    assert.fail("EEAR Returned");
                 }
                 catch (exc) {
                     clearTimeout(emitTimeout);
-                    assert_1.default.ok("Timeout of EEAR");
+                    assert.ok("Timeout of EEAR");
                 }
@@ -130,3 +150,3 @@ });
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, timermaxTimeoutToExpectAResponse);
@@ -139,8 +159,8 @@ await emitter.onReturnableEvent(thisCaller, thisEvent, () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.fail("EEAR Returned");
+                    assert.fail("EEAR Returned");
                 }
                 catch (exc) {
                     clearTimeout(emitTimeout);
-                    assert_1.default.ok("EEAR");
-                    assert_1.default.strictEqual(exc, "THISISANERROR");
+                    assert.ok("EEAR");
+                    assert.strictEqual(exc, "THISISANERROR");
                 }
@@ -201,3 +221,3 @@ });
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received");
+                        assert.fail("Event not received");
                     }, timermaxTimeoutToExpectAResponse);
@@ -211,3 +231,3 @@ await emitter.onReturnableEvent(thisPlugin, thisEvent, async () => {
                     clearTimeout(emitTimeout);
-                    assert_1.default.strictEqual(JSON.stringify(resp), JSON.stringify(typeToTest.rData !== undefined
+                    assert.strictEqual(JSON.stringify(resp), JSON.stringify(typeToTest.rData !== undefined
                         ? typeToTest.rData
@@ -220,10 +240,10 @@ : typeToTest.data));
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received - timeout");
+                        assert.fail("Event not received - timeout");
                     }, timermaxTimeoutToExpectAResponse);
                     await emitter.onReturnableEvent(thisCaller, thisEvent, async (data) => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.strictEqual(JSON.stringify(data[0]), JSON.stringify(typeToTest.data), "Received data");
+                        assert.strictEqual(JSON.stringify(data[0]), JSON.stringify(typeToTest.data), "Received data");
                         return typeToTest.rData || typeToTest.data;
                     });
-                    assert_1.default.strictEqual(JSON.stringify(await emitter.emitEventAndReturn(thisCaller, thisEvent, maxTimeoutToExpectAResponse / 1000, [typeToTest.data])), JSON.stringify(typeToTest.rData || typeToTest.data), "Returned data");
+                    assert.strictEqual(JSON.stringify(await emitter.emitEventAndReturn(thisCaller, thisEvent, maxTimeoutToExpectAResponse / 1000, [typeToTest.data])), JSON.stringify(typeToTest.rData || typeToTest.data), "Returned data");
                     clearTimeout(emitTimeout);
@@ -236,6 +256,6 @@ });
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.ok(true);
+                        assert.ok(true);
                     }, timermaxTimeoutToExpectAResponse);
                     await emitter.onReturnableEvent(thisPlugin, thisEvent, () => {
-                        assert_1.default.fail("EEAR MSG Received");
+                        assert.fail("EEAR MSG Received");
                     });
@@ -245,7 +265,7 @@ try {
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("EEAR Returned");
+                        assert.fail("EEAR Returned");
                     }
                     catch (exc) {
                         clearTimeout(emitTimeout);
-                        assert_1.default.ok("Timeout of EEAR");
+                        assert.ok("Timeout of EEAR");
                     }
@@ -258,6 +278,6 @@ });
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.ok(true);
+                        assert.ok(true);
                     }, timermaxTimeoutToExpectAResponse);
                     await emitter.onReturnableEvent(thisCaller, thisEvent, () => {
-                        assert_1.default.fail("EEAR MSG Received");
+                        assert.fail("EEAR MSG Received");
                     });
@@ -267,7 +287,7 @@ try {
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("EEAR Returned");
+                        assert.fail("EEAR Returned");
                     }
                     catch (exc) {
                         clearTimeout(emitTimeout);
-                        assert_1.default.ok("Timeout of EEAR");
+                        assert.ok("Timeout of EEAR");
                     }
@@ -279,3 +299,3 @@ });
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received");
+                        assert.fail("Event not received");
                     }, timermaxTimeoutToExpectAResponse + 10);
@@ -286,7 +306,7 @@ await emitter.onReturnableEvent(thisCaller, thisEvent, async () => { });
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("EEAR Returned");
+                        assert.fail("EEAR Returned");
                     }
                     catch (exc) {
                         clearTimeout(emitTimeout);
-                        assert_1.default.ok("Timeout of EEAR");
+                        assert.ok("Timeout of EEAR");
                     }
@@ -298,3 +318,3 @@ });
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received");
+                        assert.fail("Event not received");
                     }, timermaxTimeoutToExpectAResponse + 10);
@@ -304,7 +324,7 @@ try {
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("EEAR Returned");
+                        assert.fail("EEAR Returned");
                     }
                     catch (exc) {
                         clearTimeout(emitTimeout);
-                        assert_1.default.ok("Timeout of EEAR");
+                        assert.ok("Timeout of EEAR");
                     }
@@ -316,3 +336,3 @@ });
                     const emitTimeout = setTimeout(() => {
-                        assert_1.default.fail("Event not received");
+                        assert.fail("Event not received");
                     }, timermaxTimeoutToExpectAResponse);
@@ -325,8 +345,8 @@ await emitter.onReturnableEvent(thisCaller, thisEvent, () => {
                         clearTimeout(emitTimeout);
-                        assert_1.default.fail("EEAR Returned");
+                        assert.fail("EEAR Returned");
                     }
                     catch (exc) {
                         clearTimeout(emitTimeout);
-                        assert_1.default.ok("EEAR");
-                        assert_1.default.strictEqual(JSON.stringify(exc), JSON.stringify(typeToTest.rData || typeToTest.data));
+                        assert.ok("EEAR");
+                        assert.strictEqual(JSON.stringify(exc), JSON.stringify(typeToTest.rData || typeToTest.data));
                     }
@@ -333,0 +353,0 @@ });

lib/tests/sb/plugins/events/emitStreamAndReceiveStream.js

@@ -25,5 +25,2 @@ "use strict";
 };
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
-};
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -35,3 +32,3 @@ exports.emitStreamAndReceiveStream = void 0;
 const stream_1 = require("stream");
-const assert_1 = __importDefault(require("assert"));
+const assert = __importStar(require("assert"));
 const __1 = require("../../../..");
@@ -98,3 +95,3 @@ const randomName = () => crypto.randomUUID();
             const uuid = await emitter.receiveStream(thisCaller, async () => { }, maxTimeoutToExpectAResponse);
-            assert_1.default.ok(`${uuid}`.length >= 10, "Not a valid unique ID for stream");
+            assert.ok(`${uuid}`.length >= 10, "Not a valid unique ID for stream");
         });
@@ -106,6 +103,6 @@ it("sendStream triggers timeout when no receiveStream setup", async () => {
                 await emitter.sendStream(thisCaller, thisEvent, mockBareFakeStream());
-                assert_1.default.fail("Timeout not called");
+                assert.fail("Timeout not called");
             }
             catch (xc) {
-                assert_1.default.ok(true, "Timeout called exception");
+                assert.ok(true, "Timeout called exception");
             }
@@ -116,3 +113,3 @@ });
             const emitTimeout = setTimeout(() => {
-                assert_1.default.fail("Event not received");
+                assert.fail("Event not received");
             }, timermaxTimeoutToExpectAResponse);
@@ -122,3 +119,3 @@ const uuid = await emitter.receiveStream(thisCaller, async (err, stream) => {
                 stream.emit("end");
-                assert_1.default.ok(true, "Listener called");
+                assert.ok(true, "Listener called");
             }, maxTimeoutToExpectAResponse);
@@ -135,3 +132,3 @@ try {
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, timermaxTimeoutToExpectAResponse);
@@ -141,3 +138,3 @@ const uuid = await emitter.receiveStream(thisCaller, async (err, stream) => {
                     stream.emit("end");
-                    assert_1.default.strictEqual(err, null, "Error is not null");
+                    assert.strictEqual(err, null, "Error is not null");
                 }, maxTimeoutToExpectAResponse);
@@ -152,3 +149,3 @@ try {
                 const emitTimeout = setTimeout(() => {
-                    assert_1.default.fail("Event not received");
+                    assert.fail("Event not received");
                 }, timermaxTimeoutToExpectAResponse);
@@ -158,3 +155,3 @@ const uuid = await emitter.receiveStream(thisCaller, async (err, stream) => {
                     stream.emit("end");
-                    assert_1.default.strictEqual(typeof stream, typeof mockBareFakeStream(), "Listener called");
+                    assert.strictEqual(typeof stream, typeof mockBareFakeStream(), "Listener called");
                 }, maxTimeoutToExpectAResponse);
@@ -183,11 +180,11 @@ try {
                         const emitTimeout = setTimeout(() => {
-                            assert_1.default.fail("Event not received");
+                            assert.fail("Event not received");
                         }, timermaxTimeoutToExpectAResponse);
                         const uuid = await emitter.receiveStream(thisCaller, async (err, stream) => {
                             if (err)
-                                return assert_1.default.fail(err);
+                                return assert.fail(err);
                             clearTimeout(emitTimeout);
                             (0, stream_1.pipeline)(stream, fs.createWriteStream(fileNameOut), (errf) => {
                                 if (errf)
-                                    assert_1.default.fail(errf);
+                                    assert.fail(errf);
                             });
@@ -197,3 +194,3 @@ }, maxTimeoutToExpectAResponse);
                         fs.unlinkSync(fileName);
-                        assert_1.default.strictEqual(await getFileHash(fileNameOut), srcFileHash, "Validate data equals");
+                        assert.strictEqual(await getFileHash(fileNameOut), srcFileHash, "Validate data equals");
                         fs.unlinkSync(fileNameOut);
@@ -210,3 +207,3 @@ const done = new Date().getTime();
                             fs.unlinkSync(fileNameOut);
-                        assert_1.default.fail(xx.toString());
+                        assert.fail(xx.toString());
                     }
@@ -213,0 +210,0 @@ });

package.json

@@ -5,3 +5,3 @@ {
   "repository": {
-    "url": "https://github.com/BetterCorp/better-service-base"
+    "url": "git+https://github.com/BetterCorp/better-service-base.git"
   },
@@ -32,3 +32,3 @@ "engines": {
   "main": "lib/index.js",
-  "version": "8.5.47",
+  "version": "8.5.50",
   "bsb_project": true,
@@ -35,0 +35,0 @@ "bsbInit": {

New alerts

No repository

Supply chain risk

Package does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.

Found 1 instance in 1 package

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

No repository

Supply chain risk

Package does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

383870

increased by0.94%

Lines of code

4781

increased by2.75%

Number of medium supply chain risk alerts

1

decreased by-50%

No dependency changes