# feat

## Deskripsi :
- Notifikasi donasi
### No Issue

src/app_modules/notifikasi/fun/create/create_notif_to_user_kabar_donasi.ts

@@ -1,24 +1,58 @@
+"use server";
+
 import prisma from "@/app/lib/prisma";
+import _ from "lodash";
+import mqtt_client from "@/util/mqtt_client";
 
 export async function notifikasiToUser_CreateKabarDonasi({
   donasiId,
+  kabarId,
 }: {
   donasiId: string;
+  kabarId: string;
 }) {
+  const getDataDonasi = await prisma.donasi.findFirst({
+    where: {
+      id: donasiId,
+    },
+  });
+
   const getDonatur = await prisma.donasi_Invoice.findMany({
     where: {
       donasiId: donasiId,
     },
     select: {
-      Donasi: {
-        select: {
-          id: true,
-          authorId: true,
-          title: true,
-        },
-      },
+      authorId: true,
     },
   });
 
-  console.log(getDonatur)
+  const data = new Set(getDonatur.map((e) => e.authorId));
+  const dataFix = Array.from(data);
+
+  for (let authorId of dataFix) {
+    console.log(authorId);
+    const createNotifikasi = await prisma.notifikasi.create({
+      data: {
+        userRoleId: "1",
+        userId: authorId,
+        appId: kabarId,
+        pesan: getDataDonasi?.title as any,
+        kategoriApp: "DONASI",
+        status: "Kabar Donasi",
+        title: "Kabar terupdate donasi anda !",
+      },
+    });
+
+    if (!createNotifikasi)
+      return { status: 400, message: "Gagal membuat notifikasi" };
+
+    mqtt_client.publish(
+      "USER",
+      JSON.stringify({
+        userId: authorId,
+        count: 1,
+      })
+    );
+  }
+  return { status: 201, message: "Berhasil membuat notifikasi" };
 }