From 367a690dc88fd1d0dd7cfcbd5a93d00021280680 Mon Sep 17 00:00:00 2001
From: CyB3RC0nN0R <kske@outlook.de>
Date: Wed, 10 Jun 2020 11:05:28 +0200
Subject: [PATCH] Replace UserStatusChangeProcessor with inline code in
 ChatScene

---
 src/main/java/envoy/client/net/Client.java    |  2 +-
 .../client/net/UserStatusChangeProcessor.java | 33 -------------------
 .../envoy/client/ui/controller/ChatScene.java | 15 ++++++---
 3 files changed, 12 insertions(+), 38 deletions(-)
 delete mode 100644 src/main/java/envoy/client/net/UserStatusChangeProcessor.java

diff --git a/src/main/java/envoy/client/net/Client.java b/src/main/java/envoy/client/net/Client.java
index 0d09780..7aaf28b 100644
--- a/src/main/java/envoy/client/net/Client.java
+++ b/src/main/java/envoy/client/net/Client.java
@@ -141,7 +141,7 @@ public class Client implements Closeable {
 		receiver.registerProcessor(MessageStatusChangeEvent.class, new MessageStatusChangeEventProcessor());
 
 		// Process user status changes
-		receiver.registerProcessor(UserStatusChangeEvent.class, new UserStatusChangeProcessor(localDB));
+		receiver.registerProcessor(UserStatusChangeEvent.class, eventBus::dispatch);
 
 		// Process message ID generation
 		receiver.registerProcessor(IDGenerator.class, localDB::setIDGenerator);
diff --git a/src/main/java/envoy/client/net/UserStatusChangeProcessor.java b/src/main/java/envoy/client/net/UserStatusChangeProcessor.java
deleted file mode 100644
index 9120662..0000000
--- a/src/main/java/envoy/client/net/UserStatusChangeProcessor.java
+++ /dev/null
@@ -1,33 +0,0 @@
-package envoy.client.net;
-
-import java.util.function.Consumer;
-
-import envoy.client.data.LocalDB;
-import envoy.data.User;
-import envoy.event.EventBus;
-import envoy.event.UserStatusChangeEvent;
-
-/**
- * Project: <strong>envoy-client</strong><br>
- * File: <strong>UserStatusChangeProcessor.java</strong><br>
- * Created: <strong>2 Feb 2020</strong><br>
- *
- * @author Leon Hofmeister
- * @since Envoy Client v0.3-alpha
- */
-public class UserStatusChangeProcessor implements Consumer<UserStatusChangeEvent> {
-
-	private final LocalDB localDB;
-
-	/**
-	 * @param localDB the local database in which status updates will by applied
-	 * @since Envoy Client v0.3-alpha
-	 */
-	public UserStatusChangeProcessor(LocalDB localDB) { this.localDB = localDB; }
-
-	@Override
-	public void accept(UserStatusChangeEvent evt) {
-		localDB.getUsers().values().stream().filter(u -> u.getID() == evt.getID()).map(User.class::cast).findFirst().get().setStatus(evt.get());
-		EventBus.getInstance().dispatch(evt);
-	}
-}
diff --git a/src/main/java/envoy/client/ui/controller/ChatScene.java b/src/main/java/envoy/client/ui/controller/ChatScene.java
index 6fdbd2f..e57dedf 100644
--- a/src/main/java/envoy/client/ui/controller/ChatScene.java
+++ b/src/main/java/envoy/client/ui/controller/ChatScene.java
@@ -22,9 +22,7 @@ import envoy.client.net.WriteProxy;
 import envoy.client.ui.ContactListCell;
 import envoy.client.ui.MessageListCell;
 import envoy.client.ui.SceneContext;
-import envoy.data.Contact;
-import envoy.data.Message;
-import envoy.data.MessageBuilder;
+import envoy.data.*;
 import envoy.event.EventBus;
 import envoy.event.MessageStatusChangeEvent;
 import envoy.event.UserStatusChangeEvent;
@@ -105,7 +103,16 @@ public final class ChatScene {
 		});
 
 		// Listen to user status changes
-		eventBus.register(UserStatusChangeEvent.class, e -> Platform.runLater(userList::refresh));
+		eventBus.register(UserStatusChangeEvent.class, e ->
+			userList.getItems()
+				.stream()
+				.filter(c -> c.getID() == e.getID())
+				.findAny()
+				.ifPresent(u -> {
+					((User) u).setStatus(e.get());
+					Platform.runLater(userList::refresh);
+				})
+		);
 
 		// Listen to contacts changes
 		eventBus.register(ContactOperationEvent.class, e -> {