Text new Follow Up Boss leads at once and log every text

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

export BLUEBOT_API_KEY="bb_live_…"
export BLUEBOT_WEBHOOK_SECRET="whsec_…"
export FUB_API_KEY="…"
export FUB_SYSTEM="Harbor-Realty-Texts"
export FUB_SYSTEM_KEY="…"

// 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 FUB = 'https://api.followupboss.com/v1';
const handled = new Set<string>(); // event ids; use a table in production
const personByNumber = new Map<string, number>(); // use a table in production

async function fub(path: string, init: RequestInit = {}) {
  const response = await fetch(`${FUB}${path}`, {
    ...init,
    headers: {
      Authorization: `Basic ${Buffer.from(`${process.env.FUB_API_KEY}:`).toString('base64')}`,
      'X-System': process.env.FUB_SYSTEM!,
      'X-System-Key': process.env.FUB_SYSTEM_KEY!,
      'Content-Type': 'application/json',
    },
  });
  if (!response.ok) throw new Error(`Follow Up Boss answered ${response.status}`);
  return response.json();
}

async function findPerson(number: string): Promise<number | null> {
  const known = personByNumber.get(number);
  if (known) return known;
  const tenDigits = number.replace(/\D/g, '').slice(-10);
  const result = await fub(`/people?phone=${tenDigits}&fields=id&limit=2`);
  if (result.people?.length !== 1) return null; // nobody, or two people share it: don't guess
  personByNumber.set(number, result.people[0].id);
  return result.people[0].id;
}

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 (handled.has(event.id)) return res.status(204).end();

  try {
    if ((event.type === 'message.sent' || event.type === 'message.received') && !event.data.chatId) {
      const message = event.data;
      const incoming = message.direction === 'in';
      const theirNumber = (incoming ? message.from : message.to)!;
      if (message.metadata.fub_person_id) personByNumber.set(theirNumber, Number(message.metadata.fub_person_id));
      const personId = await findPerson(theirNumber);
      if (personId) {
        await fub('/textMessages', {
          method: 'POST',
          body: JSON.stringify({
            personId,
            message: message.text ?? `(sent ${message.files.length} file${message.files.length === 1 ? '' : 's'})`,
            toNumber: message.to,
            fromNumber: message.from,
            isIncoming: incoming,
          }),
        });
      }
    }
    if (event.type === 'contact.stopped') {
      const personId = await findPerson(event.data.handle);
      if (personId) {
        await fub('/notes', {
          method: 'POST',
          body: JSON.stringify({ personId, subject: 'Stopped texting', body: 'Texted STOP. BlueBot won’t text them until they text START.' }),
        });
      }
    }
    handled.add(event.id);
    res.status(204).end();
  } catch (error) {
    console.error('Could not log in Follow Up Boss', event.id, error instanceof Error ? error.message : error);
    res.status(500).end(); // BlueBot tries again
  }
});

app.listen(3000);