Follow up new leads by email and WhatsApp within minutes

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
import base64, time
from clickruntime import on_event, credentials, http, state, ai

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()
gmail = lambda: build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()

def send_email(to, subject, text):
    raw = base64.urlsafe_b64encode(f"To: {to}\r\nSubject: {subject}\r\n\r\n{text}".encode()).decode()
    gmail().messages().send(userId="me", body={"raw": raw}).execute()

@on_event
def handle(event):
    lead = event.json or {}
    email, name = lead.get("email", ""), lead.get("name", "there")
    if "@" not in email or state.get(f"lead:{email}"):
        return {"skipped": True}
    body = ai.generate(f"Lead {name} wrote: {lead.get('message', '')[:1500]}", max_output_tokens=250,
                       system="Write a friendly 4-sentence reply from a small business owner. Offer a short call. No sign-off.").text
    send_email(email, f"Re: your enquiry, {name}", f"{body.strip()}\n\nBest,\nAlex")
    if lead.get("phone"):
        wa_template(lead["phone"], "lead_intro", [name])
    state.set(f"lead:{email}", {"at": time.time(), "phone": lead.get("phone")})
    return {"lead": email}