Look up and update Airtable records from a Telegram bot

from clickruntime import on_event, credentials, http, ai
BASE_ID = "appXXXXXXXXXXXXXX"
ALLOWED = {123456789, 987654321}
SCHEMA = {"type": "object", "properties": {"action": {"enum": ["find", "add", "update"]}, "name": {"type": "string"},
          "fields": {"type": "object", "properties": {"Phone": {"type": "string"}, "Team": {"type": "string"},
                     "Start date": {"type": "string"}, "Desk": {"type": "string"}}}}, "required": ["action", "name"]}
@on_event
def handle(event):
    msg = (event.json or {}).get("message") or {}
    chat_id, text = msg.get("chat", {}).get("id"), msg.get("text", "")
    tg = f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage"
    if chat_id not in ALLOWED or not text:
        return {"ignored": True}
    req = ai.generate(text, system="Decide find, add or update for an employee directory. Dates as YYYY-MM-DD.",
                      json_schema=SCHEMA, max_output_tokens=150).json
    api, headers = f"https://api.airtable.com/v0/{BASE_ID}/Employees", {"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"}
    name = req["name"].replace("'", "")
    found = http.get(api, headers=headers, params={"filterByFormula": f"SEARCH(LOWER('{name}'), LOWER({{Name}}))"}).json()["records"]
    if req["action"] == "add":
        http.post(api, headers=headers, json={"typecast": True, "records": [{"fields": {"Name": req["name"], **req.get("fields", {})}}]}).raise_for_status()
        reply = f"Added {req['name']}."
    elif len(found) != 1:
        reply = "No match found." if not found else "Several matches: " + ", ".join(r["fields"].get("Name", "") for r in found[:5])
    elif req["action"] == "update":
        http.patch(api, headers=headers, json={"records": [{"id": found[0]["id"], "fields": req.get("fields", {})}]}).raise_for_status()
        reply = f"Updated {found[0]['fields'].get('Name')}."
    else:
        reply = "\n".join(f"{k}: {v}" for k, v in found[0]["fields"].items())
    http.post(tg, json={"chat_id": chat_id, "text": reply})
    return {"action": req["action"]}