From: Kai Moritz <kai@juplo.de>
Date: Wed, 25 Jan 2023 17:51:38 +0000 (+0100)
Subject: WIP:refactor
X-Git-Tag: wip~10
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ce7f5a067b0af16442255903cb06e97dfa4fd352;p=demos%2Fkafka%2Fchat

WIP:refactor
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java
index 9ea4cef3..da5eba2a 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoom.java
@@ -66,30 +66,30 @@ public class ChatRoom
       throw new InvalidUsernameException(user);
 
     Message.MessageKey key = Message.MessageKey.of(user, id);
-
     return service
-      .getMessage(key)
-      .handle((Message existing, SynchronousSink<Message> sink) ->
-      {
-        if (existing.getMessageText().equals(text))
-        {
-          sink.next(existing);
-        }
-        else
-        {
-          sink.error(new MessageMutationException(existing, text));
-        }
-      })
-      .switchIfEmpty(Mono.defer(() -> service
-        .persistMessage(key, LocalDateTime.now(clock), text)
-        .doOnNext(m ->
+        .getMessage(key)
+        .handle((Message existing, SynchronousSink<Message> sink) ->
         {
-          Sinks.EmitResult result = sink.tryEmitNext(m);
-          if (result.isFailure())
+          if (existing.getMessageText().equals(text))
+          {
+            sink.next(existing);
+          }
+          else
           {
-            log.warn("Emitting of message failed with {} for {}", result.name(), m);
+            sink.error(new MessageMutationException(existing, text));
           }
-        })));
+        })
+        .switchIfEmpty(
+            Mono
+                .defer(() -> service.persistMessage(key, LocalDateTime.now(clock), text))
+                .doOnNext(m ->
+                {
+                  Sinks.EmitResult result = sink.tryEmitNext(m);
+                  if (result.isFailure())
+                  {
+                    log.warn("Emitting of message failed with {} for {}", result.name(), m);
+                  }
+                }));
   }