He escrito el siguiente script que crea múltiples conexiones WebSocket con un contrato inteligente para escuchar eventos. está funcionando bien, pero siento que esta no es una solución optimizada y probablemente podría hacerse de una mejor manera.
const main = async (PAIR_NAME, PAIR_ADDRESS_UNISWAP, PAIR_ADDRESS_SUSHISWAP) => { const PairContractHTTPUniswap = new Blockchain.web3http.eth.Contract( UniswapV2Pair.abi, PAIR_ADDRESS_UNISWAP ); const PairContractWSSUniswap = new Blockchain.web3ws.eth.Contract( UniswapV2Pair.abi, PAIR_ADDRESS_UNISWAP ); const PairContractHTTPSushiswap = new Blockchain.web3http.eth.Contract( UniswapV2Pair.abi, PAIR_ADDRESS_SUSHISWAP ); const PairContractWSSSushiswap = new Blockchain.web3ws.eth.Contract( UniswapV2Pair.abi, PAIR_ADDRESS_SUSHISWAP ); var Price_Uniswap = await getReserves(PairContractHTTPUniswap); var Price_Sushiswap = await getReserves(PairContractHTTPSushiswap); // subscribe to Sync event of Pair PairContractWSSUniswap.events.Sync({}).on("data", (data) => { Price_Uniswap = (Big(data.returnValues.reserve0)).div(Big(data.returnValues.reserve1)); priceDifference(Price_Uniswap, Price_Sushiswap, PAIR_NAME); }); PairContractWSSSushiswap.events.Sync({}).on("data", (data) => { Price_Sushiswap = (Big(data.returnValues.reserve0)).div(Big(data.returnValues.reserve1)); priceDifference(Price_Uniswap, Price_Sushiswap, PAIR_NAME); }); }; for (let i = 0; i < pairsArray.length; i++){ main(pairsArray[i].tokenPair, pairsArray[i].addressUniswap, pairsArray[i].addressSushiswap); }Al final, instancia la función principal varias veces para cada par de una matriz de pares, en un bucle for. Creo que esta forma de resolver es la fuerza bruta y hay una mejor manera de hacerlo.
Cualquier sugerencia/opinión sería realmente apreciada.
Solo para aclarar los términos: está abriendo una conexión websocket al proveedor del nodo WSS, no a los contratos inteligentes. Pero sí, su fragmento JS se suscribe a varios canales (uno para cada contrato) dentro de esta conexión (al proveedor del nodo).
Puede recopilar registros de eventos de varios contratos a través de un solo canal de WSS utilizando la web3.eth.subscribe("logs") ( docs ), pasándole la lista de direcciones de contratos como un parámetro. Ejemplo:
const options = { // list of contract addresses that you want to subscribe to their event logs address: ["0x123", "0x456"] }; web3.eth.subscribe("logs", options, (err, data) => { console.log(data); }); Pero tiene un inconveniente: no decodifica los datos del registro de eventos por usted. Por lo tanto, su código deberá encontrar los tipos de datos esperados en función de la firma del evento (devuelto en data.topics[0] ). Una vez que sepa qué registro de eventos se emite en función de la firma de eventos de themes topics[0] (valor de ejemplo de la vida real en esta respuesta ), puede usar la función decodeLog() ( docs ) para obtener los valores decodificados.