Fixed issue in EngineIoSocket related to initial query and headers re…

…turning null
socketio · Mar 4, 2021 · 0f2b7ca · 0f2b7ca
1 parent 4022c1c
commit 0f2b7ca
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/engine.io-server/src/main/java/io/socket/engineio/server/EngineIoServer.java b/engine.io-server/src/main/java/io/socket/engineio/server/EngineIoServer.java
@@ -186,6 +186,7 @@ private void handshakePolling(HttpServletRequest request, HttpServletResponse re
         final Transport transport = new Polling(lockObject);
         socket.init(transport, request);
         transport.onRequest(request, response);
+        socket.updateInitialHeadersFromActiveTransport();
 
         mClients.put(sid, socket);
         socket.once("close", args -> mClients.remove(sid));

diff --git a/engine.io-server/src/main/java/io/socket/engineio/server/EngineIoSocket.java b/engine.io-server/src/main/java/io/socket/engineio/server/EngineIoSocket.java
@@ -133,6 +133,11 @@ void init(Transport transport, @SuppressWarnings("unused") HttpServletRequest in
         onOpen();
     }
 
+    void updateInitialHeadersFromActiveTransport() {
+        mInitialQuery = mTransport.getInitialQuery();
+        mInitialHeaders = mTransport.getInitialHeaders();
+    }
+
     /**
      * Handle an HTTP request.
      *