summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue
diff options
context:
space:
mode:
authordakkar <dakkar@thenautilus.net>2024-06-25 13:10:48 +0000
committerdakkar <dakkar@thenautilus.net>2024-06-25 13:10:48 +0000
commit348366fa7d3d5a027d973d116990bba210aa4f49 (patch)
tree3e2c9e998a2f97244a37f3f8cb7f1831e4108ab7 /packages/backend/src/queue
parentmerge: ugly work-around to prevent plugins from breaking timelines (!558) (diff)
parentfix: notRespondingSinceが実装される前に不通になったインスタ... (diff)
downloadsharkey-348366fa7d3d5a027d973d116990bba210aa4f49.tar.gz
sharkey-348366fa7d3d5a027d973d116990bba210aa4f49.tar.bz2
sharkey-348366fa7d3d5a027d973d116990bba210aa4f49.zip
merge: parse `notRespondingSince` from redis instance cache (!560)
View MR for information: https://activitypub.software/TransFem-org/Sharkey/-/merge_requests/560 Approved-by: Tess K <me@thvxl.se> Approved-by: Marie <marie@kaifa.ch>
Diffstat (limited to 'packages/backend/src/queue')
-rw-r--r--packages/backend/src/queue/processors/DeliverProcessorService.ts6
1 files changed, 6 insertions, 0 deletions
diff --git a/packages/backend/src/queue/processors/DeliverProcessorService.ts b/packages/backend/src/queue/processors/DeliverProcessorService.ts
index b73195afc3..d665945861 100644
--- a/packages/backend/src/queue/processors/DeliverProcessorService.ts
+++ b/packages/backend/src/queue/processors/DeliverProcessorService.ts
@@ -109,6 +109,12 @@ export class DeliverProcessorService {
suspensionState: 'autoSuspendedForNotResponding',
});
}
+ } else {
+ // isNotRespondingがtrueでnotRespondingSinceがnullの場合はnotRespondingSinceをセット
+ // notRespondingSinceは新たな機能なので、それ以前のデータにはnotRespondingSinceがない場合がある
+ this.federatedInstanceService.update(i.id, {
+ notRespondingSince: new Date(),
+ });
}
this.apRequestChart.deliverFail();