oberknecht-emitters - npm Package Compare versions

Comparing version 1.0.0 to 1.0.1

lib-js/emitters/oberknecht.action.emitter.d.ts

@@ -8,2 +8,3 @@ import { oberknechtActionEmitterOptions } from "../types/oberknecht.action.emitter.options";
     _options: oberknechtActionEmitterOptions;
+    num: number;
     constructor(options: oberknechtActionEmitterOptions);
@@ -10,0 +11,0 @@ emit: (eventName: string, args: any, returntype?: number) => any;

lib-js/emitters/oberknecht.action.emitter.js

@@ -15,2 +15,3 @@ "use strict";
     _options;
+    num = 0;
     constructor(options) {
@@ -65,4 +66,5 @@ __1.i.actionEmitterData[this.symbol] = {};
             ;
+            const itemsym = `${this.num++}`;
             const item = {
-                sym: String(Symbol()),
+                sym: itemsym,
                 eventName: eventName,
@@ -82,3 +84,3 @@ expectedEventName: expectedEventName ?? (this._options.useExpectedEventNames ? (0, oberknecht_utils_1.expectedEventName)(eventName) : undefined),
             if (!__1.i.actionEmitterData[this.symbol].isWorkingHard)
-                this.next(item.sym);
+                this.next(itemsym);
         });
@@ -88,5 +90,7 @@ };
         __1.i.actionEmitterData[this.symbol].isWorkingHard = true;
