Used query to get GuestStayDetails

Author: oskardudycz

src/guestStayAccounts/api/api.ts

@@ -32,6 +32,7 @@ import {
   initialState,
   toGuestStayAccountId,
 } from '../guestStayAccount';
+import { getGuestStayDetails } from '../guestStayDetails';
 
 export const handle = CommandHandler(evolve, initialState);
 
@@ -186,10 +187,10 @@ export const guestStayAccountsApi =
       on(async (request: GetShoppingCartRequest) => {
         const guestStayAccountId = parseGuestStayAccountId(request.params);
 
-        const result = await eventStore.aggregateStream(guestStayAccountId, {
-          evolve,
-          initialState,
-        });
+        const result = await getGuestStayDetails(
+          eventStore,
+          guestStayAccountId,
+        );
 
         if (result === null) return NotFound();
 

src/guestStayAccounts/guestStayDetails.ts

@@ -1,3 +1,4 @@
+import { type EventStore } from '@event-driven-io/emmett';
 import type { GuestStayAccountEvent } from './guestStayAccount';
 
 export type NotExisting = { status: 'NotExisting' };
@@ -83,3 +84,12 @@ export const evolve = (
     }
   }
 };
+
+export const getGuestStayDetails = (
+  eventStore: EventStore,
+  guestStayAccountId: string,
+) =>
+  eventStore.aggregateStream(guestStayAccountId, {
+    evolve,
+    initialState,
+  });