allow passing of custom implementation EventStore.appendToStream opti…

…ons to CommandHandler handle
event-driven-io · May 17, 2024 · 3feae3f · 3feae3f
1 parent 1f8db48
commit 3feae3f
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/packages/emmett/src/commandHandling/handleCommand.ts b/src/packages/emmett/src/commandHandling/handleCommand.ts
@@ -20,11 +20,11 @@ export const CommandHandler =
     getInitialState: () => State,
     mapToStreamId: (id: string) => string = (id) => id,
   ) =>
-  async (
-    eventStore: EventStore<StreamVersion>,
+  async <Store extends EventStore<StreamVersion>>(
+    eventStore: Store,
     id: string,
     handle: (state: State) => StreamEvent | StreamEvent[],
-    options?: {
+    options?: Parameters<Store['appendToStream']>[2] & {
       expectedStreamVersion?: ExpectedStreamVersion<StreamVersion>;
     },
   ): Promise<CommandHandlerResult<State, StreamVersion>> => {
@@ -68,6 +68,7 @@ export const CommandHandler =
       streamName,
       newEvents,
       {
+        ...options,
         expectedStreamVersion,
       },
     );