upd: web push

Deskripsi:
- install package
- table database
- nb : masih blm bisa

No Issues

src/app/api/get-subscribe/route.ts

@@ -0,0 +1,6 @@
+import prisma from "@/lib/prisma";
+
+export async function GET() {
+  const sub = await prisma.subscription.findMany();
+  return new Response(JSON.stringify({ data: sub }));
+}

src/app/api/send-notification/route.ts

@@ -0,0 +1,70 @@
+import webpush from "web-push";
+import prisma from "@/lib/prisma";
+
+// Set VAPID details for web-push
+webpush.setVapidDetails(
+  "mailto:bip.production.js@gmail.com",
+  process.env.NEXT_PUBLIC_VAPID_PUBLIC_KEY!,
+  process.env.VAPID_PRIVATE_KEY!
+);
+
+export async function POST() {
+  try {
+    // Fetch all subscriptions from your database
+    const subscriptions = await prisma.subscription.findMany();
+
+    if (!subscriptions || subscriptions.length === 0) {
+      console.error("No subscriptions available to send notification");
+      return new Response("No subscriptions available", { status: 400 });
+    }
+
+    // Notification payload
+    const notificationPayload = JSON.stringify({
+      title: "Test Notification",
+      body: "This is a test notification | makuro",
+      icon: "/icon-192x192.png",
+      badge: "/icon-192x192.png",
+      image: "/icon-192x192.png",
+    });
+
+    let successCount = 0;
+    let failureCount = 0;
+
+    // Loop through all subscriptions and send notifications
+    for (const sub of subscriptions) {
+      try {
+        const subscriptionData = sub.data as any;
+
+        await webpush.sendNotification(subscriptionData, notificationPayload);
+        console.log(
+          `Notification sent successfully to ${subscriptionData.endpoint}`
+        );
+        successCount++;
+      } catch (error: any) {
+        console.error(
+          `Error sending push notification to subscription ${sub.id}:`,
+          error
+        );
+        failureCount++;
+      }
+    }
+
+    // Return a success or failure response
+    return new Response(
+      JSON.stringify({
+        message: `Notifications sent: ${successCount}, Failed: ${failureCount}`,
+        success: failureCount === 0
+      }),
+      { status: 200 }
+    );
+  } catch (error: any) {
+    console.error("Error during notification process:", error);
+    return new Response(
+      JSON.stringify({
+        success: false,
+        error: error.message || "Failed to process notifications"
+      }),
+      { status: 500 }
+    );
+  }
+}

src/app/api/set-subscribe/route.ts

@@ -0,0 +1,25 @@
+import webpush from "web-push";
+import prisma from "@/lib/prisma";
+webpush.setVapidDetails(
+  "mailto:bip.production.js@gmail.com",
+  process.env.NEXT_PUBLIC_VAPID_PUBLIC_KEY!,
+  process.env.VAPID_PRIVATE_KEY!
+);
+
+export async function POST(req: Request) {
+  const { sub } = await req.json();
+  console.log(sub);
+  if (!sub || !sub.endpoint) {
+    console.error("Invalid subscription object");
+    return new Response("Invalid subscription object", { status: 400 });
+  }
+
+  const data = await prisma.subscription.create({
+    data: {
+      id: sub.keys.auth,
+      data: sub
+    }
+  });
+
+  return new Response(JSON.stringify({ data }));
+}

src/app/api/unsubscribe/route.ts

@@ -0,0 +1,11 @@
+import prisma from "@/lib/prisma";
+
+export async function POST(req: Request) {
+  const { sub } = await req.json();
+  const data = await prisma.subscription.delete({
+    where: {
+      id: sub.keys.auth
+    }
+  });
+  return new Response(JSON.stringify({ data }));
+}