Send lead details to your Telegram bot and save them in HubSpot

from clickruntime import on_event, credentials, http, ai

ALLOWED_CHATS = {123456789}
PORTAL_ID = "1234567"
SCHEMA = {"type": "object", "properties": {k: {"type": "string"} for k in ["name", "email", "phone", "company", "note"]}, "required": ["email"]}

def tg(chat_id, text):
    http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage", json={"chat_id": chat_id, "text": text}).raise_for_status()

@on_event
def handle(event):
    msg = (event.json or {}).get("message") or {}
    chat = msg.get("chat", {}).get("id")
    if chat not in ALLOWED_CHATS or not msg.get("text"):
        return {"ignored": True}
    lead = ai.generate("Extract the lead's contact details from this text:\n" + msg["text"][:1500], json_schema=SCHEMA, max_output_tokens=150).json
    if "@" not in (lead.get("email") or ""):
        tg(chat, "I couldn't find an email address in that. Send it again with one?")
        return {"saved": False}
    props = {"email": lead["email"].lower(), "firstname": lead.get("name", ""), "phone": lead.get("phone", ""), "company": lead.get("company", "")}
    r = http.post("https://api.hubapi.com/crm/v3/objects/contacts/batch/upsert", json={"inputs": [{"idProperty": "email", "id": props["email"], "properties": props}]},
                  headers={"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"})
    r.raise_for_status()
    cid = r.json()["results"][0]["id"]
    tg(chat, f"Saved {props['firstname']} ({props['company']}), {props['email']}\nhttps://app.hubspot.com/contacts/{PORTAL_ID}/record/0-1/{cid}")
    return {"saved": True, "contact": cid}