AG Scroll Settings Budget Push und Rechnungsdokumente umsetzen

src/lib/push-notifications.ts

@@ -1,5 +1,5 @@
 import webpush from "web-push";
-import type { ApprovalType } from "@prisma/client";
+import type { ApprovalType, BudgetReleaseNotifyTarget } from "@prisma/client";
 
 import { approvalLabel } from "@/lib/domain";
 import prisma from "@/lib/prisma";
@@ -10,6 +10,14 @@ type PushTargetExpense = {
   amount: number;
 };
 
+type PushTargetBudgetRelease = {
+  id: string;
+  name: string;
+  workingGroupId: string;
+  workingGroupName: string;
+  releasedAmount: number;
+};
+
 function configureWebPush() {
   const publicKey = process.env.NEXT_PUBLIC_VAPID_PUBLIC_KEY;
   const privateKey = process.env.VAPID_PRIVATE_KEY;
@@ -92,3 +100,52 @@ export async function notifyApprovalRequest(expense: PushTargetExpense, approval
     })
   );
 }
+
+export async function notifyBudgetRelease(budget: PushTargetBudgetRelease, target: BudgetReleaseNotifyTarget) {
+  if (!configureWebPush()) {
+    return;
+  }
+
+  const subscriptions = await prisma.pushSubscription.findMany({
+    where: {
+      user: {
+        workingGroupId: budget.workingGroupId,
+        ...(target === "GROUP_MEMBERS_ONLY" ? { role: "MEMBER" } : {})
+      }
+    }
+  });
+
+  await Promise.all(
+    subscriptions.map(async (subscription) => {
+      const payload = JSON.stringify({
+        title: "Budget freigegeben",
+        body: `${budget.workingGroupName}: ${budget.name} wurde mit ${budget.releasedAmount.toFixed(2)} EUR freigegeben.`,
+        url: `/?budget=${encodeURIComponent(budget.id)}`,
+        tag: `budget-release-${budget.id}`
+      });
+
+      try {
+        await webpush.sendNotification(
+          {
+            endpoint: subscription.endpoint,
+            keys: {
+              p256dh: subscription.p256dh,
+              auth: subscription.auth
+            }
+          },
+          payload
+        );
+      } catch (error) {
+        const statusCode = typeof error === "object" && error && "statusCode" in error ? error.statusCode : null;
+
+        if (statusCode === 404 || statusCode === 410) {
+          await prisma.pushSubscription.delete({
+            where: {
+              endpoint: subscription.endpoint
+            }
+          });
+        }
+      }
+    })
+  );
+}