Method sendWsApiRequest

src/node-binance-api.ts:1637–1676

* Send a JSON-RPC request on the WebSocket API connection * @param {string} connectionId - connection identifier * @param {string} method - JSON-RPC method name * @param {object} params - method parameters * @return {Promise} - resolves with the result or rejects with error

(connectionId: string, method: string, params: any = {})

     * @return {Promise} - resolves with the result or rejects with error
     */
    sendWsApiRequest(connectionId: string, method: string, params: any = {}): Promise<any> {
        return new Promise((resolve, reject) => {
            const ws = this.wsApiConnections[connectionId];
            if (!ws || ws.readyState !== WebSocket.OPEN) {
                reject(new Error('WebSocket API connection not open'));
                return;
            }

            const requestId = this.generateRequestId();
            const request = {
                id: requestId,
                method: method,
                params: params
            };

            const settle = (fn: Function, value: any) => {
                const pending = this.wsApiPendingRequests[requestId];
                if (!pending) return; // already settled
                clearTimeout(pending.timer);
                delete this.wsApiPendingRequests[requestId];
                fn(value);
            };

            const timer = setTimeout(() => {
                settle(reject, new Error('WebSocket API request timeout'));
            }, 30000);

            this.wsApiPendingRequests[requestId] = { resolve: (v: any) => settle(resolve, v), reject: (e: any) => settle(reject, e), timer, connectionId };

            if (this.Options.verbose) {
                this.Options.log('WebSocket API: Sending request:', JSON.stringify(request));
            }

            ws.send(JSON.stringify(request), (error) => {
                if (error) {
                    settle(reject, error);
                }
            });
        });
    }

    /**
     * Generate a unique request ID for JSON-RPC requests