fixed messages fixed devtokengeneration and

deletion

firebase.json

@@ -3,6 +3,7 @@
     "predeploy": [
       "npm --prefix \"$RESOURCE_DIR\" run lint",
       "npm --prefix \"$RESOURCE_DIR\" run build"
-    ]
+    ],
+    "source": "functions"
   }
 }

functions/src/cloud_Functions/messages.ts

@@ -0,0 +1,70 @@
+import * as functions from "firebase-functions";
+import * as admin from "firebase-admin";
+import { DocumentSnapshot } from "@google-cloud/firestore";
+
+const db = admin.firestore();
+
+export class Messages {
+    async uploadMessage(data: any, context: functions.https.CallableContext) {
+        return db
+            .collection("messages")
+            .doc()
+            .set(data.message)
+            .then(response => console.log(response));
+    }
+
+    async sendNotificationForMessage(
+        data: any,
+        context: functions.https.CallableContext
+    ) {
+        const title: string = data.title;
+        const snippet: string = data.snippet;
+        const receivers: string[] = data.receivers;
+        let registrationTokens: string[] = [];
+        for (let receiver of receivers) {
+            const group: DocumentSnapshot = await db
+                .collection("groups")
+                .doc(receiver)
+                .get();
+            const priviledgedList: string[] = Object.keys(
+                group.get("Priviledge")
+            );
+            for (let uid of priviledgedList) {
+                const userMap: DocumentSnapshot = await db
+                    .collection("user")
+                    .doc(uid)
+                    .get();
+                const test = userMap.get("devtoken");
+                if (test !== undefined) {
+                    const devtokensObject: { [key: string]: any } = test;
+                    for (let token of Object.values(devtokensObject)) {
+                        registrationTokens.push(token);
+                    }
+                }
+            }
+        }
+        const message = {
+            notification: { title: title, body: snippet },
+            priority: "high",
+            data: { click_action: "FLUTTER_NOTIFICATION_CLICK" },
+            tokens: registrationTokens
+        };
+        console.log(registrationTokens);
+        return admin
+            .messaging()
+            .sendMulticast(message)
+            .then(response => {
+                if (response.failureCount > 0) {
+                    const failedTokens: string[] = [];
+                    response.responses.forEach((resp, idx) => {
+                        if (!resp.success) {
+                            failedTokens.push(registrationTokens[idx]);
+                        }
+                    });
+                    console.log(
+                        "List of tokens that caused failures: " + failedTokens
+                    );
+                }
+            });
+    }
+}