Method proxyRequest

src/node-binance-api.ts:444–503

(opt: any)

    }

    async proxyRequest(opt: any) {
        const urlBody = new URLSearchParams(opt.form);
        const reqOptions: Dict = {
            method: opt.method,
            headers: opt.headers,
        };
        if (opt.method !== 'GET') {
            reqOptions.body = urlBody;
        }
        if (this.Options.verbose) {
            this.Options.log('HTTP Request:', opt.method, opt.url, reqOptions);
        }

        // https-proxy
        const httpsproxy = this.getHttpsProxy();
        const socksproxy = this.getSocksProxy();
        const urlProxy = this.getUrlProxy();
        if (httpsproxy) {
            if (this.Options.verbose) this.Options.log('using https proxy: ' + httpsproxy);
            reqOptions.agent = new HttpsProxyAgent(httpsproxy);
        } else if (socksproxy) {
            if (this.Options.verbose) this.Options.log('using socks proxy: ' + socksproxy);
            reqOptions.agent = new SocksProxyAgent(socksproxy);
        }

        if (urlProxy) {
            opt.url = urlProxy + opt.url;
        }

        // Apply timeout via AbortController
        const timeout = opt.timeout || this.Options.recvWindow || 30000;
        const controller = new AbortController();
        const timeoutId = setTimeout(() => controller.abort(), timeout);
        reqOptions.signal = controller.signal;

        let fetchImplementation = fetch;
        // require node-fetch
        if (reqOptions.agent) {
            fetchImplementation = nodeFetch;
        }

        try {
            const response = await fetchImplementation(opt.url, reqOptions);
            clearTimeout(timeoutId);

            await this.reqHandler(response);
            const json = await response.json();

            if (this.Options.verbose) {
                this.Options.log('HTTP Response:', json);
            }
            return json;
        } catch (error) {
            clearTimeout(timeoutId);
            if (error.name === 'AbortError') {
                throw new Error(`Request timeout: ${opt.method} ${opt.url} (${timeout}ms)`);
            }
            throw error;