feat: add users to Hubspot on creation

.vscode/settings.json

@@ -38,6 +38,7 @@
     "EHRC",
     "estree",
     "estruyf",
+    "firstname",
     "fkey",
     "fontsource",
     "Geist",
@@ -64,6 +65,7 @@
     "keyv",
     "langchain",
     "languagedetect",
+    "lastname",
     "Lewandowski",
     "Lexend",
     "likert",

packages/api/src/router/auth.ts

@@ -1,5 +1,6 @@
 import { clerkClient } from "@clerk/nextjs/server";
 import { demoUsers } from "@oakai/core";
+import { createHubspotCustomer } from "@oakai/core/src/analytics/hubspotClient";
 import { posthogServerClient } from "@oakai/core/src/analytics/posthogServerClient";
 import { z } from "zod";
 
@@ -80,6 +81,20 @@ export const authRouter = router({
           },
         });
 
+        const email = updatedUser.emailAddresses[0]?.emailAddress;
+        if (!email) {
+          throw new Error("Email address is expected on clerk user");
+        }
+
+        await createHubspotCustomer({
+          email,
+          firstName: updatedUser.firstName,
+          lastName: updatedUser.lastName,
+          marketingAccepted: Boolean(
+            updatedUser.privateMetadata.acceptedPrivacyPolicy,
+          ),
+        });
+
         const { acceptedPrivacyPolicy, acceptedTermsOfUse } =
           updatedUser.privateMetadata;
 

packages/core/package.json

@@ -36,6 +36,7 @@
     "@googleapis/docs": "^3.0.0",
     "@googleapis/drive": "^8.7.0",
     "@googleapis/slides": "^1.0.5",
+    "@hubspot/api-client": "^11.2.0",
     "@oakai/db": "*",
     "@oakai/logger": "*",
     "@slack/web-api": "^7.3.1",

packages/core/src/analytics/hubspotClient.ts

@@ -0,0 +1,63 @@
+import { Client } from "@hubspot/api-client";
+import { ApiException } from "@hubspot/api-client/lib/codegen/crm/contacts/apis/exception";
+
+const accessToken = process.env.HUBSPOT_ACCESS_TOKEN;
+if (!accessToken) {
+  throw new Error("Missing HUBSPOT_ACCESS_TOKEN");
+}
+
+const hubspotClient = new Client({ accessToken });
+
+interface CreateHubspotCustomerInput {
+  email: string;
+  firstName: string | null;
+  lastName: string | null;
+  marketingAccepted: boolean;
+}
+
+export const createHubspotCustomer = async ({
+  email,
+  firstName,
+  lastName,
+  marketingAccepted,
+}: CreateHubspotCustomerInput) => {
+  let id: string | undefined;
+  try {
+    const result = await hubspotClient.crm.contacts.basicApi.getById(
+      email,
+      undefined,
+      undefined,
+      undefined,
+      undefined,
+      "email",
+    );
+    id = result.id;
+  } catch (e) {
+    const isNotFoundError = e instanceof ApiException && e.code === 404;
+    if (!isNotFoundError) {
+      throw e;
+    }
+  }
+
+  const properties = {
+    email,
+    ...(firstName && {
+      firstname: firstName,
+    }),
+    ...(lastName && {
+      lastname: lastName,
+    }),
+    email_consent_on_ai_account_creation: marketingAccepted ? "true" : "false",
+  };
+
+  if (id) {
+    return await hubspotClient.crm.contacts.basicApi.update(id, {
+      properties,
+    });
+  }
+
+  return await hubspotClient.crm.contacts.basicApi.create({
+    properties,
+    associations: [],
+  });
+};