Compare commits

...
Sign in to create a new pull request.

3 commits

Author SHA1 Message Date
Scrum4Me Agent
b2bde6934e feat(ST-d9sl8egw): token-components — CartesianGrid, useRouter click, client-side sort + index.ts
TokenDayChart: CartesianGrid, height 280, DD/MM formatter, var(--color-primary).
SprintTokenHistoryTable: 'use client' + useRouter click naar ?sprint=<id>.
PbiTokenTable: 'use client' + useState/useMemo kostensort.
index.ts barrel export toegevoegd.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-06 03:24:02 +02:00
Scrum4Me Agent
51c8a86be4 feat(ST-d9sl8egw): /insights/tokens pagina — sprint-selector, historiek-tabel, dag-grafiek & PBI-aggregaat
Server Component met data-fetching via getSprintTokenHistory/getDayTokenData/
getPbiTokenAggregates. SprintTokenHistoryTable, TokenDayChart (Recharts LineChart),
PbiTokenTable en TokenSelectors (client, URL-params). Link toegevoegd in
insights/page.tsx.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-06 03:20:53 +02:00
Scrum4Me Agent
d81f18149a feat(ST-d9sl8egw): lib/insights/token-history.ts — sprint-historiek, dag-data & PBI-aggregaat
Drie functies via prisma.$queryRaw: getSprintTokenHistory (per-sprint
aggregaat), getDayTokenData (dag-totalen met guard op lege sprintId),
getPbiTokenAggregates (per-PBI met guard). Tests voor alle drie.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-06 03:17:45 +02:00
9 changed files with 562 additions and 1 deletions

View file

@ -0,0 +1,74 @@
import { describe, it, expect, vi, beforeEach } from 'vitest'
const { mockQueryRaw } = vi.hoisted(() => ({ mockQueryRaw: vi.fn() }))
vi.mock('@/lib/prisma', () => ({
prisma: { $queryRaw: mockQueryRaw },
}))
import {
getSprintTokenHistory,
getDayTokenData,
getPbiTokenAggregates,
} from '@/lib/insights/token-history'
beforeEach(() => {
vi.clearAllMocks()
})
describe('getSprintTokenHistory', () => {
it('returns mapped sprint rows', async () => {
mockQueryRaw.mockResolvedValueOnce([
{ sprint_id: 'sp-1', sprint_goal: 'Goal A', total_tokens: BigInt(5000), total_cost: 0.1, job_count: BigInt(2) },
])
const rows = await getSprintTokenHistory('user-1')
expect(rows).toHaveLength(1)
expect(rows[0].sprintId).toBe('sp-1')
expect(rows[0].totalTokens).toBe(5000)
expect(rows[0].totalCostUsd).toBe(0.1)
expect(rows[0].jobCount).toBe(2)
})
it('returns zero cost when total_cost is null', async () => {
mockQueryRaw.mockResolvedValueOnce([
{ sprint_id: 'sp-2', sprint_goal: 'Goal B', total_tokens: BigInt(0), total_cost: null, job_count: BigInt(0) },
])
const rows = await getSprintTokenHistory('user-1')
expect(rows[0].totalCostUsd).toBe(0)
})
})
describe('getDayTokenData', () => {
it('returns empty array for empty sprintId', async () => {
const rows = await getDayTokenData('user-1', '')
expect(rows).toHaveLength(0)
expect(mockQueryRaw).not.toHaveBeenCalled()
})
it('maps day rows with ISO date string', async () => {
mockQueryRaw.mockResolvedValueOnce([
{ day: new Date('2026-05-01T00:00:00Z'), total_tokens: BigInt(2000), total_cost: 0.05 },
])
const rows = await getDayTokenData('user-1', 'sprint-1')
expect(rows).toHaveLength(1)
expect(rows[0].day).toBe('2026-05-01')
expect(rows[0].totalTokens).toBe(2000)
})
})
describe('getPbiTokenAggregates', () => {
it('returns empty array for empty sprintId', async () => {
const rows = await getPbiTokenAggregates('user-1', '')
expect(rows).toHaveLength(0)
expect(mockQueryRaw).not.toHaveBeenCalled()
})
it('maps pbi rows', async () => {
mockQueryRaw.mockResolvedValueOnce([
{ pbi_id: 'pbi-1', pbi_code: 'M1', pbi_title: 'First PBI', total_tokens: BigInt(3000), total_cost: 0.08 },
])
const rows = await getPbiTokenAggregates('user-1', 'sprint-1')
expect(rows[0].pbiCode).toBe('M1')
expect(rows[0].totalTokens).toBe(3000)
})
})

