Ask customers for a review by text after each job

import time
from datetime import datetime, timezone
from clickruntime import on_event, on_trigger, credentials, http, state

FROM, REVIEW_LINK, DELAY = "+447700900000", "https://g.page/r/northwind/review", 2 * 3600

@on_event
def job_done(event):
    jobs = state.get("jobs") or []
    jobs.append({"phone": event.json["phone"], "name": event.json["name"], "at": time.time()})
    state.set("jobs", jobs)
    return {"queued": len(jobs)}

@on_trigger
def send_due(event):
    if not 9 <= datetime.now(timezone.utc).hour < 20:
        return {"skipped": "quiet hours"}
    jobs, asked = state.get("jobs") or [], set(state.get("asked") or [])
    sid, pending, sent = credentials.secret("TWILIO_ACCOUNT_SID"), [], 0
    for j in jobs:
        if time.time() - j["at"] < DELAY:
            pending.append(j)
        elif j["phone"] not in asked:
            http.post(f"https://api.twilio.com/2010-04-01/Accounts/{sid}/Messages.json", auth=(sid, credentials.secret("TWILIO_AUTH_TOKEN")),
                      data={"To": j["phone"], "From": FROM, "Body": f"Hi {j['name']}, thanks for choosing Northwind! Would you leave us a quick review? {REVIEW_LINK}"})
            asked.add(j["phone"])
            sent += 1
    state.set("jobs", pending)
    state.set("asked", list(asked))
    return {"sent": sent}