Added analytics on transition

EZFrames · Jun 25, 2024 · 1a9f9df · 1a9f9df
1 parent 382b034
commit 1a9f9df
Show file tree

Hide file tree

Showing 4 changed files with 51 additions and 8 deletions.
diff --git a/packages/nextjs/app/api/orchestrator/[frameId]/route.ts b/packages/nextjs/app/api/orchestrator/[frameId]/route.ts
@@ -1,15 +1,23 @@
 import { NextRequest, NextResponse } from "next/server";
-import { FrameMetadataType, FrameRequest, getFrameHtmlResponse, getFrameMessage } from "@coinbase/onchainkit";
+import { FrameMetadataType, FrameRequest, getFrameHtmlResponse } from "@coinbase/onchainkit";
+import Analytics from "~~/model/analytics";
+import connectDB from "~~/services/connectDB";
 import { getFrameById } from "~~/services/frames";
 
 async function getResponse(req: NextRequest): Promise<NextResponse> {
+  await connectDB();
   const body: FrameRequest = await req.json();
-  const { isValid } = await getFrameMessage(body);
-
-  if (!isValid) {
-    return new NextResponse("Message not valid", { status: 500 });
-  }
-
+  const state = JSON.parse(decodeURIComponent(body.untrustedData.state as string));
+  // Create Analytics for the frame asynchronously
+  const analyticsEntry = new Analytics({
+    journeyId: state?.journeyId || "",
+    frameId: state?.frameId || "",
+    fid: body.untrustedData.fid,
+    buttonClicked: body.untrustedData.buttonIndex || 0,
+    inputtedText: body.untrustedData.inputText || "",
+    timestamp: body.untrustedData.timestamp,
+  });
+  await analyticsEntry.save();
   return new NextResponse(getFrameHtmlResponse(getFrameById(1) as FrameMetadataType));
 }
 

diff --git a/packages/nextjs/model/analytics.ts b/packages/nextjs/model/analytics.ts
@@ -0,0 +1,29 @@
+import mongoose, { Document, Schema } from "mongoose";
+
+interface Analytics extends Document {
+  journeyId: string;
+  frameId: string;
+  fid: string;
+  buttonClicked: number;
+  inputtedText: string;
+  timestamp: Date;
+}
+
+const AnalyticsSchema: Schema<Analytics> = new Schema<Analytics>(
+  {
+    journeyId: String, // journeyId to correlate
+    frameId: String, //frameId to correlate
+    fid: String, // fid of the user
+    buttonClicked: Number, // 0 for no button clicked, 1 for button 1 clicked....
+    inputtedText: String, // text inputted by the user, null if empty
+    timestamp: Number, // timestamp of the event
+  },
+  {
+    timestamps: true,
+  },
+);
+
+// Define and export the Analytics model
+const Analytics = mongoose.models.Analytics || mongoose.model<Analytics>("Analytics", AnalyticsSchema);
+
+export default Analytics;
diff --git a/packages/nextjs/services/connectDB.ts b/packages/nextjs/services/connectDB.ts
@@ -32,7 +32,9 @@ async function connectDB(): Promise<Mongoose> {
       bufferCommands: false,
     };
 
-    cached.promise = mongoose.connect(DATABASE_URL, opts).then(mongoose => mongoose);
+    cached.promise = mongoose.connect(DATABASE_URL, opts).then(mongoose => {
+      return mongoose;
+    });
   }
 
   cached.conn = await cached.promise;

diff --git a/packages/nextjs/services/frames.ts b/packages/nextjs/services/frames.ts
@@ -2,6 +2,8 @@ export const getFrameById = (id: number) => {
   return {
     buttons: [
       {
+        action: "post",
+        target: "http://localhost:3000/api/orchestrator/1",
         label: `Home ${id}`,
       },
       {
@@ -19,6 +21,8 @@ export const getFrameById = (id: number) => {
     },
     state: {
       time: new Date().toISOString(),
+      journey_id: "1",
+      frame_id: "2",
     },
   };
 };