Added getWorkflowId to route messages to specific workflow

Author: oskardudycz

src/packages/emmett/src/workflows/workflow.unit.spec.ts

@@ -211,7 +211,7 @@ export const decide = (
     }
     case 'GuestCheckedOut':
     case 'GuestCheckoutFailed': {
-      return onCheckoutFinished(input, state);
+      return completeGroupCheckout(input, state);
     }
     case 'TimeoutGroupCheckout': {
       return timedOut(input, state);
@@ -240,6 +240,7 @@ export const GroupCheckoutWorkflow: Workflow<
 export const groupCheckoutWorkflowProcessor = workflowProcessor({
   processorId: 'GroupCheckoutWorkflow',
   workflow: GroupCheckoutWorkflow,
+  getWorkflowId: (input) => input.data.groupCheckoutId ?? null,
   inputs: {
     commands: ['InitiateGroupCheckout', 'TimeoutGroupCheckout'],
     events: ['GuestCheckedOut', 'GuestCheckoutFailed'],
@@ -289,7 +290,7 @@ const initiateGroupCheckout = (
   ];
 };
 
-const onCheckoutFinished = (
+const completeGroupCheckout = (
   { type, data }: GuestCheckedOut | GuestCheckoutFailed,
   state: GroupCheckout,
 ): GroupCheckoutCompleted | GroupCheckoutFailed | [] => {

src/packages/emmett/src/workflows/workflowProcessor.ts

@@ -34,6 +34,9 @@ export type WorkflowOptions<
   'type' | 'canHandle'
 > & {
   workflow: Workflow<Input, State, Output>;
+  getWorkflowId: (
+    input: RecordedMessage<Input, MessageMetadataType>,
+  ) => string | null;
   inputs: {
     commands: CanHandle<WorkflowCommand<Input>>;
     events: CanHandle<WorkflowEvent<Input>>;