Replace getEventById with EventQuery for event retrieval (#41)

* Replace getEventById usage with query-based event lookup in examples

The eventmodeling library no longer calls getEventById from the
eventstore library. The two example apps now query all AccountOpened
events and filter by event ID instead.

https://claude.ai/code/session_01LPcFaA1bRJrcZjP4Rh3Mwe

* fixed examples by adding bounded context start

---------

Co-authored-by: Claude <noreply@anthropic.com>

Author: vanrogu

sliceworkz-eventmodeling-examples/src/main/java/org/sliceworkz/eventmodeling/examples/banking/BankingClosingTheBooksExample.java

@@ -41,7 +41,10 @@
 import org.sliceworkz.eventstore.EventStoreFactory;
 import org.sliceworkz.eventstore.events.Event;
 import org.sliceworkz.eventstore.events.EventReference;
+import org.sliceworkz.eventstore.events.Tags;
 import org.sliceworkz.eventstore.infra.inmem.InMemoryEventStorage;
+import org.sliceworkz.eventstore.query.EventQuery;
+import org.sliceworkz.eventstore.query.EventTypesFilter;
 import org.sliceworkz.eventstore.spi.EventStorage;
 import org.sliceworkz.eventstore.stream.EventStream;
 import org.sliceworkz.eventstore.stream.EventStreamId;
@@ -100,6 +103,8 @@ public static void main(String[] args) {
 			.done();
 
 		ClosingTheBooksBoundedContext bc = builder.build(ClosingTheBooksBoundedContext.class);
+		
+		bc.start();
 
 		EventStream<BankingEvent> eventStream = eventStore.getEventStream(
 			EventStreamId.forContext("banking-ctb").withPurpose("domain"),
@@ -117,9 +122,11 @@ public static void main(String[] args) {
 		Optional<EventReference> ref = bc.execute(new OpenBankAccountCommand(customerId, january));
 
 		// Retrieve the AccountOpened event to get the generated accountId
-		AccountOpened accountOpened = eventStream.getEventById(ref.get().id())
+		AccountOpened accountOpened = eventStream.query(EventQuery.forEvents(EventTypesFilter.of(AccountOpened.class), Tags.none()))
+			.filter(e -> e.reference().id().equals(ref.get().id()))
 			.map(Event::data)
 			.map(e -> (AccountOpened) e)
+			.findFirst()
 			.get();
 		DomainConceptId accountId = accountOpened.accountId();
 

sliceworkz-eventmodeling-examples/src/main/java/org/sliceworkz/eventmodeling/examples/banking/BankingExample.java

@@ -35,8 +35,10 @@
 import org.sliceworkz.eventstore.EventStoreFactory;
 import org.sliceworkz.eventstore.events.Event;
 import org.sliceworkz.eventstore.events.EventReference;
+import org.sliceworkz.eventstore.events.Tags;
 import org.sliceworkz.eventstore.infra.inmem.InMemoryEventStorage;
 import org.sliceworkz.eventstore.query.EventQuery;
+import org.sliceworkz.eventstore.query.EventTypesFilter;
 import org.sliceworkz.eventstore.spi.EventStorage;
 import org.sliceworkz.eventstore.stream.EventStream;
 import org.sliceworkz.eventstore.stream.EventStreamEventuallyConsistentAppendListener;
@@ -63,6 +65,8 @@ public static void main ( String[] args ) {
 				.done()
 			.build(BankingBoundedContext.class);
 
+		bc.start();
+		
 		EventStream<BankingDomainEvent> eventStream = eventStore.getEventStream(EventStreamId.forContext("banking").withPurpose("domain"), BankingDomainEvent.class);
 
 		/*
@@ -95,7 +99,12 @@ public EventReference eventsAppended(EventReference atLeastUntil) {
 		Optional<EventReference> ref = bc.execute(new OpenAccountCommand(DomainConceptId.create()));
 
 		// Go fetch the AccountOpened Event that should have been raised by the OpenAccountCommmand
-		AccountOpened ao = eventStream.getEventById(ref.get().id()).map(Event::data).map(e->(AccountOpened)e).get();
+		AccountOpened ao = eventStream.query(EventQuery.forEvents(EventTypesFilter.of(AccountOpened.class), Tags.none()))
+			.filter(e -> e.reference().id().equals(ref.get().id()))
+			.map(Event::data)
+			.map(e -> (AccountOpened) e)
+			.findFirst()
+			.get();
 
 		// Render a live model with the details of the Account
 		AccountDetailsReadModel rm = bc.read(AccountDetailsReadModel.class, ao.accountId());