tokenbridge/monitor/checkWorker2.js

40 lines
1.7 KiB
JavaScript
Raw Normal View History

require('dotenv').config()
2019-05-08 16:12:02 +03:00
const logger = require('./logger')('checkWorker2')
const eventsStats = require('./eventsStats')
2021-04-02 12:59:49 +03:00
const getEventsInfo = require('./utils/events')
2019-05-08 16:12:02 +03:00
const alerts = require('./alerts')
const { writeFile, createDir } = require('./utils/file')
const { saveCache } = require('./utils/web3Cache')
const { MONITOR_BRIDGE_NAME } = process.env
2019-05-08 16:12:02 +03:00
async function checkWorker2() {
try {
createDir(`/responses/${MONITOR_BRIDGE_NAME}`)
2021-04-02 12:59:49 +03:00
logger.debug('calling getEventsInfo()')
const eventsInfo = await getEventsInfo()
2019-05-08 16:12:02 +03:00
logger.debug('calling eventsStats()')
2021-04-02 12:59:49 +03:00
const evStats = await eventsStats(eventsInfo)
2019-05-08 16:12:02 +03:00
if (!evStats) throw new Error('evStats is empty: ' + JSON.stringify(evStats))
evStats.ok =
(evStats.onlyInHomeDeposits || evStats.home.deliveredMsgNotProcessedInForeign).length === 0 &&
(evStats.onlyInForeignDeposits || evStats.home.processedMsgNotDeliveredInForeign).length === 0 &&
(evStats.onlyInHomeWithdrawals || evStats.foreign.deliveredMsgNotProcessedInHome).length === 0 &&
(evStats.onlyInForeignWithdrawals || evStats.foreign.processedMsgNotDeliveredInHome).length === 0
evStats.health = true
writeFile(`/responses/${MONITOR_BRIDGE_NAME}/eventsStats.json`, evStats)
2019-05-08 16:12:02 +03:00
logger.debug('calling alerts()')
2021-04-02 12:59:49 +03:00
const _alerts = await alerts(eventsInfo)
2019-05-08 16:12:02 +03:00
if (!_alerts) throw new Error('alerts is empty: ' + JSON.stringify(_alerts))
_alerts.ok = !_alerts.executeAffirmations.mostRecentTxHash && !_alerts.executeSignatures.mostRecentTxHash
_alerts.health = true
writeFile(`/responses/${MONITOR_BRIDGE_NAME}/alerts.json`, _alerts)
saveCache()
2019-05-08 16:12:02 +03:00
logger.debug('Done x2')
} catch (e) {
2019-05-30 21:05:36 +03:00
logger.error(e)
2019-05-08 16:12:02 +03:00
}
}
checkWorker2()