diff --git a/src/healthWatcher.js b/src/healthWatcher.js index 0dde5bc..ac0ca3c 100644 --- a/src/healthWatcher.js +++ b/src/healthWatcher.js @@ -4,7 +4,7 @@ const { setSafeInterval } = require('./utils') const { httpRpcUrl, privateKey, minimumBalance, nativeCurrency, instances } = require('./config') const web3 = new Web3(httpRpcUrl) -const { redis } = require('modules/redis') +const { redis } = require('./modules/redis') async function main() { try { diff --git a/src/status.js b/src/status.js index 88b8936..2499847 100644 --- a/src/status.js +++ b/src/status.js @@ -6,7 +6,7 @@ const { redis } = require('./modules/redis') async function status(req, res) { const health = await redis.hgetall('health') - health.errorsLog = readRelayerErrors(redis) + health.errorsLog = await readRelayerErrors(redis) const { waiting: currentQueue } = await queue.queue.getJobCounts() res.json({ diff --git a/src/worker.js b/src/worker.js index f12665b..b120620 100644 --- a/src/worker.js +++ b/src/worker.js @@ -1,7 +1,7 @@ const Web3 = require('web3') const { GasPriceOracle } = require('gas-price-oracle') const { toBN, toWei, fromWei, toHex } = require('web3-utils') -const { redis } = require('modules/redis') +const { redis } = require('./modules/redis') const proxyLightABI = require('../abis/proxyLightABI.json') const { queue } = require('./queue') const { getInstance, fromDecimals, logRelayerError } = require('./utils')