lamassu/lamassu-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: remove old failed QR scans

Browse source
This commit is contained in:
siiky 2024-06-18 17:06:37 +01:00
parent 7e6783c7b2
commit 2d91c55539
1 changed files with 28 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

28
lib/poller.js
View file

@ -1,3 +1,5 @@
const fs = require('fs/promises')
const path = require('path')
const _ = require('lodash/fp') const _ = require('lodash/fp')
const Queue = require('queue-promise') const Queue = require('queue-promise')
const plugins = require('./plugins') const plugins = require('./plugins')
@ -31,6 +33,7 @@ const RADAR_UPDATE_INTERVAL = 5 * T.minutes
const PRUNE_MACHINES_HEARTBEAT = 1 * T.day const PRUNE_MACHINES_HEARTBEAT = 1 * T.day
const TRANSACTION_BATCH_LIFECYCLE = 20 * T.minutes const TRANSACTION_BATCH_LIFECYCLE = 20 * T.minutes
const TICKER_RATES_INTERVAL = 59 * T.seconds const TICKER_RATES_INTERVAL = 59 * T.seconds
const FAILED_SCANS_INTERVAL = 1 * T.day
const CHECK_NOTIFICATION_INTERVAL = 20 * T.seconds const CHECK_NOTIFICATION_INTERVAL = 20 * T.seconds
const PENDING_INTERVAL = 10 * T.seconds const PENDING_INTERVAL = 10 * T.seconds
@ -39,6 +42,8 @@ const CACHE_ENTRY_TTL = 3600 // seconds
const FAST_QUEUE_WAIT = 1 * T.seconds const FAST_QUEUE_WAIT = 1 * T.seconds
const SLOW_QUEUE_WAIT = 10 * T.seconds const SLOW_QUEUE_WAIT = 10 * T.seconds
const OPERATOR_DATA_DIR = process.env.OPERATOR_DATA_DIR
const FAST_QUEUE = new Queue({ const FAST_QUEUE = new Queue({
concurrent: 600, concurrent: 600,
interval: FAST_QUEUE_WAIT interval: FAST_QUEUE_WAIT
@ -127,6 +132,28 @@ function updateCoinAtmRadar () {
.then(rates => coinAtmRadar.update(rates, settings())) .then(rates => coinAtmRadar.update(rates, settings()))
} }
const cleanOldFailedScans = () => {
const old = new Date()
old.setDate(old.getDate() - 2) // 2 days ago
const isOld = filepath => {
const then = new Date(path.basename(filepath).replace(/-[0-9]+\.jpg$/, ''))
return then < old
}
const baseDirPath = path.join(OPERATOR_DATA_DIR, 'failedQRScans')
fs.readdir(baseDirPath)
.then(machines => Promise.all(
machines.map(
machine => {
const machineDirPath = path.join(baseDirPath, machine)
return fs.readdir(machineDirPath)
.then(fnames => fnames.map(fname => path.join(machineDirPath, fname)))
}
)
))
.then(_.flatten)
.then(filepaths => Promise.all(filepaths.filter(isOld).map(fs.unlink)))
}
function initializeEachSchema (schemas = ['public']) { function initializeEachSchema (schemas = ['public']) {
// for each schema set "thread variables" and do polling // for each schema set "thread variables" and do polling
return _.forEach(schema => { return _.forEach(schema => {
@ -206,6 +233,7 @@ function doPolling (schema) {
addToQueue(updateAndLoadSanctions, SANCTIONS_UPDATE_INTERVAL, schema, QUEUE.SLOW) addToQueue(updateAndLoadSanctions, SANCTIONS_UPDATE_INTERVAL, schema, QUEUE.SLOW)
addToQueue(updateCoinAtmRadar, RADAR_UPDATE_INTERVAL, schema, QUEUE.SLOW) addToQueue(updateCoinAtmRadar, RADAR_UPDATE_INTERVAL, schema, QUEUE.SLOW)
addToQueue(pi().pruneMachinesHeartbeat, PRUNE_MACHINES_HEARTBEAT, schema, QUEUE.SLOW, settings) addToQueue(pi().pruneMachinesHeartbeat, PRUNE_MACHINES_HEARTBEAT, schema, QUEUE.SLOW, settings)
addToQueue(cleanOldFailedScans, FAILED_SCANS_INTERVAL, schema, QUEUE.SLOW, settings)
} }
function setup (schemasToAdd = [], schemasToRemove = []) { function setup (schemasToAdd = [], schemasToRemove = []) {