Save Telegram group messages to Google Drive daily

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from googleapiclient.http import MediaInMemoryUpload
from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, state

GROUP_ID, FOLDER_ID = -1001234567890, "your-archive-folder-id"

@on_trigger
def run(event):
    update = event.get("json") or {}
    msg = update.get("message")
    if msg:  # webhook: a new group message
        if msg.get("chat", {}).get("id") != GROUP_ID:
            return {"skipped": True}
        who = msg.get("from", {}).get("first_name", "someone")
        when = datetime.fromtimestamp(msg["date"], timezone.utc).strftime("%H:%M")
        text = msg.get("text") or msg.get("caption") or "[" + next((k for k in ("photo", "document", "voice", "sticker") if k in msg), "media") + "]"
        lines = state.get("buffer") or []
        lines.append(f"[{when}] {who}: {text}")
        state.set("buffer", lines)
        return {"buffered": len(lines)}
    lines = state.get("buffer") or []  # schedule: write the day's file
    if not lines:
        return {"saved": 0}
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    name = f"{event.get('scheduled_time', '')[:10]} group chat.txt"
    drive.files().create(body={"name": name, "parents": [FOLDER_ID]},
                         media_body=MediaInMemoryUpload("\n".join(lines).encode(), mimetype="text/plain")).execute()
    state.set("buffer", [])
    return {"saved": len(lines)}