Handle WS-ping

olle · Nov 25, 2024 · ecaf613 · ecaf613
1 parent fca9926
commit ecaf613
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 3 deletions.
diff --git a/ui/Makefile b/ui/Makefile
@@ -1,4 +1,4 @@
-JAVA_HOME=$(shell unset JAVA_HOME; /usr/libexec/java_home -v 17)
+JAVA_HOME=$(shell unset JAVA_HOME; /usr/libexec/java_home -v 21)
 
 .PHONY: run build test verify clean tidy
 

diff --git a/ui/pom.xml b/ui/pom.xml
@@ -12,14 +12,14 @@
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>3.0.4</version>
+        <version>3.4.0</version>
         <relativePath />
     </parent>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-        <java.version>17</java.version>
+        <java.version>21</java.version>
     </properties>
 
     <dependencies>

diff --git a/ui/src/main/java/com/studiomediatech/queryresponse/ui/api/WebSocketApiHandler.java b/ui/src/main/java/com/studiomediatech/queryresponse/ui/api/WebSocketApiHandler.java
@@ -43,6 +43,8 @@ public WebSocketApiHandler(EventEmitter emitter) {
     @Override
     public void afterConnectionEstablished(WebSocketSession session) throws Exception {
 
+        log().info("CONNECTED {}", session);
+
         sessionsById.put(session.getId(),
                 new ConcurrentWebSocketSessionDecorator(session, SEND_TIME_LIMIT, SEND_BUFFER_SIZE_LIMIT));
     }
@@ -56,6 +58,11 @@ public void afterConnectionClosed(WebSocketSession session, CloseStatus status)
     @Override
     protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
 
+        if ("ping".equals(message.getPayload())) {
+            session.sendMessage(new TextMessage("pong"));
+            return;
+        }
+
         emitter.emitEvent(QueryRecordedEvent.valueOf(message.getPayload(), session.getId()));
     }