tornadocontrib/tokenbridge
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add watcher idle option

Browse Source
This commit is contained in:
Gerardo Nardelli 2019-12-04 09:58:27 -03:00
parent ab2c0ea120
commit 8fa715089b
3 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oracle/config/half-duplex-transfer-watcher.config.js
View File

@ -34,5 +34,6 @@ module.exports = {
queue: 'home',
workerQueue: 'swap-tokens',
name: `watcher-${id}`,
id
id,
idle: initialChecks.idle
}

11
oracle/scripts/initialChecks.js
View File

@ -18,7 +18,16 @@ async function initialChecks() {
} else if (ORACLE_BRIDGE_MODE === 'ERC_TO_NATIVE') {
const bridge = new foreignWeb3.eth.Contract(FOREIGN_ERC_TO_NATIVE_ABI, COMMON_FOREIGN_BRIDGE_ADDRESS)
result.bridgeableTokenAddress = await bridge.methods.erc20token().call()
result.halfDuplexTokenAddress = await bridge.methods.halfDuplexErc20token().call()
try {
const halfDuplexErc20tokenAddress = await bridge.methods.halfDuplexErc20token().call()
if (halfDuplexErc20tokenAddress !== result.bridgeableTokenAddress) {
result.halfDuplexTokenAddress = halfDuplexErc20tokenAddress
} else {
result.idle = true
}
} catch (e) {
result.idle = true
}
}
if (ORACLE_BRIDGE_MODE === 'ERC_TO_ERC') {

5
oracle/src/watcher.js
View File

@ -130,6 +130,11 @@ async function getLastBlockToProcess() {
async function main({ sendToQueue, sendToWorker }) {
try {
if (config.idle) {
logger.debug('Watcher in idle mode, skipping getting events')
return
}
const lastBlockToProcess = await getLastBlockToProcess()
if (lastBlockToProcess.lte(lastProcessedBlock)) {