View file

@ -91,7 +91,12 @@ export default async function InsightsPage({ searchParams }: InsightsPageProps)
return (
<div className="p-6 space-y-8 max-w-6xl mx-auto w-full">
<h1 className="text-2xl font-semibold text-foreground">Insights</h1>
<div className="flex items-center justify-between gap-4">
<h1 className="text-2xl font-semibold text-foreground">Insights</h1>
<a href="/insights/tokens" className="text-primary text-sm underline">
Historisch token-overzicht
</a>
</div>
{/* Sprint Health */}
<section className="space-y-3">

View file

@ -0,0 +1,3 @@
export { TokenDayChart } from './token-day-chart'
export { SprintTokenHistoryTable } from './sprint-token-history-table'
export { PbiTokenTable } from './pbi-token-table'

View file

@ -0,0 +1,56 @@
'use client'
import { useState, useMemo } from 'react'
import type { PbiTokenRow } from '@/lib/insights/token-history'
interface Props {
rows: PbiTokenRow[]
}
export function PbiTokenTable({ rows }: Props) {
const [sortDesc, setSortDesc] = useState(true)
const sorted = useMemo(
() => [...rows].sort((a, b) => sortDesc ? b.totalCostUsd - a.totalCostUsd : a.totalCostUsd - b.totalCostUsd),
[rows, sortDesc],
)
if (rows.length === 0) {
return <p className="text-muted-foreground text-sm">Geen PBI-data voor deze sprint.</p>
}
return (
<div className="overflow-x-auto">
<table className="w-full text-sm">
<thead>
<tr className="border-b border-border bg-muted text-muted-foreground text-xs uppercase tracking-wide">
<th className="py-2 pr-4 text-left font-medium">PBI-code</th>
<th className="py-2 pr-4 text-left font-medium">Titel</th>
<th className="py-2 pr-4 text-right font-medium">Tokens</th>
<th
className="py-2 text-right font-medium cursor-pointer select-none text-primary"
onClick={() => setSortDesc(d => !d)}
>
Kosten (USD) {sortDesc ? '▾' : '▴'}
</th>
</tr>
</thead>
<tbody>
{sorted.map(r => {
const title = r.pbiTitle.length > 60 ? r.pbiTitle.slice(0, 57) + '…' : r.pbiTitle
return (
<tr key={r.pbiId} className="border-b border-border last:border-0">
<td className="py-2 pr-4 text-muted-foreground whitespace-nowrap">{r.pbiCode}</td>
<td className="py-2 pr-4 text-foreground">{title}</td>
<td className="py-2 pr-4 text-right tabular-nums">{r.totalTokens.toLocaleString()}</td>
<td className="py-2 text-right tabular-nums">
{r.totalCostUsd > 0 ? `$${r.totalCostUsd.toFixed(4)}` : '—'}
</td>
</tr>
)
})}
</tbody>
</table>
</div>
)
}

View file

@ -0,0 +1,49 @@
'use client'
import { useRouter } from 'next/navigation'
import type { SprintTokenRow } from '@/lib/insights/token-history'
interface Props {
rows: SprintTokenRow[]
selectedSprintId: string
}
export function SprintTokenHistoryTable({ rows, selectedSprintId }: Props) {
const router = useRouter()
if (rows.length === 0) {
return <p className="text-muted-foreground text-sm">Geen sprint-data met token-registratie.</p>
}
return (
<div className="overflow-x-auto">
<table className="w-full text-sm">
<thead>
<tr className="border-b border-border bg-muted text-muted-foreground text-xs uppercase tracking-wide">
<th className="py-2 pr-4 text-left font-medium">Sprint goal</th>
<th className="py-2 pr-4 text-right font-medium">Tokens</th>
<th className="py-2 pr-4 text-right font-medium">Kosten (USD)</th>
<th className="py-2 text-right font-medium">Aantal jobs</th>
</tr>
</thead>
<tbody>
{rows.map(r => {
const goal = r.sprintGoal.length > 40 ? r.sprintGoal.slice(0, 37) + '…' : r.sprintGoal
return (
<tr
key={r.sprintId}
className={`border-b border-border last:border-0 cursor-pointer hover:bg-muted/40 ${r.sprintId === selectedSprintId ? 'bg-muted/50' : ''}`}
onClick={() => router.push(`/insights/tokens?sprint=${r.sprintId}`)}
>
<td className="py-2 pr-4 text-foreground">{goal}</td>
<td className="py-2 pr-4 text-right tabular-nums">{r.totalTokens.toLocaleString()}</td>
<td className="py-2 pr-4 text-right tabular-nums">${r.totalCostUsd.toFixed(4)}</td>
<td className="py-2 text-right tabular-nums">{r.jobCount}</td>
</tr>
)
})}
</tbody>
</table>
</div>
)
}

View file

@ -0,0 +1,33 @@
'use client'
import { LineChart, Line, XAxis, YAxis, Tooltip, CartesianGrid, ResponsiveContainer } from 'recharts'
import type { DayTokenRow } from '@/lib/insights/token-history'
interface Props {
data: DayTokenRow[]
}
export function TokenDayChart({ data }: Props) {
if (data.length === 0) {
return <p className="text-muted-foreground">Geen dag-data beschikbaar</p>
}
return (
<ResponsiveContainer width="100%" height={280}>
<LineChart data={data}>
<CartesianGrid strokeDasharray="3 3" stroke="var(--border)" />
<XAxis dataKey="day" tick={{ fontSize: 11 }} tickFormatter={v => (v as string).slice(5).replace('-', '/')} />
<YAxis tick={{ fontSize: 11 }} tickFormatter={v => `$${(v as number).toFixed(3)}`} />
<Tooltip formatter={(v: unknown) => [`$${Number(v).toFixed(4)}`, 'Kosten']} />
<Line
type="monotone"
dataKey="totalCostUsd"
stroke="var(--color-primary)"
strokeWidth={2}
dot={false}
name="Kosten (USD)"
/>
</LineChart>
</ResponsiveContainer>
)
}

View file

@ -0,0 +1,81 @@
'use client'
import { useRouter, usePathname, useSearchParams } from 'next/navigation'
import { useTransition } from 'react'
import {
Select,
SelectContent,
SelectItem,
SelectTrigger,
SelectValue,
} from '@/components/ui/select'
interface Sprint {
id: string
sprint_goal: string
}
interface Props {
productList: { id: string; name: string }[]
sprintList: Sprint[]
currentProductId?: string
currentSprintId?: string
}
export function TokenSelectors({ productList, sprintList, currentProductId, currentSprintId }: Props) {
const router = useRouter()
const pathname = usePathname()
const searchParams = useSearchParams()
const [isPending, startTransition] = useTransition()
function setParam(key: string, value: string | null) {
startTransition(() => {
const params = new URLSearchParams(searchParams.toString())
if (value === null || value === '') {
params.delete(key)
} else {
params.set(key, value)
}
router.replace(`${pathname}?${params.toString()}`)
})
}
return (
<div className="flex gap-3 flex-wrap">
{productList.length > 0 && (
<Select
value={currentProductId ?? '__all__'}
onValueChange={v => setParam('product', v === '__all__' ? null : v)}
>
<SelectTrigger className="w-44" disabled={isPending}>
<SelectValue placeholder="Product" />
</SelectTrigger>
<SelectContent>
<SelectItem value="__all__">Alle producten</SelectItem>
{productList.map(p => (
<SelectItem key={p.id} value={p.id}>{p.name}</SelectItem>
))}
</SelectContent>
</Select>
)}
{sprintList.length > 0 && (
<Select
value={currentSprintId ?? ''}
onValueChange={v => setParam('sprint', v)}
>
<SelectTrigger className="w-64" disabled={isPending}>
<SelectValue placeholder="Sprint kiezen" />
</SelectTrigger>
<SelectContent>
{sprintList.map(s => (
<SelectItem key={s.id} value={s.id}>
{s.sprint_goal.length > 50 ? s.sprint_goal.slice(0, 47) + '…' : s.sprint_goal}
</SelectItem>
))}
</SelectContent>
</Select>
)}
</div>
)
}

View file

@ -0,0 +1,84 @@
import { cookies } from 'next/headers'
import { getIronSession } from 'iron-session'
import { SessionData, sessionOptions } from '@/lib/session'
import { prisma } from '@/lib/prisma'
import { productAccessFilter } from '@/lib/product-access'
import { getSprintTokenHistory, getDayTokenData, getPbiTokenAggregates } from '@/lib/insights/token-history'
import { SprintTokenHistoryTable } from './components/sprint-token-history-table'
import { TokenDayChart } from './components/token-day-chart'
import { PbiTokenTable } from './components/pbi-token-table'
import { TokenSelectors } from './components/token-selectors'
interface TokensPageProps {
searchParams: Promise<{ product?: string; sprint?: string }>
}
export default async function TokensPage({ searchParams }: TokensPageProps) {
const session = await getIronSession<SessionData>(await cookies(), sessionOptions)
const userId = session.userId!
const { product: filterProductId, sprint: filterSprintId } = await searchParams
const [sprintHistory, productList, activeSprint, allSprints] = await Promise.all([
getSprintTokenHistory(userId, filterProductId),
prisma.product.findMany({
where: productAccessFilter(userId),
select: { id: true, name: true },
orderBy: { name: 'asc' },
}),
prisma.sprint.findFirst({
where: { status: 'ACTIVE', product: productAccessFilter(userId) },
select: { id: true, sprint_goal: true },
}),
prisma.sprint.findMany({
where: { product: productAccessFilter(userId) },
select: { id: true, sprint_goal: true },
orderBy: { created_at: 'desc' },
take: 20,
}),
])
const selectedSprintId = filterSprintId ?? activeSprint?.id ?? ''
const [dayData, pbiData] = selectedSprintId
? await Promise.all([
getDayTokenData(userId, selectedSprintId),
getPbiTokenAggregates(userId, selectedSprintId),
])
: [[], []]
return (
<div className="p-6 space-y-8 max-w-5xl mx-auto w-full">
<div className="flex items-center justify-between gap-4 flex-wrap">
<h1 className="text-2xl font-semibold text-foreground">Token-gebruik &amp; kosten</h1>
<a href="/insights" className="text-primary text-sm underline">
Terug naar Insights
</a>
</div>
<TokenSelectors
productList={productList}
sprintList={allSprints}
currentProductId={filterProductId}
currentSprintId={selectedSprintId}
/>
{/* Sprint historiek */}
<section className="space-y-3">
<h2 className="text-lg font-medium text-foreground">Sprint-historiek</h2>
<SprintTokenHistoryTable rows={sprintHistory} selectedSprintId={selectedSprintId} />
</section>
{/* Dagelijkse kosten */}
<section className="space-y-3">
<h2 className="text-lg font-medium text-foreground">Dagelijkse kosten</h2>
<TokenDayChart data={dayData} />
</section>
{/* PBI-aggregaat */}
<section className="space-y-3">
<h2 className="text-lg font-medium text-foreground">Per PBI</h2>
<PbiTokenTable rows={pbiData} />
</section>
</div>
)
}

View file

@ -0,0 +1,176 @@
import { prisma } from '@/lib/prisma'
export interface SprintTokenRow {
sprintId: string
sprintGoal: string
totalTokens: number
totalCostUsd: number
jobCount: number
}
export interface DayTokenRow {
day: string
totalTokens: number
totalCostUsd: number
}
export interface PbiTokenRow {
pbiId: string
pbiCode: string
pbiTitle: string
totalTokens: number
totalCostUsd: number
}
type RawSprintRow = {
sprint_id: string
sprint_goal: string
total_tokens: bigint
total_cost: number | null
job_count: bigint
}
type RawDayRow = {
day: Date
total_tokens: bigint
total_cost: number | null
}
type RawPbiRow = {
pbi_id: string
pbi_code: string
pbi_title: string
total_tokens: bigint
total_cost: number | null
}
export async function getSprintTokenHistory(
userId: string,
productId?: string,
limit = 8,
): Promise<SprintTokenRow[]> {
const rows = productId
? await prisma.$queryRaw<RawSprintRow[]>`
SELECT
sp.id AS sprint_id,
sp.sprint_goal,
COALESCE(SUM(cj.input_tokens + cj.output_tokens + cj.cache_read_tokens + cj.cache_write_tokens), 0) AS total_tokens,
SUM(
cj.input_tokens * mp.input_price_per_1m / 1000000.0
+ cj.output_tokens * mp.output_price_per_1m / 1000000.0
+ cj.cache_read_tokens * mp.cache_read_price_per_1m / 1000000.0
+ cj.cache_write_tokens * mp.cache_write_price_per_1m / 1000000.0
) FILTER (WHERE cj.input_tokens IS NOT NULL) AS total_cost,
COUNT(*) FILTER (WHERE cj.input_tokens IS NOT NULL) AS job_count
FROM claude_jobs cj
JOIN tasks t ON cj.task_id = t.id
JOIN stories s ON t.story_id = s.id
JOIN sprints sp ON s.sprint_id = sp.id
LEFT JOIN model_prices mp ON mp.model_id = cj.model_id
WHERE cj.user_id = ${userId}
AND cj.status = 'DONE'
AND cj.product_id = ${productId}
GROUP BY sp.id, sp.sprint_goal
ORDER BY sp.created_at DESC
LIMIT ${limit}
`
: await prisma.$queryRaw<RawSprintRow[]>`
SELECT
sp.id AS sprint_id,
sp.sprint_goal,
COALESCE(SUM(cj.input_tokens + cj.output_tokens + cj.cache_read_tokens + cj.cache_write_tokens), 0) AS total_tokens,
SUM(
cj.input_tokens * mp.input_price_per_1m / 1000000.0
+ cj.output_tokens * mp.output_price_per_1m / 1000000.0
+ cj.cache_read_tokens * mp.cache_read_price_per_1m / 1000000.0
+ cj.cache_write_tokens * mp.cache_write_price_per_1m / 1000000.0
) FILTER (WHERE cj.input_tokens IS NOT NULL) AS total_cost,
COUNT(*) FILTER (WHERE cj.input_tokens IS NOT NULL) AS job_count
FROM claude_jobs cj
JOIN tasks t ON cj.task_id = t.id
JOIN stories s ON t.story_id = s.id
JOIN sprints sp ON s.sprint_id = sp.id
LEFT JOIN model_prices mp ON mp.model_id = cj.model_id
WHERE cj.user_id = ${userId}
AND cj.status = 'DONE'
GROUP BY sp.id, sp.sprint_goal
ORDER BY sp.created_at DESC
LIMIT ${limit}
`
return rows.map(r => ({
sprintId: r.sprint_id,
sprintGoal: r.sprint_goal,
totalTokens: Number(r.total_tokens),
totalCostUsd: Number(r.total_cost ?? 0),
jobCount: Number(r.job_count),
}))
}
export async function getDayTokenData(userId: string, sprintId: string): Promise<DayTokenRow[]> {
if (!sprintId) return []
const rows = await prisma.$queryRaw<RawDayRow[]>`
SELECT
DATE(cj.finished_at) AS day,
COALESCE(SUM(cj.input_tokens + cj.output_tokens + cj.cache_read_tokens + cj.cache_write_tokens), 0) AS total_tokens,
SUM(
cj.input_tokens * mp.input_price_per_1m / 1000000.0
+ cj.output_tokens * mp.output_price_per_1m / 1000000.0
+ cj.cache_read_tokens * mp.cache_read_price_per_1m / 1000000.0
+ cj.cache_write_tokens * mp.cache_write_price_per_1m / 1000000.0
) FILTER (WHERE cj.input_tokens IS NOT NULL) AS total_cost
FROM claude_jobs cj
JOIN tasks t ON cj.task_id = t.id
JOIN stories s ON t.story_id = s.id
LEFT JOIN model_prices mp ON mp.model_id = cj.model_id
WHERE cj.user_id = ${userId}
AND s.sprint_id = ${sprintId}
AND cj.status = 'DONE'
AND cj.finished_at IS NOT NULL
GROUP BY DATE(cj.finished_at)
ORDER BY day ASC
`
return rows.map(r => ({
day: r.day.toISOString().slice(0, 10),
totalTokens: Number(r.total_tokens),
totalCostUsd: Number(r.total_cost ?? 0),
}))
}
export async function getPbiTokenAggregates(userId: string, sprintId: string): Promise<PbiTokenRow[]> {
if (!sprintId) return []
const rows = await prisma.$queryRaw<RawPbiRow[]>`
SELECT
p.id AS pbi_id,
p.code AS pbi_code,
p.title AS pbi_title,
COALESCE(SUM(cj.input_tokens + cj.output_tokens + cj.cache_read_tokens + cj.cache_write_tokens), 0) AS total_tokens,
SUM(
cj.input_tokens * mp.input_price_per_1m / 1000000.0
+ cj.output_tokens * mp.output_price_per_1m / 1000000.0
+ cj.cache_read_tokens * mp.cache_read_price_per_1m / 1000000.0
+ cj.cache_write_tokens * mp.cache_write_price_per_1m / 1000000.0
) FILTER (WHERE cj.input_tokens IS NOT NULL) AS total_cost
FROM claude_jobs cj
JOIN tasks t ON cj.task_id = t.id
JOIN stories s ON t.story_id = s.id
JOIN pbis p ON s.pbi_id = p.id
LEFT JOIN model_prices mp ON mp.model_id = cj.model_id
WHERE cj.user_id = ${userId}
AND s.sprint_id = ${sprintId}
AND cj.status = 'DONE'
GROUP BY p.id, p.code, p.title
ORDER BY total_cost DESC
`
return rows.map(r => ({
pbiId: r.pbi_id,
pbiCode: r.pbi_code,
pbiTitle: r.pbi_title,
totalTokens: Number(r.total_tokens),
totalCostUsd: Number(r.total_cost ?? 0),
}))
}