Reply to new leads by text and email within seconds

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

FROM = "+15005550006"

def sms(to, body):
    return Client(credentials.secret("TWILIO_ACCOUNT_SID"), credentials.secret("TWILIO_AUTH_TOKEN")).messages.create(to=to, from_=FROM, body=body)
gmail = lambda: build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users()

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

@on_event
def handle(event):
    f = event.json or {}
    phone = f.get("phone") or (f.get("From") if f.get("CallStatus") in ("no-answer", "busy") else None)
    email, name = f.get("email"), f.get("name", "there")
    key = f"lead:{phone or email}"
    if not (phone or email) or time.time() - (state.get(key) or 0) < 7 * 86400:
        return {"skipped": True}
    text = f"Hi {name}, thanks for getting in touch with Northwind Electrical. We'll call you shortly."
    if f.get("message"):
        text = ai.generate(f["message"][:800], system=f"Write a 2-sentence friendly reply to {name} from Northwind Electrical.", max_output_tokens=80).text.strip()
    if phone: sms(phone, text)
    if email: send_email(email, "Thanks for getting in touch", text)
    notify.email_me(f"New lead: {name}", f"Phone: {phone}\nEmail: {email}\n{f.get('message', '')}")
    state.set(key, time.time())
    return {"lead": phone or email}