2026-03-24 15:02:16 +01:00
1 changed files with 18 additions and 0 deletions
@@ -0,0 +1,18 @@
+package ch.unibas.dmi.dbis.cs108.casono.server.network.response;
+
+import ch.unibas.dmi.dbis.cs108.casono.server.network.sessions.Session;
+import ch.unibas.dmi.dbis.cs108.casono.server.network.sessions.SessionManager;
+
+public class ResponseDispatcher {
+    private final SessionManager sessionManager;
+
+    public ResponseDispatcher(SessionManager sessionManager) {
+        this.sessionManager = sessionManager;
+    }
+
+    public void dispatch(Response response) throws InterruptedException {
+        PrimitiveResponse primitiveResponse = ResponseEncoder.encode(response);
+        Session session = sessionManager.getSessionById(response.getSessionId());
+        session.getResponseQueue().put(primitiveResponse);
+    }
+}