summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors/InboxProcessorService.ts
diff options
context:
space:
mode:
authorHazelnoot <acomputerdog@gmail.com>2024-11-03 17:59:33 -0500
committerHazelnoot <acomputerdog@gmail.com>2024-11-22 09:16:03 -0500
commit2bbccde2ce0f04afc7f2b20ba0c0404075cddef1 (patch)
tree2a464734a06fc48b0b80e070e61e721c5b0a8733 /packages/backend/src/queue/processors/InboxProcessorService.ts
parentfetch target note of Like(Note) activities (diff)
downloadsharkey-2bbccde2ce0f04afc7f2b20ba0c0404075cddef1.tar.gz
sharkey-2bbccde2ce0f04afc7f2b20ba0c0404075cddef1.tar.bz2
sharkey-2bbccde2ce0f04afc7f2b20ba0c0404075cddef1.zip
reduce inbox log spam when fetching blocked / unavailable notes
Diffstat (limited to 'packages/backend/src/queue/processors/InboxProcessorService.ts')
-rw-r--r--packages/backend/src/queue/processors/InboxProcessorService.ts14
1 files changed, 14 insertions, 0 deletions
diff --git a/packages/backend/src/queue/processors/InboxProcessorService.ts b/packages/backend/src/queue/processors/InboxProcessorService.ts
index 102e835e24..260ebe0d40 100644
--- a/packages/backend/src/queue/processors/InboxProcessorService.ts
+++ b/packages/backend/src/queue/processors/InboxProcessorService.ts
@@ -7,6 +7,7 @@ import { URL } from 'node:url';
import { Inject, Injectable, OnApplicationShutdown } from '@nestjs/common';
import httpSignature from '@peertube/http-signature';
import * as Bull from 'bullmq';
+import { AbortError } from 'node-fetch';
import type Logger from '@/logger.js';
import { FederatedInstanceService } from '@/core/FederatedInstanceService.js';
import { FetchInstanceMetadataService } from '@/core/FetchInstanceMetadataService.js';
@@ -232,6 +233,19 @@ export class InboxProcessorService implements OnApplicationShutdown {
return e.message;
}
}
+
+ if (e instanceof StatusError) {
+ if (e.isRetryable) {
+ return `temporary error ${e.statusCode}`;
+ } else {
+ return `skip: permanent error ${e.statusCode}`;
+ }
+ }
+
+ if (e instanceof AbortError) {
+ return 'request aborted';
+ }
+
throw e;
}
return 'ok';