summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors
diff options
context:
space:
mode:
Diffstat (limited to 'packages/backend/src/queue/processors')
-rw-r--r--packages/backend/src/queue/processors/DeliverProcessorService.ts12
1 files changed, 12 insertions, 0 deletions
diff --git a/packages/backend/src/queue/processors/DeliverProcessorService.ts b/packages/backend/src/queue/processors/DeliverProcessorService.ts
index 2a053a12e0..065501fe21 100644
--- a/packages/backend/src/queue/processors/DeliverProcessorService.ts
+++ b/packages/backend/src/queue/processors/DeliverProcessorService.ts
@@ -115,6 +115,18 @@ export class DeliverProcessorService {
if (res instanceof StatusError) {
// 4xx
if (res.isClientError) {
+ // 相手が閉鎖していることを明示しているため、配送停止する
+ if (res.statusCode === 410) {
+ this.federatedInstanceService.fetch(host).then(i => {
+ this.instancesRepository.update(i.id, {
+ isSuspended: true,
+ });
+ this.federatedInstanceService.updateCachePartial(host, {
+ isSuspended: true,
+ });
+ });
+ return `${host} is gone`;
+ }
// HTTPステータスコード4xxはクライアントエラーであり、それはつまり
// 何回再送しても成功することはないということなのでエラーにはしないでおく
return `${res.statusCode} ${res.statusMessage}`;