refactor(push-notifications): send notification always fetch all user…

… tokens for specified platform (#979)

* refactor(push-notifications): send notification always fetch all user tokens for specified platform
fix(push-notifications): firebase notifications crash due to expired tokens

* fix(push-notifications): missing platform param in sendToDevice
fix(push-notifications): platform not considered in send many messages

modules/push-notifications/src/providers/Firebase.provider.ts

@@ -7,6 +7,7 @@ import {
 import ConduitGrpcSdk from '@conduitplatform/grpc-sdk';
 import { getMessaging, Message, Messaging } from 'firebase-admin/messaging';
 import { cert, initializeApp, ServiceAccount } from 'firebase-admin/app';
+import { NotificationToken } from '../models/index.js';
 
 export class FirebaseProvider extends BaseNotificationProvider<IFirebaseSettings> {
   private fcm?: Messaging;
@@ -76,6 +77,9 @@ export class FirebaseProvider extends BaseNotificationProvider<IFirebaseSettings
         },
       };
     }
-    return this.fcm!.send(message);
+    return this.fcm!.send(message).catch(e => {
+      ConduitGrpcSdk.Logger.error('Failed to send notification: ', e);
+      NotificationToken.getInstance().deleteOne({ token });
+    });
   }
 }

modules/push-notifications/src/providers/base.provider.ts

@@ -37,23 +37,26 @@ export class BaseNotificationProvider<T> {
       });
     }
     if (this.isBaseProvider) return;
-    const notificationToken = (await this.fetchTokens(sendTo)) as NotificationToken;
-    if (isNil(notificationToken)) {
+    const notificationTokens = await this.fetchTokens(sendTo, params.platform);
+    if (notificationTokens.length === 0) {
       throw new Error('No notification token found');
     }
-    return this.sendMessage(notificationToken.token, params);
+    const promises = notificationTokens.map(async notToken => {
+      await this.sendMessage(notToken.token, params);
+    });
+    return Promise.all(promises);
   }
 
-  fetchTokens(
-    users: string | string[],
-  ): Promise<NotificationToken | NotificationToken[] | null> {
+  fetchTokens(users: string | string[], platform?: string): Promise<NotificationToken[]> {
     if (Array.isArray(users)) {
       return NotificationToken.getInstance().findMany({
         userId: { $in: users },
+        ...(platform ? { platform } : {}),
       });
     }
-    return NotificationToken.getInstance().findOne({
+    return NotificationToken.getInstance().findMany({
       userId: users as string,
+      ...(platform ? { platform } : {}),
     });
   }
 
@@ -90,6 +93,7 @@ export class BaseNotificationProvider<T> {
     const promises = notificationTokens.map(async token => {
       const id = token.userId.toString();
       const data = notificationsObj[id];
+      if (data.platform && data.platform !== token.platform) return;
       await this.sendMessage(token.token, data).catch(e => {
         ConduitGrpcSdk.Logger.error(e);
       });
@@ -115,6 +119,7 @@ export class BaseNotificationProvider<T> {
     if (this.isBaseProvider) return;
     const notificationTokens = (await this.fetchTokens(
       params.sendTo,
+      params.platform,
     )) as NotificationToken[];
 
     if (notificationTokens.length === 0) throw new Error('Could not find tokens');