hubspot integration

Author: gioelecerati

apps/app/app/api/capacity-notification/route.ts

@@ -1,17 +1,5 @@
 import { NextRequest, NextResponse } from "next/server";
-
-async function saveEmailForNotification(email: string): Promise<boolean> {
-  try {
-    // TODO: Implement actual storage logic
-    // DB? hubspot?
-    console.log(`Saving email for capacity notification: ${email}`);
-
-    return true;
-  } catch (error) {
-    console.error("Failed to save email for notification:", error);
-    return false;
-  }
-}
+import { submitCapacityNotification } from "@/lib/analytics/hubspot";
 
 export async function POST(req: NextRequest): Promise<NextResponse> {
   try {
@@ -29,7 +17,7 @@ export async function POST(req: NextRequest): Promise<NextResponse> {
       );
     }
 
-    const success = await saveEmailForNotification(email);
+    const success = await submitCapacityNotification(email);
 
     if (success) {
       return NextResponse.json({ success: true }, { status: 200 });

apps/app/components/welcome/featured/PlayerOverlay.tsx

@@ -92,7 +92,7 @@ export function PlayerOverlay({
 
   const handleCommunityClick = () => {
     track("capacity_community_clicked");
-    window.open("ttps://discord.com/invite/hxyNHeSzCK", "_blank");
+    window.open("https://discord.com/invite/hxyNHeSzCK", "_blank");
   };
 
   if (isLoading) {

apps/app/lib/analytics/hubspot.ts

@@ -62,3 +62,38 @@ export async function submitToHubspot(user: PrivyUser) {
     console.error("Error submitting to HubSpot:", error);
   }
 }
+
+export async function submitCapacityNotification(
+  email: string,
+): Promise<boolean> {
+  try {
+    const fields: HubspotField[] = [
+      { name: "email", value: email },
+      { name: "source", value: "capacity_notification" },
+    ];
+
+    const url = `https://api.hsforms.com/submissions/v3/integration/submit/${HubspotConfig.portalId}/${HubspotConfig.capacityFormId}`;
+
+    const response = await fetch(url, {
+      method: "POST",
+      headers: {
+        "Content-Type": "application/json",
+      },
+      body: JSON.stringify({
+        fields,
+      }),
+    });
+
+    if (!response.ok) {
+      const errorData = await response.json();
+      throw new Error(
+        `Failed to submit to HubSpot: ${errorData.error || response.statusText}`,
+      );
+    }
+
+    return true;
+  } catch (error) {
+    console.error("Error submitting capacity notification to HubSpot:", error);
+    return false;
+  }
+}

apps/app/lib/env.ts

@@ -16,6 +16,7 @@ const IntercomConfig = z.object({
 const HubspotConfig = z.object({
   portalId: z.string().min(1),
   formId: z.string().min(1),
+  capacityFormId: z.string().min(1),
 });
 
 const MixpanelConfig = z.object({
@@ -74,6 +75,7 @@ const envConfig = {
   hubspot: {
     portalId: process.env.NEXT_PUBLIC_HUBSPOT_PORTAL_ID,
     formId: process.env.NEXT_PUBLIC_HUBSPOT_FORM_ID,
+    capacityFormId: process.env.NEXT_PUBLIC_HUBSPOT_FORM_ID_CAPACITY,
   },
 } as const;