Add addFrame() action, sending notifications and getting webhook events

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

@@ -0,0 +1,66 @@
+import {
+  SendNotificationRequest,
+  sendNotificationResponseSchema,
+} from "@farcaster/frame-sdk";
+import { NextRequest } from "next/server";
+import { z } from "zod";
+
+const requestSchema = z.object({
+  token: z.string(),
+  url: z.string(),
+  targetUrl: z.string(),
+});
+
+export async function POST(request: NextRequest) {
+  const requestJson = await request.json();
+  const requestBody = requestSchema.safeParse(requestJson);
+
+  if (requestBody.success === false) {
+    return Response.json(
+      { success: false, errors: requestBody.error.errors },
+      { status: 400 }
+    );
+  }
+
+  const response = await fetch(requestBody.data.url, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+    },
+    body: JSON.stringify({
+      notificationId: crypto.randomUUID(),
+      title: "Hello from Frames v2!",
+      body: "This is a test notification",
+      targetUrl: requestBody.data.targetUrl,
+      tokens: [requestBody.data.token],
+    } satisfies SendNotificationRequest),
+  });
+
+  const responseJson = await response.json();
+
+  if (response.status === 200) {
+    // Ensure correct response
+    const responseBody = sendNotificationResponseSchema.safeParse(responseJson);
+    if (responseBody.success === false) {
+      return Response.json(
+        { success: false, errors: responseBody.error.errors },
+        { status: 500 }
+      );
+    }
+
+    // Fail when rate limited
+    if (responseBody.data.result.rateLimitedTokens.length) {
+      return Response.json(
+        { success: false, error: "Rate limited" },
+        { status: 429 }
+      );
+    }
+
+    return Response.json({ success: true });
+  } else {
+    return Response.json(
+      { success: false, error: responseJson },
+      { status: 500 }
+    );
+  }
+}

src/app/api/webhook/route.ts

@@ -0,0 +1,72 @@
+import {
+  eventHeaderSchema,
+  eventPayloadSchema,
+  eventSchema,
+} from "@farcaster/frame-sdk";
+import { NextRequest } from "next/server";
+
+export async function POST(request: NextRequest) {
+  const requestJson = await request.json();
+
+  const requestBody = eventSchema.safeParse(requestJson);
+
+  if (requestBody.success === false) {
+    return Response.json(
+      { success: false, errors: requestBody.error.errors },
+      { status: 400 }
+    );
+  }
+
+  // TODO: verify signature
+
+  const headerData = JSON.parse(
+    Buffer.from(requestBody.data.header, "base64url").toString("utf-8")
+  );
+  const header = eventHeaderSchema.safeParse(headerData);
+  if (header.success === false) {
+    return Response.json(
+      { success: false, errors: header.error.errors },
+      { status: 400 }
+    );
+  }
+  const fid = header.data.fid;
+
+  const payloadData = JSON.parse(
+    Buffer.from(requestBody.data.payload, "base64url").toString("utf-8")
+  );
+  const payload = eventPayloadSchema.safeParse(payloadData);
+
+  if (payload.success === false) {
+    return Response.json(
+      { success: false, errors: payload.error.errors },
+      { status: 400 }
+    );
+  }
+
+  switch (payload.data.event) {
+    case "frame-added":
+      console.log(
+        payload.data.notificationDetails
+          ? `Got frame-added event for fid ${fid} with notification token ${payload.data.notificationDetails.token} and url ${payload.data.notificationDetails.url}`
+          : `Got frame-added event for fid ${fid} with no notification details`
+      );
+      break;
+    case "frame-removed":
+      console.log(`Got frame-removed event for fid ${fid}`);
+      break;
+    case "notifications-enabled":
+      console.log(
+        `Got notifications-enabled event for fid ${fid} with token ${
+          payload.data.notificationDetails.token
+        } and url ${payload.data.notificationDetails.url} ${JSON.stringify(
+          payload.data
+        )}`
+      );
+      break;
+    case "notifications-disabled":
+      console.log(`Got notifications-disabled event for fid ${fid}`);
+      break;
+  }
+
+  return Response.json({ success: true });
+}