Get a digest of the best Reddit discussions

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, ai

SUBS, ME = ["datascience", "MachineLearning"], "me@example.com"

def reddit(path, **params):
    headers = {"Authorization": "Bearer " + credentials.connection("reddit", "main"), "User-Agent": "clickruntime/1.0"}
    return [c["data"] for c in http.get(f"https://oauth.reddit.com{path}", headers=headers, params=params).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):
    posts = [p for s in SUBS for p in reddit(f"/r/{s}/top", t="week", limit=25)]
    best = sorted(posts, key=lambda p: p["score"] + 3 * p["num_comments"], reverse=True)[:8]
    listing = "\n\n".join(f"{p['title']} (r/{p['subreddit']}, {p['num_comments']} comments)\n{p['selftext'][:800]}\nhttps://reddit.com{p['permalink']}" for p in best)
    digest = ai.generate(listing, max_output_tokens=1000,
                         system="Write a weekly digest of the 5 best discussions: a bold title, 2-3 sentence summary and link for each.").text
    send_email("Your weekly Reddit digest", digest)
    return {"threads": len(best)}