From 50eb6174e03fd5d78458a13f9c80d0c267f0f3f0 Mon Sep 17 00:00:00 2001 From: Collin Duncan <3679940+cgduncan7@users.noreply.github.com> Date: Mon, 8 Jul 2024 16:01:51 +0200 Subject: [PATCH] Changing default priorities of ntfy messages --- src/ntfy/provider.ts | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/src/ntfy/provider.ts b/src/ntfy/provider.ts index aede038..3d9e576 100644 --- a/src/ntfy/provider.ts +++ b/src/ntfy/provider.ts @@ -5,7 +5,12 @@ import { Job, JobOptions, Queue } from 'bull' import { Dayjs } from 'dayjs' import { NtfyClient } from './client' -import { MessageConfig, MessageTags, NTFY_PUBLISH_QUEUE_NAME } from './types' +import { + MessageConfig, + MessagePriority, + MessageTags, + NTFY_PUBLISH_QUEUE_NAME, +} from './types' @Processor(NTFY_PUBLISH_QUEUE_NAME) @Injectable() @@ -36,7 +41,10 @@ export class NtfyProvider implements OnApplicationBootstrap { data: Omit, ): [Omit, JobOptions] { return [ - data, + { + ...data, + priority: MessagePriority.min, + }, { attempts: 3, removeOnComplete: true, @@ -99,6 +107,7 @@ export class NtfyProvider implements OnApplicationBootstrap { ) { await this.publishQueue.add( ...NtfyProvider.defaultJob({ + priority: MessagePriority.default, title: 'Error performing reservation', message: `${reservationId} - ${startTime.format()} to ${endTime.format()} : (${ error.name @@ -135,6 +144,7 @@ export class NtfyProvider implements OnApplicationBootstrap { async sendEmailClientErrorNotification(errorMessage: string) { await this.publishQueue.add( ...NtfyProvider.defaultJob({ + priority: MessagePriority.high, title: 'Email client error', message: errorMessage, tags: [MessageTags.exclamation],