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

Update monitor check-all script to generate stuckTransfers statistics for v1 bridges (#279)

Browse Source
This commit is contained in:
Gerardo Nardelli 2020-02-03 09:50:18 -03:00 committed by GitHub
parent c408d57716
commit fe4a569e34
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 18 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
monitor/checkWorker3.js
View File

@ -1,19 +1,27 @@
const Web3 = require('web3')
const logger = require('./logger')('checkWorker3') const logger = require('./logger')('checkWorker3')
const stuckTransfers = require('./stuckTransfers') const stuckTransfers = require('./stuckTransfers')
const { writeFile, createDir } = require('./utils/file') const { writeFile, createDir } = require('./utils/file')
const { MONITOR_BRIDGE_NAME } = process.env const { MONITOR_BRIDGE_NAME, COMMON_HOME_BRIDGE_ADDRESS, COMMON_HOME_RPC_URL } = process.env
const { getBridgeMode, HOME_NATIVE_TO_ERC_ABI, BRIDGE_MODES } = require('../commons')
const homeProvider = new Web3.providers.HttpProvider(COMMON_HOME_RPC_URL)
const web3Home = new Web3(homeProvider)
async function checkWorker3() { async function checkWorker3() {
try { try {
createDir(`/responses/${MONITOR_BRIDGE_NAME}`) const homeBridge = new web3Home.eth.Contract(HOME_NATIVE_TO_ERC_ABI, COMMON_HOME_BRIDGE_ADDRESS)
logger.debug('calling stuckTransfers()') const bridgeMode = await getBridgeMode(homeBridge)
const transfers = await stuckTransfers() if (bridgeMode === BRIDGE_MODES.NATIVE_TO_ERC_V1) {
// console.log(transfers) createDir(`/responses/${MONITOR_BRIDGE_NAME}`)
if (!transfers) throw new Error('transfers is empty: ' + JSON.stringify(transfers)) logger.debug('calling stuckTransfers()')
transfers.ok = transfers.total.length === 0 const transfers = await stuckTransfers()
writeFile(`/responses/${MONITOR_BRIDGE_NAME}/stuckTransfers.json`, transfers) if (!transfers) throw new Error('transfers is empty: ' + JSON.stringify(transfers))
logger.debug('Done') transfers.ok = transfers.total.length === 0
writeFile(`/responses/${MONITOR_BRIDGE_NAME}/stuckTransfers.json`, transfers)
logger.debug('Done')
}
} catch (e) { } catch (e) {
logger.error('checkWorker3.js', e) logger.error('checkWorker3.js', e)
} }

2
monitor/package.json
View File

@ -4,7 +4,7 @@
"description": "", "description": "",
"main": "index.js", "main": "index.js",
"scripts": { "scripts": {
"check-all": "timeout -s 9 5m node checkWorker.js && timeout -s 9 5m node checkWorker2.js", "check-all": "timeout -s 9 5m node checkWorker.js && timeout -s 9 5m node checkWorker2.js && timeout -s 9 5m node checkWorker3.js",
"start": "node index.js", "start": "node index.js",
"check-and-start": "yarn check-all && yarn start", "check-and-start": "yarn check-all && yarn start",
"lint": "eslint . --ignore-path ../.eslintignore", "lint": "eslint . --ignore-path ../.eslintignore",