mirror of
https://github.com/tornadocash/tornado-relayer
synced 2024-02-02 15:04:06 +01:00
24 lines
905 B
JavaScript
24 lines
905 B
JavaScript
const Redis = require('ioredis')
|
|
const { redisUrl, oracleAddress, oracleRpcUrl, tornEthPrice } = require('./config')
|
|
const { getArgsForOracle, setSafeInterval } = require('./utils')
|
|
const redis = new Redis(redisUrl)
|
|
const Web3 = require('web3')
|
|
const web3 = new Web3(oracleRpcUrl)
|
|
|
|
const priceOracleABI = require('../abis/PriceOracle.abi.json')
|
|
const oracle = new web3.eth.Contract(priceOracleABI, oracleAddress)
|
|
const { tokenAddresses, oneUintAmount, currencyLookup } = getArgsForOracle()
|
|
|
|
async function main() {
|
|
const prices = await oracle.methods.getPricesInETH(tokenAddresses, oneUintAmount).call()
|
|
const ethPrices = prices.reduce((acc, price, i) => {
|
|
acc[currencyLookup[tokenAddresses[i]]] = price
|
|
return acc
|
|
}, {})
|
|
ethPrices.torn = tornEthPrice
|
|
await redis.hmset('prices', ethPrices)
|
|
console.log('Wrote following prices to redis', ethPrices)
|
|
}
|
|
|
|
setSafeInterval(main, 30 * 1000)
|