c457faab40
Chore: fiatBalancesNotify refactor Chore: removed now-unused code in some files Feat: change column "detail" in database to use jsonb Chore: add notification center background and button Chore: notifications screen scaffolding Fix: change position of notification UI Feat: join backend and frontend Feat: notification icons and machine names Feat: add clear all button, stripe overlay on invalid notification Fix: rework notification styles Feat: use popper to render notifications Feat: make notification center UI Fix: fix css on notification center Fix: fix invalidateNotification Chore: apply PR requested changes Fix: PR fixes Fix: make toggleable body/root styles be handled by react Chore: delete old notifier file Fix: undo variable name changes for cryptobalance notifs
107 lines
3.8 KiB
JavaScript
107 lines
3.8 KiB
JavaScript
const _ = require('lodash/fp')
|
|
|
|
const plugins = require('./plugins')
|
|
const notifier = require('./notifier')
|
|
const T = require('./time')
|
|
const logger = require('./logger')
|
|
const cashOutTx = require('./cash-out/cash-out-tx')
|
|
const cashInTx = require('./cash-in/cash-in-tx')
|
|
const sanctionsUpdater = require('./ofac/update')
|
|
const sanctions = require('./ofac/index')
|
|
const coinAtmRadar = require('./coinatmradar/coinatmradar')
|
|
const configManager = require('./new-config-manager')
|
|
const complianceTriggers = require('./compliance-triggers')
|
|
|
|
const INCOMING_TX_INTERVAL = 30 * T.seconds
|
|
const LIVE_INCOMING_TX_INTERVAL = 5 * T.seconds
|
|
const INCOMING_TX_INTERVAL_FILTER = 1 * T.minute
|
|
const LIVE_INCOMING_TX_INTERVAL_FILTER = 10 * T.seconds
|
|
const UNNOTIFIED_INTERVAL = 10 * T.seconds
|
|
const SWEEP_HD_INTERVAL = T.minute
|
|
const TRADE_INTERVAL = 60 * T.seconds
|
|
const PONG_INTERVAL = 10 * T.seconds
|
|
const LOGS_CLEAR_INTERVAL = 1 * T.day
|
|
const SANCTIONS_INITIAL_DOWNLOAD_INTERVAL = 5 * T.minutes
|
|
const SANCTIONS_UPDATE_INTERVAL = 1 * T.week
|
|
const RADAR_UPDATE_INTERVAL = 5 * T.minutes
|
|
|
|
const CHECK_NOTIFICATION_INTERVAL = 20 * T.seconds
|
|
|
|
const PENDING_INTERVAL = 10 * T.seconds
|
|
|
|
const coinFilter = ['ETH']
|
|
|
|
let _pi, _settings
|
|
|
|
function reload (__settings) {
|
|
_settings = __settings
|
|
_pi = plugins(_settings)
|
|
logger.debug('settings reloaded in poller')
|
|
updateAndLoadSanctions()
|
|
}
|
|
|
|
function pi () { return _pi }
|
|
function settings () { return _settings }
|
|
|
|
function initialSanctionsDownload () {
|
|
const structs = sanctions.getStructs()
|
|
const isEmptyStructs = _.isNil(structs) || _.flow(_.values, _.all(_.isEmpty))(structs)
|
|
|
|
if (!isEmptyStructs) return Promise.resolve()
|
|
|
|
return updateAndLoadSanctions()
|
|
}
|
|
|
|
function updateAndLoadSanctions () {
|
|
const triggers = configManager.getTriggers(settings().config)
|
|
const hasSanctions = complianceTriggers.hasSanctions(triggers)
|
|
|
|
if (!hasSanctions) return Promise.resolve()
|
|
|
|
logger.info('Updating sanctions database...')
|
|
return sanctionsUpdater.update()
|
|
.then(sanctions.load)
|
|
.then(() => logger.info('Sanctions database updated.'))
|
|
}
|
|
|
|
function updateCoinAtmRadar () {
|
|
return pi().getRawRates()
|
|
.then(rates => coinAtmRadar.update(rates, settings()))
|
|
}
|
|
|
|
function start (__settings) {
|
|
reload(__settings)
|
|
|
|
pi().executeTrades()
|
|
pi().pong()
|
|
pi().clearOldLogs()
|
|
cashOutTx.monitorLiveIncoming(settings(), false, coinFilter)
|
|
cashOutTx.monitorStaleIncoming(settings(), false, coinFilter)
|
|
if (!_.isEmpty(coinFilter)) {
|
|
cashOutTx.monitorLiveIncoming(settings(), true, coinFilter)
|
|
cashOutTx.monitorStaleIncoming(settings(), true, coinFilter)
|
|
}
|
|
cashOutTx.monitorUnnotified(settings())
|
|
pi().sweepHd()
|
|
notifier.checkNotification(pi())
|
|
updateCoinAtmRadar()
|
|
|
|
setInterval(() => pi().executeTrades(), TRADE_INTERVAL)
|
|
setInterval(() => cashOutTx.monitorLiveIncoming(settings(), false, coinFilter), LIVE_INCOMING_TX_INTERVAL)
|
|
setInterval(() => cashOutTx.monitorStaleIncoming(settings(), false, coinFilter), INCOMING_TX_INTERVAL)
|
|
if (!_.isEmpty(coinFilter)) {
|
|
setInterval(() => cashOutTx.monitorLiveIncoming(settings(), true, coinFilter), LIVE_INCOMING_TX_INTERVAL_FILTER)
|
|
setInterval(() => cashOutTx.monitorStaleIncoming(settings(), true, coinFilter), INCOMING_TX_INTERVAL_FILTER)
|
|
}
|
|
setInterval(() => cashOutTx.monitorUnnotified(settings()), UNNOTIFIED_INTERVAL)
|
|
setInterval(() => cashInTx.monitorPending(settings()), PENDING_INTERVAL)
|
|
setInterval(() => pi().sweepHd(), SWEEP_HD_INTERVAL)
|
|
setInterval(() => pi().pong(), PONG_INTERVAL)
|
|
setInterval(() => pi().clearOldLogs(), LOGS_CLEAR_INTERVAL)
|
|
setInterval(() => notifier.checkNotification(pi()), CHECK_NOTIFICATION_INTERVAL)
|
|
setInterval(initialSanctionsDownload, SANCTIONS_INITIAL_DOWNLOAD_INTERVAL)
|
|
setInterval(updateAndLoadSanctions, SANCTIONS_UPDATE_INTERVAL)
|
|
setInterval(updateCoinAtmRadar, RADAR_UPDATE_INTERVAL)
|
|
}
|
|
|
|
module.exports = { start, reload }
|