Used EventStore instead of CommandBus in Event Sourced business processes solution

oskardudycz · oskardudycz · commit 0c09ee451731 · 2025-05-20T09:04:05.000+02:00
diff --git a/Workshops/IntroductionToEventSourcing/16-EntitiesDefinition/Core/EventStore.cs b/Workshops/IntroductionToEventSourcing/16-EntitiesDefinition/Core/EventStore.cs
@@ -42,7 +42,7 @@ public async ValueTask AppendToStream(string streamId, object[] toAppend, Cancel
     public ValueTask<TEvent[]> ReadStream<TEvent>(string streamId, CancellationToken ct = default)
         where TEvent : notnull =>
         ValueTask.FromResult(events.TryGetValue(streamId, out var stream)
-            ? stream.Select(e => e.Data).Cast<TEvent>().ToArray()
+            ? stream.Select(e => e.Data).OfType<TEvent>().ToArray()
             : []);
 
     public EventStore Subscribe<T>(Func<T, CancellationToken, ValueTask> eventHandler)
diff --git a/Workshops/IntroductionToEventSourcing/17-BusinessProcesses/Core/EventStore.cs b/Workshops/IntroductionToEventSourcing/17-BusinessProcesses/Core/EventStore.cs
@@ -42,7 +42,7 @@ public async ValueTask AppendToStream(string streamId, object[] toAppend, Cancel
     public ValueTask<TEvent[]> ReadStream<TEvent>(string streamId, CancellationToken ct = default)
         where TEvent : notnull =>
         ValueTask.FromResult(events.TryGetValue(streamId, out var stream)
-            ? stream.Select(e => e.Data).Cast<TEvent>().ToArray()
+            ? stream.Select(e => e.Data).OfType<TEvent>().ToArray()
             : []);
 
     public EventStore Subscribe<T>(Func<T, CancellationToken, ValueTask> eventHandler)
diff --git a/Workshops/IntroductionToEventSourcing/Solved/16-EntitiesDefinition/Core/EventStore.cs b/Workshops/IntroductionToEventSourcing/Solved/16-EntitiesDefinition/Core/EventStore.cs
@@ -42,7 +42,7 @@ public async ValueTask AppendToStream(string streamId, object[] toAppend, Cancel
     public ValueTask<TEvent[]> ReadStream<TEvent>(string streamId, CancellationToken ct = default)
         where TEvent : notnull =>
         ValueTask.FromResult(events.TryGetValue(streamId, out var stream)
-            ? stream.Select(e => e.Data).Cast<TEvent>().ToArray()
+            ? stream.Select(e => e.Data).OfType<TEvent>().ToArray()
             : []);
 
     public EventStore Subscribe<T>(Func<T, CancellationToken, ValueTask> eventHandler)
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Choreography/BusinessProcessTests.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Choreography/BusinessProcessTests.cs
@@ -207,7 +207,6 @@ public async Task GroupCheckoutForMultipleGuestStayWithAllUnsettled_ShouldFail()
     }
 
     private readonly EventStore eventStore = new();
-    private readonly CommandBus commandBus = new();
     private readonly MessageCatcher publishedMessages = new();
     private readonly GuestStayFacade guestStayFacade;
     private readonly GroupCheckOutFacade groupCheckoutFacade;
@@ -219,12 +218,11 @@ public BusinessProcessTests(ITestOutputHelper testOutputHelper)
     {
         this.testOutputHelper = testOutputHelper;
         guestStayFacade = new GuestStayFacade(eventStore);
-        groupCheckoutFacade = new GroupCheckOutFacade(eventStore, commandBus);
+        groupCheckoutFacade = new GroupCheckOutFacade(eventStore);
 
         eventStore.Use(publishedMessages.Catch);
-        commandBus.Use(publishedMessages.Catch);
 
         ConfigureGroupCheckouts(eventStore, groupCheckoutFacade);
-        ConfigureGuestStayAccounts(commandBus, guestStayFacade);
+        ConfigureGuestStayAccounts(eventStore, guestStayFacade);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Choreography/GroupCheckouts/GroupCheckoutFacade.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Choreography/GroupCheckouts/GroupCheckoutFacade.cs
@@ -7,7 +7,7 @@ namespace BusinessProcesses.Choreography.GroupCheckouts;
 using static GuestStayAccountEvent;
 using static GuestStayAccountCommand;
 
-public class GroupCheckOutFacade(EventStore eventStore, CommandBus commandBus)
+public class GroupCheckOutFacade(EventStore eventStore)
 {
     public async ValueTask InitiateGroupCheckout(InitiateGroupCheckout command, CancellationToken ct = default)
     {
@@ -19,7 +19,7 @@ public async ValueTask InitiateGroupCheckout(InitiateGroupCheckout command, Canc
 
     public ValueTask GroupCheckoutInitiated(GroupCheckoutEvent.GroupCheckoutInitiated @event,
         CancellationToken ct = default) =>
-        commandBus.Send(
+        eventStore.AppendToStream("commands",
             [
                 ..@event.GuestStayIds
                     .Select(guestStayId => new CheckOutGuest(guestStayId, @event.InitiatedAt, @event.GroupCheckoutId))
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Choreography/GuestStayAccounts/GroupCheckoutsConfig.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Choreography/GuestStayAccounts/GroupCheckoutsConfig.cs
@@ -7,10 +7,10 @@ namespace BusinessProcesses.Choreography.GuestStayAccounts;
 public static class GuestStayAccountsConfig
 {
     public static void ConfigureGuestStayAccounts(
-        CommandBus commandBus,
+        EventStore eventStore,
         GuestStayFacade guestStayFacade
     )
     {
-        commandBus.Handle<CheckOutGuest>(guestStayFacade.CheckOutGuest);
+        eventStore.Subscribe<CheckOutGuest>(guestStayFacade.CheckOutGuest);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Core/EventStore.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Core/EventStore.cs
@@ -42,7 +42,7 @@ public async ValueTask AppendToStream(string streamId, object[] toAppend, Cancel
     public ValueTask<TEvent[]> ReadStream<TEvent>(string streamId, CancellationToken ct = default)
         where TEvent : notnull =>
         ValueTask.FromResult(events.TryGetValue(streamId, out var stream)
-            ? stream.Select(e => e.Data).Cast<TEvent>().ToArray()
+            ? stream.Select(e => e.Data).OfType<TEvent>().ToArray()
             : []);
 
     public EventStore Subscribe<T>(Func<T, CancellationToken, ValueTask> eventHandler)
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/ProcessManagers/BusinessProcessTests.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/ProcessManagers/BusinessProcessTests.cs
@@ -207,7 +207,6 @@ public async Task GroupCheckoutForMultipleGuestStayWithAllUnsettled_ShouldFail()
     }
 
     private readonly EventStore eventStore = new();
-    private readonly CommandBus commandBus = new();
     private readonly MessageCatcher publishedMessages = new();
     private readonly GuestStayFacade guestStayFacade;
     private readonly GroupCheckOutFacade groupCheckoutFacade;
@@ -219,12 +218,11 @@ public BusinessProcessTests(ITestOutputHelper testOutputHelper)
     {
         this.testOutputHelper = testOutputHelper;
         guestStayFacade = new GuestStayFacade(eventStore);
-        groupCheckoutFacade = new GroupCheckOutFacade(eventStore, commandBus);
+        groupCheckoutFacade = new GroupCheckOutFacade(eventStore);
 
         eventStore.Use(publishedMessages.Catch);
-        commandBus.Use(publishedMessages.Catch);
 
         ConfigureGroupCheckouts(eventStore, groupCheckoutFacade);
-        ConfigureGuestStayAccounts(commandBus, guestStayFacade);
+        ConfigureGuestStayAccounts(eventStore, guestStayFacade);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/ProcessManagers/GroupCheckouts/GroupCheckoutFacade.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/ProcessManagers/GroupCheckouts/GroupCheckoutFacade.cs
@@ -7,7 +7,7 @@ namespace BusinessProcesses.ProcessManagers.GroupCheckouts;
 using static GuestStayAccountEvent;
 using static ProcessManagerResult;
 
-public class GroupCheckOutFacade(EventStore eventStore, CommandBus commandBus)
+public class GroupCheckOutFacade(EventStore eventStore)
 {
     public async ValueTask InitiateGroupCheckout(InitiateGroupCheckout command, CancellationToken ct = default)
     {
@@ -21,7 +21,7 @@ public async ValueTask GuestCheckedOut(GuestCheckedOut @event, CancellationToken
         if (!@event.GroupCheckOutId.HasValue)
             return;
 
-        var groupCheckout = await  GetGroupCheckOut(@event.GroupCheckOutId.Value, ct);
+        var groupCheckout = await GetGroupCheckOut(@event.GroupCheckOutId.Value, ct);
 
         var messages = groupCheckout.On(@event);
 
@@ -33,7 +33,7 @@ public async ValueTask GuestCheckOutFailed(GuestCheckOutFailed @event, Cancellat
         if (!@event.GroupCheckOutId.HasValue)
             return;
 
-        var groupCheckout = await  GetGroupCheckOut(@event.GroupCheckOutId.Value, ct);
+        var groupCheckout = await GetGroupCheckOut(@event.GroupCheckOutId.Value, ct);
 
         var messages = groupCheckout.On(@event);
 
@@ -47,18 +47,11 @@ private async Task ProcessMessages(
         CancellationToken ct
     )
     {
-        foreach (var message in messages)
-        {
-            switch (message)
-            {
-                case Event (GroupCheckoutEvent @event):
-                    await eventStore.AppendToStream(groupCheckOutId.ToString(), [@event], ct);
-                    break;
-                case Command(GuestStayAccountCommand command):
-                    await commandBus.Send([command], ct);
-                    break;
-            }
-        }
+        await eventStore.AppendToStream(
+            groupCheckOutId.ToString(),
+            messages.Where(m => m is not None).Select(m => m is Event @event ? @event.Message : ((Command)m).Message).ToArray(),
+            ct
+        );
     }
 
     private async ValueTask<GroupCheckOut> GetGroupCheckOut(Guid guestStayId, CancellationToken ct)
@@ -70,7 +63,7 @@ private async ValueTask<GroupCheckOut> GetGroupCheckOut(Guid guestStayId, Cancel
             ct
         );
 
-        if(groupCheckout == GroupCheckOut.Initial)
+        if (groupCheckout == GroupCheckOut.Initial)
             throw new InvalidOperationException("Entity not found");
 
         return groupCheckout;
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/ProcessManagers/GuestStayAccounts/GroupCheckoutsConfig.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/ProcessManagers/GuestStayAccounts/GroupCheckoutsConfig.cs
@@ -7,10 +7,10 @@ namespace BusinessProcesses.ProcessManagers.GuestStayAccounts;
 public static class GuestStayAccountsConfig
 {
     public static void ConfigureGuestStayAccounts(
-        CommandBus commandBus,
+        EventStore eventStore,
         GuestStayFacade guestStayFacade
     )
     {
-        commandBus.Handle<CheckOutGuest>(guestStayFacade.CheckOutGuest);
+        eventStore.Subscribe<CheckOutGuest>(guestStayFacade.CheckOutGuest);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version1-Aggregates/BusinessProcessTests.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version1-Aggregates/BusinessProcessTests.cs
@@ -220,7 +220,6 @@ public async Task GroupCheckoutForMultipleGuestStayWithAllUnsettled_ShouldFail()
     }
 
     private readonly EventStore eventStore = new();
-    private readonly CommandBus commandBus = new();
     private readonly MessageCatcher publishedMessages = new();
     private readonly GuestStayFacade guestStayFacade;
     private readonly GroupCheckOutFacade groupCheckoutFacade;
@@ -235,9 +234,8 @@ public BusinessProcessTests(ITestOutputHelper testOutputHelper)
         groupCheckoutFacade = new GroupCheckOutFacade(eventStore);
 
         eventStore.Use(publishedMessages.Catch);
-        commandBus.Use(publishedMessages.Catch);
 
-        ConfigureGroupCheckouts(eventStore, commandBus, groupCheckoutFacade);
-        ConfigureGuestStayAccounts(commandBus, guestStayFacade);
+        ConfigureGroupCheckouts(eventStore, groupCheckoutFacade);
+        ConfigureGuestStayAccounts(eventStore, guestStayFacade);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version1-Aggregates/GroupCheckouts/GroupCheckoutsConfig.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version1-Aggregates/GroupCheckouts/GroupCheckoutsConfig.cs
@@ -11,26 +11,25 @@ public static class GroupCheckoutsConfig
 {
     public static void ConfigureGroupCheckouts(
         EventStore eventStore,
-        CommandBus commandBus,
         GroupCheckOutFacade groupCheckoutFacade
     )
     {
         eventStore
             .Subscribe<GroupCheckoutEvent.GroupCheckoutInitiated>((@event, ct) =>
-                commandBus.Send(GroupCheckoutSaga.Handle(@event).Select(c => c.Message).ToArray(), ct)
+                eventStore.AppendToStream("commands", GroupCheckoutSaga.Handle(@event).Select(c => c.Message).ToArray<object>(), ct)
             )
             .Subscribe<GuestCheckedOut>((@event, ct) =>
                 GroupCheckoutSaga.Handle(@event) is Command<RecordGuestCheckoutCompletion>(var command)
-                    ? commandBus.Send([command], ct)
+                    ? eventStore.AppendToStream("commands", [command], ct)
                     : ValueTask.CompletedTask
             )
             .Subscribe<GuestCheckOutFailed>((@event, ct) =>
                 GroupCheckoutSaga.Handle(@event) is Command<RecordGuestCheckoutFailure>(var command)
-                    ? commandBus.Send([command], ct)
+                    ? eventStore.AppendToStream("commands", [command], ct)
                     : ValueTask.CompletedTask
             );
 
-        commandBus.Handle<RecordGuestCheckoutCompletion>(groupCheckoutFacade.RecordGuestCheckoutCompletion);
-        commandBus.Handle<RecordGuestCheckoutFailure>(groupCheckoutFacade.RecordGuestCheckoutFailure);
+        eventStore.Subscribe<RecordGuestCheckoutCompletion>(groupCheckoutFacade.RecordGuestCheckoutCompletion);
+        eventStore.Subscribe<RecordGuestCheckoutFailure>(groupCheckoutFacade.RecordGuestCheckoutFailure);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version1-Aggregates/GuestStayAccounts/GroupCheckoutsConfig.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version1-Aggregates/GuestStayAccounts/GroupCheckoutsConfig.cs
@@ -7,10 +7,10 @@ namespace BusinessProcesses.Sagas.Version1_Aggregates.GuestStayAccounts;
 public static class GuestStayAccountsConfig
 {
     public static void ConfigureGuestStayAccounts(
-        CommandBus commandBus,
+        EventStore eventStore,
         GuestStayFacade guestStayFacade
     )
     {
-        commandBus.Handle<CheckOutGuest>(guestStayFacade.CheckOutGuest);
+        eventStore.Subscribe<CheckOutGuest>(guestStayFacade.CheckOutGuest);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version2-ImmutableEntities/BusinessProcessTests.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version2-ImmutableEntities/BusinessProcessTests.cs
@@ -219,7 +219,6 @@ public async Task GroupCheckoutForMultipleGuestStayWithAllUnsettled_ShouldFail()
     }
 
     private readonly EventStore eventStore = new();
-    private readonly CommandBus commandBus = new();
     private readonly MessageCatcher publishedMessages = new();
     private readonly GuestStayFacade guestStayFacade;
     private readonly GroupCheckOutFacade groupCheckoutFacade;
@@ -234,9 +233,8 @@ public BusinessProcessTests(ITestOutputHelper testOutputHelper)
         groupCheckoutFacade = new GroupCheckOutFacade(eventStore);
 
         eventStore.Use(publishedMessages.Catch);
-        commandBus.Use(publishedMessages.Catch);
 
-        ConfigureGroupCheckouts(eventStore, commandBus, groupCheckoutFacade);
-        ConfigureGuestStayAccounts(commandBus, guestStayFacade);
+        ConfigureGroupCheckouts(eventStore, groupCheckoutFacade);
+        ConfigureGuestStayAccounts(eventStore, guestStayFacade);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version2-ImmutableEntities/GroupCheckouts/GroupCheckoutsConfig.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version2-ImmutableEntities/GroupCheckouts/GroupCheckoutsConfig.cs
@@ -11,26 +11,25 @@ public static class GroupCheckoutsConfig
 {
     public static void ConfigureGroupCheckouts(
         EventStore eventStore,
-        CommandBus commandBus,
         GroupCheckOutFacade groupCheckoutFacade
     )
     {
         eventStore
             .Subscribe<GroupCheckoutEvent.GroupCheckoutInitiated>((@event, ct) =>
-                commandBus.Send(GroupCheckoutSaga.Handle(@event).Select(c => c.Message).ToArray(), ct)
+                eventStore.AppendToStream("commands", GroupCheckoutSaga.Handle(@event).Select(c => c.Message).ToArray<object>(), ct)
             )
             .Subscribe<GuestCheckedOut>((@event, ct) =>
                 GroupCheckoutSaga.Handle(@event) is Command<RecordGuestCheckoutCompletion>(var command)
-                    ? commandBus.Send([command], ct)
+                    ? eventStore.AppendToStream("commands", [command], ct)
                     : ValueTask.CompletedTask
             )
             .Subscribe<GuestCheckOutFailed>((@event, ct) =>
                 GroupCheckoutSaga.Handle(@event) is Command<RecordGuestCheckoutFailure>(var command)
-                    ? commandBus.Send([command], ct)
+                    ? eventStore.AppendToStream("commands", [command], ct)
                     : ValueTask.CompletedTask
             );
 
-        commandBus.Handle<RecordGuestCheckoutCompletion>(groupCheckoutFacade.RecordGuestCheckoutCompletion);
-        commandBus.Handle<RecordGuestCheckoutFailure>(groupCheckoutFacade.RecordGuestCheckoutFailure);
+        eventStore.Subscribe<RecordGuestCheckoutCompletion>(groupCheckoutFacade.RecordGuestCheckoutCompletion);
+        eventStore.Subscribe<RecordGuestCheckoutFailure>(groupCheckoutFacade.RecordGuestCheckoutFailure);
     }
 }
diff --git a/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version2-ImmutableEntities/GuestStayAccounts/GroupCheckoutsConfig.cs b/Workshops/IntroductionToEventSourcing/Solved/17-BusinessProcesses/Sagas/Version2-ImmutableEntities/GuestStayAccounts/GroupCheckoutsConfig.cs
@@ -7,10 +7,10 @@ namespace BusinessProcesses.Sagas.Version2_ImmutableEntities.GuestStayAccounts;
 public static class GuestStayAccountsConfig
 {
     public static void ConfigureGuestStayAccounts(
-        CommandBus commandBus,
+        EventStore eventStore,
         GuestStayFacade guestStayFacade
     )
     {
-        commandBus.Handle<CheckOutGuest>(guestStayFacade.CheckOutGuest);
+        eventStore.Subscribe<CheckOutGuest>(guestStayFacade.CheckOutGuest);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -207,7 +207,6 @@ public async Task GroupCheckoutForMultipleGuestStayWithAllUnsettled_ShouldFail()`
`207`	`207`	`}`
`208`	`208`
`209`	`209`	`private readonly EventStore eventStore = new();`
`210`		`- private readonly CommandBus commandBus = new();`
`211`	`210`	`private readonly MessageCatcher publishedMessages = new();`
`212`	`211`	`private readonly GuestStayFacade guestStayFacade;`
`213`	`212`	`private readonly GroupCheckOutFacade groupCheckoutFacade;`
`@@ -219,12 +218,11 @@ public BusinessProcessTests(ITestOutputHelper testOutputHelper)`
`219`	`218`	`{`
`220`	`219`	`this.testOutputHelper = testOutputHelper;`
`221`	`220`	`guestStayFacade = new GuestStayFacade(eventStore);`
`222`		`- groupCheckoutFacade = new GroupCheckOutFacade(eventStore, commandBus);`
	`221`	`+ groupCheckoutFacade = new GroupCheckOutFacade(eventStore);`
`223`	`222`
`224`	`223`	`eventStore.Use(publishedMessages.Catch);`
`225`		`- commandBus.Use(publishedMessages.Catch);`
`226`	`224`
`227`	`225`	`ConfigureGroupCheckouts(eventStore, groupCheckoutFacade);`
`228`		`- ConfigureGuestStayAccounts(commandBus, guestStayFacade);`
	`226`	`+ ConfigureGuestStayAccounts(eventStore, guestStayFacade);`
`229`	`227`	`}`
`230`	`228`	`}`
Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@ namespace BusinessProcesses.Choreography.GroupCheckouts;`
`7`	`7`	`using static GuestStayAccountEvent;`
`8`	`8`	`using static GuestStayAccountCommand;`
`9`	`9`
`10`		`-public class GroupCheckOutFacade(EventStore eventStore, CommandBus commandBus)`
	`10`	`+public class GroupCheckOutFacade(EventStore eventStore)`
`11`	`11`	`{`
`12`	`12`	`public async ValueTask InitiateGroupCheckout(InitiateGroupCheckout command, CancellationToken ct = default)`
`13`	`13`	`{`
`@@ -19,7 +19,7 @@ public async ValueTask InitiateGroupCheckout(InitiateGroupCheckout command, Canc`
`19`	`19`
`20`	`20`	`public ValueTask GroupCheckoutInitiated(GroupCheckoutEvent.GroupCheckoutInitiated @event,`
`21`	`21`	`CancellationToken ct = default) =>`
`22`		`- commandBus.Send(`
	`22`	`+ eventStore.AppendToStream("commands",`
`23`	`23`	`[`
`24`	`24`	`..@event.GuestStayIds`
`25`	`25`	`.Select(guestStayId => new CheckOutGuest(guestStayId, @event.InitiatedAt, @event.GroupCheckoutId))`
Original file line number	Diff line number	Diff line change
`@@ -7,10 +7,10 @@ namespace BusinessProcesses.Choreography.GuestStayAccounts;`
`7`	`7`	`public static class GuestStayAccountsConfig`
`8`	`8`	`{`
`9`	`9`	`public static void ConfigureGuestStayAccounts(`
`10`		`- CommandBus commandBus,`
	`10`	`+ EventStore eventStore,`
`11`	`11`	`GuestStayFacade guestStayFacade`
`12`	`12`	`)`
`13`	`13`	`{`
`14`		`- commandBus.Handle<CheckOutGuest>(guestStayFacade.CheckOutGuest);`
	`14`	`+ eventStore.Subscribe<CheckOutGuest>(guestStayFacade.CheckOutGuest);`
`15`	`15`	`}`
`16`	`16`	`}`