Log invoice photos from WhatsApp on HubSpot deals

import base64, json
from datetime import datetime, timezone
from clickruntime import on_event, credentials, http
API = "https://api.hubapi.com/crm/v3/objects"
WA = "https://graph.facebook.com/v21.0"
@on_event
def handle(event):
    msg = (event.json["entry"][0]["changes"][0]["value"].get("messages") or [{}])[0]
    if msg.get("type") != "image":
        return {"skipped": "not an image"}
    wa = {"Authorization": f"Bearer {credentials.secret('WHATSAPP_TOKEN')}"}
    media = http.get(f"{WA}/{msg['image']['id']}", headers=wa).json()
    img = base64.b64encode(http.get(media["url"], headers=wa).content).decode()
    r = http.post("https://api.openai.com/v1/chat/completions", timeout=60, headers={"Authorization": f"Bearer {credentials.secret('OPENAI_API_KEY')}"}, json={
        "model": "gpt-4o-mini", "response_format": {"type": "json_object"}, "messages": [{"role": "user", "content": [
            {"type": "text", "text": "Read this invoice or receipt. Reply as JSON with invoice_number, amount, currency, date (YYYY-MM-DD)."},
            {"type": "image_url", "image_url": {"url": f"data:{media['mime_type']};base64,{img}"}}]}]})
    inv = json.loads(r.json()["choices"][0]["message"]["content"])
    hs = {"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"}
    found = http.post(f"{API}/contacts/search", headers=hs, json={"filterGroups": [{"filters": [
        {"propertyName": "phone", "operator": "EQ", "value": f"+{msg['from']}"}]}]}).json()["results"]
    deals = http.get(f"{API}/contacts/{found[0]['id']}/associations/deals", headers=hs).json()["results"] if found else []
    details = f"invoice {inv.get('invoice_number')}, {inv.get('amount')} {inv.get('currency')} on {inv.get('date')}"
    if deals:
        http.post(f"{API}/notes", headers=hs, json={"properties": {"hs_note_body": f"Payment received on WhatsApp: {details}",
            "hs_timestamp": datetime.now(timezone.utc).isoformat()}, "associations": [{"to": {"id": deals[0]["id"]}, "types": [
                {"associationCategory": "HUBSPOT_DEFINED", "associationTypeId": 214}]}]}).raise_for_status()
    reply = f"Thanks, we've logged {details}." if deals else "Thanks, we've received your document and the team will check it."
    http.post(f"{WA}/123456789012345/messages", headers=wa, json={"messaging_product": "whatsapp", "to": msg["from"], "type": "text", "text": {"body": reply}})
    return {"logged": bool(deals), "invoice": inv.get("invoice_number")}