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);