Outbound Sales Agent

import { Voice, type CallStatus } from "@clutchcall/sdk/voice";

const v = new Voice({
  baseUrl: "https://engine.clutchcall.dev",
  apiKey:  process.env.CLUTCHCALL_CREDENTIALS!,
  orgId:   "org_abc",
});

// Terminal states: the attempt is over and the slot can be reused.
const TERMINAL = new Set<CallStatus>(["completed", "failed", "no_answer"]);

interface Lead { phone: string; name?: string }
type Outcome = "answered" | "no_answer" | "failed";

interface DialerOpts {
  from: string;
  trunkId: string;
  agent: string;
  callsPerSecond?: number;   // pacing gate  (default 2)
  maxConcurrent?: number;    // live-call ceiling (default 20)
  ringTimeoutSec?: number;   // give up ringing after N s (default 25)
  onOutcome?: (lead: Lead, outcome: Outcome, sid?: string) => void;
}

const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));

async function runCampaign(leads: Lead[], opts: DialerOpts) {
  const cps       = opts.callsPerSecond ?? 2;
  const maxLive   = opts.maxConcurrent ?? 20;
  const minGapMs  = 1000 / cps;

  let inFlight = 0;
  let lastOriginate = 0;

  // Acquire a concurrency slot, respecting the CPS gate before each dial.
  async function acquire() {
    while (inFlight >= maxLive) await sleep(50);
    const wait = lastOriginate + minGapMs - Date.now();
    if (wait > 0) await sleep(wait);
    lastOriginate = Date.now();
    inFlight++;
  }

  const dialing: Promise<void>[] = [];

  for (const lead of leads) {
    await acquire();
    dialing.push(
      dialOne(lead, opts)
        .catch(() => opts.onOutcome?.(lead, "failed"))
        .finally(() => { inFlight--; }),
    );
  }
  await Promise.all(dialing);
}

// Originate one lead with the agent attached, then poll to a terminal state.
async function dialOne(lead: Lead, opts: DialerOpts) {
  const call = await v.calls.originate({
    to:             lead.phone,
    from:           opts.from,
    trunkId:        opts.trunkId,
    agent:          opts.agent,          // attaches on answer
    ringTimeoutSec: opts.ringTimeoutSec ?? 25,
  });

  let answered = false;
  for (;;) {
    const c = await v.calls.get({ sid: call.sid });
    if (c.status === "in_progress") answered = true;  // agent is on the line
    if (TERMINAL.has(c.status)) {
      const outcome: Outcome =
        answered ? "answered" : c.status === "no_answer" ? "no_answer" : "failed";
      opts.onOutcome?.(lead, outcome, call.sid);
      return;
    }
    await sleep(500);
  }
}

// ── run it ────────────────────────────────────────────────────────────────
await runCampaign(
  [
    { phone: "+15551234567", name: "Dana R." },
    { phone: "+15557654321", name: "Sam K." },
    // …up to your whole list
  ],
  {
    from:           "+15558675309",
    trunkId:        "trunk_sales",
    agent:          "outbound-sales",
    callsPerSecond: 5,
    maxConcurrent:  50,
    onOutcome: (lead, outcome, sid) => {
      console.log(`${lead.phone} → ${outcome}`, sid ?? "");
      // persist to your CRM: dispositions, retry queue, sid for the recording
    },
  },
);

// Blind-transfer the live call to a human closer's phone. Same sid continues.
await v.calls.get({ sid })
  .then((call) => call.transfer({ to: "+15550112233" }));

// …or re-attach to a specialist AI agent instead of a human:
await v.calls.get({ sid })
  .then((call) => call.transfer({ agent: "enterprise-closer-bot" }));