Revenue goals, built into systems that run.

// Website form -> HubSpot: upsert the contact, open a deal, link the two.
const HS = 'https://api.hubapi.com';
const headers = {
  Authorization: `Bearer ${process.env.HUBSPOT_TOKEN}`,
  'Content-Type': 'application/json',
};

async function hs(path, body) {
  const res = await fetch(HS + path, { method: 'POST', headers, body: JSON.stringify(body) });
  if (!res.ok) throw new Error(`HubSpot ${res.status}: ${await res.text()}`);
  return res.json();
}

export async function onBrief(form) {
  // upsert by email, so a returning lead never becomes a duplicate
  const { results: [contact] } = await hs('/crm/v3/objects/contacts/batch/upsert', {
    inputs: [{
      idProperty: 'email', id: form.email,
      properties: { email: form.email, firstname: form.name, company: form.company,
                    lifecyclestage: 'lead', utm_campaign: form.utm_campaign },
    }],
  });
  const deal = await hs('/crm/v3/objects/deals', {
    properties: { dealname: `${form.company} · ${form.plan}`, pipeline: 'default',
                  dealstage: 'appointmentscheduled', amount: form.budget },
    associations: [{ to: { id: contact.id },
      types: [{ associationCategory: 'HUBSPOT_DEFINED', associationTypeId: 3 }] }],  // deal -> contact
  });
  return { contactId: contact.id, dealId: deal.id };
}

"""New HubSpot lead -> read their website -> Claude writes the opening line -> back to HubSpot."""
import os, re, requests, anthropic

HS = "https://api.hubapi.com"
H = {"Authorization": f"Bearer {os.environ['HUBSPOT_TOKEN']}"}
claude = anthropic.Anthropic()  # reads ANTHROPIC_API_KEY from the environment

def site_text(url: str) -> str:
    url = url if url.startswith("http") else f"https://{url}"
    page = requests.get(url, timeout=10).text
    return re.sub(r"<[^>]+>", " ", page)[:6000]

def personalise(contact_id: str) -> str:
    c = requests.get(f"{HS}/crm/v3/objects/contacts/{contact_id}", headers=H,
                     params={"properties": "firstname,jobtitle,company,website"}).json()["properties"]
    reply = claude.messages.create(
        model="claude-sonnet-5-5",
        max_tokens=200,
        system="Write one specific opening line for a sales email. No flattery, no cliches, under 30 words.",
        messages=[{"role": "user", "content":
                   f"{c['firstname']}, {c.get('jobtitle')} at {c['company']}.\n"
                   f"Their website says:\n{site_text(c['website'])}"}],
    )
    line = reply.content[0].text.strip()
    requests.patch(f"{HS}/crm/v3/objects/contacts/{contact_id}", headers=H,
                   json={"properties": {"ai_first_line": line}}).raise_for_status()
    return line  # the HubSpot sequence template uses {{ contact.ai_first_line }}