Merge pull request #18 from tabkram/engine-id-as-execution-id

Engine id as executionId

src/engine/executionEngine.ts

@@ -43,6 +43,16 @@ export class ExecutionEngine<
     return this;
   }
 
+  /**
+   * Get the current options of the Execution Engine.
+   *
+   * @returns {Object} An object containing the execution date and ID.
+   * @public
+   */
+  getOptions(): { executionDate: Date; executionId: string } {
+    return { executionDate: this.executionDate, executionId: this.executionId };
+  }
+
   setContext(value: CXT) {
     this.context = this.deepClone(value);
     return this;

src/engine/executionEngineDecorators.spec.ts

@@ -14,10 +14,8 @@ describe('decorators', () => {
     });
 
     it('should apply the run decorator to a method', async () => {
-      const id = 'testId';
-
-      @engine({ id })
-      class TestClass {
+      @engine()
+      class TestClass extends EngineTask {
         @run()
         async testMethod() {
           return 'Test Result';
@@ -26,7 +24,7 @@ describe('decorators', () => {
 
       const instance = new TestClass();
       const result = await instance.testMethod();
-
+      expect(instance.engine.getOptions().executionId).toEqual(expect.stringMatching(/^exec.*$/));
       expect(result).toBe('Test Result');
     });
 
@@ -90,6 +88,7 @@ describe('decorators', () => {
         }
       );
       const greetingTrace = instance.engine.getTrace();
+      expect(instance.engine.getOptions().executionId).toEqual('greetingId');
       expect(greetingTrace?.length).toEqual(1);
       expect(greetingTrace[0]).toEqual({
         data: {
@@ -139,7 +138,10 @@ describe('decorators', () => {
     class MyVigilanceTask extends EngineTask {
       @run({
         trace: { id: 'decideIfIShouldGoOut_custom_id', narratives: ['Narrative 0 GoOut'] },
-        config: { parallel: true, traceExecution: { inputs: true, outputs: true, narratives: ['Narrative 1 GoOut', 'Narrative 2 GoOut'] } }
+        config: {
+          parallel: true,
+          traceExecution: { inputs: true, outputs: true, narratives: ['Narrative 1 GoOut', 'Narrative 2 GoOut'] }
+        }
       })
       async decideIfIShouldGoOut(city: string) {
         const temperature = await new MyWeatherTask().fetchCurrentTemperature(city);

src/engine/executionEngineDecorators.ts

@@ -24,7 +24,7 @@ export abstract class EngineTask {
  * A class decorator that enhances a class with execution engine capabilities.
  * @param options - Configuration options for the execution engine.
  */
-export function engine(options: { id: string }): ClassDecorator {
+export function engine(options?: { id: string }): ClassDecorator {
   /**
    * The actual decorator function.
    * @param target - The target class.
@@ -38,10 +38,13 @@ export function engine(options: { id: string }): ClassDecorator {
      */
     const newConstructor: any = function (...args: any[]) {
       const instance = new originalConstructor(...args);
-      if (!executionEngines[options.id]) {
-        executionEngines[options.id] = new ExecutionEngine();
+      let executionId = options?.id;
+      if (!executionId || !executionEngines[executionId]) {
+        const engineInstance = new ExecutionEngine({ executionId: options?.id });
+        executionId = engineInstance.getOptions().executionId;
+        executionEngines[executionId] = engineInstance;
       }
-      instance.engine = executionEngines[options.id];
+      instance.engine = executionEngines[executionId];
       return instance;
     };