ALS tweaks (#80)

package.json

@@ -5,7 +5,7 @@
   "repository": {
     "url": "git+https://github.com/Digital-Alchemy-TS/core"
   },
-  "version": "24.10.2",
+  "version": "24.10.3",
   "author": {
     "url": "https://github.com/zoe-codez",
     "name": "Zoe Codez"

src/helpers/wiring.helper.ts

@@ -174,10 +174,11 @@ export interface AsyncLocalData {
 export type AlsExtension = {
   asyncStorage: () => AsyncLocalStorage<AsyncLocalData>;
   getStore: () => AsyncLocalData;
-  init(source: object, callback: () => TBlackHole): void;
+  run(data: AsyncLocalData, callback: () => TBlackHole): void;
+  enterWith(data: AsyncLocalData): void;
   getLogData: () => AsyncLogData;
-  // register(callback: AlsHook): void;
 };
+
 export type AlsHook = () => object;
 
 // #MARK: TServiceParams

src/services/als.extension.ts

@@ -1,17 +1,18 @@
 import { AsyncLocalStorage } from "async_hooks";
-import { v4 } from "uuid";
 
-import { AlsExtension, AsyncLocalData, AsyncLogData, TBlackHole, TServiceParams } from "../helpers";
+import { AlsExtension, AsyncLocalData, AsyncLogData, TBlackHole } from "../helpers";
 
-export function ALS({ config }: TServiceParams): AlsExtension {
+export function ALS(): AlsExtension {
   const storage = new AsyncLocalStorage<AsyncLocalData>();
   return {
-    asyncStorage: () => (config.boilerplate.NODE_ENV ? storage : undefined),
+    asyncStorage: () => storage,
+    enterWith(data) {
+      storage.enterWith(data);
+    },
     getLogData: () => storage.getStore()?.logs ?? ({} as AsyncLogData),
     getStore: () => storage.getStore(),
-    init(source: object, callback: () => TBlackHole) {
-      const data = { logs: { id: v4(), ...source } };
-      storage.run(data as AsyncLocalData, () => {
+    run(data: AsyncLocalData, callback: () => TBlackHole) {
+      storage.run(data, () => {
         callback();
       });
     },