Follow up three times and stop when they reply

// drip.ts
import BlueBot from '@usebluebot/sdk';

const client = new BlueBot({ apiKey: process.env.BLUEBOT_API_KEY });
const DAY = 24 * 60 * 60 * 1000;

const STEPS = [
  { after: 0, text: (name: string) => `Hi ${name}, it’s Tanya Brooks. Thanks for stopping by 412 Oak St today. Anything you’d like to know about it?` },
  { after: 2 * DAY, text: (name: string) => `Hi ${name}, Tanya again. If Oak St wasn’t quite right, I have two similar homes coming up this month. Want the details?` },
  { after: 7 * DAY, text: (name: string) => `Last one from me, ${name}. If you’re still looking, reply here and I’ll send you new listings as they come up.` },
];

export async function startDrip(visitor: { id: string; firstName: string; mobile: string }) {
  const start = Date.now();
  for (const [index, step] of STEPS.entries()) {
    await client.messages.send(
      {
        to: visitor.mobile,
        text: step.text(visitor.firstName),
        // The first goes now; the others are scheduled.
        ...(step.after ? { sendAt: new Date(start + step.after).toISOString() } : {}),
        metadata: { drip: 'open-house-oak', visitor_id: visitor.id, step: String(index + 1) },
      },
      { idempotencyKey: `drip-open-house-oak-${visitor.id}-${index + 1}` },
    );
  }
}

curl -X POST "https://usebluebot.com/api/v1/messages" \
  -H "Authorization: Bearer $BLUEBOT_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: drip-open-house-oak-v_2291-2" \
  -d '{
    "to": "+15555550123",
    "text": "Hi Maria, Tanya again. If Oak St wasn’t quite right, I have two similar homes coming up this month. Want the details?",
    "send_at": "2026-11-15T23:00:00.000Z",
    "metadata": {
      "drip": "open-house-oak",
      "visitor_id": "v_2291",
      "step": "2"
    }
  }'

curl -X POST "https://usebluebot.com/api/v1/webhooks" \
  -H "Authorization: Bearer $BLUEBOT_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://tanyabrookshomes.example/hooks/bluebot",
    "events": [
      "message.received",
      "reaction.added"
    ],
    "description": "Stop drips on reply"
  }'

// app/hooks/bluebot/route.ts (Next.js)
import BlueBot, { WebhookVerificationError } from '@usebluebot/sdk';

const client = new BlueBot({ apiKey: process.env.BLUEBOT_API_KEY });

async function stopDrips(person: string) {
  const page = await client.messages.list({ person, state: 'scheduled', limit: 100 });
  for (const message of page.data) {
    if (!message.metadata.drip) continue; // not part of a drip: leave it
    try {
      await client.messages.cancel(message.id);
    } catch (error) {
      if ((error as { code?: string }).code !== 'conflict') throw error; // it became due and went a moment ago
    }
  }
}

export async function POST(request: Request) {
  const payload = await request.text();
  let event;
  try {
    event = client.webhooks.verify(payload, request.headers, process.env.BLUEBOT_WEBHOOK_SECRET);
  } catch (error) {
    if (error instanceof WebhookVerificationError) return new Response('Bad signature', { status: 400 });
    throw error;
  }

  const fromThem = event.type === 'message.received' || (event.type === 'reaction.added' && event.data.direction === 'in');
  if (fromThem && !event.data.chatId && event.data.from) await stopDrips(event.data.from);
  return new Response(null, { status: 204 });
}

curl "https://usebluebot.com/api/v1/messages?person=%2B15555550123&state=scheduled&limit=100" \
  -H "Authorization: Bearer $BLUEBOT_API_KEY"

curl -X POST "https://usebluebot.com/api/v1/messages/msg_1Hq2LxW9cVbN3mKpRtYs0a/cancel" \
  -H "Authorization: Bearer $BLUEBOT_API_KEY"