From 2c6e275f4cdb65d99bd75a0fb44e91243b02e339 Mon Sep 17 00:00:00 2001
From: Collin Duncan <3679940+cgduncan7@users.noreply.github.com>
Date: Thu, 19 Sep 2024 12:51:21 +0200
Subject: [PATCH] Adding some logs for ntfy module

---
 src/ntfy/client.ts   | 4 ++++
 src/ntfy/provider.ts | 5 +++++
 2 files changed, 9 insertions(+)

diff --git a/src/ntfy/client.ts b/src/ntfy/client.ts
index b8971b4..d44b69e 100644
--- a/src/ntfy/client.ts
+++ b/src/ntfy/client.ts
@@ -37,6 +37,10 @@ export class NtfyClient {
 					...message,
 				}),
 			)
+			this.loggerService.debug('Published ntfy-cation', {
+				topic: this.topic,
+				message,
+			})
 		} catch (error: unknown) {
 			this.loggerService.error('ntfy client failed', { error })
 		}
diff --git a/src/ntfy/provider.ts b/src/ntfy/provider.ts
index 3d9e576..d6e1ad8 100644
--- a/src/ntfy/provider.ts
+++ b/src/ntfy/provider.ts
@@ -4,6 +4,7 @@ import { ConfigService } from '@nestjs/config'
 import { Job, JobOptions, Queue } from 'bull'
 import { Dayjs } from 'dayjs'
 
+import { LoggerService } from '../logger/service.logger'
 import { NtfyClient } from './client'
 import {
 	MessageConfig,
@@ -22,6 +23,9 @@ export class NtfyProvider implements OnApplicationBootstrap {
 		@Inject(NtfyClient)
 		private readonly ntfyClient: NtfyClient,
 
+		@Inject(LoggerService)
+		private readonly loggerService: LoggerService,
+
 		@InjectQueue(NTFY_PUBLISH_QUEUE_NAME)
 		private readonly publishQueue: Queue,
 	) {}
@@ -32,6 +36,7 @@ export class NtfyProvider implements OnApplicationBootstrap {
 
 	@Process()
 	async handlePublishJob(job: Job<Omit<MessageConfig, 'topic'>>) {
+		this.loggerService.debug('Handling publish job', { data: job.data })
 		await this.ntfyClient.publish({
 			...job.data,
 		})