Support for an async decide / handle function for CommandHandler (

#99) * async decider for command handler * formatting --------- Co-authored-by: Oskar Dudycz <[email protected]>
event-driven-io · Oct 11, 2024 · 3f1c6c4 · 3f1c6c4
1 parent 84dd2ae
commit 3f1c6c4
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/packages/emmett/src/commandHandling/handleCommand.ts b/src/packages/emmett/src/commandHandling/handleCommand.ts
@@ -81,7 +81,13 @@ export const CommandHandler =
   async <Store extends EventStore<StreamVersion>>(
     store: Store,
     id: string,
-    handle: (state: State) => StreamEvent | StreamEvent[],
+    handle: (
+      state: State,
+    ) =>
+      | StreamEvent
+      | StreamEvent[]
+      | Promise<StreamEvent>
+      | Promise<StreamEvent[]>,
     handleOptions?: HandleOptions<StreamVersion, EventStore<StreamVersion>>,
   ): Promise<CommandHandlerResult<State, StreamEvent, StreamVersion>> =>
     asyncRetry(
@@ -116,7 +122,7 @@ export const CommandHandler =
           const currentStreamVersion = aggregationResult.currentStreamVersion;
 
           // 3. Run business logic
-          const result = handle(state);
+          const result = await handle(state);
 
           const newEvents = Array.isArray(result) ? result : [result];