Binary eio v3 + Engine IO v3, v4 Interop JS integration tests

.gitattributes

@@ -0,0 +1,9 @@
+# Auto-detect text files and normalize line endings
+* text=auto
+
+# Declare explicit line endings for java files
+*.java text eol=lf
+*.xml text eol=lf
+*.yml text eol=lf
+*.yaml text eol=lf
+*.md text eol=lf

.github/workflows/build-pr.yml

@@ -18,14 +18,9 @@ jobs:
   build:
     strategy:
       matrix:
-        include:
-          - java-version: 17
-            delay: 0
-          - java-version: 21
-            delay: 0
-          - java-version: 25
-            delay: 0
+        os: [ubuntu-latest]
+        java-version: [17, 21, 25]
     uses: ./.github/workflows/build.yml
     with:
+      os: "${{ matrix.os }}"
       javaVersion: "${{ matrix.java-version }}"
-      delay: "${{ matrix.delay }}"

.github/workflows/build.yml

@@ -9,14 +9,18 @@ on:
       javaVersion:
         required: true
         type: string
+      os:
+        required: false
+        type: string
+        default: "ubuntu-latest"
       delay:
         required: false
         type: string
         default: "0"
 
 jobs:
   build:
-    runs-on: ubuntu-latest
+    runs-on: ${{ inputs.os }}
 
     env:
       # Allow Testcontainers to control Docker
@@ -26,39 +30,68 @@ jobs:
     steps:
       # --- Staggered delay ---
       - name: Stagger job start
-        run: sleep ${{ inputs.delay }}
+        env:
+          DELAY: ${{ inputs.delay }}
+        run: sleep "$DELAY"
 
       # --- Checkout ---
       - name: Checkout
-        uses: actions/checkout@v4
-
-      # --- Enable Docker (already preinstalled on runners) ---
-      - name: Start Docker daemon
-        run: |
-          sudo systemctl start docker
-          sudo systemctl status docker --no-pager
-
-      # --- Validate Docker works ---
-      - name: Docker Info
-        run: docker info
+        uses: actions/checkout@v7
 
       # --- Java / Maven Setup ---
       - name: Set up Java
-        uses: actions/setup-java@v3
+        uses: actions/setup-java@v5
         with:
           java-version: ${{ inputs.javaVersion }}
           distribution: temurin
           cache: maven
 
+      # --- Node.js 22 Setup with Package Caching ---
+      - name: Set up Node.js
+        uses: actions/setup-node@v7
+        with:
+          node-version: 22
+          cache: 'npm'
+          cache-dependency-path: 'netty-socketio-core/src/test/resources/js-interop/package-lock.json'
+
+      # --- Install JS Client Interop Dependencies ---
+      - name: Install JS Interop Dependencies
+        working-directory: netty-socketio-core/src/test/resources/js-interop
+        run: npm ci
+
+      # --- Cache Playwright Browsers ---
+      - name: Cache Playwright Browsers
+        id: playwright-cache
+        uses: actions/cache@v6
+        with:
+          path: ~/.cache/ms-playwright
+          key: ${{ runner.os }}-playwright-${{ hashFiles('netty-socketio-core/src/test/resources/js-interop/package-lock.json', 'netty-socketio-core/src/test/resources/js-interop/package.json') }}
+          restore-keys: |
+            ${{ runner.os }}-playwright-
+
+      # --- Install Playwright Browsers & OS Deps (On Cache Miss) ---
+      - name: Install Playwright Browsers & OS Deps
+        if: steps.playwright-cache.outputs.cache-hit != 'true'
+        working-directory: netty-socketio-core/src/test/resources/js-interop
+        run: npx playwright install --with-deps chromium firefox webkit
+
+      # --- Install OS Deps Only (On Cache Hit) ---
+      - name: Install Playwright OS Dependencies
+        if: steps.playwright-cache.outputs.cache-hit == 'true'
+        working-directory: netty-socketio-core/src/test/resources/js-interop
+        run: npx playwright install-deps chromium firefox webkit
+
       # --- Testcontainers configuration for CI ---
       - name: Disable Testcontainers reuse
         run: |
           echo "testcontainers.reuse.enable=false" > ~/.testcontainers.properties
