fix: use query params for private listenKey URL per new Binance spec

The new /private/ endpoint requires ?listenKey=<key> format
instead of the legacy path-based /<key> format.

Author: pcriadoperez

src/node-binance-api.ts

@@ -1802,6 +1802,10 @@ export default class Binance {
         let ws: any = undefined;
         const category = this.classifyFuturesStream(endpoint);
         const baseUrl = this.getFStreamSingleUrl(category);
+        // Private streams use query params: ?listenKey=<key> instead of path: /<key>
+        const wsUrl = category === 'private'
+            ? baseUrl.replace(/\/$/, '') + '?listenKey=' + endpoint
+            : baseUrl + endpoint;
 
         if (socksproxy) {
             socksproxy = this.proxyReplacewithIp(socksproxy);
@@ -1811,14 +1815,14 @@ export default class Binance {
                 host: this.parseProxy(socksproxy)[1],
                 port: this.parseProxy(socksproxy)[2]
             });
-            ws = new WebSocket(baseUrl + endpoint, { agent });
+            ws = new WebSocket(wsUrl, { agent });
         } else if (httpsproxy) {
             const config = url.parse(httpsproxy);
             const agent = new HttpsProxyAgent(config);
             if (this.Options.verbose) this.Options.log(`futuresSubscribeSingle: using proxy server: ${agent}`);
-            ws = new WebSocket(baseUrl + endpoint, { agent });
+            ws = new WebSocket(wsUrl, { agent });
         } else {
-            ws = new WebSocket(baseUrl + endpoint);
+            ws = new WebSocket(wsUrl);
         }
 
         if (this.Options.verbose) this.Options.log('futuresSubscribeSingle: Subscribed to ' + endpoint);

tests/ws-endpoints-migration.test.ts

@@ -133,6 +133,25 @@ describe('Demo mode uses category-based URLs', function () {
     });
 });
 
+describe('Private stream URL uses query params for listenKey', function () {
+    it('constructs ?listenKey= URL instead of path-based', function () {
+        const listenKey = 'pqia91ma19a5s61cv6a81va65sdf19v8a65a1a5s61cv6a81va65sdf19v8a1a65a1a5s61cv6a81va65sd';
+        const category = binance.classifyFuturesStream(listenKey);
+        const baseUrl = binance.getFStreamSingleUrl(category);
+        const wsUrl = baseUrl.replace(/\/$/, '') + '?listenKey=' + listenKey;
+        assert.equal(category, 'private');
+        assert.equal(wsUrl, `wss://fstream.binance.com/private/ws?listenKey=${listenKey}`);
+    });
+
+    it('constructs query-param URL for demo too', function () {
+        const listenKey = 'pqia91ma19a5s61cv6a81va65sdf19v8a65a1a5s61cv6a81va65sdf19v8a1a65a1a5s61cv6a81va65sd';
+        const category = demoBinance.classifyFuturesStream(listenKey);
+        const baseUrl = demoBinance.getFStreamSingleUrl(category);
+        const wsUrl = baseUrl.replace(/\/$/, '') + '?listenKey=' + listenKey;
+        assert.equal(wsUrl, `wss://fstream.binancefuture.com/private/ws?listenKey=${listenKey}`);
+    });
+});
+
 describe('Live: production market stream (aggTrade via /market/)', function () {
     let trade;
     let cnt = 0;