From 9e8ea37e882ef9487a85e7478491f75cfb2014ad Mon Sep 17 00:00:00 2001 From: Lars Simon Winzer Date: Fri, 20 Mar 2026 16:37:46 +0100 Subject: [PATCH] Remove: DisconnectEvent handler from NetworkManager --- .../casono/server/network/NetworkManager.java | 17 +---------------- 1 file changed, 1 insertion(+), 16 deletions(-) diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/NetworkManager.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/NetworkManager.java index 4833d61..d9382a4 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/NetworkManager.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/NetworkManager.java @@ -1,7 +1,5 @@ package ch.unibas.dmi.dbis.cs108.casono.server.network; -import ch.unibas.dmi.dbis.cs108.casono.server.network.events.DisconnectEvent; -import ch.unibas.dmi.dbis.cs108.casono.server.network.events.EventBus; import ch.unibas.dmi.dbis.cs108.casono.server.network.sessions.SessionManager; import ch.unibas.dmi.dbis.cs108.casono.server.network.transport.TcpTransport; import java.io.IOException; @@ -17,23 +15,19 @@ public class NetworkManager implements Runnable { private Thread thread; private Boolean running; private SessionManager sessionManager; - private EventBus eventBus; /** * Creates a new NetworkManager with the given port, session manager, and event bus. * * @param port the port to listen on * @param sessionManager the session manager to use - * @param eventBus the event bus for events */ - public NetworkManager(Integer port, SessionManager sessionManager, EventBus eventBus) { + public NetworkManager(Integer port, SessionManager sessionManager) { this.port = port; this.logger = LogManager.getLogger(NetworkManager.class); this.thread = new Thread(this, "networkManager"); this.running = true; this.sessionManager = sessionManager; - this.eventBus = eventBus; - this.eventBus.subscribe(DisconnectEvent.class, event -> clientDisconnected(event)); } /** Starts the internal thread to accept new connections. */ @@ -42,15 +36,6 @@ public class NetworkManager implements Runnable { thread.start(); } - /** - * Handles client disconnection events. - * - * @param event the disconnect event - */ - public void clientDisconnected(DisconnectEvent event) { - logger.info("Session {} disconnected", event.sessionId().value()); - } - /** Runs the network manager loop, accepting connections. */ @Override public void run() {