Log calls or sales to both Airtable and Notion

from clickruntime import on_event, credentials, http, state

AIRTABLE_URL = "https://api.airtable.com/v0/your-base-id/Records"
DATABASE_ID = "your-database-id"

@on_event
def handle(event):
    if state.get(f"done:{event.event_id}"):
        return {"skipped": "duplicate"}
    data = event.json or {}
    name = data.get("name") or data.get("email") or "New record"
    fields = {"Name": name, "Email": data.get("email", ""), "Product": data.get("product_name", ""),
              "Amount": data.get("price"), "Summary": (data.get("call_summary") or "")[:1900]}
    http.post(AIRTABLE_URL, headers={"Authorization": f"Bearer {credentials.secret('AIRTABLE_TOKEN')}"},
              json={"records": [{"fields": {k: v for k, v in fields.items() if v not in (None, "")}}]}).raise_for_status()
    http.post("https://api.notion.com/v1/pages", headers={"Authorization": f"Bearer {credentials.connection('notion', 'work')}",
              "Notion-Version": "2022-06-28"}, json={"parent": {"database_id": DATABASE_ID}, "properties": {
              "Name": {"title": [{"text": {"content": name}}]},
              "Product": {"rich_text": [{"text": {"content": fields["Product"]}}]}},
              "children": [{"paragraph": {"rich_text": [{"text": {"content": fields["Summary"] or "No summary"}}]}}]}).raise_for_status()
    state.set(f"done:{event.event_id}", True)
    return {"logged": name}