fix NPE when session not found.

tomazic89 · tomazic89 · commit 1ebc2b4d5a98 · 2024-08-09T15:21:59.000+02:00
diff --git a/src/main/java/org/iris_events/router/model/WSResponseHandler.java b/src/main/java/org/iris_events/router/model/WSResponseHandler.java
@@ -58,8 +58,10 @@ private void sendToSession(AmqpMessage message) {
         }
         UserSession session = websocketRegistry.getSession(sessionId);
         // assert session != null;
-        if (session == null && !nonRpcEvents.contains(message.eventType())) {
-            LOGGER.warn("Could not find session on this router message: {}", BackendRequest.sanitizeBody(message.body()));
+        if (session == null) {
+            if (!nonRpcEvents.contains(message.eventType())) {
+                LOGGER.warn("Could not find session on this router message: {}", BackendRequest.sanitizeBody(message.body()));
+            }
             return;
         }
         session.sendMessage(message);

Original file line number	Diff line number	Diff line change
`@@ -58,8 +58,10 @@ private void sendToSession(AmqpMessage message) {`
`58`	`58`	`}`
`59`	`59`	`UserSession session = websocketRegistry.getSession(sessionId);`
`60`	`60`	`// assert session != null;`
`61`		`- if (session == null && !nonRpcEvents.contains(message.eventType())) {`
`62`		`- LOGGER.warn("Could not find session on this router message: {}", BackendRequest.sanitizeBody(message.body()));`
	`61`	`+ if (session == null) {`
	`62`	`+ if (!nonRpcEvents.contains(message.eventType())) {`
	`63`	`+ LOGGER.warn("Could not find session on this router message: {}", BackendRequest.sanitizeBody(message.body()));`
	`64`	`+ }`
`63`	`65`	`return;`
`64`	`66`	`}`
`65`	`67`	`session.sendMessage(message);`