-        const item = __1.i.actionEmitterData[this.symbol].queue.filter((v, i) => {
+        let item = __1.i.actionEmitterData[this.symbol].queue.filter(v => {
             return v.sym === sym;
         })[0];
+        if (!item)
+            return console.error(Error("EROAIOAIOSDAOERRROR ITEM NOT FOUND BABYRAGE"));
         item.inQueue = true;
@@ -93,0 +97,0 @@ item.fn(item.args);

lib-js/emitters/oberknecht.emitter.d.ts

 export declare class oberknechtEmitter {
     #private;
-    get symbol(): symbol;
+    get symbol(): string;
     constructor();
-    on: (eventName: any, callback: any) => void;
-    addListener: (eventName: any, callback: any) => void;
-    once: (eventName: any, callback: any) => void;
-    removeListener: (eventName: any, callback: any) => void;
-    removeAllListeners: (eventName: any) => void;
-    getListeners: (eventName: any) => any;
-    emit: (eventName: any, args: any) => void;
-    emitError: (eventName: any, error: any) => void;
+    on: (eventName: string | string[], callback: Function) => void;
+    addListener: (eventName: string | string[], callback: Function) => void;
+    once: (eventName: string | string[], callback: Function) => void;
+    removeListener: (eventName: string, callback: Function) => void;
+    removeAllListeners: (eventName: string) => void;
+    getListeners: (eventName: string) => any;
+    emit: (eventName: string | string[], args: any) => void;
+    emitError: (eventName: string | string[], error: any) => void;
 }

lib-js/emitters/oberknecht.emitter.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.oberknechtEmitter = void 0;
+const oberknecht_utils_1 = require("oberknecht-utils");
 const __1 = require("..");
 class oberknechtEmitter {
     #symbol = Symbol();
-    get symbol() { return this.#symbol; }
+    get symbol() { return String(this.#symbol); }
     ;
@@ -16,8 +17,6 @@ constructor() {
     on = (eventName, callback) => {
-        if (!Array.isArray(eventName))
-            eventName = [eventName];
-        eventName.forEach((eventName2) => {
-            if (!__1.i.emitterData[this.symbol].events[eventName2]) {
+        let eventName_ = (0, oberknecht_utils_1.convertToArray)(eventName);
+        eventName_.forEach((eventName2) => {
+            if (!__1.i.emitterData[this.symbol].events[eventName2])
                 __1.i.emitterData[this.symbol].events[eventName2] = [];
-            }
             __1.i.emitterData[this.symbol].events[eventName2].push(callback);
@@ -28,9 +27,10 @@ });
     once = (eventName, callback) => {
-        if (!Array.isArray(eventName))
-            eventName = [eventName];
+        let eventName_ = (0, oberknecht_utils_1.convertToArray)(eventName);
         const onceCallback = (args) => {
-            this.removeListener(eventName, onceCallback);
+            eventName_.forEach(a => {
+                this.removeListener(a, onceCallback);
+            });
             callback(args);
         };
-        this.on(eventName, onceCallback);
+        this.on(eventName_, onceCallback);
     };
@@ -51,6 +51,5 @@ removeListener = (eventName, callback) => {
     emit = (eventName, args) => {
-        if (!Array.isArray(eventName))
-            eventName = [eventName];
-        eventName.forEach((eventName2) => {
-            this.getListeners(eventName2).forEach((callback) => {
+        let eventName_ = (0, oberknecht_utils_1.convertToArray)(eventName);
+        eventName_.forEach(a => {
+            this.getListeners(a).forEach((callback) => {
                 callback(args ?? undefined);
@@ -57,0 +56,0 @@ });

lib-js/emitters/oberknecht.queue.emitter.d.ts

 export declare class oberknechtQueueEmitter {
     events: {};
     constructor();
-    once: (eventName: string, arg: any) => Promise<unknown>;
+    once: (eventName: string, arg: any) => Promise<any>;
     emitResolve: (eventName: string, arg: any, resp?: any) => void;
     emitReject: (eventName: string, arg: any, e: Error) => Promise<void>;
 }

lib-ts/emitters/oberknecht.action.emitter.ts

@@ -14,2 +14,3 @@ import { expectedEventName as expectedEventName_ } from "oberknecht-utils";
   _options: oberknechtActionEmitterOptions;
+  num = 0;
 
@@ -70,4 +71,5 @@ constructor(options: oberknechtActionEmitterOptions) {
 
+      const itemsym = `${this.num++}`;
       const item = {
-        sym: String(Symbol()),
+        sym: itemsym,
         eventName: eventName,
@@ -88,3 +90,3 @@ expectedEventName: expectedEventName ?? (this._options.useExpectedEventNames ? expectedEventName_(eventName) : undefined),
 
-      if (!i.actionEmitterData[this.symbol].isWorkingHard) this.next(item.sym);
+      if (!i.actionEmitterData[this.symbol].isWorkingHard) this.next(itemsym);
     });
@@ -95,6 +97,8 @@ };
     i.actionEmitterData[this.symbol].isWorkingHard = true;
-    const item = i.actionEmitterData[this.symbol].queue.filter((v, i) => {
+    let item = i.actionEmitterData[this.symbol].queue.filter(v => {
       return v.sym === sym;
     })[0];
 
+    if (!item) return console.error(Error("EROAIOAIOSDAOERRROR ITEM NOT FOUND BABYRAGE"));
+
     item.inQueue = true;
@@ -101,0 +105,0 @@ item.fn(item.args);

lib-ts/emitters/oberknecht.emitter.ts

@@ -0,1 +1,2 @@
+import { convertToArray } from "oberknecht-utils";
 import { i } from "..";
@@ -5,3 +6,3 @@
   #symbol = Symbol();
-  get symbol() { return this.#symbol };
+  get symbol() { return String(this.#symbol) };
 
@@ -14,9 +15,7 @@ constructor() {
 
-  on = (eventName, callback) => {
-    if (!Array.isArray(eventName)) eventName = [eventName];
+  on = (eventName: string | string[], callback: Function) => {
+    let eventName_ = convertToArray(eventName)
 
-    eventName.forEach((eventName2) => {
-      if (!i.emitterData[this.symbol].events[eventName2]) {
-        i.emitterData[this.symbol].events[eventName2] = [];
-      }
+    eventName_.forEach((eventName2) => {
+      if (!i.emitterData[this.symbol].events[eventName2]) i.emitterData[this.symbol].events[eventName2] = [];
 
@@ -29,13 +28,17 @@ i.emitterData[this.symbol].events[eventName2].push(callback);
 
-  once = (eventName, callback) => {
-    if (!Array.isArray(eventName)) eventName = [eventName];
+  once = (eventName: string | string[], callback: Function) => {
+    let eventName_ = convertToArray(eventName);
+
     const onceCallback = (args) => {
-      this.removeListener(eventName, onceCallback);
+      eventName_.forEach(a => {
+        this.removeListener(a, onceCallback);
+      });
+
       callback(args);
     };
 
-    this.on(eventName, onceCallback);
+    this.on(eventName_, onceCallback);
   };
 
-  removeListener = (eventName, callback) => {
+  removeListener = (eventName: string, callback: Function) => {
     if (!i.emitterData[this.symbol].events[eventName]) return;
@@ -48,3 +51,3 @@
 
-  removeAllListeners = (eventName) => {
+  removeAllListeners = (eventName: string) => {
     if (!i.emitterData[this.symbol].events[eventName]) return;
@@ -55,11 +58,11 @@
 
-  getListeners = (eventName) => {
+  getListeners = (eventName: string) => {
     return i.emitterData[this.symbol].events[eventName] || [];
   };
 
-  emit = (eventName, args) => {
-    if (!Array.isArray(eventName)) eventName = [eventName];
+  emit = (eventName: string | string[], args: any) => {
+    let eventName_ = convertToArray(eventName);
 
-    eventName.forEach((eventName2) => {
-      this.getListeners(eventName2).forEach((callback) => {
+    eventName_.forEach(a => {
+      this.getListeners(a).forEach((callback) => {
         callback(args ?? undefined);
@@ -73,3 +76,3 @@ });
 
-  emitError = (eventName, error) => {
+  emitError = (eventName: string | string[], error) => {
     try {
@@ -76,0 +79,0 @@ if (!error) return;

package.json

 {
   "name": "oberknecht-emitters",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "description": "",
@@ -5,0 +5,0 @@ "main": "export",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

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

Improved metrics

Total package byte prevSize

36280

increased by1.76%

Lines of code

491

increased by1.66%

Number of medium supply chain risk alerts

0

decreased by-100%

No dependency changes