Forward Reddit inbox messages and replies to Gmail

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, report_fetched

ME = "me@example.com"

def reddit_unread():
    headers = {"Authorization": "Bearer " + credentials.connection("reddit", "main"), "User-Agent": "clickruntime/1.0"}
    r = http.get("https://oauth.reddit.com/message/unread", headers=headers, params={"limit": 50})
    return [c["data"] for c in r.json()["data"]["children"]]

def send_email(subject, text):
    msg = EmailMessage()
    msg["To"], msg["Subject"] = ME, subject
    msg.set_content(text)
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()

@on_trigger
def run(event):
    seen = state.get("seen") or []
    items = [m for m in reddit_unread() if m["name"] not in seen]
    report_fetched(len(items))
    for m in reversed(items):
        if m.get("was_comment"):
            kind = "mentioned you" if m["subject"] == "username mention" else "replied to you"
            subject = f"Reddit: u/{m['author']} {kind} in r/{m['subreddit']}"
            link = f"https://reddit.com{m['context']}"
        else:
            subject = f"Reddit message from u/{m['author']}: {m['subject']}"
            link = "https://www.reddit.com/message/messages/" + m["id"]
        send_email(subject, f"{m['body']}\n\nOpen it: {link}")
    state.set("seen", (seen + [m["name"] for m in items])[-1000:])
    return {"forwarded": len(items)}