Feature/posthog backend

app/api/user/settings/route.ts

@@ -1,6 +1,7 @@
 import { NextResponse } from "next/server";
 import getUserSettings from "../../../../utils/db/user/settings";
 import validateParams from "../../../../utils/api/validateParams";
+import posthog from "../../../../utils/posthog/posthog";
 
 export async function POST(request: Request) {
   const req = await request.json();
@@ -11,7 +12,13 @@ export async function POST(request: Request) {
       error: `Missing parameters: ${missingParams.join(", ")}`,
     });
   }
-
+  posthog.capture({
+    distinctId: req.email,
+    event: "user_settings_viewed",
+    properties: {
+      email: req.email,
+    },
+  });
   try {
     let dbResponse = await getUserSettings({ email: req.email });
     return NextResponse.json(dbResponse);

utils/posthog/posthog.ts

@@ -0,0 +1,36 @@
+import { PostHog } from "posthog-node";
+interface PostHogEvent {
+  event: string;
+  distinctId?: string;
+  properties?: Record<string, any>;
+  groups?: Record<string, any>;
+}
+
+function PostHogClient(apiKey: string) {
+  const posthogClient = new PostHog(apiKey, {
+    host: process.env.NEXT_PUBLIC_POSTHOG_HOST,
+  });
+
+  return {
+    capture: ({ event, distinctId, properties, groups }: PostHogEvent) => {
+      posthogClient.capture({
+        distinctId: distinctId || "unknown_user",
+        event,
+        properties,
+        groups,
+      });
+      console.log("posthog event", event, properties);
+      if (process.env.NODE_ENV === "development") {
+        console.log(
+          `PostHog event: ${event} with properties: ${JSON.stringify(
+            properties
+          )}`
+        );
+      }
+    },
+  };
+}
+
+const posthog = PostHogClient(process.env.NEXT_PUBLIC_POSTHOG_KEY!);
+
+export default posthog;