At-risk onboarding radar

# Ask OnRamp for everything overdue right now (count is in data.pagination.total)
curl -H "Authorization: Bearer YOUR_API_KEY" \
  "https://api.onramp.us/v1/tasks?is_overdue=true&limit=1"

# Post a test line to Slack
curl -X POST -H "Content-Type: application/json" \
  -d '{"text": "OnRamp radar test — hello!"}' \
  "https://hooks.slack.com/services/YOUR/SLACK/WEBHOOK"

import requests

overdue = requests.get(
    "https://api.onramp.us/v1/tasks",
    headers={"Authorization": "Bearer YOUR_API_KEY"},
    params={"is_overdue": "true", "limit": 1},
).json()["data"]["pagination"]["total"]

requests.post(
    "https://hooks.slack.com/services/YOUR/SLACK/WEBHOOK",
    json={"text": f"OnRamp radar test — {overdue} overdue tasks right now"},
)

const HEADERS = { Authorization: "Bearer YOUR_API_KEY" };

const body = await (await fetch(
  "https://api.onramp.us/v1/tasks?is_overdue=true&limit=1",
  { headers: HEADERS },
)).json();

await fetch("https://hooks.slack.com/services/YOUR/SLACK/WEBHOOK", {
  method: "POST",
  headers: { "Content-Type": "application/json" },
  body: JSON.stringify({
    text: `OnRamp radar test — ${body.data.pagination.total} overdue tasks right now`,
  }),
});

import datetime as dt
from collections import defaultdict

import requests

BASE = "https://api.onramp.us/v1"
HEADERS = {"Authorization": "Bearer YOUR_API_KEY"}
SLACK_URL = "https://hooks.slack.com/services/YOUR/SLACK/WEBHOOK"
DUE_SOON_DAYS = 3  # tune to how far ahead your team plans

def pages(path, list_key, **params):
    page = 1
    while page:
        body = requests.get(f"{BASE}{path}", headers=HEADERS,
                            params=dict(params, page=page, limit=100)).json()
        yield from body["data"][list_key]
        page = body["data"]["pagination"]["nextPage"]

# 1. Group overdue tasks by project
overdue = defaultdict(list)
for task in pages("/tasks", "tasks", is_overdue="true"):
    overdue[task["project"]["uuid"]].append(task)

# 2. Projects with deadlines approaching (not yet overdue)
soon_cutoff = (dt.date.today() + dt.timedelta(days=DUE_SOON_DAYS)).isoformat()
due_soon = defaultdict(list)
for task in pages("/tasks", "tasks", due_date_before=soon_cutoff):
    if task["project"]["uuid"] not in overdue and not task.get("is_overdue"):
        due_soon[task["project"]["uuid"]].append(task)

if not overdue and not due_soon:
    raise SystemExit(0)  # nothing at risk — stay silent, protect the signal

# 3. Fetch names + portal links for the flagged projects only
def project(uuid):
    body = requests.get(f"{BASE}/projects/{uuid}", headers=HEADERS).json()
    return body["data"]

lines = [f"🚨 *{len(overdue) + len(due_soon)} onboardings need attention today*"]
for uuid, tasks in sorted(overdue.items(), key=lambda kv: -len(kv[1])):
    p = project(uuid)
    lines.append(
        f"• *{p['name']}* — {len(tasks)} overdue "
        f"({p['completed_percentage']:.0f}% complete) — <{p['internal_project_url']}|Open in OnRamp>"
    )
for uuid, tasks in due_soon.items():
    p = project(uuid)
    lines.append(
        f"• *{p['name']}* — {len(tasks)} due in the next {DUE_SOON_DAYS} days "
        f"— <{p['internal_project_url']}|Open in OnRamp>"
    )

requests.post(SLACK_URL, json={"text": "\n".join(lines)})

const BASE = "https://api.onramp.us/v1";
const HEADERS = { Authorization: "Bearer YOUR_API_KEY" };
const SLACK_URL = "https://hooks.slack.com/services/YOUR/SLACK/WEBHOOK";
const DUE_SOON_DAYS = 3;

const get = async (path, params = {}) => {
  const url = new URL(BASE + path);
  Object.entries(params).forEach(([k, v]) => url.searchParams.set(k, v));
  return (await fetch(url, { headers: HEADERS })).json();
};

async function* pages(path, listKey, params = {}) {
  let page = 1;
  while (page) {
    const { data } = await get(path, { ...params, page, limit: 100 });
    yield* data[listKey];
    page = data.pagination.nextPage;
  }
}

const overdue = new Map();
for await (const t of pages("/tasks", "tasks", { is_overdue: "true" })) {
  const key = t.project.uuid;
  overdue.set(key, [...(overdue.get(key) ?? []), t]);
}

const soonCutoff = new Date(Date.now() + DUE_SOON_DAYS * 864e5)
  .toISOString().slice(0, 10);
const dueSoon = new Map();
for await (const t of pages("/tasks", "tasks", { due_date_before: soonCutoff })) {
  if (!overdue.has(t.project.uuid)) {
    dueSoon.set(t.project.uuid, [...(dueSoon.get(t.project.uuid) ?? []), t]);
  }
}

if (overdue.size + dueSoon.size === 0) process.exit(0); // quiet day — send nothing

const lines = [`🚨 *${overdue.size + dueSoon.size} onboardings need attention today*`];
for (const [uuid, tasks] of [...overdue].sort((a, b) => b[1].length - a[1].length)) {
  const p = (await get(`/projects/${uuid}`)).data;
  lines.push(`• *${p.name}* — ${tasks.length} overdue (${Math.round(p.completed_percentage)}% complete) — <${p.internal_project_url}|Open in OnRamp>`);
}
for (const [uuid, tasks] of dueSoon) {
  const p = (await get(`/projects/${uuid}`)).data;
  lines.push(`• *${p.name}* — ${tasks.length} due in the next ${DUE_SOON_DAYS} days — <${p.internal_project_url}|Open in OnRamp>`);
}

await fetch(SLACK_URL, {
  method: "POST",
  headers: { "Content-Type": "application/json" },
  body: JSON.stringify({ text: lines.join("\n") }),
});

# The digest needs grouping logic, so script it in Python or Node.
# The three API building blocks it uses:

# Every overdue task across all onboardings (grouped by .project in the reply)
curl -H "Authorization: Bearer YOUR_API_KEY" \
  "https://api.onramp.us/v1/tasks?is_overdue=true&limit=100"

# Tasks with deadlines before a date
curl -H "Authorization: Bearer YOUR_API_KEY" \
  "https://api.onramp.us/v1/tasks?due_date_before=2026-08-01&limit=100"

# A project's name, completion %, and links (for the digest lines)
curl -H "Authorization: Bearer YOUR_API_KEY" \
  "https://api.onramp.us/v1/projects/PROJECT_UUID"