Блог

Я использую [https://github.com/huobiapi/REST-Node.js-demo ] [1] для моего подключения к криптобирже huobi, но у меня возникают некоторые ошибки, такие как :

  (node:29550) Warning: a promise was rejected with a non-error: [object Undefined]
  

и

  GET /v1/account/accounts/15548622/balance
  { Error: ESOCKETTIMEDOUT
 at ClientRequest.<anonymous> (/home/ttr/node_modules/request/request.js:816:19)
 at Object.onceWrapper (events.js:285:13)
 at ClientRequest.emit (events.js:197:13)
 at TLSSocket.emitRequestTimeout (_http_client.js:668:40)
 at Object.onceWrapper (events.js:285:13)
 at TLSSocket.emit (events.js:197:13)
 at TLSSocket.Socket._onTimeout (net.js:447:8)
 at listOnTimeout (timers.js:324:15)
 at processTimers (timers.js:268:5) code: 'ESOCKETTIMEDOUT', connect: false }
  

Я считаю, что они связаны с файлом:

   framework/httpClient.js
  

который имеет устаревший модуль
«запрос», может быть изменен на модуль axios, чтобы мои ошибки могли исчезнуть.

 const http = require('http');
const request = require('request');
const moment = require('moment');
const logger = console;

var default_post_headers = {
    'content-type': 'application/json;charset=utf-8',
}

var agentOptions = {
    keepAlive: true,
    maxSockets: 256,
}

exports.get = function(url, options) {
   return new Promise((resolve, reject) => {
        options = options || {};
        var httpOptions = {
            url: url,
            method: 'get',
            timeout: options.timeout || 3000,
            headers: options.headers || default_post_headers,
            proxy: options.proxy || '',
            agentOptions: agentOptions
        }
        request.get(httpOptions, function(err, res, body) {
            if (err) {
                reject(err);
            } else {
                if (res.statusCode == 200) {
                    resolve(body);
                } else {
                    reject(res.statusCode);
                }
            }
        }).on('error', logger.error);
    });
}

exports.post = function(url, postdata, options) {
    return new Promise((resolve, reject) => {
        options = options || {};
        var httpOptions = {
            url: url,
            body: JSON.stringify(postdata),
            method: 'post',
            timeout: options.timeout || 3000,
            headers: options.headers || default_post_headers,
            proxy: options.proxy || '',
            agentOptions: agentOptions
        };
        request(httpOptions, function(err, res, body) {
            if (err) {
                reject(err);
            } else {
                if (res.statusCode == 200) {
                    resolve(body);
                } else {
                    reject(res.statusCode);
                }
            }
        }).on('error', logger.error);
    });
};

exports.form_post = function(url, postdata, options) {
    return new Promise((resolve, reject) => {
        options = options || {};
        var httpOptions = {
            url: url,
            form: postdata,
            method: 'post',
            timeout: options.timeout || 3000,
            headers: options.headers || default_post_headers,
            proxy: options.proxy || '',
            agentOptions: agentOptions
        };
        request(httpOptions, function(err, res, body) {
            if (err) {
                reject(err);
            } else {
                if (res.statusCode == 200) {
                    resolve(body);
                } else {
                    reject(res.statusCode);
                }
            }
        }).on('error', logger.error);
    });
};
  

До сих пор я пытался :

     return new Promise((resolve, reject) => {
        options = options || {};
        var httpOptions = {
            url: url,
            method: 'get',
            timeout: options.timeout || 3000,
            headers: options.headers || default_post_headers,
            proxy: options.proxy || '',
            agentOptions: agentOptions
        }
        axios.get(httpOptions, function(err, res, body) {
            if (err) {
                reject(err);
            } else {
                if (res.statusCode == 200) {
                    resolve(body);
                } else {
                    reject(res.statusCode);
                }
            }
        }).on('error', logger.error);
    });
} 
  

Подобное решение, но похоже, что они не работают точно так же, поэтому не сработали.

  [1]: https://github.com/huobiapi/REST-Node.js-demo
  

Я только что перешел с запроса на axios и рекомендую внести следующие изменения:

импорт пакета qs

 const httpsAgent = new https.Agent({
    rejectUnauthorized: false / true,
    cert: <your cert>
    key: <your key> })



var httpOptions = {
    url: url
    data: qs.stringify(postdata)
    method: 'post',
    timeout: options.timeout || 3000,
    headers: options.headers || default_post_headers,
    proxy: options.proxy || '', (not sure about this)
    httpsAgent };
  

И это правильный способ отправки запроса:

 axios(httpOptions).then((resp)=>{
    // on success - for exmaple: console.log(response.status);
}).catch((err) => {
    //on failure - for example: return null;
});
  

ваш запрос, с одной стороны, содержит метод:post, а с другой стороны, вы выполнили axios.get
если полезная нагрузка вашего запроса содержит поле метода, вы можете просто запустить axios(параметры)

я только что удалил bluebird из модулей, и ошибки исчезли.