Reply to new leads on WhatsApp in a matching tone

from clickruntime import on_trigger, credentials, http, ai, report_fetched

TEMPLATES = {"keen": "lead_book_call", "neutral": "lead_intro", "frustrated": "lead_reassure"}
SUPABASE_URL = "https://your-project.supabase.co"
sb = lambda: {"apikey": credentials.secret("SUPABASE_SECRET_KEY"), "Authorization": f"Bearer {credentials.secret('SUPABASE_SECRET_KEY')}"}
WA = "https://graph.facebook.com/v20.0/your-phone-number-id/messages"

def wa_template(to, name, params):
    body = {"messaging_product": "whatsapp", "to": to, "type": "template", "template": {"name": name, "language": {"code": "en"},
            "components": [{"type": "body", "parameters": [{"type": "text", "text": str(p)} for p in params]}]}}
    return http.post(WA, headers={"Authorization": f"Bearer {credentials.secret('WHATSAPP_TOKEN')}"}, json=body).json()

@on_trigger
def run(event):
    leads = http.get(f"{SUPABASE_URL}/rest/v1/leads", headers=sb(),
                     params={"contacted": "is.false", "phone": "not.is.null", "select": "id,name,phone,message", "limit": 20}).json()
    report_fetched(len(leads))
    if not leads:
        return {"summary": "No new leads"}
    for lead in leads:
        tone = ai.generate((lead.get("message") or "")[:1000], system="Reply with one word: keen, neutral or frustrated.",
                           max_output_tokens=5).text.strip().lower()
        template = TEMPLATES.get(tone, "lead_intro")
        wa_template(lead["phone"], template, [lead.get("name") or "there"])
        http.patch(f"{SUPABASE_URL}/rest/v1/leads", headers=sb(), params={"id": f"eq.{lead['id']}"},
                   json={"contacted": True, "template": template})
    return {"contacted": len(leads)}