From 9868db4f35f1878ae7391806876a52a9544210a4 Mon Sep 17 00:00:00 2001 From: Pol Pinol Castuera Date: Mon, 26 May 2025 09:31:40 +0200 Subject: [PATCH 1/2] fix query mongo --- .../infrastructure/repositories/MongoEventStoreRepository.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/io/autoinvestor/infrastructure/repositories/MongoEventStoreRepository.java b/src/main/java/io/autoinvestor/infrastructure/repositories/MongoEventStoreRepository.java index 6305588..85f765e 100644 --- a/src/main/java/io/autoinvestor/infrastructure/repositories/MongoEventStoreRepository.java +++ b/src/main/java/io/autoinvestor/infrastructure/repositories/MongoEventStoreRepository.java @@ -40,7 +40,7 @@ public void save(Decision decision) { public Decision get(DecisionId decisionId) { Query q = Query.query( Criteria.where("aggregateId") - .is(decisionId.toString()) + .is(decisionId.value()) ) .with(Sort.by("version")); From f54becea58df981941f9ff680ae269bed4c2ab58 Mon Sep 17 00:00:00 2001 From: Pol Pinol Castuera Date: Mon, 26 May 2025 09:36:33 +0200 Subject: [PATCH 2/2] toString to value() --- .../infrastructure/event_publishers/EventMessageMapper.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/io/autoinvestor/infrastructure/event_publishers/EventMessageMapper.java b/src/main/java/io/autoinvestor/infrastructure/event_publishers/EventMessageMapper.java index e09cb39..5f2c762 100644 --- a/src/main/java/io/autoinvestor/infrastructure/event_publishers/EventMessageMapper.java +++ b/src/main/java/io/autoinvestor/infrastructure/event_publishers/EventMessageMapper.java @@ -24,7 +24,7 @@ PubsubMessage toMessage(Event event) { try { Map envelope = new HashMap<>(); envelope.put("payload", event.getPayload().asMap()); - envelope.put("eventId", event.getId().toString()); + envelope.put("eventId", event.getId().value()); envelope.put("type", event.getType()); envelope.put("aggregateId", event.getAggregateId().value()); envelope.put("occurredAt",