Add new_user hubspot contact creation (#660)

In order to populate our crm (hubspot) with new user sign-up data, we
need to send the data received by our edge function to the hubspot api.

The hubspot api call got tested via postman and works successfully.

The new environment variable is already added to our supabase production
projects edge function secrets.

Author: ben-fornefeld

supabase/functions/new_user/index.ts

@@ -3,16 +3,16 @@ import { serve } from 'https://deno.land/std@0.168.0/http/server.ts'
 // Created via https://slack.com/apps/new/A0F7XDUAZ-incoming-webhooks
 const SLACK_WEBHOOK_URL = Deno.env.get('SLACK_USER_SIGNUP_WEBHOOK_URL')
 if (!SLACK_WEBHOOK_URL) {
-  throw new Error('Missing SLACK_NEW_USER_FEEDBACK_APP_OAUTH_TOKEN environment variable')
+  throw new Error(
+    'Missing SLACK_NEW_USER_FEEDBACK_APP_OAUTH_TOKEN environment variable'
+  )
 }
 const SLACK_CHANNEL = 'user-signups'
 
-
-
 function sendSlackMessage(email: string) {
   const message = `:fire: *New User Signed Up *\n*User*\n${email}\n`
 
-  return fetch(SLACK_WEBHOOK_URL,{
+  return fetch(SLACK_WEBHOOK_URL, {
     method: 'POST',
     headers: {
       'Content-Type': 'application/json',
@@ -25,38 +25,82 @@ function sendSlackMessage(email: string) {
 }
 
 function sendToLoops(body: any) {
-  return fetch(
-    'https://app.loops.so/api/v1/contacts/create',
-    {
-      method: 'POST',
-      headers: {
-        'Content-Type': 'application/json',
-        'Accept': 'application/json',
-        'Authorization': `Bearer ${Deno.env.get('API_KEY_LOOPS')}`,
-      },
-      body: JSON.stringify(body),
+  return fetch('https://app.loops.so/api/v1/contacts/create', {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+      Accept: 'application/json',
+      Authorization: `Bearer ${Deno.env.get('API_KEY_LOOPS')}`,
+    },
+    body: JSON.stringify(body),
+  })
+}
+
+function createHubspotContact(userData: {
+  id: string
+  email: string
+  raw_user_meta_data?: {
+    full_name?: string
+    name?: string
+  }
+}) {
+  const name =
+    userData.raw_user_meta_data?.full_name || userData.raw_user_meta_data?.name
+
+  // Fix for names without spaces - firstName should be the entire name, lastName should be undefined
+  let firstName: string | undefined
+  let lastName: string | undefined
+
+  if (name) {
+    const nameParts = name.split(' ')
+    if (nameParts.length > 1) {
+      firstName = nameParts[0]
+      lastName = nameParts[1]
+    } else {
+      firstName = name // Use the entire name as firstName if no space is found
     }
-  )
+  }
+
+  // Map Supabase user data to HubSpot properties
+  const hubspotContactData = {
+    properties: {
+      db_user_id: userData.id,
+      email: userData.email,
+      firstname: firstName,
+      lastname: lastName,
+    },
+  }
+
+  return fetch('https://api.hubapi.com/crm/v3/objects/contacts', {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+      Accept: 'application/json',
+      Authorization: `Bearer ${Deno.env.get('ACCESS_TOKEN_HUBSPOT')}`,
+    },
+    body: JSON.stringify(hubspotContactData),
+  })
 }
 
 serve(async (req) => {
   /**
    * Creates a new contact in Loops.so on a new created user in users table.
    */
   const data = await req.json()
-  const userEmail = data.record.email
+  const userRecord = data.record
+  const userEmail = userRecord.email
 
   console.log(`New user with email: ${userEmail} created`)
 
   const errors: {
-    service: 'Loops' | 'Slack',
-    message: string,
+    service: 'Loops' | 'Slack' | 'HubSpot'
+    message: string
   }[] = []
 
   // Send to Loops
   const loopsResponse = await sendToLoops({
     email: userEmail,
-    userGroup: 'Authenticated'
+    userGroup: 'Authenticated',
   })
   if (loopsResponse.ok) {
     console.log('Successfully sent email to Loops')
@@ -72,15 +116,34 @@ serve(async (req) => {
   try {
     await sendSlackMessage(userEmail)
     console.log('Successfully sent Slack message')
-  }
-  catch (error) {
+  } catch (error) {
     console.error(`Failed to send Slack message: ${error}`)
     errors.push({
       service: 'Slack',
       message: error.message,
     })
   }
 
+  // Create HubSpot contact
+  try {
+    const hubspotResponse = await createHubspotContact(userRecord)
+    if (hubspotResponse.ok) {
+      console.log('Successfully created HubSpot contact')
+    } else {
+      const errMessage = await hubspotResponse.text()
+      errors.push({
+        service: 'HubSpot',
+        message: errMessage,
+      })
+    }
+  } catch (error) {
+    console.error(`Failed to create HubSpot contact: ${error}`)
+    errors.push({
+      service: 'HubSpot',
+      message: error.message,
+    })
+  }
+
   if (errors.length == 0) {
     return new Response(undefined, { status: 200 })
   } else {