nntrivi2001
57dc91585d
Internal SmartGift build of a Claude Code monitoring dashboard. Lanes: a durable unit of parallel agent work, one per working directory, tracked across session restarts. Managed lanes are git worktrees the dashboard provisions and can reset or remove behind a three-check destroy guard and a counted preflight; adopted lanes are directories you already own and are never destroyable. Pipelines: a lane moves through pipeline stages. A stage the agent declares with evidence renders green; a stage inferred from the tool-event stream renders dashed amber and never counts as done. Detection is forward-only within a 30-minute window, and never writes the declared stage. Workspace: one page at /run with a lane grid, the selected lane's pipeline, and a full Claude console behind a disclosure.
90 lines
3.7 KiB
JavaScript
90 lines
3.7 KiB
JavaScript
/**
|
|
* @file Express router for analytics endpoints, providing aggregated statistics on token usage, tool usage, daily events/sessions, agent types, and more. It queries the database for various metrics and returns them in a structured JSON format for frontend consumption.
|
|
* @author Nguyễn Ngọc Trí Vĩ <vinnt@smartgift.vn>
|
|
*/
|
|
|
|
const { Router } = require("express");
|
|
const { stmts, db } = require("../db");
|
|
const { parseSources } = require("../lib/source-filter");
|
|
const scoped = require("../lib/scoped-stats");
|
|
|
|
const { calculateCost } = require("./pricing");
|
|
|
|
const router = Router();
|
|
|
|
router.get("/", (req, res) => {
|
|
// Client sends tz_offset (minutes from getTimezoneOffset(), e.g. 420 for PDT)
|
|
// Negate it to get the SQLite modifier: 420 → '-420 minutes'
|
|
const rawOffset = parseInt(req.query.tz_offset, 10);
|
|
const tzModifier = Number.isFinite(rawOffset) ? `${-rawOffset} minutes` : "+0 minutes";
|
|
|
|
// Data-scope: restrict every metric to a subset of source machines when the
|
|
// user has chosen one; otherwise use the cached prepared statements.
|
|
const sources = parseSources(req);
|
|
const tokenTotals = sources ? scoped.tokenTotals(db, sources) : stmts.getTokenTotals.get();
|
|
const toolUsage = sources ? scoped.toolUsageCounts(db, sources) : stmts.toolUsageCounts.all();
|
|
const dailyEvents = sources
|
|
? scoped.dailyEventCounts(db, sources, tzModifier)
|
|
: stmts.dailyEventCounts.all(tzModifier);
|
|
const dailySessions = sources
|
|
? scoped.dailySessionCounts(db, sources, tzModifier)
|
|
: stmts.dailySessionCounts.all(tzModifier);
|
|
const agentTypes = sources
|
|
? scoped.agentTypeDistribution(db, sources)
|
|
: stmts.agentTypeDistribution.all();
|
|
const overview = sources ? scoped.statsOverview(db, sources) : stmts.stats.get();
|
|
const agentsByStatus = sources
|
|
? scoped.agentStatusCounts(db, sources)
|
|
: stmts.agentStatusCounts.all();
|
|
const sessionsByStatus = sources
|
|
? scoped.sessionStatusCounts(db, sources)
|
|
: stmts.sessionStatusCounts.all();
|
|
const totalSubagents = sources
|
|
? scoped.totalSubagentCount(db, sources)
|
|
: stmts.totalSubagentCount.get();
|
|
const eventTypes = sources ? scoped.eventTypeCounts(db, sources) : stmts.eventTypeCounts.all();
|
|
const avgEvents = sources
|
|
? scoped.avgEventsPerSession(db, sources)
|
|
: stmts.avgEventsPerSession.get();
|
|
|
|
// Calculate total cost across all sessions
|
|
const pricingRules = stmts.listPricing.all();
|
|
// Join the owning session's start date so each bucket is priced at the rate
|
|
// effective when it was used (date-effective promo rates, e.g. Sonnet 5 intro).
|
|
const allTokenUsage = sources
|
|
? scoped.scopedTokenUsageWithDate(db, sources)
|
|
: db
|
|
.prepare(
|
|
"SELECT tu.*, DATE(s.started_at) as date FROM token_usage tu JOIN sessions s ON s.id = tu.session_id"
|
|
)
|
|
.all();
|
|
|
|
let totalCost = 0;
|
|
for (const usage of allTokenUsage) {
|
|
const { total_cost } = calculateCost([usage], pricingRules);
|
|
totalCost += total_cost;
|
|
}
|
|
|
|
res.json({
|
|
tokens: {
|
|
total_input: tokenTotals?.total_input ?? 0,
|
|
total_output: tokenTotals?.total_output ?? 0,
|
|
total_cache_read: tokenTotals?.total_cache_read ?? 0,
|
|
total_cache_write: tokenTotals?.total_cache_write ?? 0,
|
|
},
|
|
total_cost: totalCost,
|
|
tool_usage: toolUsage,
|
|
daily_events: dailyEvents,
|
|
daily_sessions: dailySessions,
|
|
agent_types: agentTypes,
|
|
event_types: eventTypes,
|
|
avg_events_per_session: avgEvents?.avg ?? 0,
|
|
total_subagents: totalSubagents?.count ?? 0,
|
|
overview,
|
|
agents_by_status: Object.fromEntries(agentsByStatus.map((r) => [r.status, r.count])),
|
|
sessions_by_status: Object.fromEntries(sessionsByStatus.map((r) => [r.status, r.count])),
|
|
});
|
|
});
|
|
|
|
module.exports = router;
|