-          cat ~/.testcontainers.properties
 
       # --- Build + Tests ---
       - name: Build Project
-        timeout-minutes: 90
+        timeout-minutes: 120
         run: |
-          export MAVEN_OPTS="-Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=WARN"
-          mvn --batch-mode --errors --fail-at-end -DforkCount=1 verify
+          export MAVEN_OPTS="-Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=WARN \
+                             -Dorg.slf4j.simpleLogger.defaultLogLevel=WARN \
+                             -Dcom.socketio4j.socketio.level=WARN \
+                             -Dio.netty.leakDetection.level=PARANOID"
+          mvn --batch-mode --errors --fail-at-end -DforkCount=1C verify

.github/workflows/maven-publish.yml

@@ -10,9 +10,9 @@ jobs:
       contents: read
       packages: write
     steps:
-    - uses: actions/checkout@v4
+    - uses: actions/checkout@v7
     - name: Set up JDK 21
-      uses: actions/setup-java@v4
+      uses: actions/setup-java@v5
       with:
           java-version: '21'
           distribution: 'temurin'

.gitignore

@@ -10,4 +10,5 @@
 **/.vscode
 **/.idea
 **/*.iml
-**/dependency-reduced-pom.xml
+**/dependency-reduced-pom.xml
+**/node_modules/

checkstyle.xml

@@ -191,7 +191,9 @@
         <module name="NestedIfDepth">
            <property name="max" value="3"/>
         </module>
-        <module name="NestedTryDepth"/>
+        <module name="NestedTryDepth">
+              <property name="max" value="2"/>
+        </module>
         <module name="NoClone"/>
         <module name="NoFinalizer"/>
         <module name="OneStatementPerLine"/>

netty-socketio-core/pom.xml

@@ -152,11 +152,6 @@
       <artifactId>testcontainers-kafka</artifactId>
       <scope>test</scope>
     </dependency>
-    <dependency>
-      <groupId>org.jmockit</groupId>
-      <artifactId>jmockit</artifactId>
-      <scope>test</scope>
-    </dependency>
     <dependency>
       <groupId>net.bytebuddy</groupId>
       <artifactId>byte-buddy-agent</artifactId>
@@ -177,6 +172,16 @@
       <artifactId>junit-platform-launcher</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.junit.platform</groupId>
+      <artifactId>junit-platform-suite-api</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.junit.platform</groupId>
+      <artifactId>junit-platform-suite-engine</artifactId>
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>org.testcontainers</groupId>
       <artifactId>testcontainers</artifactId>
@@ -207,6 +212,12 @@
       <artifactId>socket.io-client</artifactId>
       <scope>test</scope>
     </dependency>
+    <!-- OkHttp for raw HTTP/WS integration tests (EIOv3, SSL, etc.) -->
+    <dependency>
+      <groupId>com.squareup.okhttp3</groupId>
+      <artifactId>okhttp</artifactId>
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>com.github.javafaker</groupId>
       <artifactId>javafaker</artifactId>

netty-socketio-core/src/main/java/com/socketio4j/socketio/AckRequest.java

