summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors/SystemWebhookDeliverProcessorService.ts
diff options
context:
space:
mode:
authorHazelnoot <acomputerdog@gmail.com>2025-06-09 10:53:59 +0000
committerHazelnoot <acomputerdog@gmail.com>2025-06-09 10:53:59 +0000
commit00c0bdbc947ea0a049d920f73467be62d88f6858 (patch)
tree23c3e4281a10141948fcfc39239da4b388e781af /packages/backend/src/queue/processors/SystemWebhookDeliverProcessorService.ts
parentmerge: Fix inverted condition in resolveLocal (!1103) (diff)
parentfix merge error (diff)
downloadsharkey-00c0bdbc947ea0a049d920f73467be62d88f6858.tar.gz
sharkey-00c0bdbc947ea0a049d920f73467be62d88f6858.tar.bz2
sharkey-00c0bdbc947ea0a049d920f73467be62d88f6858.zip
merge: Reduce log spam (!1004)
View MR for information: https://activitypub.software/TransFem-org/Sharkey/-/merge_requests/1004 Approved-by: dakkar <dakkar@thenautilus.net> Approved-by: Marie <github@yuugi.dev>
Diffstat (limited to 'packages/backend/src/queue/processors/SystemWebhookDeliverProcessorService.ts')
-rw-r--r--packages/backend/src/queue/processors/SystemWebhookDeliverProcessorService.ts12
1 files changed, 4 insertions, 8 deletions
diff --git a/packages/backend/src/queue/processors/SystemWebhookDeliverProcessorService.ts b/packages/backend/src/queue/processors/SystemWebhookDeliverProcessorService.ts
index f6bef52684..f9fcd1e928 100644
--- a/packages/backend/src/queue/processors/SystemWebhookDeliverProcessorService.ts
+++ b/packages/backend/src/queue/processors/SystemWebhookDeliverProcessorService.ts
@@ -12,6 +12,7 @@ import type Logger from '@/logger.js';
import { HttpRequestService } from '@/core/HttpRequestService.js';
import { StatusError } from '@/misc/status-error.js';
import { bindThis } from '@/decorators.js';
+import { renderInlineError } from '@/misc/render-inline-error.js';
import { QueueLoggerService } from '../QueueLoggerService.js';
import { SystemWebhookDeliverJobData } from '../types.js';
@@ -63,21 +64,16 @@ export class SystemWebhookDeliverProcessorService {
return 'Success';
} catch (res) {
- this.logger.error(res as Error);
+ this.logger.error(`Failed to send webhook: ${renderInlineError(res)}`);
this.systemWebhooksRepository.update({ id: job.data.webhookId }, {
latestSentAt: new Date(),
latestStatus: res instanceof StatusError ? res.statusCode : 1,
});
- if (res instanceof StatusError) {
+ if (res instanceof StatusError && !res.isRetryable) {
// 4xx
- if (!res.isRetryable) {
- throw new Bull.UnrecoverableError(`${res.statusCode} ${res.statusMessage}`);
- }
-
- // 5xx etc.
- throw new Error(`${res.statusCode} ${res.statusMessage}`);
+ throw new Bull.UnrecoverableError(`${res.statusCode} ${res.statusMessage}`);
} else {
// DNS error, socket error, timeout ...
throw res;