pandalib-ws-client/src/main/java/fr/pandacube/lib/ws/client/AbstractClientWS.java

@@ -1,5 +1,6 @@
 package fr.pandacube.lib.ws.client;
 
+import fr.pandacube.lib.util.Log;
 import fr.pandacube.lib.util.ThrowableUtil;
 import fr.pandacube.lib.ws.AbstractWS;
 
@@ -15,6 +16,7 @@ import java.util.concurrent.CompletionException;
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.atomic.AtomicReference;
 
+// TODO implement auto-reconnect
 /**
  * Minimal implementation of a Websocket client endpoint using the java.net.http Websocket API.
  */
@@ -22,7 +24,6 @@ public abstract class AbstractClientWS implements AbstractWS {
 
     private final URI uri;
     private boolean autoReconnect;
-    private boolean isConnecting;
     private final AtomicReference<WebSocket> socket = new AtomicReference<>();
 
 
@@ -47,27 +48,14 @@ public abstract class AbstractClientWS implements AbstractWS {
 
         @Override
         public CompletionStage<?> onClose(WebSocket webSocket, int statusCode, String reason) {
-            try {
-                AbstractClientWS.this.onClose(statusCode, reason);
-            } finally {
-                synchronized (socket) {
-                    socket.set(null);
-                    reconnectIfNecessary();
-                }
-            }
-            return null;
+            AbstractClientWS.this.onClose(statusCode, reason);
+            return Listener.super.onClose(webSocket, statusCode, reason);
         }
 
         @Override
         public void onError(WebSocket webSocket, Throwable error) {
-            try {
-                AbstractClientWS.this.onError(error);
-            } finally {
-                synchronized (socket) {
-                    socket.set(null);
-                    reconnectIfNecessary();
-                }
-            }
+            AbstractClientWS.this.onError(error);
+            Listener.super.onError(webSocket, error);
         }
     };
 
@@ -81,40 +69,21 @@ public abstract class AbstractClientWS implements AbstractWS {
     public AbstractClientWS(String uri, boolean autoReconnect) throws URISyntaxException {
         this.uri = new URI(uri);
         this.autoReconnect = autoReconnect;
-        connect();
-    }
-
-
-    private void reconnectIfNecessary() {
-        synchronized (socket) {
-            if (autoReconnect && !isConnecting && socket.get() == null) {
-                connect();
-            }
+        if (autoReconnect) {
+            Log.warning("Websocket client auto-reconnect is not yet implemented.");
         }
+        connect();
     }
 
 
     private void connect() {
         synchronized (socket) {
-            isConnecting = true;
-            HttpClient.newHttpClient()
+            socket.set(HttpClient.newHttpClient()
                     .newWebSocketBuilder()
-                    .connectTimeout(Duration.ofSeconds(5))
+                    .connectTimeout(Duration.ofSeconds(2))
                     .buildAsync(uri, receiveListener)
-                    .whenCompleteAsync((ws, ex) -> {
-                        synchronized (socket) {
-                            isConnecting = false;
-                            if (ws != null) {
-                                socket.set(ws);
-                            }
-                        }
-                        if (ex instanceof IOException) {
-                            reconnectIfNecessary();
-                        }
-                        else {
-                            logError("Error connecting (not trying to reconnect even if asked): ", ex);
-                        }
-                    });
+                    .join()
+            );
         }
     }
 
@@ -123,11 +92,7 @@ public abstract class AbstractClientWS implements AbstractWS {
     public final void sendString(String message) throws IOException {
         try {
             synchronized (socket) {
-                WebSocket ws = socket.get();
-                if (ws != null)
-                    ws.sendText(message, true).join();
-                else
-                    throw new IOException("Connection is currently closed");
+                socket.get().sendText(message, true).join();
             }
         } catch (CompletionException ce) {
             if (ce.getCause() instanceof IOException ioe)
@@ -145,9 +110,7 @@ public abstract class AbstractClientWS implements AbstractWS {
     public final void sendClose(int code, String reason) throws IOException {
         synchronized (socket) {
             autoReconnect = false; // if we ask for closing connection, dont reconnect automatically
-            WebSocket ws = socket.get();
-            if (ws != null)
-                ws.sendClose(code, reason).join();
+            socket.get().sendClose(code, reason).join();
         }
     }
 

pandalib-ws-server/src/main/java/fr/pandacube/lib/ws/server/AbstractServerWS.java

@@ -5,7 +5,6 @@ import org.eclipse.jetty.websocket.api.Session;
 import org.eclipse.jetty.websocket.api.WebSocketAdapter;
 
 import java.io.IOException;
-import java.nio.channels.ClosedChannelException;
 import java.time.Duration;
 
 /**
@@ -13,8 +12,6 @@ import java.time.Duration;
  */
 public abstract class AbstractServerWS extends WebSocketAdapter implements AbstractWS {
 	
-	private boolean isClosed = false;
-	
 	@Override
 	public final void onWebSocketConnect(Session sess)
 	{
@@ -40,8 +37,6 @@ public abstract class AbstractServerWS extends WebSocketAdapter implements Abstr
 
 	@Override
 	public final void onWebSocketError(Throwable cause) {
-		if (isClosed && cause instanceof ClosedChannelException)
-			return; // ignore because this exception is expected when we just sent a close packet.
 		onError(cause);
 	}
 
@@ -58,7 +53,6 @@ public abstract class AbstractServerWS extends WebSocketAdapter implements Abstr
 	@Override
 	public final void sendClose(int code, String reason) throws IOException {
 		getSession().close(code, reason);
-		isClosed = true;
 	}
 
 	@Override

pandalib-ws/src/main/java/fr/pandacube/lib/ws/AbstractWS.java

@@ -32,26 +32,15 @@ public interface AbstractWS {
             return;
         }
 
-        if (payload instanceof ErrorPayload errorPayload) {
-            try {
-                onReceiveErrorPayload(errorPayload);
-            } catch(Exception e) {
-                logError("Error while handling received error payload", e);
-            }
+        try {
+            onReceivePayload(payload);
+        } catch (Throwable t) {
+            trySendAsJson(new ErrorPayload("Error handling payload: " + t));
+            if (t instanceof Exception)
+                logError("Error handling payload", t);
+            else
+                throw t;
         }
-        else {
-            try {
-                onReceivePayload(payload);
-            } catch (Throwable t) {
-                trySendAsJson(new ErrorPayload("Error while handling your payload: " + t));
-                if (t instanceof Exception)
-                    logError("Error while handling received payload", t);
-                else
-                    throw t;
-            }
-        }
-
-
     }
 
     /**
@@ -73,15 +62,6 @@ public interface AbstractWS {
      */
     void onReceivePayload(Payload payload);
 
-    /**
-     * Called on reception of a valid {@link ErrorPayload}.
-     * @param error the received {@link ErrorPayload}.
-     * @implNote default implementation will log the received error.
-     */
-    default void onReceiveErrorPayload(ErrorPayload error) {
-        logError("Received the following error from the remote side: " + error.message, error.throwable);
-    }
-
     /**
      * Called on reception of a websocket Close packet.
      * The connection is closed after this method call.

pandalib-ws/src/main/java/fr/pandacube/lib/ws/PayloadRegistry.java

@@ -49,12 +49,12 @@ public class PayloadRegistry {
     public static Payload fromString(String message) {
         String[] split = message.split(Pattern.quote(PAYLOAD_TYPE_SEPARATOR), 2);
         if (split.length != 2) {
-            throw new IllegalArgumentException("Malformed message: does not respect format ‘<type>" + PAYLOAD_TYPE_SEPARATOR + "<jsonObject>’.");
+            throw new IllegalArgumentException("Malformed message: does not respect format '<type>" + PAYLOAD_TYPE_SEPARATOR + "<jsonObject>'.");
         }
 
         Class<? extends Payload> detectedClass = payloadClasses.get(split[0]);
         if (detectedClass == null) {
-            throw new IllegalArgumentException("Unrecognized data type ‘" + split[0] + "’.");
+            throw new IllegalArgumentException("Unrecognized data type '" + split[0] + "'.");
         }
 
         try {