` | `GET /token-events/{id}` |
+
+Further record types (repos, workstreams, tasks) will be added in subsequent workplans.
+
+---
+
## Meta
| Topic | What it covers |
diff --git a/dashboard/src/repos/[slug].md b/dashboard/src/repos/[slug].md
new file mode 100644
index 0000000..3a090d6
--- /dev/null
+++ b/dashboard/src/repos/[slug].md
@@ -0,0 +1,42 @@
+---
+title: Repo
+---
+
+```js
+import {API} from "../components/config.js";
+import {fieldRow} from "../components/field-help.js";
+```
+
+```js
+const repoSlug = observable.params.slug;
+const raw = await fetch(`${API}/repos/${repoSlug}/`)
+ .then(r => r.ok ? r.json() : r.json().then(e => ({error: e.detail ?? `HTTP ${r.status}`})))
+ .catch(e => ({error: String(e)}));
+```
+
+```js
+if (raw.error) {
+ display(html`⚠️ ${raw.error}
`);
+} else {
+ const name = raw.name || raw.slug || repoSlug;
+ display(html`Repo · ${name}
`);
+ display(html`← Repos | ← Token Cost
`);
+
+ const FIELD_ORDER = [
+ "id","slug","name","domain_slug","status","description",
+ "local_path","remote_url","git_fingerprint",
+ "sbom_source","last_sbom_at","last_state_synced_at",
+ "created_at","updated_at",
+ ];
+
+ const rows = FIELD_ORDER.map(k => fieldRow(k, raw[k] ?? null));
+ for (const k of Object.keys(raw)) {
+ if (!FIELD_ORDER.includes(k)) rows.push(fieldRow(k, raw[k]));
+ }
+
+ display(html``);
+}
+```
diff --git a/dashboard/src/tasks/[id].md b/dashboard/src/tasks/[id].md
new file mode 100644
index 0000000..8e7308d
--- /dev/null
+++ b/dashboard/src/tasks/[id].md
@@ -0,0 +1,42 @@
+---
+title: Task
+---
+
+```js
+import {API} from "../components/config.js";
+import {fieldRow} from "../components/field-help.js";
+```
+
+```js
+const taskId = observable.params.id;
+const raw = await fetch(`${API}/tasks/${taskId}`)
+ .then(r => r.ok ? r.json() : r.json().then(e => ({error: e.detail ?? `HTTP ${r.status}`})))
+ .catch(e => ({error: String(e)}));
+```
+
+```js
+if (raw.error) {
+ display(html`⚠️ ${raw.error}
`);
+} else {
+ const name = raw.title || taskId;
+ const shortName = name.length > 60 ? name.slice(0, 60) + "…" : name;
+ display(html`Task · ${shortName}
`);
+ display(html`← Tasks | ← Token Cost
`);
+
+ const FIELD_ORDER = [
+ "id","title","status","priority","assignee",
+ "workstream_id","due_date","needs_human","intervention_note",
+ "created_at","updated_at",
+ ];
+
+ const rows = FIELD_ORDER.map(k => fieldRow(k, raw[k] ?? null));
+ for (const k of Object.keys(raw)) {
+ if (!FIELD_ORDER.includes(k)) rows.push(fieldRow(k, raw[k]));
+ }
+
+ display(html``);
+}
+```
diff --git a/dashboard/src/token-cost.md b/dashboard/src/token-cost.md
index 1ad4b9b..df001a7 100644
--- a/dashboard/src/token-cost.md
+++ b/dashboard/src/token-cost.md
@@ -4,26 +4,37 @@ title: Token Cost
```js
import {API} from "./components/config.js";
+import {refCell} from "./components/ref-cell.js";
const POLL = 60_000;
```
```js
-// Fetch both /by-repo/ and raw events in parallel
+// Fetch token events, by-repo summary, workstreams, and tasks in parallel
const tokenState = (async function*() {
while (true) {
- let byRepo = [], events = [], ok = false;
+ let byRepo = [], events = [], wsMap = {}, taskMap = {}, ok = false;
try {
- const [r1, r2] = await Promise.all([
+ const [r1, r2, r3, r4] = await Promise.all([
fetch(`${API}/token-events/by-repo/`),
fetch(`${API}/token-events/?limit=1000`),
+ fetch(`${API}/workstreams/`),
+ fetch(`${API}/tasks/`),
]);
ok = r1.ok && r2.ok;
if (ok) {
byRepo = await r1.json();
events = await r2.json();
}
+ if (r3.ok) {
+ const wsList = await r3.json();
+ for (const w of wsList) wsMap[w.id] = w;
+ }
+ if (r4.ok) {
+ const taskList = await r4.json();
+ for (const t of taskList) taskMap[t.id] = t;
+ }
} catch {}
- yield {byRepo, events, ok, ts: new Date()};
+ yield {byRepo, events, wsMap, taskMap, ok, ts: new Date()};
await new Promise(res => setTimeout(res, POLL));
}
})();
@@ -58,11 +69,22 @@ function buildSummary(events) {
total_events: events.length,
};
}
+
+function nameCell(name, fullName) {
+ const s = String(name ?? fullName ?? "—");
+ const full = String(fullName ?? name ?? "—");
+ const el = document.createElement("span");
+ el.title = full;
+ el.textContent = s.length > 80 ? s.slice(0, 80) + "…" : s;
+ return el;
+}
```
```js
-const byRepo = tokenState.byRepo ?? [];
-const summary = buildSummary(tokenState.events ?? []);
+const byRepo = tokenState.byRepo ?? [];
+const summary = buildSummary(tokenState.events ?? []);
+const wsMap = tokenState.wsMap ?? {};
+const taskMap = tokenState.taskMap ?? {};
const _ok = tokenState.ok ?? false;
const _ts = tokenState.ts;
```
@@ -99,6 +121,26 @@ if (byRepo.length === 0) {
),
],
}));
+
+ display(Inputs.table(byRepo.map((r, i) => ({...r, _ref: i})), {
+ columns: ["_ref", "repo_slug", "tokens_in", "tokens_out", "tokens_total", "event_count"],
+ header: {
+ _ref: "REF",
+ repo_slug: "Repo",
+ tokens_in: "Tokens In",
+ tokens_out: "Tokens Out",
+ tokens_total: "Total",
+ event_count: "Events",
+ },
+ format: {
+ _ref: (_, i) => refCell(i + 1, "repos", byRepo[i].repo_slug),
+ repo_slug: d => nameCell(d, d),
+ tokens_in: d => d.toLocaleString(),
+ tokens_out: d => d.toLocaleString(),
+ tokens_total: d => d.toLocaleString(),
+ },
+ width: {_ref: 50, repo_slug: 160, tokens_in: 110, tokens_out: 110, tokens_total: 110, event_count: 80},
+ }));
}
```
@@ -109,22 +151,27 @@ const wsRows = summary.by_workstream.slice(0, 20);
if (wsRows.length === 0) {
display(html`No workstream data yet.
`);
} else {
- display(Inputs.table(wsRows, {
- columns: ["scope_id", "tokens_in", "tokens_out", "tokens_total", "event_count"],
+ display(Inputs.table(wsRows.map((r, i) => ({...r, _ref: i})), {
+ columns: ["_ref", "scope_id", "tokens_in", "tokens_out", "tokens_total", "event_count"],
header: {
- scope_id: "Workstream ID",
+ _ref: "REF",
+ scope_id: "Workstream",
tokens_in: "Tokens In",
tokens_out: "Tokens Out",
tokens_total: "Total",
event_count: "Events",
},
format: {
- scope_id: d => d.slice(0,8) + "…",
+ _ref: (_, i) => refCell(i + 1, "workstreams", wsRows[i].scope_id),
+ scope_id: d => {
+ const ws = wsMap[d];
+ return nameCell(ws?.title ?? ws?.slug, d);
+ },
tokens_in: d => d.toLocaleString(),
tokens_out: d => d.toLocaleString(),
tokens_total: d => d.toLocaleString(),
},
- width: {scope_id: 120, tokens_in: 110, tokens_out: 110, tokens_total: 110, event_count: 80},
+ width: {_ref: 50, scope_id: 200, tokens_in: 110, tokens_out: 110, tokens_total: 110, event_count: 80},
}));
}
```
@@ -153,15 +200,20 @@ if (summary.by_model.length === 0) {
if (summary.top_tasks.length === 0) {
display(html`No task-level data yet.
`);
} else {
- display(Inputs.table(summary.top_tasks, {
- columns: ["task_id", "tokens_in", "tokens_out", "tokens_total"],
- header: {task_id: "Task ID", tokens_in: "In", tokens_out: "Out", tokens_total: "Total"},
+ display(Inputs.table(summary.top_tasks.map((r, i) => ({...r, _ref: i})), {
+ columns: ["_ref", "task_id", "tokens_in", "tokens_out", "tokens_total"],
+ header: {_ref: "REF", task_id: "Task", tokens_in: "In", tokens_out: "Out", tokens_total: "Total"},
format: {
- task_id: d => d.slice(0,8) + "…",
+ _ref: (_, i) => refCell(i + 1, "tasks", summary.top_tasks[i].task_id),
+ task_id: d => {
+ const task = taskMap[d];
+ return nameCell(task?.title, d);
+ },
tokens_in: d => d.toLocaleString(),
tokens_out: d => d.toLocaleString(),
tokens_total: d => d.toLocaleString(),
},
+ width: {_ref: 50, task_id: 240},
}));
}
```
diff --git a/dashboard/src/token-events/[id].md b/dashboard/src/token-events/[id].md
new file mode 100644
index 0000000..770d3fd
--- /dev/null
+++ b/dashboard/src/token-events/[id].md
@@ -0,0 +1,42 @@
+---
+title: Token Event
+---
+
+```js
+import {API} from "../components/config.js";
+import {fieldRow} from "../components/field-help.js";
+```
+
+```js
+const eventId = observable.params.id;
+const raw = await fetch(`${API}/token-events/${eventId}`)
+ .then(r => r.ok ? r.json() : r.json().then(e => ({error: e.detail ?? `HTTP ${r.status}`})))
+ .catch(e => ({error: String(e)}));
+```
+
+```js
+if (raw.error) {
+ display(html`⚠️ ${raw.error}
`);
+} else {
+ const shortId = raw.id ? raw.id.slice(0, 8) + "…" : eventId;
+ display(html`Token Event · ${shortId}
`);
+ display(html`← Token Cost
`);
+
+ const FIELD_ORDER = [
+ "id","tokens_in","tokens_out","tokens_total",
+ "note","model","agent","session_id",
+ "task_id","workstream_id","repo_id",
+ "ref_type","ref_id","created_at",
+ ];
+
+ const rows = FIELD_ORDER.map(k => fieldRow(k, raw[k] ?? null));
+ for (const k of Object.keys(raw)) {
+ if (!FIELD_ORDER.includes(k)) rows.push(fieldRow(k, raw[k]));
+ }
+
+ display(html``);
+}
+```
diff --git a/dashboard/src/workstreams/[id].md b/dashboard/src/workstreams/[id].md
new file mode 100644
index 0000000..dbcd46c
--- /dev/null
+++ b/dashboard/src/workstreams/[id].md
@@ -0,0 +1,41 @@
+---
+title: Workstream
+---
+
+```js
+import {API} from "../components/config.js";
+import {fieldRow} from "../components/field-help.js";
+```
+
+```js
+const wsId = observable.params.id;
+const raw = await fetch(`${API}/workstreams/${wsId}`)
+ .then(r => r.ok ? r.json() : r.json().then(e => ({error: e.detail ?? `HTTP ${r.status}`})))
+ .catch(e => ({error: String(e)}));
+```
+
+```js
+if (raw.error) {
+ display(html`⚠️ ${raw.error}
`);
+} else {
+ const name = raw.title || raw.slug || wsId;
+ const shortName = name.length > 60 ? name.slice(0, 60) + "…" : name;
+ display(html`Workstream · ${shortName}
`);
+ display(html`← Workstreams | ← Token Cost
`);
+
+ const FIELD_ORDER = [
+ "id","slug","title","status","topic_id","repo_id","repo_goal_id",
+ "created_at","updated_at",
+ ];
+
+ const rows = FIELD_ORDER.map(k => fieldRow(k, raw[k] ?? null));
+ for (const k of Object.keys(raw)) {
+ if (!FIELD_ORDER.includes(k)) rows.push(fieldRow(k, raw[k]));
+ }
+
+ display(html``);
+}
+```
diff --git a/tests/test_token_events.py b/tests/test_token_events.py
index 1df9da4..324e95e 100644
--- a/tests/test_token_events.py
+++ b/tests/test_token_events.py
@@ -196,3 +196,22 @@ class TestTokenSummary:
s = r.json()
assert s["tokens_total"] == 0
assert s["event_count"] == 0
+
+
+@pytest.mark.asyncio
+class TestTokenEventGetById:
+ async def test_get_by_id(self, client):
+ ev = await _post_event(client, tokens_in=111, tokens_out=222, note="get-by-id-test")
+ r = await client.get(f"/token-events/{ev['id']}")
+ assert r.status_code == 200
+ result = r.json()
+ assert result["id"] == ev["id"]
+ assert result["tokens_in"] == 111
+ assert result["tokens_out"] == 222
+ assert result["tokens_total"] == 333
+ assert result["note"] == "get-by-id-test"
+
+ async def test_get_by_id_not_found(self, client):
+ import uuid
+ r = await client.get(f"/token-events/{uuid.uuid4()}")
+ assert r.status_code == 404