Back up your Supabase storage files to Google Drive every night

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

SUPABASE_URL, BUCKET, FOLDER_ID = "https://yourproject.supabase.co", "uploads", "your-backups-folder-id"

@on_trigger
def run(event):
    key = credentials.secret("SUPABASE_SERVICE_KEY")
    h = {"Authorization": f"Bearer {key}", "apikey": key}
    files = http.post(f"{SUPABASE_URL}/storage/v1/object/list/{BUCKET}", headers=h,
                      json={"prefix": "", "limit": 1000, "sortBy": {"column": "updated_at", "order": "asc"}}).json()
    done = state.get("versions") or {}
    changed = [f for f in files if f.get("id") and done.get(f["name"]) != f["updated_at"]]
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    for f in changed:
        content = http.get(f"{SUPABASE_URL}/storage/v1/object/{BUCKET}/{f['name']}", headers=h).content
        drive.files().create(body={"name": f"{f['updated_at'][:10]} {f['name']}", "parents": [FOLDER_ID]},
                             media_body=MediaInMemoryUpload(content, mimetype=f.get("metadata", {}).get("mimetype", "application/octet-stream"))).execute()
        done[f["name"]] = f["updated_at"]
    state.set("versions", done)
    notify.email_me(f"Supabase backup: {len(changed)} files copied", "\n".join(f["name"] for f in changed) or "No changes tonight.")
    return {"copied": len(changed), "total": len(files)}