fix backend

AndreKoepke · Feb 22, 2025 · 856f651 · 856f651
1 parent 27671cf
commit 856f651
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/...src/main/java/ch/akop/homesystem/controller/for_private/websocket/AbstractBaseSocket.java b/...src/main/java/ch/akop/homesystem/controller/for_private/websocket/AbstractBaseSocket.java
@@ -28,7 +28,7 @@ public void deregisterSession(String sessionId) {
   }
 
   public void broadcast(Object message) {
-    sessions.values().forEach(session -> sendMessage(session, message));
+    sessions.keySet().forEach(sessionId -> sendMessage(sessionId, message));
   }
 
   @SneakyThrows

diff --git a/...rc/main/java/ch/akop/homesystem/controller/for_private/websocket/ActorsChangedSocket.java b/...rc/main/java/ch/akop/homesystem/controller/for_private/websocket/ActorsChangedSocket.java
@@ -38,7 +38,7 @@ void updateLight(String updatedDeviceId) {
   public void onOpen(Session session) {
     log.info("Opening session: {}", session.getId());
     registerSession(session);
-    sendAllLightsToSession(session);
+    sendAllLightsToSession(session.getId());
   }
 
   @OnClose
@@ -54,10 +54,10 @@ public void onError(Session session, Throwable throwable) {
   }
 
   @SneakyThrows
-  private void sendAllLightsToSession(Session session) {
+  private void sendAllLightsToSession(String sessionId) {
     deviceService.getDevicesOfType(SimpleLight.class)
         .stream()
         .map(ActorDto::from)
-        .forEach(motionSensor -> sendMessage(session, motionSensor));
+        .forEach(motionSensor -> sendMessage(sessionId, motionSensor));
   }
 }
diff --git a/...c/main/java/ch/akop/homesystem/controller/for_private/websocket/SensorsChangedSocket.java b/...c/main/java/ch/akop/homesystem/controller/for_private/websocket/SensorsChangedSocket.java
@@ -38,7 +38,7 @@ void updateSensor(String updatedDeviceId) {
   public void onOpen(Session session) {
     log.info("Opening session: {}", session.getId());
     registerSession(session);
-    sendAllSensorsToSession(session);
+    sendAllSensorsToSession(session.getId());
   }
 
   @OnClose
@@ -54,10 +54,10 @@ public void onError(Session session, Throwable throwable) {
   }
 
   @SneakyThrows
-  private void sendAllSensorsToSession(Session session) {
+  private void sendAllSensorsToSession(String sessionId) {
     deviceService.getDevicesOfType(MotionSensor.class)
         .stream()
         .map(SensorDto::from)
-        .forEach(motionSensor -> sendMessage(session, motionSensor));
+        .forEach(motionSensor -> sendMessage(sessionId, motionSensor));
   }
 }