Save notes and business cards from a Teams chat to OneDrive

GRAPH = "https://graph.microsoft.com/v1.0"
import csv, io
from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched

CHAT_ID = "your-chat-id"
SCHEMA = {"type": "object", "properties": {"kind": {"type": "string", "enum": ["contact", "note"]}, "name": {"type": "string"},
          "company": {"type": "string"}, "email": {"type": "string"}, "phone": {"type": "string"}, "note": {"type": "string"}}, "required": ["kind"]}

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.connection('microsoft', 'work')}"}
    since = state.get("since") or "2026-01-01T00:00:00Z"
    msgs = [m for m in http.get(f"{GRAPH}/chats/{CHAT_ID}/messages", headers=h, params={"$top": 30}).json()["value"]
            if m["createdDateTime"] > since and m.get("from", {}).get("user") and not m["body"]["content"].startswith("✅")]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    for m in msgs:
        r = ai.generate(m["body"]["content"][:2000], system="Is this a contact or a note? Extract the fields.", json_schema=SCHEMA, max_output_tokens=200).json
        if r["kind"] == "contact":
            line = io.StringIO(); csv.writer(line).writerow([r.get(k, "") for k in ("name", "company", "email", "phone")])
            old = http.get(f"{GRAPH}/me/drive/root:/Notes/contacts.csv:/content", headers=h).text
            http.put(f"{GRAPH}/me/drive/root:/Notes/contacts.csv:/content", headers=h, data=(old + line.getvalue()).encode())
            reply = f"✅ Saved contact {r.get('name')} ({r.get('company', '')})"
        else:
            stamp = datetime.now(timezone.utc).strftime("%Y-%m-%d-%H%M")
            http.put(f"{GRAPH}/me/drive/root:/Notes/{stamp}.txt:/content", headers=h, data=r.get("note", "").encode())
            reply = f"✅ Saved note {stamp}"
        http.post(f"{GRAPH}/chats/{CHAT_ID}/messages", headers=h, json={"body": {"content": reply}})
    state.set("since", max(m["createdDateTime"] for m in msgs))
    return {"saved": len(msgs)}