Merge pull request #485 from NaucMeIT/feat/add-posthog-analytics-to-l…

…egacy

feat(legacy): 📈 identify users in posthog

apps/legacy_nmit/hooks/useTrackedUser.ts

@@ -1,3 +1,4 @@
+import posthog from "posthog-js"
 import splitbee from "@splitbee/web"
 import { signIn, signOut, useSession } from "next-auth/react"
 import { useRouter } from "next/router"
@@ -16,6 +17,8 @@ export const useTrackedUser = () => {
         const data = await signOut({ redirect: false, callbackUrl: signUrl })
         splitbee.track("Sign out")
         splitbee.reset()
+        posthog.capture('Sign out')
+        posthog.reset()
         if (router && shouldRedirect(router.asPath)) {
             router.push(data.url)
         }
@@ -25,7 +28,11 @@ export const useTrackedUser = () => {
     async function sign(provider: AllowedOauth): Promise<void>
     async function sign(provider: AllowedProviders, email?: string): Promise<void> {
         try {
-            splitbee.track(`${provider} sign attempt`)
+            posthog.capture('sign_attempt', {
+              email,
+              provider,
+            })
+            splitbee.track(`${provider} sign attempt ${email ? `with email ${email}` : ""}`)
             const isEmail = provider === "email"
             setSignStatus("signing")
             const signInStatus = await signIn(provider, {
@@ -38,18 +45,30 @@ export const useTrackedUser = () => {
             }
             setSignStatus(isEmail ? "send" : "oauth")
         } catch (e) {
-            typeof e === "string" && splitbee.track("Sign error", { signError: e, email, provider })
+            posthog.capture('sign_failure', {
+              email,
+              provider,
+              error: JSON.stringify(e),
+            })
+            splitbee.track("Sign error", { signError: JSON.stringify(e), email, provider })
             setSignStatus("error")
         }
     }
 
     useEffect(() => {
         if (status === "authenticated" && data?.user.email) {
+            const { email, name, planId } = data.user
             splitbee.track("Sign success")
             splitbee.user.set({
-                userId: data.user.email,
-                name: data.user.name,
-                planId: data.user.planId,
+                userId: email,
+                name: name,
+                planId: planId,
+            })
+            posthog.identify(email, { name: name })
+            posthog.capture('sign_success', {
+              email,
+              name,
+              planId,
             })
         }
         // If status changes, we are sure that user data exist, should prevent duplicate calls

apps/legacy_nmit/package.json

@@ -50,6 +50,7 @@
     "next-runtime": "^2.4.2",
     "nodemailer": "^6.9.16",
     "posthog-js": "^1.188.0",
+    "posthog-node": "^4.2.3",
     "react": "^18.3.1",
     "react-calendly": "^4.3.1",
     "react-dom": "^18.3.1",

apps/legacy_nmit/pages/api/webhooks.ts

@@ -3,8 +3,14 @@ import createStripe from "stripe"
 import bodyParser from "body-parser"
 import { log } from "next-axiom"
 import { PaymentStatus } from "@prisma/client"
+import { PostHog } from 'posthog-node'
 import { prisma } from "../../utils/prisma"
 
+const client = new PostHog(
+    process.env["NEXT_PUBLIC_POSTHOG_KEY"] || "",
+    { host: 'https://eu.i.posthog.com' }
+)
+
 const stripe = new createStripe(process.env.STRIPE_SECRET_KEY || "", { apiVersion: "2024-11-20.acacia", typescript: true })
 const endpointSecret = process.env.STRIPE_WEBHOOK_SECRET || ""
 
@@ -72,6 +78,18 @@ async function handlePaymentIntentSucceeded(id: string, email: string) {
         where: { email },
         data: { credits: user.credits + plan.credits, paymentStatus: PaymentStatus.Done },
     })
+
+    client.identify({ distinctId: user.id })
+    client.capture({
+        distinctId: user.id,
+        event: 'order_paid',
+        properties: {
+            subtotal: plan.price,
+            customer_email: user.email,
+        },
+    })
+
+    await client.shutdown()
 }
 
 async function handlePaymentIntentInProgress(email: string) {
@@ -82,6 +100,15 @@ async function handlePaymentIntentInProgress(email: string) {
         where: { email },
         data: { paymentStatus: PaymentStatus.InProgress },
     })
+
+    client.identify({ distinctId: user.id })
+    client.capture({
+        distinctId: user.id,
+        event: 'order_in_progress',
+        properties: {
+            customer_email: user.email,
+        },
+    })
 }
 
 async function handlePaymentIntentFailed(email: string) {
@@ -92,4 +119,13 @@ async function handlePaymentIntentFailed(email: string) {
         where: { email },
         data: { paymentStatus: PaymentStatus.Failed },
     })
+
+    client.identify({ distinctId: user.id })
+    client.capture({
+        distinctId: user.id,
+        event: 'order_failed',
+        properties: {
+            customer_email: user.email,
+        },
+    })
 }

apps/legacy_nmit/pages/profile/edit.tsx

@@ -9,6 +9,12 @@ import { ProfileDetailsForm } from "../../components/ProfileDetailsForm"
 import { prisma } from "../../utils/prisma"
 import { PaymentStatus, Plan } from "@prisma/client"
 import { allowedStatus } from "../../utils/stripe"
+import { PostHog } from 'posthog-node'
+
+const client = new PostHog(
+    process.env["NEXT_PUBLIC_POSTHOG_KEY"] || "",
+    { host: 'https://eu.i.posthog.com' }
+)
 
 type PageProps = {
     readonly session: Session
@@ -98,6 +104,19 @@ export const getServerSideProps = handle<{}, UrlQuery, FormData>({
                     paymentStatus: isPaidPlan ? PaymentStatus.Awaiting : PaymentStatus.NotNecessary,
                 },
             })
+            const userEmail = session?.user?.email || ""
+            client.identify({ distinctId: userEmail, properties: {
+              name: body.name,
+            } })
+            client.capture({
+                distinctId: userEmail,
+                event: 'profile_edited',
+                properties: {
+                    subtotal: dbPlan.price,
+                    customer_email: userEmail,
+                },
+            })
+            await client.shutdown()
 
             return {
                 redirect: {