diff options
| author | anatawa12 <anatawa12@icloud.com> | 2024-06-22 12:44:01 +0900 |
|---|---|---|
| committer | dakkar <dakkar@thenautilus.net> | 2024-06-23 10:59:43 +0100 |
| commit | 0e5a52c6789b2f23dc17f2c18489e706b3fae3a9 (patch) | |
| tree | 3e2c9e998a2f97244a37f3f8cb7f1831e4108ab7 /packages/backend/src/queue/processors/DeliverProcessorService.ts | |
| parent | parse `notRespondingSince` from redis instance cache (diff) | |
| download | sharkey-0e5a52c6789b2f23dc17f2c18489e706b3fae3a9.tar.gz sharkey-0e5a52c6789b2f23dc17f2c18489e706b3fae3a9.tar.bz2 sharkey-0e5a52c6789b2f23dc17f2c18489e706b3fae3a9.zip | |
fix: notRespondingSinceが実装される前に不通になったインスタンスが自動的に配信停止にならない (#14059)
Co-authored-by: syuilo <4439005+syuilo@users.noreply.github.com>
Diffstat (limited to 'packages/backend/src/queue/processors/DeliverProcessorService.ts')
| -rw-r--r-- | packages/backend/src/queue/processors/DeliverProcessorService.ts | 6 |
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(); |