2024/08/chat_demo1/chat_demo1_web/src/main/java/ch/polgrabia/demos/client/WebsocketClientApp.java

@@ -9,7 +9,7 @@ public class WebsocketClientApp {
     public static void main(String[] args) {
         var vertx = Vertx.vertx();
         logger.info("Deploying websocket particle");
-        WebsocketClientParticle websocketClientParticle = new WebsocketClientParticle("localhost", 8080, "/test");
+        WebsocketClientParticle websocketClientParticle = new WebsocketClientParticle("localhost", 8080, "/");
         vertx.deployVerticle(websocketClientParticle);
         logger.info("Deployed websocket particle");
         websocketClientParticle

2024/08/chat_demo1/chat_demo1_web/src/main/java/ch/polgrabia/demos/client/WebsocketClientParticle.java

@@ -11,17 +11,18 @@ import io.vertx.core.impl.VertxInternal;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.ByteArrayOutputStream;
 import java.util.concurrent.CompletableFuture;
 
 public class WebsocketClientParticle extends AbstractVerticle {
     private static final Logger logger = LoggerFactory.getLogger(WebsocketClientParticle.class);
     private final String hostname;
     private final int port;
-    // path maps to channel
     private final String path;
     private HttpClient client;
     private boolean isShuttingDownActivated = false;
     private final Object runningMonitor = new Object();
+    private ByteArrayOutputStream clientTextInput;
 
     public WebsocketClientParticle(String hostname, int port, String path) {
         this.hostname = hostname;
@@ -30,7 +31,7 @@ public class WebsocketClientParticle extends AbstractVerticle {
     }
 
     @Override
-    public void start() {
+    public void start() throws Exception {
         this.client = getVertx()
                 .createHttpClient();
         new WebSocketClientImpl((VertxInternal) getVertx(), new HttpClientOptions(), new CloseFuture())
@@ -55,7 +56,7 @@ public class WebsocketClientParticle extends AbstractVerticle {
         ));
 
         webSocket
-                .binaryMessageHandler(msg -> logger.info("[{}] Got message: {}", path, msg))
+                .binaryMessageHandler(msg -> logger.info("Got message: {}", msg))
                 .closeHandler(unused -> {
                     try {
                         stop();
@@ -67,7 +68,7 @@ public class WebsocketClientParticle extends AbstractVerticle {
     }
 
     @Override
-    public void stop() {
+    public void stop() throws Exception {
         isShuttingDownActivated = true;
         client.close();
         synchronized (runningMonitor) {

2024/08/chat_demo1/chat_demo1_web/src/main/java/ch/polgrabia/demos/server/WebsocketServerHandler.java

@@ -1,5 +1,6 @@
 package ch.polgrabia.demos.server;
 
+import ch.polgrabia.demos.client.WebsocketClientApp;
 import io.vertx.core.Handler;
 import io.vertx.core.buffer.Buffer;
 import io.vertx.core.http.ServerWebSocket;
@@ -26,7 +27,7 @@ public class WebsocketServerHandler implements Handler<ServerWebSocket> {
 
         @Override
         public void handle(Buffer s) {
-            logger.info("[{}] Got message {}", serverWebSocket.path(), s);
+            logger.info("Got message {}", s);
             serverWebSocket.writeBinaryMessage(Buffer.buffer("Pong: " + s.toString() + "\n")); // TBD send to kafka
         }
     }