@@ -85,7 +85,7 @@ public void sendAckData(List<Object> objs) {
         if (!isAckRequested() || !sent.compareAndSet(false, true)) {
             return;
         }
-        Packet ackPacket = new Packet(PacketType.MESSAGE, client.getEngineIOVersion());
+        Packet ackPacket = new Packet(PacketType.MESSAGE);
         ackPacket.setSubType(PacketType.ACK);
         ackPacket.setAckId(originalPacket.getAckId());
         ackPacket.setData(objs);

netty-socketio-core/src/main/java/com/socketio4j/socketio/SingleRoomBroadcastOperations.java

@@ -21,8 +21,10 @@
 import java.util.Objects;
 import java.util.function.Predicate;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import com.socketio4j.socketio.misc.IterableCollection;
-import com.socketio4j.socketio.protocol.EngineIOVersion;
 import com.socketio4j.socketio.protocol.Packet;
 import com.socketio4j.socketio.protocol.PacketType;
 import com.socketio4j.socketio.store.StoreFactory;
@@ -34,6 +36,7 @@
  * Date: 2020/8/8 6:08 PM
  */
 public class SingleRoomBroadcastOperations implements BroadcastOperations {
+    private static final Logger log = LoggerFactory.getLogger(SingleRoomBroadcastOperations.class);
     private final String namespace;
     private final String room;
     private final Iterable<SocketIOClient> clients;
@@ -61,7 +64,6 @@ public Collection<SocketIOClient> getClients() {
     @Override
     public void send(Packet packet) {
         for (SocketIOClient client : clients) {
-            packet.setEngineIOVersion(client.getEngineIOVersion());
             client.send(packet);
         }
         dispatch(packet);
@@ -92,13 +94,12 @@ public void sendEvent(String name, SocketIOClient excludedClient, Object... data
 
     @Override
     public void sendEvent(String name, Predicate<SocketIOClient> excludePredicate, Object... data) {
-        Packet packet = new Packet(PacketType.MESSAGE, EngineIOVersion.UNKNOWN);
+        Packet packet = new Packet(PacketType.MESSAGE);
         packet.setSubType(PacketType.EVENT);
         packet.setName(name);
         packet.setData(Arrays.asList(data));
 
         for (SocketIOClient client : clients) {
-            packet.setEngineIOVersion(client.getEngineIOVersion());
             if (excludePredicate.test(client)) {
                 continue;
             }
@@ -109,7 +110,7 @@ public void sendEvent(String name, Predicate<SocketIOClient> excludePredicate, O
 
     @Override
     public void sendEvent(String name, Object... data) {
-        Packet packet = new Packet(PacketType.MESSAGE, EngineIOVersion.UNKNOWN);
+        Packet packet = new Packet(PacketType.MESSAGE);
         packet.setSubType(PacketType.EVENT);
         packet.setName(name);
         packet.setData(Arrays.asList(data));

netty-socketio-core/src/main/java/com/socketio4j/socketio/SocketIOServer.java

@@ -507,6 +507,7 @@ public Future<Void> startAsync() {
         }
 
         try {
+            configCopy.setPort(configuration.getPort());
             fireBeforeStart();
             log.info("Session store / event store factory: {}", configCopy.getStoreFactory());
             initGroups();
@@ -1068,6 +1069,16 @@ public void addConnectListener(ConnectListener listener) {
         mainNamespace.addConnectListener(listener);
     }
 
+    @Override
+    public void removeConnectListener(ConnectListener listener) {
+        mainNamespace.removeConnectListener(listener);
+    }
+
+    @Override
+    public void removeDisconnectListener(DisconnectListener listener) {
+        mainNamespace.removeDisconnectListener(listener);
+    }
+
     /**
      * Registers a listener that is notified when a ping frame
      * is received from a client.

netty-socketio-core/src/main/java/com/socketio4j/socketio/annotation/Internal.java

@@ -0,0 +1,54 @@
+/**
+ * Copyright (c) 2025 The Socketio4j Project
+ * Parent project : Copyright (c) 2012-2025 Nikita Koksharov
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.socketio4j.socketio.annotation;
+
+/**
+ * @author https://github.com/sanjomo
+ * @date 02/08/26 6:40 pm
+ */
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.Retention;
+import java.lang.annotation.Target;
+
+import static java.lang.annotation.ElementType.CONSTRUCTOR;
+import static java.lang.annotation.ElementType.FIELD;
+import static java.lang.annotation.ElementType.METHOD;
+import static java.lang.annotation.ElementType.PACKAGE;
+import static java.lang.annotation.ElementType.TYPE;
+import static java.lang.annotation.RetentionPolicy.CLASS;
+
+/**
+ * Marks an API as internal to socketio4j.
+ *
+ * <p>Types and members annotated with {@code @Internal} are implementation
+ * details and are <strong>NOT</strong> part of the supported public API.
+ * They may change, move, or be removed without notice in any release.
+ *
+ * <p>Application code should not depend on these APIs.
+ */
+@Documented
+@Retention(CLASS)
+@Target({
+        TYPE,
+        METHOD,
+        CONSTRUCTOR,
+        FIELD,
+        PACKAGE
+})
+public @interface Internal {
+}