Merge pull request #89 from Plant-for-the-Planet-org/hotfix/fix-notif…

…ication-bug

Hotfix/fix notification bug

apps/server/src/Services/Notifier/Notifier/DeviceNotifier.ts

@@ -2,13 +2,35 @@ import {type NotificationParameters} from '../../../Interfaces/NotificationParam
 import type Notifier from '../Notifier';
 import {NOTIFICATION_METHOD} from '../methodConstants';
 import {env} from '../../../env.mjs';
-import {logger} from '../../../../src/server/logger';
+import {logger} from '../../../server/logger';
+import {prisma} from '../../../server/db';
 
 class DeviceNotifier implements Notifier {
   getSupportedMethods(): Array<string> {
     return [NOTIFICATION_METHOD.DEVICE];
   }
 
+  async deleteNotificationAndDevice(destination: string, notificationId: string): Promise<void> {
+    try {
+      // Delete the notification
+      await prisma.notification.delete({
+        where: {
+          id: notificationId,
+        },
+      });
+      // Unverify and disable the alertMethod
+      await prisma.alertMethod.deleteMany({
+        where: {
+          destination: destination,
+          method: NOTIFICATION_METHOD.DEVICE,
+        }
+      });
+      logger(`Notification with ID: ${notificationId} deleted and alertMethod for destination: ${destination} has been unverified and disabled.`, "info");
+    } catch (error) {
+      logger(`Database Error: Couldn't modify the alertMethod or delete the notification: ${error}`, "error");
+    }
+  }
+
   // OneSignal can send both iOS and android notifications,
   // "destination" from AlertMethod for method "device"
   // is the OneSignal player ID of the device.
@@ -46,6 +68,10 @@ class DeviceNotifier implements Notifier {
         `Failed to send device notification. Error: ${response.statusText} for ${parameters.id}`,
         'error',
       );
+      // If device not found
+      if(response.status === 404){
+        await this.deleteNotificationAndDevice(destination, parameters.id)
+      }
       return false;
     }
 

apps/server/src/Services/Notifier/Notifier/WebhookNotifier.ts

@@ -1,3 +1,4 @@
+import {prisma} from '../../../server/db';
 import {logger} from '../../../../src/server/logger';
 import {type NotificationParameters} from '../../../Interfaces/NotificationParameters';
 import type Notifier from '../Notifier';
@@ -8,6 +9,31 @@ class WebhookNotifier implements Notifier {
     return [NOTIFICATION_METHOD.WEBHOOK];
   }
 
+  async deleteNotificationDisableAndUnverifyWebhook(destination: string, notificationId: string): Promise<void> {
+    try {
+      // Delete the notification
+      await prisma.notification.delete({
+        where: {
+          id: notificationId,
+        },
+      });
+      // Unverify and disable the alertMethod
+      await prisma.alertMethod.updateMany({
+        where: {
+          destination: destination,
+          method: NOTIFICATION_METHOD.WEBHOOK,
+        },
+        data: {
+          isVerified: false,
+          isEnabled: false,
+        },
+      });
+      logger(`Notification with ID: ${notificationId} deleted and alertMethod for destination: ${destination} has been unverified and disabled.`, "info");
+    } catch (error) {
+      logger(`Database Error: Couldn't modify the alertMethod or delete the notification: ${error}`, "error");
+    }
+  }
+
   async notify(
     destination: string,
     parameters: NotificationParameters,
@@ -34,12 +60,27 @@ class WebhookNotifier implements Notifier {
 
     if (!response.ok) {
       logger(
-        `Failed to send webhook notification. Error: ${response.statusText}  for ${parameters.id}`,
+        `Failed to send webhook notification. Error: ${response.statusText}  for ${parameters.id}.`,
         'error',
       );
+      // Specific status code handling
+      if (response.status === 404) {
+        // Webhook URL Not Found - Token not found
+        await this.deleteNotificationDisableAndUnverifyWebhook(destination, parameters.id);
+      } else if (response.status === 401){
+        // Unauthorized
+        await this.deleteNotificationDisableAndUnverifyWebhook(destination, parameters.id);
+      } else if (response.status === 403){
+        // Forbidden
+        await this.deleteNotificationDisableAndUnverifyWebhook(destination, parameters.id);
+      } else {
+        logger(
+          `Failed to send webhook notification. Something went wrong. Try again in next run.`,
+          'error',
+        );
+      }
       return false;
     }
-
     return true;
   }
 }