Merge pull request #967 from addicheung/patch-auth-data

Make custom namespaces support auth data
mrniko · Mar 22, 2024 · 8243315 · 8243315
2 parents de4187e + 363b6c6
commit 8243315
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java b/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java
@@ -326,15 +326,19 @@ private String readNamespace(ByteBuf frame, final boolean defaultToAll) {
 
         int endIndex = buffer.bytesBefore((byte) '?');
         if (endIndex > 0) {
-            // skip this frame
-            frame.readerIndex(frame.readerIndex() + frame.readableBytes());
-            return readString(buffer, endIndex);
+            String namespace = readString(buffer, endIndex);
+            if(namespace.startsWith("/")) {
+                frame.readerIndex(frame.readerIndex() + endIndex + 1);
+                return namespace;
+            }
         }
         endIndex = buffer.bytesBefore((byte) ',');
         if (endIndex > 0) {
-            // skip this frame
-            frame.readerIndex(frame.readerIndex() + frame.readableBytes());
-            return readString(buffer, endIndex);
+            String namespace = readString(buffer, endIndex);
+            if(namespace.startsWith("/")) {
+                frame.readerIndex(frame.readerIndex() + endIndex + 1);
+                return namespace;
+            }
         }
         if (defaultToAll) {
             // skip this frame