From e88211faee4da4a26aa532dfa0684cd96aff807f Mon Sep 17 00:00:00 2001
From: Christina Papadogianni <59121443+ChrisPdgn@users.noreply.github.com>
Date: Tue, 2 Jul 2024 14:12:07 +0300
Subject: [PATCH] feat(push-notifications): delete expired tokens for
 one-signal provider (#1088)

---
 .../src/providers/OneSignal.provider.ts                   | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/modules/push-notifications/src/providers/OneSignal.provider.ts b/modules/push-notifications/src/providers/OneSignal.provider.ts
index 0b9530d21..de57162eb 100644
--- a/modules/push-notifications/src/providers/OneSignal.provider.ts
+++ b/modules/push-notifications/src/providers/OneSignal.provider.ts
@@ -6,6 +6,7 @@ import {
 } from '../interfaces/ISendNotification.js';
 import { createConfiguration, DefaultApi, Notification } from '@onesignal/node-onesignal';
 import ConduitGrpcSdk from '@conduitplatform/grpc-sdk';
+import { NotificationToken } from '../models/index.js';
 
 export class OneSignalProvider extends BaseNotificationProvider<IOneSignalSettings> {
   private client?: DefaultApi;
@@ -42,7 +43,12 @@ export class OneSignalProvider extends BaseNotificationProvider<IOneSignalSettin
         include_player_ids: Array.isArray(token) ? token : [token],
       };
     }
-    await this.client!.createNotification(notification);
+    const response = await this.client!.createNotification(notification);
+    if (response.errors?.invalid_player_ids?.length) {
+      await NotificationToken.getInstance().deleteMany({
+        token: { $in: response.errors.invalid_player_ids },
+      });
+    }
     return;
   }