Log every text on the HubSpot contact’s timeline

curl -X POST "https://usebluebot.com/api/v1/webhooks" \
  -H "Authorization: Bearer $BLUEBOT_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://brightpath.example/bluebot/webhooks",
    "events": [
      "message.received",
      "message.sent",
      "contact.stopped"
    ],
    "description": "Log texts on HubSpot contacts"
  }'

export BLUEBOT_API_KEY="bb_live_…"        # a key with messages:send, for the texts you send in the next step
export BLUEBOT_WEBHOOK_SECRET="whsec_…"
export HUBSPOT_TOKEN="pat-na1-…"

// server.ts: npm install express @usebluebot/sdk
import express from 'express';
import BlueBot, { WebhookVerificationError } from '@usebluebot/sdk';

const bluebot = new BlueBot({ apiKey: process.env.BLUEBOT_API_KEY });
const HUBSPOT = 'https://api.hubapi.com';
const COMMUNICATION_TO_CONTACT = 81; // HubSpot's association type for a communication on a contact

const logged = new Set<string>(); // event ids; use a table in production
const contactByNumber = new Map<string, string>(); // +15555550123 -> HubSpot record ID; use a table in production

async function hubspot(path: string, init: RequestInit = {}) {
  const response = await fetch(`${HUBSPOT}${path}`, {
    ...init,
    headers: { Authorization: `Bearer ${process.env.HUBSPOT_TOKEN}`, 'Content-Type': 'application/json' },
  });
  if (!response.ok) throw new Error(`HubSpot answered ${response.status}: ${await response.text()}`);
  return response.json();
}

async function findContact(number: string): Promise<string | null> {
  const known = contactByNumber.get(number);
  if (known) return known;
  const tenDigits = number.replace(/\D/g, '').slice(-10);
  const values = [number, tenDigits];
  const result = await hubspot('/crm/v3/objects/contacts/search', {
    method: 'POST',
    body: JSON.stringify({
      filterGroups: ['phone', 'mobilephone'].flatMap((propertyName) =>
        values.map((value) => ({ filters: [{ propertyName, operator: 'EQ', value }] })),
      ),
      properties: ['firstname', 'lastname'],
      limit: 2,
    }),
  });
  if (result.total !== 1) return null; // nobody, or two people share the number: don't guess
  contactByNumber.set(number, result.results[0].id);
  return result.results[0].id;
}

function describe(message: { text: string | null; files: { kind: string }[] }) {
  if (message.text) return message.text;
  const kinds = message.files.map((file) => file.kind.replace('_', ' ')).join(', ');
  return kinds ? `(sent ${kinds})` : '(no words)';
}

const app = express();

app.post('/bluebot/webhooks', express.raw({ type: 'application/json' }), async (req, res) => {
  let event;
  try {
    event = bluebot.webhooks.verify(req.body.toString('utf8'), req.headers, process.env.BLUEBOT_WEBHOOK_SECRET!);
  } catch (error) {
    if (error instanceof WebhookVerificationError) return res.status(400).send('Bad signature');
    throw error;
  }
  if (logged.has(event.id)) return res.status(204).end();

  try {
    if (event.type === 'message.sent' || event.type === 'message.received') {
      const message = event.data;
      if (message.chatId) return res.status(204).end(); // a group chat has no one contact
      const incoming = message.direction === 'in';
      const number = (incoming ? message.from : message.to)!;
      if (message.metadata.hubspot_contact_id) contactByNumber.set(number, message.metadata.hubspot_contact_id);

      const contactId = await findContact(number);
      if (contactId) {
        await hubspot('/crm/v3/objects/communications', {
          method: 'POST',
          body: JSON.stringify({
            properties: {
              hs_communication_channel_type: 'SMS',
              hs_communication_logged_from: 'CRM',
              hs_communication_body: `${incoming ? `Text from ${number}` : `Text to ${number}`}: ${describe(message)}`,
              hs_timestamp: incoming ? message.receivedAt : message.sentAt,
            },
            associations: [
              { to: { id: contactId }, types: [{ associationCategory: 'HUBSPOT_DEFINED', associationTypeId: COMMUNICATION_TO_CONTACT }] },
            ],
          }),
        });
      }
    }

    if (event.type === 'contact.stopped') {
      const contactId = await findContact(event.data.handle);
      if (contactId) {
        await hubspot(`/crm/v3/objects/contacts/${contactId}`, {
          method: 'PATCH',
          body: JSON.stringify({ properties: { stopped_texting: 'true' } }),
        });
      }
    }

    logged.add(event.id);
    res.status(204).end();
  } catch (error) {
    console.error('Could not log the text in HubSpot', event.id, error instanceof Error ? error.message : error);
    res.status(500).end(); // BlueBot tries again in a minute, then on a schedule for 3 days
  }
});

app.listen(3000);

curl -X POST "https://usebluebot.com/api/v1/messages" \
  -H "Authorization: Bearer $BLUEBOT_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: hubspot-48213-welcome" \
  -d '{
    "to": "+15555550123",
    "text": "Hi Ana, this is Jordan at Bright Path. Thanks for your note. What’s a good time to talk this week?",
    "metadata": {
      "hubspot_contact_id": "48213"
    }
  }'