Get a payment task for every invoice in your inbox

from datetime import date, timedelta
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, report_fetched, credentials, ai

LABEL_ID = "Label_123"  # your "Tasked" label
SCHEMA = {"type": "object", "properties": {k: {"type": "string"} for k in ["is_invoice", "supplier", "amount", "due_date"]}}

@on_trigger
def run(event):
    creds = Credentials(credentials.connection("google", "work"))
    gmail = build("gmail", "v1", credentials=creds, cache_discovery=False).users().messages()
    new = gmail.list(userId="me", q="invoice -label:Tasked newer_than:7d", maxResults=20).execute().get("messages", [])
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    tasks, added = build("tasks", "v1", credentials=creds, cache_discovery=False).tasks(), 0
    for m in new:
        msg = gmail.get(userId="me", id=m["id"], format="metadata", metadataHeaders=["From", "Subject"]).execute()
        info = ai.generate(f"Is this a supplier invoice (yes/no)? Give supplier, amount with currency and due date as "
                           f"YYYY-MM-DD.\n{msg['snippet']}\n{msg['payload']['headers']}", json_schema=SCHEMA,
                           max_output_tokens=120).json
        if info.get("is_invoice") == "yes":
            due = info.get("due_date") or (date.today() + timedelta(days=14)).isoformat()
            tasks.insert(tasklist="@default", body={"title": f"Pay {info['supplier']} {info['amount']}", "due": f"{due}T00:00:00.000Z",
                         "notes": f"https://mail.google.com/mail/u/0/#all/{m['id']}"}).execute()
            added += 1
        gmail.modify(userId="me", id=m["id"], body={"addLabelIds": [LABEL_ID]}).execute()
    return {"checked": len(new), "tasks": added}