Resize and watermark new photos

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
import io
from PIL import Image  # declare "pillow" in dependencies
from googleapiclient.http import MediaInMemoryUpload
from clickruntime import on_trigger, report_fetched, credentials, state

SOURCE, TARGET, LOGO = "product-photos-folder-id", "product-photos-web-folder-id", "logo-file-id"

@on_trigger
def run(event):
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    since = state.get("since") or "2026-01-01T00:00:00Z"
    files = drive.files().list(q=f"'{SOURCE}' in parents and mimeType contains 'image/' and createdTime > '{since}'",
                               orderBy="createdTime", fields="files(id,name,createdTime)").execute()["files"]
    report_fetched(len(files))
    if not files:
        return {"summary": "Nothing new"}
    logo = Image.open(io.BytesIO(drive.files().get_media(fileId=LOGO).execute())).convert("RGBA")
    for f in files:
        img = Image.open(io.BytesIO(drive.files().get_media(fileId=f["id"]).execute())).convert("RGB")
        img = img.resize((1600, round(img.height * 1600 / img.width)))
        mark = logo.copy()
        mark.thumbnail((240, 240))
        img.paste(mark, (img.width - mark.width - 32, img.height - mark.height - 32), mark)
        out = io.BytesIO()
        img.save(out, "JPEG", quality=80, optimize=True)
        name = f["name"].rsplit(".", 1)[0] + ".jpg"
        drive.files().create(body={"name": name, "parents": [TARGET]},
                             media_body=MediaInMemoryUpload(out.getvalue(), "image/jpeg")).execute()
    state.set("since", files[-1]["createdTime"])
    return {"processed": len(files)}