diff options
| author | Hazelnoot <acomputerdog@gmail.com> | 2024-11-03 17:59:33 -0500 |
|---|---|---|
| committer | Hazelnoot <acomputerdog@gmail.com> | 2024-11-22 09:16:03 -0500 |
| commit | 2bbccde2ce0f04afc7f2b20ba0c0404075cddef1 (patch) | |
| tree | 2a464734a06fc48b0b80e070e61e721c5b0a8733 /packages/backend/src/queue/processors/InboxProcessorService.ts | |
| parent | fetch target note of Like(Note) activities (diff) | |
| download | sharkey-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.ts | 14 |
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'; |