diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/ServerApp.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/ServerApp.java index a7814b0..d4cc99b 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/ServerApp.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/ServerApp.java @@ -5,9 +5,7 @@ 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; -/** - * Application class for starting the server. - */ +/** Application class for starting the server. */ public class ServerApp { public static void start(String arg) { int port = Integer.parseInt(arg); 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 cd2f677..016cd47 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 @@ -11,9 +11,7 @@ import java.net.Socket; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; -/** - * Creates and manages the server socket. Accepts new incoming connections and creates sessions. - */ +/** Creates and manages the server socket. Accepts new incoming connections and creates sessions. */ public class NetworkManager implements Runnable { private Integer port; private Logger logger; @@ -39,9 +37,7 @@ public class NetworkManager implements Runnable { this.eventBus.subscribe(DisconnectEvent.class, event -> clientDisconnected(event)); } - /** - * Starts the internal thread to accept new connections. - */ + /** Starts the internal thread to accept new connections. */ public void start() { logger.debug("Starting server at port " + port); thread.start(); @@ -56,9 +52,7 @@ public class NetworkManager implements Runnable { logger.info("Session " + event.sessionId().value() + " disconnected adhasghd"); } - /** - * Runs the network manager loop, accepting connections. - */ + /** Runs the network manager loop, accepting connections. */ @Override public void run() { try (ServerSocket serverSocket = new ServerSocket(port)) { diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/DisconnectEvent.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/DisconnectEvent.java index b6b0d78..a866d56 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/DisconnectEvent.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/DisconnectEvent.java @@ -2,7 +2,5 @@ package ch.unibas.dmi.dbis.cs108.casono.server.network.events; import ch.unibas.dmi.dbis.cs108.casono.server.network.sessions.SessionId; -/** - * Represents a disconnect event for a session. - */ +/** Represents a disconnect event for a session. */ public record DisconnectEvent(SessionId sessionId) implements Event {} diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/Event.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/Event.java index 75c0954..1a8fc4b 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/Event.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/Event.java @@ -1,6 +1,4 @@ package ch.unibas.dmi.dbis.cs108.casono.server.network.events; -/** - * Marker interface for events in the event bus system. - */ +/** Marker interface for events in the event bus system. */ interface Event {} diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/EventBus.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/EventBus.java index 4141ab8..85b8ff8 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/EventBus.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/events/EventBus.java @@ -7,9 +7,7 @@ import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.function.Consumer; -/** - * A simple event bus for publishing and subscribing to events. - */ +/** A simple event bus for publishing and subscribing to events. */ public class EventBus { private final Map, List>> handlers = new ConcurrentHashMap<>(); diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/Session.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/Session.java index 11b57d5..d716ac0 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/Session.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/Session.java @@ -8,9 +8,7 @@ import java.io.IOException; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; -/** - * Represents a client session in the network server. - */ +/** Represents a client session in the network server. */ public class Session implements Runnable { private SessionId id; private Thread thread; @@ -18,12 +16,12 @@ public class Session implements Runnable { private Logger logger; private Boolean running; private EventBus eventBus; - + /** * Creates a new Session with the given transport and event bus. * * @param transport the transport layer for communication - * @param eventBus the event bus for publishing events + * @param eventBus the event bus for publishing events * @throws IOException if an I/O error occurs during initialization */ public Session(TransportLayer transport, EventBus eventBus) throws IOException { @@ -46,9 +44,7 @@ public class Session implements Runnable { return this.id; } - /** - * Starts the session thread. - */ + /** Starts the session thread. */ public void start() { thread.start(); } @@ -63,9 +59,7 @@ public class Session implements Runnable { this.running = false; } - /** - * Runs the session loop, reading from the transport. - */ + /** Runs the session loop, reading from the transport. */ @Override public void run() { while (running) { diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionId.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionId.java index 431ebdc..2645323 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionId.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionId.java @@ -2,15 +2,11 @@ package ch.unibas.dmi.dbis.cs108.casono.server.network.sessions; import java.util.UUID; -/** - * Represents a unique identifier for a session. - */ +/** Represents a unique identifier for a session. */ public class SessionId { private final UUID value; - /** - * Creates a new SessionId with a randomly generated UUID. - */ + /** Creates a new SessionId with a randomly generated UUID. */ public SessionId() { this.value = UUID.randomUUID(); } diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionManager.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionManager.java index 42bc4ac..e12b319 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionManager.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/sessions/SessionManager.java @@ -3,15 +3,11 @@ package ch.unibas.dmi.dbis.cs108.casono.server.network.sessions; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; -/** - * Manages active sessions in the server. - */ +/** Manages active sessions in the server. */ public class SessionManager { private Map sessions; - /** - * Constructs a new SessionManager. - */ + /** Constructs a new SessionManager. */ public SessionManager() { this.sessions = new ConcurrentHashMap<>(); } diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/transport/TcpTransport.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/transport/TcpTransport.java index 3f80d6c..bd754bd 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/transport/TcpTransport.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/transport/TcpTransport.java @@ -6,9 +6,7 @@ import java.io.IOException; import java.net.Socket; import java.nio.charset.StandardCharsets; -/** - * Implements TCP-based transport layer for network communication. - */ +/** Implements TCP-based transport layer for network communication. */ public class TcpTransport implements TransportLayer { private Socket socket; private DataInputStream in; diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/transport/TransportLayer.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/transport/TransportLayer.java index f487a9c..4bd9e36 100644 --- a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/transport/TransportLayer.java +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/network/transport/TransportLayer.java @@ -2,9 +2,7 @@ package ch.unibas.dmi.dbis.cs108.casono.server.network.transport; import java.io.IOException; -/** - * Interface for transport layer implementations. - */ +/** Interface for transport layer implementations. */ public interface TransportLayer { /** * Reads data from the transport layer.