fetch user from db before publish

FINTLabs · Nov 20, 2023 · 4746a3d · 4746a3d
1 parent 8e7991d
commit 4746a3d
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/main/java/no/fintlabs/user/UserService.java b/src/main/java/no/fintlabs/user/UserService.java
@@ -42,7 +42,7 @@ public void save(User user) {
     private Runnable onSaveNewUser(User user) {
         return () -> {
             User newUser = userRepository.save(user);
-            log.info("Create new user: " + user.getId());
+            //log.info("Create new user: " + user.getId());
             memberService.process(memberService.create(newUser));
             userEntityProducerService.publish(newUser);
         };
@@ -51,10 +51,11 @@ private Runnable onSaveNewUser(User user) {
     private Consumer<User> onSaveExistingUser(User user) {
         return existingUser -> {
             user.setId(existingUser.getId());
-            log.info("Update user: " + user.getId());
+            //log.info("Update user: " + user.getId());
             memberService.process(memberService.create(user));
             userRepository.save(user);
-            userEntityProducerService.publish(user);
+            User userToPublish = userRepository.findById(user.getId()).orElse(user);
+            userEntityProducerService.publish(userToPublish);
         };
     }