Get a weekly email of your team's Salesforce activity

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from collections import Counter
from clickruntime import on_trigger, credentials, http, ai
ME = "me@northwind.example"
API = "https://yourcompany.my.salesforce.com/services/data/v61.0"
def send(subject, body):
    msg = EmailMessage()
    msg["To"], msg["Subject"] = ME, subject
    msg.set_content(body)
    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):
    headers = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    q = lambda s: http.get(f"{API}/query", headers=headers, params={"q": s}).json()["records"]
    tasks = Counter(t["Owner"]["Name"] for t in q("SELECT Owner.Name FROM Task WHERE CreatedDate = LAST_WEEK"))
    events = Counter(e["Owner"]["Name"] for e in q("SELECT Owner.Name FROM Event WHERE CreatedDate = LAST_WEEK"))
    opps = q("SELECT Owner.Name, Amount, IsWon FROM Opportunity WHERE LastModifiedDate = LAST_WEEK")
    lines = []
    for rep in sorted(set(tasks) | set(events) | {o["Owner"]["Name"] for o in opps}):
        mine = [o for o in opps if o["Owner"]["Name"] == rep]
        won = sum(o["Amount"] or 0 for o in mine if o["IsWon"])
        lines.append(f"{rep}: {tasks[rep]} tasks, {events[rep]} meetings, {len(mine)} deals moved, {won:,.0f} won")
    notes = ai.generate("Write two or three short coaching notes for a sales manager from these weekly numbers:\n" + "\n".join(lines), max_output_tokens=300).text
    send("Last week in Salesforce, by rep", "\n".join(lines) + "\n\n" + notes)
    return {"reps": len(lines)}