From 414ddba60e5d44c8859c6d48ba05b32417066931 Mon Sep 17 00:00:00 2001 From: Pol Pinol Castuera Date: Thu, 29 May 2025 14:47:05 +0200 Subject: [PATCH] Save inbox id --- .../io/autoinvestor/application/RegisterUserCommandHandler.java | 2 ++ .../read_models/users/MongoInboxReadModelRepository.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/io/autoinvestor/application/RegisterUserCommandHandler.java b/src/main/java/io/autoinvestor/application/RegisterUserCommandHandler.java index b941064..8ef8dec 100644 --- a/src/main/java/io/autoinvestor/application/RegisterUserCommandHandler.java +++ b/src/main/java/io/autoinvestor/application/RegisterUserCommandHandler.java @@ -43,6 +43,8 @@ public void handle(RegisterUserCommand command) { this.portfolioRepository.addUser(command.userId(), command.riskLevel()); + this.inboxReadModel.save(UserId.from(command.userId()), inbox.getState().getInboxId()); + this.eventPublisher.publish(events); inbox.markEventsAsCommitted(); diff --git a/src/main/java/io/autoinvestor/infrastructure/read_models/users/MongoInboxReadModelRepository.java b/src/main/java/io/autoinvestor/infrastructure/read_models/users/MongoInboxReadModelRepository.java index 49c8f18..aff4fde 100644 --- a/src/main/java/io/autoinvestor/infrastructure/read_models/users/MongoInboxReadModelRepository.java +++ b/src/main/java/io/autoinvestor/infrastructure/read_models/users/MongoInboxReadModelRepository.java @@ -20,7 +20,7 @@ public MongoInboxReadModelRepository(MongoTemplate template) { } @Override - public void save(UserId userId, io.autoinvestor.domain.model.InboxId inboxId) { + public void save(UserId userId, InboxId inboxId) { String userIdStr = userId.value(); String inboxIdStr = inboxId.value(); DecisionDocument doc = new DecisionDocument(userIdStr, inboxIdStr);