Tengo una función que me básicamente consulta todos los exchanges y las monedas que tengo alojadas en unas constantes. La información la consulta sin problemas sin embargo soy nuevo en esto de Node y tengo problemas con las promesas. Necesito retornar la consulta total con todos los resultados y mostrarlos todos juntos y la verdad no logro hacerlo bien, he intentado de muchísimas formas.
"use strict";
const ccxt = require("ccxt");
let dataCoins = [];
const exchanges = [
["binance", "USDT", ["BTC", "BNB"]],
["coinbase", "USD", ["BTC"]],
["kraken", "USDT", ["BTC"]],
["kucoin", "USDT", ["BTC", "BNB"]],
["bitstamp", "USDT", ["BTC"]],
["okx", "USDT", ["BTC"]],
["bybit", "USD:USDC", ["BTC", "BNB"]],
["bitget", "USDT", ["BTC", "BNB"]],
["gateio", "USDT", ["BTC", "BNB"]],
["cryptocom", "USDT", ["BTC"]],
["huobi", "USDT", ["BTC", "BNB"]],
];
const cryptoCoins = [ "BTC", "ETH", "BNB", "XRP", "DOGE", "ADA", "MATIC", "DOT", "DAI", "LTC", "SHIB", "TRX", "SOL", "UNI", "AVAX", "LINK", "XMR"];
let num = 0;
const consult = async () => {
exchanges.forEach( (exch) => {
const exchangeId = exch[0],
exchangeClass = ccxt[exchangeId],
exchange = new exchangeClass();
let resp;
cryptoCoins.forEach( async (coin) => {
try {
resp = await exchange.fetchTicker(`${coin}/${exch[1]}`);
dataCoins.push({
position: num,
name: exchangeId,
symbold: resp.symbol,
bid: resp.bid,
ask: resp.ask,
});
} catch (e) {
dataCoins.push({
position: num,
name: exchangeId,
symbold: `${coin}/${exch[1]}`,
bid: "not value",
ask: "not value",
});
}
num++;
})
});
console.log(await dataCoins);
};
consult();
Ese es mi codigo, es bien simple, espero alguien pueda ayudarme lo que necesito, es poder mostrar dataCoins completo, despues de que ejecute todos las consultas.
Tambien intente mediante Promise.All sin embargo debido a la gran cantidad de consultas, decidi recorrer primero cada una de las opciones generando la funcion para cada una y asi ejecutarla de manera asincrona, sin embargo si la coloco como una funcion en el foreach, osea dejandolas sin comillas, entonces me ejecuta la funcion al mismo tiempo que me recorre todo y la verdad nisiquiera funciona bien. Y si la dejo con comillas me lo toma como string y tampoco funciona.
"use strict";
const ccxt = require("ccxt");
const exchanges = [
["binance", "USDT"],
["coinbase", "USD"],
["kraken", "USDT"],
["kucoin", "USDT"],
["bitstamp", "USDT"],
["okx", "USDT"],
["bybit", "USD:USDC"],
// ["bitget", "USDT"],
["gateio", "USDT"],
["cryptocom", "USDT"],
["huobi", "USDT"],
];
const cryptoCoins = [ "BTC", "ETH", "BNB", "XRP", "DOGE", "ADA", "MATIC", "DOT", "DAI", "LTC", "SHIB", "TRX", "SOL", "UNI", "AVAX", "LINK", "XMR"];
let consultData = [];
exchanges.forEach(exchange => {
cryptoCoins.forEach(coins => {
consultData.push(`consult(${exchange[0]},${exchange[1]},${coins})`)
});
});
function consult(exch,par,coin){
const exchangeId = exch
const exchangeClass = ccxt[exchangeId]
const exchange = new exchangeClass();
let resp;
return new Promise((resolved,reject) => {
resp = exchange.fetchTicker(`${coin}/${par}`);
resolved({
name: exchangeId,
symbold: resp.symbol,
bid: resp.bid,
ask: resp.ask,
})
reject({
position: num,
name: exchangeId,
symbold: `${coin}/${par}`,
bid: "not value",
ask: "not value",
})
});
};
Promise.all(consultData).then((response) => {
console.log(response)
})
Necesito poder obtener los resultados ejecutando las funciones asincronas, pero me ha costado bastante.
async
a una variable, dicha variable será siempre una Promesa. Saludos