state-hub/dashboard/src/progress.md

146 lines
4.3 KiB
Markdown
Raw Normal View History

---
title: Progress
---
```js
import {API, POLL} from "./components/config.js";
```
```js
const progState = (async function*() {
while (true) {
let data = [], tokenEvents = [], ok = false;
try {
const [r1, r2] = await Promise.all([
fetch(`${API}/progress/?limit=500`),
fetch(`${API}/token-events/?limit=1000`),
]);
ok = r1.ok;
data = ok ? await r1.json() : [];
tokenEvents = r2.ok ? await r2.json() : [];
} catch {}
yield {data, tokenEvents, ok, ts: new Date()};
await new Promise(res => setTimeout(res, POLL));
}
})();
```
```js
const data = progState.data ?? [];
const tokenEvents = progState.tokenEvents ?? [];
const _ok = progState.ok ?? false;
const _ts = progState.ts;
```
# Progress Log
```js
import {injectTocTop} from "./components/toc-sidebar.js";
import {withDocHelp} from "./components/doc-overlay.js";
const _liveEl = html`<div class="live-indicator">
<span style="color:${_ok ? 'var(--theme-foreground-focus)' : 'red'}"></span>
${_ok
? `Live · updated ${_ts?.toLocaleTimeString()} · ${data.length} events total`
: html`<span style="color:red">Offline — run: <code>make api</code></span>`}
</div>`;
withDocHelp(_liveEl, "/docs/live-data");
injectTocTop("live-indicator", _liveEl);
const _h1 = document.querySelector("#observablehq-main h1");
if (_h1) { _h1.style.position = "relative"; withDocHelp(_h1, "/docs/progress-log"); }
```
## Event Volume (Last 30 Days)
```js
import * as Plot from "npm:@observablehq/plot";
const cutoff = new Date(Date.now() - 30 * 24 * 60 * 60 * 1000);
const byDay = Object.entries(
data
.filter(e => new Date(e.created_at) >= cutoff)
.reduce((acc, e) => {
const day = e.created_at.slice(0, 10);
acc[day] = (acc[day] ?? 0) + 1;
return acc;
}, {})
).sort().map(([day, count]) => ({day, count}));
display(byDay.length === 0
? html`<p style="color:gray">No events in the last 30 days.</p>`
: Plot.plot({
title: "Progress events per day (30-day window)",
x: {label: "Date", tickRotate: -30},
y: {label: "Events", grid: true},
marks: [
Plot.areaY(byDay, {x: "day", y: "count", fill: "steelblue", fillOpacity: 0.3}),
Plot.lineY(byDay, {x: "day", y: "count", stroke: "steelblue"}),
Plot.ruleY([0]),
],
marginBottom: 60,
width: 750,
})
);
```
```js
const tokensByDay = Object.entries(
tokenEvents
.filter(e => new Date(e.created_at) >= cutoff)
.reduce((acc, e) => {
const day = e.created_at.slice(0, 10);
acc[day] = (acc[day] ?? 0) + (e.tokens_in || 0) + (e.tokens_out || 0);
return acc;
}, {})
).sort().map(([day, tokens]) => ({day, tokens}));
display(tokensByDay.length === 0
? html`<p style="color:gray">No token data in the last 30 days.</p>`
: Plot.plot({
title: "Tokens consumed per day (30-day window)",
x: {label: "Date", tickRotate: -30},
y: {label: "Tokens", grid: true, tickFormat: "~s"},
marks: [
Plot.areaY(tokensByDay, {x: "day", y: "tokens", fill: "#f28e2b", fillOpacity: 0.3}),
Plot.lineY(tokensByDay, {x: "day", y: "tokens", stroke: "#f28e2b"}),
Plot.ruleY([0]),
],
marginBottom: 60,
width: 750,
})
);
```
## Event Log
```js
const authorOpts = ["(all)", ...new Set(data.map(e => e.author ?? "unknown"))].sort();
const typeOpts = ["(all)", ...new Set(data.map(e => e.event_type))].sort();
const authorFilter = view(Inputs.select(authorOpts, {label: "Author"}));
const typeFilter = view(Inputs.select(typeOpts, {label: "Event type"}));
const sinceFilter = view(Inputs.date({label: "Since"}));
```
```js
const filtered = data.filter(e =>
(authorFilter === "(all)" || (e.author ?? "unknown") === authorFilter) &&
(typeFilter === "(all)" || e.event_type === typeFilter) &&
(!sinceFilter || new Date(e.created_at) >= sinceFilter)
);
display(html`<p><strong>${filtered.length}</strong> events shown (append-only, no deletions).</p>`);
display(Inputs.table(filtered.map(e => ({
Time: new Date(e.created_at).toLocaleString(),
Type: e.event_type,
Author: e.author ?? "—",
Summary: e.summary,
})), {rows: 50}));
```
<style>
.live-indicator { font-size: 0.8rem; color: gray; position: relative; padding: 0.55rem 1.8rem 0.55rem 0.7rem; margin-bottom: 0.75rem; }
</style>