From 78aa1512446072fdec94c86360c9aee3ea932db1 Mon Sep 17 00:00:00 2001
From: Pinapelz <yukais@pinapelz.com>
Date: Fri, 3 Oct 2025 13:07:33 -0700
Subject: add redis fcm notif topic saving

---
 middleware/src/app/api/notifications/set/route.ts | 30 +++++++++++++++++++++++
 1 file changed, 30 insertions(+)
 create mode 100644 middleware/src/app/api/notifications/set/route.ts

(limited to 'middleware/src/app/api/notifications/set')

diff --git a/middleware/src/app/api/notifications/set/route.ts b/middleware/src/app/api/notifications/set/route.ts
new file mode 100644
index 0000000..3a584fb
--- /dev/null
+++ b/middleware/src/app/api/notifications/set/route.ts
@@ -0,0 +1,30 @@
+import { Redis } from "@upstash/redis";
+
+export const runtime = "edge";
+const redis = new Redis({
+  url: process.env.KV_REST_API_URL!,
+  token: process.env.KV_REST_API_TOKEN!,
+});
+
+// /api/fcm?topic=<topic>&token=<fcm_token>&action=subscribe|unsubscribe
+export async function GET(req: Request) {
+  const { searchParams } = new URL(req.url);
+  const topic = searchParams.get("topic");
+  const token = searchParams.get("token");
+  const action = searchParams.get("action"); // "subscribe" | "unsubscribe"
+
+  if (!topic || !token || !action) {
+    return new Response(JSON.stringify({ error: "Missing params" }), { status: 400 });
+  }
+  const key = `fcm-${topic}`;
+
+  if (action === "subscribe") {
+    await redis.sadd(key, token);
+  } else if (action === "unsubscribe") {
+    await redis.srem(key, token);
+  } else {
+    return new Response(JSON.stringify({ error: "Invalid action" }), { status: 400 });
+  }
+
+  return new Response(JSON.stringify({ success: true }), { status: 200 });
+}
-- 
cgit v1.2.3