Feature/posthog frontend (#242)

pages/api/analytics/vsmarketplace/update.ts → app/api/analytics/vsmarketplace/update/route.ts

@@ -1,3 +1,5 @@
+import { NextResponse } from "next/server";
+import validateParams from "../../../../../utils/api/validateParams";
 import Airtable from "airtable";
 Airtable.configure({
   endpointUrl: "https://api.airtable.com",
@@ -24,13 +26,21 @@ function toRecords(infoArray) {
   }
   return records;
 }
-export default async function handler(req, res) {
-  const { dailyStats } = req.body;
+export async function POST(request: Request) {
+  const req = await request.json();
+  const { missingParams } = validateParams(req, ["dailyStats"]);
+
+  if (missingParams.length > 0) {
+    return NextResponse.json({
+      error: `Missing parameters: ${missingParams.join(", ")}`,
+    });
+  }
+  const { dailyStats } = req;
   let records;
   if (dailyStats.length < 10) {
     records = toRecords(dailyStats.slice(0, 10));
     let createdRecord = await base("vscmarketplace").create(records);
-    res.status(200).json(createdRecord);
+    return NextResponse.json(createdRecord);
   } else {
     records = toRecords(dailyStats);
     // now take the records and chunk them into groups of 10
@@ -53,6 +63,6 @@ export default async function handler(req, res) {
       // @ts-ignore
       createdRecords.push(createdRecord);
     }
-    res.status(200).json(createdRecords);
+    return NextResponse.json(createdRecords);
   }
 }

app/api/sendgrid/sendTeammateInvite/route.ts

@@ -0,0 +1,28 @@
+import { NextResponse } from "next/server";
+import validateParams from "../../../../utils/api/validateParams";
+import sendTeammateInvite from "../../../../utils/sendgrid/sendTeammateInvite";
+
+export async function POST(request: Request) {
+  const req = await request.json();
+  const { missingParams } = validateParams(req, [
+    "sender",
+    "email",
+    "inviteUrl",
+    "teamName",
+  ]);
+
+  if (missingParams.length > 0) {
+    return NextResponse.json({
+      error: `Missing parameters: ${missingParams.join(", ")}`,
+    });
+  }
+  const { sender, email, inviteUrl, teamName } = req;
+
+  let emailSent = await sendTeammateInvite({
+    sender,
+    teammateEmail: email,
+    inviteUrl,
+    teamName,
+  });
+  return NextResponse.json(emailSent);
+}

app/api/sendgrid/sendWelcome/route.ts

@@ -0,0 +1,18 @@
+import { NextResponse } from "next/server";
+import validateParams from "../../../../utils/api/validateParams";
+import sendWelcome from "../../../../utils/sendgrid/sendWelcome";
+
+export async function POST(request: Request) {
+  const req = await request.json();
+  const { missingParams } = validateParams(req, ["sender", "emails"]);
+
+  if (missingParams.length > 0) {
+    return NextResponse.json({
+      error: `Missing parameters: ${missingParams.join(", ")}`,
+    });
+  }
+  const { sender, emails } = req;
+
+  let emailSent = await sendWelcome({ sender, emails });
+  return NextResponse.json(emailSent);
+}

pages/api/stripe/createSubscription.ts → app/api/stripe/createSubscription/route.ts

@@ -1,15 +1,25 @@
+import { NextResponse } from "next/server";
 import Stripe from "stripe";
+import validateParams from "../../../../utils/api/validateParams";
 
 const stripe = new Stripe(process.env.NEXT_PUBLIC_STRIPE_SECRET_KEY!, {
   apiVersion: "2022-08-01",
 });
 
-export default async function handler(req, res) {
+export async function POST(request: Request) {
+  const req = await request.json();
+  const { missingParams } = validateParams(req, ["email"]);
+
+  if (missingParams.length > 0) {
+    return NextResponse.json({
+      error: `Missing parameters: ${missingParams.join(", ")}`,
+    });
+  }
   try {
     // create a stripe customer and get its id
     const customerId = await stripe.customers
       .create({
-        email: req.body.email,
+        email: req.email,
       })
       .then((customer) => {
         return customer.id;
@@ -23,15 +33,15 @@ export default async function handler(req, res) {
       items: [
         {
           price: priceId,
-          quantity: req.body.quantity,
+          quantity: req.quantity,
         },
       ],
       payment_behavior: "default_incomplete",
       payment_settings: { save_default_payment_method: "on_subscription" },
       expand: ["latest_invoice.payment_intent"],
     });
 
-    res.send({
+    return NextResponse.json({
       subscriptionId: subscription.id,
       // We use Stripe's Expand functionality to get the latest invoice and its payment intent
       // So we can pass it to the front end to confirm the payment
@@ -42,6 +52,8 @@ export default async function handler(req, res) {
   } catch (error) {
     // get error code
     const errorCode = error.raw?.code;
-    return res.status(errorCode).send({ error: { message: error.message } });
+    return NextResponse.json({
+      error: { message: error.message, errorCode },
+    });
   }
 }

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);

app/layout.tsx

@@ -5,6 +5,7 @@ import { getServerSession } from "next-auth";
 import Navbar from "../components/Navbar";
 import Header from "../components/Header";
 import LogInBtn from "../components/login-btn";
+import { PHProvider, PostHogPageview } from "./providers";
 
 import AuthProvider from "../lib/auth/AuthProvider";
 
@@ -30,17 +31,22 @@ export default async function RootLayout({
 
   return (
     <html lang="en" data-color-mode="dark" data-dark-theme="dark">
+      <Suspense fallback={null}>
+        <PostHogPageview />
+      </Suspense>
       <body style={{ minHeight: "100vh" }}>
-        {userEmail ? (
-          <>
-            <Header userEmail={userEmail} userToken={userName} />
-            <Navbar>
-              <AuthProvider>{children}</AuthProvider>
-            </Navbar>
-          </>
-        ) : (
-          <LogInBtn />
-        )}
+        <PHProvider>
+          {userEmail ? (
+            <>
+              <Header userEmail={userEmail} userToken={userName} />
+              <Navbar>
+                <AuthProvider>{children}</AuthProvider>
+              </Navbar>
+            </>
+          ) : (
+            <LogInBtn />
+          )}
+        </PHProvider>
       </body>
     </html>
   );

app/providers.tsx

@@ -1,3 +1,4 @@
+
 "use client";
 import posthog from "posthog-js";
 import { PostHogProvider } from "posthog-js/react";

pages/api/extension/getContext.ts

@@ -4,6 +4,7 @@ import getUserTokens from "../../../utils/db/user/getUserTokens";
 import updateTokensFromJira from "../../../utils/jira/updateTokens";
 import updateTokens from "../../../utils/db/jira/updateTokens";
 import searchMessageByText from "../../../utils/slack/searchMessageByText";
+import validateParams from "../../../utils/api/validateParams";
 function replaceSpecialChars(inputString) {
   const specialChars = /[!"#$%&/()=?_"{}¨*]/g; // Edit this list to include or exclude characters
   return inputString.toLowerCase().replace(specialChars, " ");
@@ -155,21 +156,20 @@ export default async function handler(req, res) {
     properties: { user, repo, owner, gitSystem },
   });
 
-  if (!user) {
-    return res.send({ error: "no user" });
-  }
-  if (!repo) {
-    return res.send({ error: "no repo" });
-  }
-  if (!owner) {
-    return res.send({ error: "no owner" });
-  }
-  if (!commitList) {
-    return res.send({ error: "no commitList" });
-  }
-  if (!gitSystem) {
-    return res.send({ error: "no gitSystem" });
+  const { missingParams } = validateParams(req.body, [
+    "user",
+    "repo",
+    "owner",
+    "gitSystem",
+    "commitList",
+  ]);
+
+  if (missingParams.length > 0) {
+    return res.json({
+      error: `Missing parameters: ${missingParams.join(", ")}`,
+    });
   }
+
   let userTokens;
   try {
     userTokens = await getUserTokens({ email: user });

pages/api/hover/getHoverData.ts

@@ -4,6 +4,7 @@ import { trackEvent } from "../../../utils/analytics/azureAppInsights";
 import updateTokensFromJira from "../../../utils/jira/updateTokens";
 import updateTokens from "../../../utils/db/jira/updateTokens";
 import searchMessageByText from "../../../utils/slack/searchMessageByText";
+import validateParams from "../../../utils/api/validateParams";
 function replaceSpecialChars(inputString) {
   const specialChars = /[!"#$%&/()=?_"{}¨*]/g; // Edit this list to include or exclude characters
   return inputString.toLowerCase().replace(specialChars, " ");
@@ -14,21 +15,18 @@ function handleRejection(reason) {
 }
 export default async function handler(req, res) {
   const { user, gitSystem, repo, owner, commitTitle } = req.body;
+  const { missingParams } = validateParams(req.body, [
+    "user",
+    "repo",
+    "owner",
+    "gitSystem",
+    "commitTitle",
+  ]);
 
-  if (!user) {
-    return res.send({ error: "no user" });
-  }
-  if (!repo) {
-    return res.send({ error: "no repo" });
-  }
-  if (!owner) {
-    return res.send({ error: "no owner" });
-  }
-  if (!gitSystem) {
-    return res.send({ error: "no gitSystem" });
-  }
-  if (!commitTitle) {
-    return res.send({ error: "no commitTitle" });
+  if (missingParams.length > 0) {
+    return res.json({
+      error: `Missing parameters: ${missingParams.join(", ")}`,
+    });
   }
 
   let userTokens;

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;

utils/sendgrid/sendTeammateInvite.ts

@@ -1,18 +1,18 @@
 export default async function sendTeammateInvite({
-  email,
+  teammateEmail,
   sender,
   inviteUrl,
   teamName,
 }: {
-  email: string;
+  teammateEmail: string;
   sender: string;
   inviteUrl: string;
   teamName: string;
 }) {
   const sgMail = require("@sendgrid/mail");
   sgMail.setApiKey(process.env.SENDGRID_API_KEY);
   const msg = {
-    to: email,
+    to: teammateEmail,
     from: "info@watermelon.tools",
     templateId: "d-dd5c729f0be5439daac6b1faaf0431d6",
     dynamic_template_data: {