upd: fungsi delete iddevice yg gagal fcm

src/app/api/mobile/announcement/route.ts

@@ -100,14 +100,15 @@ export async function GET(request: Request) {
             createdAt: moment(v.createdAt).format("ll")
         }))
 
-        // await sendFCMNotification('c89yuexsS_uc1tOErVPu5a:APA91bEb6tEKXAfReZjFVJ2mMyOzoW_RXryLSnSJTpbIVV3G0L_DCNkLuRvJ02Ip-Erz88QCQBAt-C2SN8eCRxu3-v1sBzXzKPtDv-huXpkjXsyrkifqvUo')
         await sendFCMNotificationMany({
             token: [
                'c89yuexsS_uc1tOErVPu5a:APA91bEb6tEKXAfReZjFVJ2mMyOzoW_RXryLSnSJTpbIVV3G0L_DCNkLuRvJ02Ip-Erz88QCQBAt-C2SN8eCRxu3-v1sBzXzKPtDv-huXpkjXsyrkifqvUo',
-                'cRz96GHKTRaQaRJ35e8Hxa:APA91bEUSxE0VPbqKSzseQ_zGhbYsDofMexKykRw7o_3z2aPM9YFmZbeA2enrmb3qjdZ2g4-QQtiNHAyaZqAT1ITOrwo9jVJlShTeABmEFYP5GLEUZ3dlLc'
+               'cRz96GHKTRaQaRJ35e8Hxa:APA91bEUSxE0VPbqKSzseQ_zGhbYsDofMexKykRw7o_3z2aPM9YFmZbeA2enrmb3qjdZ2g4-QQtiNHAyaZqAT1ITOrwo9jVJlShTeABmEFYP5GLEUZ3dlLc',
+               'gagal_device1',
+               'gagal_device2'
             ],
-            title: "Judul Notifikasi Pengumuman",
+            title: "Judul Notifikasi Pengumuman api biasa",
-            body: "Pengumuman untuk perangkat",
+            body: "Pengumuman untuk perangkat api biasa",
             data: { id: "cm1eqwkwj00067j2bzejyh9u7", category: "division", content: "cm1eqwkvu00017j2b8qnisp9g" }
          })
 

src/app/api/mobile/fcm/[[...slug]]/route.ts

@@ -9,10 +9,12 @@ const ApiV2 = new elysia({
       await sendFCMNotificationMany({
          token: [
             'c89yuexsS_uc1tOErVPu5a:APA91bEb6tEKXAfReZjFVJ2mMyOzoW_RXryLSnSJTpbIVV3G0L_DCNkLuRvJ02Ip-Erz88QCQBAt-C2SN8eCRxu3-v1sBzXzKPtDv-huXpkjXsyrkifqvUo',
-            'cRz96GHKTRaQaRJ35e8Hxa:APA91bEUSxE0VPbqKSzseQ_zGhbYsDofMexKykRw7o_3z2aPM9YFmZbeA2enrmb3qjdZ2g4-QQtiNHAyaZqAT1ITOrwo9jVJlShTeABmEFYP5GLEUZ3dlLc'
+            'cRz96GHKTRaQaRJ35e8Hxa:APA91bEUSxE0VPbqKSzseQ_zGhbYsDofMexKykRw7o_3z2aPM9YFmZbeA2enrmb3qjdZ2g4-QQtiNHAyaZqAT1ITOrwo9jVJlShTeABmEFYP5GLEUZ3dlLc',
+            'gagal_device1',
+            'gagal_device2'
          ],
-         title: "Judul Notifikasi Pengumuman",
+         title: "Judul Notifikasi Pengumuman Elysia",
-         body: "Pengumuman untuk perangkat",
+         body: "Pengumuman untuk perangkat Elysia",
          data: { id: "cm1eqwkwj00067j2bzejyh9u7", category: "division", content: "cm1eqwkvu00017j2b8qnisp9g" }
       })
       return {

src/lib/firebase/fcm.ts

@@ -44,7 +44,6 @@ export async function sendFCM(token: string[], title: string, body: string) {
          tokens: token,
          ...message,
       })
-      console.log("✅ FCM berhasil dikirim:", result);
       if (result.failureCount > 0) {
          const failedTokens: any[] = [];
          result.responses.forEach((resp, idx) => {

src/module/_global/fun/delete_device_error.ts

@@ -0,0 +1,17 @@
+import { prisma } from "@/module/_global";
+
+export default async function deleteDeviceError({ device }: { device: string[] }) {
+   try {
+      const deleteToken = await prisma.tokenDeviceUser.deleteMany({
+         where: {
+            token: {
+               in: device
+            }
+         }
+      });
+      return { success: true, message: "Success" }
+   } catch (error) {
+      console.error(error)
+      return { success: false, message: "Internal Server Error" }
+   }
+}

src/module/_global/index.ts

@@ -30,6 +30,7 @@ import { funSendWebPush } from "./fun/send_web_push";
 import ViewFilterData from "./view/view_filter_kategori_data";
 import LayoutModalNew from "./layout/layout_modal_new";
 import { funReadPdf } from "./fun/read_pdf";
+import deleteDeviceError from "./fun/delete_device_error";
 
 export { WARNA };
 export { LayoutLogin };
@@ -69,3 +70,4 @@ export { funSendWebPush }
 export { ViewFilterData }
 export { LayoutModalNew }
 export { funReadPdf }
+export { deleteDeviceError }

xsendMany.ts

@@ -1,4 +1,4 @@
-// Impor Firebase Admin SDK
+import { deleteDeviceError } from '@/module/_global';
 import CryptoJs from 'crypto-js';
 import { cert, getApps, initializeApp } from "firebase-admin/app";
 import { getMessaging } from "firebase-admin/messaging";
@@ -46,8 +46,17 @@ export async function sendFCMNotificationMany({ token, title, body, data }: { to
          tokens: token,
          ...message,
       } as any);
-      console.log("Notifikasi berhasil dikirim:", response);
+      if (response.failureCount > 0) {
-      return response;
+         const failedTokens: any[] = [];
+         response.responses.forEach((resp, idx) => {
+            if (!resp.success) {
+               failedTokens.push(token[idx]);
+            }
+         });
+         const del = await deleteDeviceError({ device: failedTokens });
+      }
+
+      return { success: true, message: "Notifikasi berhasil dikirim", };
    } catch (error) {
       console.error("Error mengirim notifikasi:", error);
       throw error;