FoundKeyGang/FoundKey
FoundKeyGang/FoundKey
7
19
Fork 22
Code Issues 37 Pull requests 4 Releases Activity

backend: fixup missing deadTime and incorrect import
Some checks failed
ci/woodpecker/pr/lint-backend Pipeline was successful
Details
ci/woodpecker/pr/build Pipeline was successful
Details
ci/woodpecker/pr/lint-client Pipeline failed
Details
ci/woodpecker/pr/lint-foundkey-js Pipeline was successful
Details
ci/woodpecker/push/build Pipeline was successful
Details
ci/woodpecker/push/lint-client Pipeline was successful
Details
ci/woodpecker/push/lint-backend Pipeline was successful
Details
ci/woodpecker/push/lint-foundkey-js Pipeline was successful
Details
ci/woodpecker/push/test Pipeline was successful
Details
ci/woodpecker/pr/test Pipeline failed
Details

Browse source
This commit is contained in:
Chloe Kudryavtsev 2022-10-16 09:32:01 -04:00
parent 21c1e5c06c
commit d762143b89
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
packages/backend/src/queue/processors/deliver.ts
View file

@ -13,7 +13,7 @@ import { Instance } from '@/models/entities/instance.js';
import { StatusError } from '@/misc/fetch.js'; import { StatusError } from '@/misc/fetch.js';
import { DeliverJobData } from '@/queue/types.js'; import { DeliverJobData } from '@/queue/types.js';
import { LessThan } from 'typeorm'; import { LessThan } from 'typeorm';
import { DAY } from '@/const.ts'; import { DAY } from '@/const.js';
const logger = new Logger('deliver'); const logger = new Logger('deliver');
@ -31,6 +31,7 @@ export default async (job: Bull.Job<DeliverJobData>) => {
return 'skip (blocked)'; return 'skip (blocked)';
} }
const deadTime = new Date(Date.now() - deadThreshold);
const isSuspendedOrDead = await Instances.countBy([ const isSuspendedOrDead = await Instances.countBy([
{ host: puny, isSuspended: true }, { host: puny, isSuspended: true },
{ host: puny, lastCommunicatedAt: LessThan(deadTime) }, { host: puny, lastCommunicatedAt: LessThan(deadTime) },