1 import express from 'express'
2 import { retryTransactionWrapper } from '@server/helpers/database-utils'
3 import { logger, loggerTagsFactory } from '@server/helpers/logger'
4 import { sequelizeTypescript } from '@server/initializers/database'
5 import { MRunner } from '@server/types/models/runners'
7 const lTags = loggerTagsFactory('runner')
9 const updatingRunner = new Set<number>()
11 function updateLastRunnerContact (req: express.Request, runner: MRunner) {
12 const now = new Date()
14 // Don't update last runner contact too often
15 if (now.getTime() - runner.lastContact.getTime() < 2000) return
16 if (updatingRunner.has(runner.id)) return
18 updatingRunner.add(runner.id)
20 runner.lastContact = now
23 logger.debug('Updating last runner contact for %s', runner.name, lTags(runner.name))
25 retryTransactionWrapper(() => {
26 return sequelizeTypescript.transaction(async transaction => {
27 return runner.save({ transaction })
30 .catch(err => logger.error('Cannot update last runner contact for %s', runner.name, { err, ...lTags(runner.name) }))
31 .finally(() => updatingRunner.delete(runner.id))
35 updateLastRunnerContact