Analytics export

export WEAVE_ANALYTICS_KEY=ra_...

curl -sS --compressed \
  -H "Authorization: Bearer $WEAVE_ANALYTICS_KEY" \
  "https://router.workweave.ai/v1/analytics/routing-decisions?since=2026-01-01T00:00:00Z&limit=1000" \
  -D headers.txt -o page.ndjson

import gzip, io, json, os, requests

BASE = "https://router.workweave.ai/v1/analytics/routing-decisions"
headers = {"Authorization": f"Bearer {os.environ['WEAVE_ANALYTICS_KEY']}"}
cursor = load_cursor()  # your own state store; None on the first ever run

while True:
    params = {"limit": 10000}
    params["cursor" if cursor else "since"] = cursor or "2026-01-01T00:00:00Z"

    r = requests.get(BASE, headers=headers, params=params, timeout=120)
    r.raise_for_status()

    rows = [json.loads(line) for line in r.text.splitlines() if line]
    load_into_warehouse(rows)          # MERGE on id — see below

    cursor = r.headers["X-Weave-Next-Cursor"]
    save_cursor(cursor)
    if r.headers["X-Weave-Has-More"] != "true":
        break

MERGE INTO routing_decisions t USING staging s ON t.id = s.id
WHEN NOT MATCHED THEN INSERT ...;

-- Model calls per day (what the router actually did)
SELECT date_trunc('day', recorded_at) AS day, count(*)
FROM routing_decisions GROUP BY 1;

-- User-visible turns per day
SELECT date_trunc('day', recorded_at) AS day, count(*)
FROM routing_decisions WHERE turn_type = 'main_loop' GROUP BY 1;

curl -sS -H "Authorization: Bearer $WEAVE_ANALYTICS_KEY" \
  "https://router.workweave.ai/v1/analytics/schema" | jq .

WITH priced AS (
    SELECT d.actual_input_cost_usd + d.actual_output_cost_usd AS actual_usd,
           (d.input_tokens  / 1e6) * p.input_usd_per_1m
         + (d.output_tokens / 1e6) * p.output_usd_per_1m       AS baseline_usd
    FROM routing_decisions d
    JOIN model_prices p ON p.model = d.requested_model
    WHERE d.recorded_at >= current_date - 30
      AND d.actual_input_cost_usd IS NOT NULL
)
SELECT sum(baseline_usd - actual_usd) AS savings_usd FROM priced;