summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors
diff options
context:
space:
mode:
authoranatawa12 <anatawa12@icloud.com>2024-06-22 12:44:01 +0900
committerGitHub <noreply@github.com>2024-06-22 12:44:01 +0900
commit1e78ef1cb847da719be23d55c87aaac0294665db (patch)
tree03729ed06197981b33ce00d42e89c65ecc5277d2 /packages/backend/src/queue/processors
parentfix(backend): fallback if `sinceId` is older than the oldest in cache when us... (diff)
downloadsharkey-1e78ef1cb847da719be23d55c87aaac0294665db.tar.gz
sharkey-1e78ef1cb847da719be23d55c87aaac0294665db.tar.bz2
sharkey-1e78ef1cb847da719be23d55c87aaac0294665db.zip
fix: notRespondingSinceが実装される前に不通になったインスタンスが自動的に配信停止にならない (#14059)
Co-authored-by: syuilo <4439005+syuilo@users.noreply.github.com>
Diffstat (limited to 'packages/backend/src/queue/processors')
-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();