Outbound Sales

1
const KEY = process.env.GTM_ENGINE_API_KEY!;
2
3
type Server = "admin" | "socials" | "data" | "signals";
4
5
async function call<T>(server: Server, tool: string, body: unknown = {}): Promise<T> {
6
  const res = await fetch(`https://${server}.gtm-engine.sh/api/v0/${tool}`, {
7
    method: "POST",
8
    headers: {
9
      "Authorization": `Bearer ${KEY}`,
10
      "Content-Type": "application/json",
11
    },
12
    body: JSON.stringify(body),
13
  });
14
  if (!res.ok) throw new Error(`${tool}: ${res.status} ${await res.text()}`);
15
  return res.json();
16
}
17
18
async function prospect(domain: string) {
19
  // 1. Qualify with signals
20
  const signals = await call<any>("signals", "detect_signal", {
21
    domain,
22
    techs: ["zendesk.com", "intercom.com"],
23
  });
24
  const fired = signals.signals.filter((s: any) => s.fired);
25
  if (fired.length === 0) {
26
    console.log(`[skip] ${domain} — no signals`);
27
    return;
28
  }
29
30
  // 2. Resolve company URL
31
  await call<any>("socials", "get_linkedin_company_url", { domain });
32
33
  // 3. Find decision-makers
34
  const filter = fired.some((s: any) => s.name.includes("support"))
35
    ? "(VP OR Director OR Head) AND (CX OR Support) NOT intern"
36
    : "(VP OR Director OR Head) AND Sales NOT intern";
37
38
  const { results } = await call<any>("socials", "list_linkedin_company_employees", {
39
    domain,
40
    title_filters: filter,
41
    limit: 5,
42
  });
43
44
  // 4. Verify emails for the top 3
45
  for (const r of results.slice(0, 3)) {
46
    const { email, is_catch_all } = await call<any>("data", "get_email", {
47
      name: r.name,
48
      domain,
49
    });
50
    console.log(`${r.name} → ${email}${is_catch_all ? " (catch-all)" : ""}`);
51
  }
52
}
53
54
await prospect("gymshark.com");