import express from 'express'; import { parser, formatModelName } from '../services/parser.js'; import { enricher } from '../services/enricher.js'; import { cardsService } from '../services/cards.js'; import { bookmarksService } from '../services/bookmarks.js'; import { LeaderboardService } from '../services/leaderboard.js'; import type { ParsedSession, Leaderboard } from '../types/index.js'; const leaderboardService = new LeaderboardService(parser); export function startServer(port = 3847): void { const app = express(); // Enable JSON body parsing app.use(express.json()); // Serve static dashboard app.get('/', (_req, res) => { res.send(getDashboardHTML()); }); // API endpoints app.get('/api/sessions', (req, res) => { const limit = parseInt(req.query.limit as string, 10) || 50; const project = req.query.project as string | undefined; const date = req.query.date as string | undefined; const search = req.query.search as string | undefined; let sessions: ParsedSession[]; if (date) { sessions = parser.getSessionsByDate(date); } else if (project) { sessions = parser.getProjectSessions(project, limit); } else { sessions = parser.getAllSessions(limit); } // Search filter (includes user tags and notes from bookmarks) if (search) { const q = search.toLowerCase(); sessions = sessions.filter(s => { const bookmark = bookmarksService.getBookmark(s.id); const userTags = bookmark?.tags || []; const userNote = bookmark?.note || ''; return s.projectName.toLowerCase().includes(q) || s.summaries.some(sum => sum.toLowerCase().includes(q)) || s.filesWritten.some(f => f.toLowerCase().includes(q)) || s.filesEdited.some(f => f.toLowerCase().includes(q)) || userTags.some(t => t.toLowerCase().includes(q)) || userNote.toLowerCase().includes(q); }); } // Return lightweight session data for list view (exclude toolCalls which can be huge) const formatted = sessions.map(s => { const enrichedData = enricher.getEnrichedData(s.id); const bookmark = bookmarksService.getBookmark(s.id); return { id: s.id, projectPath: s.projectPath, projectName: s.projectName, startedAt: s.startedAt, endedAt: s.endedAt, durationSeconds: s.durationSeconds, model: s.model, messageCount: s.messageCount, toolCallCount: s.toolCallCount, totalTokens: s.totalTokens, estimatedCostUsd: s.estimatedCostUsd, summaries: s.summaries, filesWritten: s.filesWritten?.slice(0, 5), // Limit to first 5 filesEdited: s.filesEdited?.slice(0, 5), // Limit to first 5 errors: s.errors?.slice(0, 3), // Limit to first 3 // Formatted fields modelFormatted: formatModelName(s.model), durationFormatted: formatDuration(s.durationSeconds), costFormatted: `$${s.estimatedCostUsd.toFixed(2)}`, tokensFormatted: formatTokens(s.totalTokens), startedAtFormatted: s.startedAt.toLocaleString(), dateKey: s.startedAt.toISOString().split('T')[0], timeFormatted: s.startedAt.toLocaleTimeString('en-US', { hour: '2-digit', minute: '2-digit' }), enriched: enrichedData, // Bookmark data starred: bookmark?.starred || false, userTags: bookmark?.tags || [], userNote: bookmark?.note || '', }; }); res.json(formatted); }); app.get('/api/sessions/:id', (req, res) => { const session = parser.getSession(req.params.id); if (!session) { res.status(404).json({ error: 'Session not found' }); return; } res.json({ ...session, modelFormatted: formatModelName(session.model), durationFormatted: formatDuration(session.durationSeconds), costFormatted: `$${session.estimatedCostUsd.toFixed(2)}`, tokensFormatted: formatTokens(session.totalTokens), }); }); app.get('/api/sessions/:id/resume', (req, res) => { const context = parser.buildResumeContext(req.params.id); if (!context) { res.status(404).json({ error: 'Session not found' }); return; } res.json({ context }); }); app.get('/api/projects', (_req, res) => { const projects = parser.getProjects(); const projectData = projects.map(p => { const sessions = parser.getProjectSessions(p, 100); return { path: p, name: p.split('/').pop(), sessionCount: sessions.length, totalTokens: sessions.reduce((sum, s) => sum + s.totalTokens, 0), totalCost: sessions.reduce((sum, s) => sum + s.estimatedCostUsd, 0), lastActive: sessions[0]?.startedAt || null, }; }); res.json(projectData); }); app.get('/api/stats', (_req, res) => { const sessions = parser.getAllSessions(500); const stats = calculateStats(sessions); res.json(stats); }); // NEW: Heatmap endpoint app.get('/api/heatmap', (req, res) => { const weeks = parseInt(req.query.weeks as string, 10) || 52; const heatmapData = parser.getHeatmapData(weeks); res.json(heatmapData); }); // NEW: Timeline endpoint app.get('/api/timeline', (req, res) => { const days = parseInt(req.query.days as string, 10) || 30; const timelineData = parser.getTimelineData(days); res.json(timelineData); }); // NEW: Leaderboard endpoint app.get('/api/leaderboard/:type', (req, res) => { const type = req.params.type as Leaderboard['type']; const limit = parseInt(req.query.limit as string, 10) || 10; const leaderboard = parser.getLeaderboard(type, limit); res.json(leaderboard); }); // NEW: Resumable sessions endpoint app.get('/api/resumable', (req, res) => { const limit = parseInt(req.query.limit as string, 10) || 10; const resumable = parser.getResumableSessions(limit); const formatted = resumable.map(s => ({ id: s.id, projectName: s.projectName, projectPath: s.projectPath, startedAt: s.startedAt, durationSeconds: s.durationSeconds, messageCount: s.messageCount, resumeReason: s.resumeReason, resumeScore: s.resumeScore, model: s.model, modelFormatted: formatModelName(s.model), durationFormatted: formatDuration(s.durationSeconds), timeAgo: formatTimeAgo(s.startedAt), })); res.json(formatted); }); // NEW: Daily activity endpoint app.get('/api/activity', (_req, res) => { const dailyActivity = parser.getDailyActivity(); res.json(dailyActivity); }); // NEW: Plans endpoint app.get('/api/plans', (_req, res) => { const plans = parser.getPlanFiles(); res.json(plans.map(p => ({ name: p.name, path: p.path, size: p.size, createdAt: p.createdAt, modifiedAt: p.modifiedAt, preview: p.content.slice(0, 500), }))); }); // NEW: Enrichment endpoints app.get('/api/enrich/stats', (_req, res) => { const stats = enricher.getStats(); res.json({ ...stats, available: enricher.isAvailable() }); }); app.get('/api/enrich/:sessionId', (req, res) => { const enriched = enricher.getEnrichedData(req.params.sessionId); if (!enriched) { res.status(404).json({ error: 'No enriched data found' }); return; } res.json(enriched); }); app.post('/api/enrich/:sessionId', async (req, res) => { try { const enriched = await enricher.enrichSession(req.params.sessionId); if (!enriched) { res.status(400).json({ error: 'Failed to enrich session' }); return; } res.json(enriched); } catch (error) { res.status(500).json({ error: 'Enrichment failed', details: String(error) }); } }); app.get('/api/enriched', (_req, res) => { const all = enricher.getAllEnriched(); res.json(all); }); // Stats Cards API app.get('/api/cards', (req, res) => { const period = (req.query.period as 'week' | 'month' | 'year' | 'all') || 'month'; const cards = cardsService.getAllCards(period); res.json(cards); }); app.get('/api/cards/summary', (req, res) => { const period = (req.query.period as 'week' | 'month' | 'year' | 'all') || 'month'; res.json(cardsService.getSummaryCard(period)); }); app.get('/api/cards/languages', (req, res) => { const period = (req.query.period as 'week' | 'month' | 'year' | 'all') || 'month'; res.json(cardsService.getLanguagesCard(period)); }); app.get('/api/cards/rhythm', (req, res) => { const period = (req.query.period as 'week' | 'month' | 'year' | 'all') || 'month'; res.json(cardsService.getRhythmCard(period)); }); app.get('/api/cards/achievement', (_req, res) => { res.json(cardsService.getAchievementCard()); }); app.get('/api/cards/wrapped', (req, res) => { const period = (req.query.period as 'week' | 'month' | 'year' | 'all') || 'month'; res.json(cardsService.getWrappedCard(period)); }); // Bookmarks API app.get('/api/bookmarks', (_req, res) => { res.json(bookmarksService.getAllBookmarks()); }); app.get('/api/bookmarks/starred', (_req, res) => { res.json(bookmarksService.getStarredSessions()); }); app.get('/api/bookmarks/tags', (_req, res) => { res.json(bookmarksService.getAllTags()); }); app.get('/api/bookmarks/:sessionId', (req, res) => { const bookmark = bookmarksService.getBookmark(req.params.sessionId); res.json(bookmark || { sessionId: req.params.sessionId, starred: false, tags: [], note: '' }); }); app.post('/api/bookmarks/:sessionId/star', (req, res) => { const starred = bookmarksService.toggleStar(req.params.sessionId); res.json({ starred }); }); app.post('/api/bookmarks/:sessionId/tags', (req, res) => { const { tag } = req.body; if (!tag) { res.status(400).json({ error: 'Tag is required' }); return; } const tags = bookmarksService.addTag(req.params.sessionId, tag); res.json({ tags }); }); app.delete('/api/bookmarks/:sessionId/tags/:tag', (req, res) => { const tags = bookmarksService.removeTag(req.params.sessionId, req.params.tag); res.json({ tags }); }); app.post('/api/bookmarks/:sessionId/note', (req, res) => { const { note } = req.body; bookmarksService.setNote(req.params.sessionId, note || ''); res.json({ note: bookmarksService.getNote(req.params.sessionId) }); }); // Global Leaderboard API app.get('/api/global-leaderboard', (req, res) => { const category = (req.query.category as 'tokens' | 'sessions' | 'streak' | 'languages' | 'hours') || 'tokens'; const leaderboard = leaderboardService.getLeaderboard(category); const userStats = leaderboardService.getUserStats(); const submission = leaderboardService.getSubmission(); const achievement = leaderboardService.getAchievementTitle(); res.json({ ...leaderboard, userStats, submission, achievement, percentile: leaderboardService.getPercentile(category) }); }); app.post('/api/global-leaderboard/submit', (req, res) => { const { displayName } = req.body; const submission = leaderboardService.submitStats(displayName || 'anonymous'); res.json({ success: true, submission }); }); app.post('/api/global-leaderboard/remove', (_req, res) => { leaderboardService.removeSubmission(); res.json({ success: true }); }); app.listen(port, () => { console.log(` ๐ŸŒ Dashboard running at http://localhost:${port}`); console.log(); // Pre-warm the session cache in background setImmediate(() => { const start = Date.now(); const sessions = parser.getAllSessions(50); console.log(` โšก Cache warmed: ${sessions.length} sessions loaded in ${Date.now() - start}ms`); }); }); } function calculateStats(sessions: ParsedSession[]) { const today = new Date().toDateString(); let totalTokens = 0; let totalCost = 0; let totalDuration = 0; let sessionsToday = 0; let tokensToday = 0; const modelMap = new Map(); for (const session of sessions) { totalTokens += session.totalTokens; totalCost += session.estimatedCostUsd; totalDuration += session.durationSeconds; if (session.startedAt.toDateString() === today) { sessionsToday++; tokensToday += session.totalTokens; } const model = formatModelName(session.model); const existing = modelMap.get(model) || { sessions: 0, tokens: 0 }; existing.sessions++; existing.tokens += session.totalTokens; modelMap.set(model, existing); } return { totalSessions: sessions.length, totalTokens, totalTokensFormatted: formatTokens(totalTokens), totalCost, totalCostFormatted: `$${totalCost.toFixed(2)}`, totalDuration, totalDurationFormatted: formatDuration(totalDuration), averageSessionDuration: sessions.length > 0 ? totalDuration / sessions.length : 0, averageDurationFormatted: formatDuration(sessions.length > 0 ? totalDuration / sessions.length : 0), sessionsToday, tokensToday, tokensTodayFormatted: formatTokens(tokensToday), modelBreakdown: Array.from(modelMap.entries()) .filter(([m]) => m && m !== 'Unknown') .map(([model, data]) => ({ model, sessions: data.sessions, tokens: data.tokens, tokensFormatted: formatTokens(data.tokens), })) .sort((a, b) => b.tokens - a.tokens), }; } function formatTimeAgo(date: Date): string { const now = new Date(); const diffMs = now.getTime() - date.getTime(); const diffMins = Math.floor(diffMs / 60000); const diffHours = Math.floor(diffMs / 3600000); const diffDays = Math.floor(diffMs / 86400000); if (diffMins < 1) return 'Just now'; if (diffMins < 60) return `${diffMins}m ago`; if (diffHours < 24) return `${diffHours}h ago`; if (diffDays === 1) return 'Yesterday'; if (diffDays < 7) return `${diffDays} days ago`; if (diffDays < 30) return `${Math.floor(diffDays / 7)} weeks ago`; return date.toLocaleDateString(); } function formatDuration(seconds: number): string { if (seconds < 60) return `${Math.round(seconds)}s`; if (seconds < 3600) return `${Math.floor(seconds / 60)}m`; const hours = Math.floor(seconds / 3600); const mins = Math.floor((seconds % 3600) / 60); return `${hours}h ${mins}m`; } function formatTokens(tokens: number): string { if (tokens < 1000) return tokens.toString(); if (tokens < 1000000) return `${(tokens / 1000).toFixed(1)}K`; return `${(tokens / 1000000).toFixed(2)}M`; } function getDashboardHTML(): string { return ` claude-sesh
Loading...
๐Ÿ—“๏ธ Activity (52 weeks)
Less
More
Sun
Mon
Tue
Wed
Thu
Fri
Sat
Click a day to filter sessions

Sessions

Loading...

Session Timeline (Last 90 Days)

Opus
Sonnet
Haiku

Activity Heatmap (52 Weeks)

Sun
Mon
Tue
Wed
Thu
Fri
Sat
Click on a day to see sessions
Less
More

Leaderboards

Loading...
Loading...

Share Your Stats

Generate shareable stats cards like Spotify Wrapped or DEX PnL cards. Click any card to download it as an image.

๐Ÿ” esc
โ†‘โ†“ Navigate โ†ต Select esc Close
`; } export default startServer;