\n PR Sprint Dashboard\n

\n \n Timeline\n \n \n Analytics\n \n \n Deployments\n \n

\n\n

\n {/* Search and Filters */}\n

\n\n {/* Metrics Cards */}\n

Total PRs

{stats.total_prs || 0}

in {dateRange}

Production Deploys

{stats.production_count || 0}

\n {stats.total_prs > 0 ? Math.round((stats.production_count / stats.total_prs) * 100) : 0}% of total\n

Code Changes

\n +{stats.total_additions || 0} -{stats.total_deletions || 0}\n

{stats.total_files_changed || 0} files

Contributors

{stats.unique_authors || 0}

unique authors

\n\n {/* Main Content Area */}\n {view === \"timeline\" && (\n

Recent Pull Requests

\n {summaries.length === 0 ? (\n

No PRs found for this period

\n ) : (\n summaries.map(pr => (\n

\n #{pr.pr_number}: {pr.pr_title}\n

\n by {pr.pr_author} • {formatDate(pr.merged_at)}\n

\n {pr.deployment_status && (\n \n {pr.deployment_status}\n \n )}\n

{pr.summary}

\n {pr.files_changed} files\n +{pr.additions}\n -{pr.deletions}\n {pr.linear_issues && pr.linear_issues.length > 0 && (\n \n {pr.linear_issues.length} Linear issue(s)\n \n )}\n

\n ))\n )}\n

\n )}\n\n {view === \"analytics\" && (\n

Velocity Analytics

\n \n

\n )}\n\n {view === \"deployments\" && (\n

Recent Deployments

\n \n \n \n \n \n \n \n \n \n \n {deployments.map(deploy => (\n \n \n \n \n \n \n ))}\n \n

PR	Environment	Deployed	Author
\n \n \n #{deploy.pr_number}\n \n {deploy.pr_title} \n \n	\n \n {deploy.environment}\n \n	\n {formatDate(deploy.deployed_at)}\n	\n {deploy.pr_author}\n

\n )}\n\n {/* Roll-up Generator */}\n

Generate Custom Roll-up

\n \n \n \n

\n\n \n \n \n );\n \n return new Response(render(dashboard), {\n headers: { \"Content-Type\": \"text/html\" }\n });\n}",[],[172],{"_103":181,"_95":182,"_152":183,"_154":-5,"_155":137,"_156":184,"_158":159,"_105":185,"_99":186,"_161":162,"_163":187,"_165":22,"_166":188,"_167":189,"_98":190},"d31bcf3e-525f-11f0-9aef-f69ea79377d9","main.tsx.backup","a1f0964a-40ff-11f0-a084-76b3cceeab13",8,["D",1750923196559],7,"export default async function(req: Request): Promise {\n // Parse the form data from Slack\n const formData = await req.formData();\n const text = formData.get(\"text\") || \"\";\n const responseUrl = formData.get(\"response_url\");\n const channelId = formData.get(\"channel_id\");\n const userId = formData.get(\"user_id\");\n const userName = formData.get(\"user_name\");\n\n // Environment variables (set these in Val Town)\n const GITHUB_TOKEN = Deno.env.get(\"GITHUB_TOKEN\");\n const GITHUB_REPO = Deno.env.get(\"GITHUB_REPOSITORY\") || \"City-Bureau/documenters\";\n const GITHUB_WORKFLOW_ID = \"sprint-summarizer.yml\";\n\n // Handle help command\n if (!text || text.trim().toLowerCase() === \"help\") {\n return new Response(\n JSON.stringify({\n response_type: \"ephemeral\",\n blocks: [{\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"*Sprint Summary Generator*\\n\\n\"\n + \"Generate AI-powered sprint summaries for any date range.\\n\\n\"\n + \"*Usage:*\\n\"\n + \"• `/sprint-summary last 4 weeks` - Summary for the last 4 weeks\\n\"\n + \"• `/sprint-summary 2024-01-31` - 4 weeks ending on this date\\n\"\n + \"• `/sprint-summary Jan 31 2024` - Same as above (various formats)\\n\"\n + \"• `/sprint-summary 2024-01-01 to 2024-01-31` - Custom date range\\n\"\n + \"• `/sprint-summary January 2024` - Entire month\\n\"\n + \"• `/sprint-summary help` - Show this help message\",\n },\n }],\n }),\n {\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n // Parse the date range\n const dateRange = parseDateRange(text.trim());\n\n if (!dateRange) {\n return new Response(\n JSON.stringify({\n response_type: \"ephemeral\",\n text: `❌ Could not parse date range: \"${text}\"`,\n blocks: [{\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: `❌ *Could not parse date range*\\n\\nYour input: \\`${text}\\`\\n\\n`\n + \"Try one of these formats:\\n\"\n + \"• `last 4 weeks`\\n\"\n + \"• `2024-01-31` (4 weeks ending on this date)\\n\"\n + \"• `2024-01-01 to 2024-01-31`\\n\"\n + \"• `January 2024`\",\n },\n }],\n }),\n {\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n // Trigger the GitHub workflow\n try {\n const response = await fetch(\n `https://api.github.com/repos/${GITHUB_REPO}/actions/workflows/${GITHUB_WORKFLOW_ID}/dispatches`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `token ${GITHUB_TOKEN}`,\n \"Accept\": \"application/vnd.github.v3+json\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n ref: \"main\", // or your default branch\n inputs: {\n start_date: dateRange.start_date,\n end_date: dateRange.end_date,\n slack_channel: channelId,\n },\n }),\n },\n );\n\n if (response.status === 204) {\n // Success! Format the dates nicely\n const start = new Date(dateRange.start_date);\n const end = new Date(dateRange.end_date);\n const dateDisplay = `${formatDate(start)} - ${formatDate(end)}`;\n\n return new Response(\n JSON.stringify({\n response_type: \"in_channel\",\n blocks: [{\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: `✅ *Sprint Summary Requested*\\n\\n`\n + `Generating summary for: *${dateDisplay}*\\n`\n + `Requested by: <@${userId}>\\n\\n`\n + `The summary will be posted here in a few minutes...`,\n },\n }, {\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: `Date range: \\`${dateRange.start_date}\\` to \\`${dateRange.end_date}\\``,\n }],\n }],\n }),\n {\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n } else {\n const error = await response.text();\n throw new Error(`GitHub API returned ${response.status}: ${error}`);\n }\n } catch (error) {\n return new Response(\n JSON.stringify({\n response_type: \"ephemeral\",\n text: `❌ Failed to trigger sprint summary: ${error.message}`,\n }),\n {\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n}\n\n// Helper function to parse date ranges\nfunction parseDateRange(text: string): { start_date: string; end_date: string } | null {\n const lower = text.toLowerCase();\n const today = new Date();\n\n // Handle \"last 4 weeks\" or \"last month\"\n if (lower.includes(\"last 4 weeks\") || lower.includes(\"last month\")) {\n const end = today;\n const start = new Date(today);\n start.setDate(start.getDate() - 28);\n return {\n start_date: formatISODate(start),\n end_date: formatISODate(end),\n };\n }\n\n // Handle explicit date range \"YYYY-MM-DD to YYYY-MM-DD\"\n const rangeMatch = text.match(/(\\d{4}-\\d{2}-\\d{2})\\s+to\\s+(\\d{4}-\\d{2}-\\d{2})/i);\n if (rangeMatch) {\n return {\n start_date: rangeMatch[1],\n end_date: rangeMatch[2],\n };\n }\n\n // Try to parse as a single date (multiple formats)\n const datePatterns = [\n /^\\d{4}-\\d{2}-\\d{2}$/, // 2024-01-31\n /^\\d{1,2}\\/\\d{1,2}\\/\\d{4}$/, // 1/31/2024 or 01/31/2024\n /^\\d{1,2}-\\d{1,2}-\\d{4}$/, // 1-31-2024\n /^(jan|feb|mar|apr|may|jun|jul|aug|sep|oct|nov|dec)\\w*\\s+\\d{1,2},?\\s+\\d{4}$/i, // Jan 31, 2024\n /^\\d{1,2}\\s+(jan|feb|mar|apr|may|jun|jul|aug|sep|oct|nov|dec)\\w*\\s+\\d{4}$/i, // 31 Jan 2024\n ];\n\n // Check if it matches any single date pattern\n let parsedDate = null;\n\n // Try ISO format first\n if (/^\\d{4}-\\d{2}-\\d{2}$/.test(text)) {\n parsedDate = new Date(text + \"T00:00:00Z\");\n } else {\n // Try other formats\n const normalized = text.replace(/,/g, \"\");\n parsedDate = new Date(normalized);\n }\n\n if (parsedDate && !isNaN(parsedDate.getTime())) {\n const start = new Date(parsedDate);\n start.setDate(start.getDate() - 28);\n return {\n start_date: formatISODate(start),\n end_date: formatISODate(parsedDate),\n };\n }\n\n // Try month/year formats (full month)\n const monthYearMatch = text.match(/^(jan|feb|mar|apr|may|jun|jul|aug|sep|oct|nov|dec)\\w*\\s+(\\d{4})$/i);\n if (monthYearMatch) {\n const monthNames = [\"jan\", \"feb\", \"mar\", \"apr\", \"may\", \"jun\", \"jul\", \"aug\", \"sep\", \"oct\", \"nov\", \"dec\"];\n const monthIndex = monthNames.findIndex(m => monthYearMatch[1].toLowerCase().startsWith(m));\n if (monthIndex !== -1) {\n const year = parseInt(monthYearMatch[2]);\n const start = new Date(year, monthIndex, 1);\n const end = new Date(year, monthIndex + 1, 0); // Last day of month\n return {\n start_date: formatISODate(start),\n end_date: formatISODate(end),\n };\n }\n }\n\n // Try YYYY-MM format\n const yearMonthMatch = text.match(/^(\\d{4})-(\\d{2})$/);\n if (yearMonthMatch) {\n const year = parseInt(yearMonthMatch[1]);\n const month = parseInt(yearMonthMatch[2]) - 1; // JavaScript months are 0-indexed\n const start = new Date(year, month, 1);\n const end = new Date(year, month + 1, 0); // Last day of month\n return {\n start_date: formatISODate(start),\n end_date: formatISODate(end),\n };\n }\n\n return null;\n}\n\n// Helper to format date as YYYY-MM-DD\nfunction formatISODate(date: Date): string {\n const year = date.getFullYear();\n const month = String(date.getMonth() + 1).padStart(2, \"0\");\n const day = String(date.getDate()).padStart(2, \"0\");\n return `${year}-${month}-${day}`;\n}\n\n// Helper to format date nicely for display\nfunction formatDate(date: Date): string {\n const months = [\n \"January\",\n \"February\",\n \"March\",\n \"April\",\n \"May\",\n \"June\",\n \"July\",\n \"August\",\n \"September\",\n \"October\",\n \"November\",\n \"December\",\n ];\n return `${months[date.getMonth()]} ${date.getDate()}, ${date.getFullYear()}`;\n}","docs-sprint-summarizer",[],[182],{"_103":192,"_95":193,"_152":194,"_154":-5,"_155":137,"_156":100,"_158":159,"_105":195,"_99":32,"_161":196,"_163":197,"_165":22,"_166":-5,"_167":198,"_98":199},"21d27180-5262-11f0-8067-f69ea79377d9","prAnalytics.http.ts","21d27220-5262-11f0-8067-f69ea79377d9",["D",1750924187524],"http","// Analytics and roll-up generation for PR summaries\n// Provides AI-powered summary generation for custom date ranges\n\nimport { GoogleGenerativeAI } from \"https://esm.sh/@google/generative-ai\";\nimport { \n getSummariesByDateRange,\n getStats,\n getAuthorStats,\n getQuarterlySummaries,\n storeQuarterlySummary,\n formatDate,\n getVelocityData\n} from \"https://val.town/v/pdw/prDatabase\";\n\n// Get Gemini API key from environment\nconst GEMINI_API_KEY = Deno.env.get(\"GEMINI_API_KEY\") || \"\";\n\ninterface RollupRequest {\n startDate: string;\n endDate: string;\n focus?: \"technical\" | \"executive\" | \"stakeholder\";\n format?: \"markdown\" | \"html\" | \"text\";\n}\n\n// Generate AI-powered rollup summary\nasync function generateAISummary(\n summaries: any[],\n stats: any,\n focus: string = \"executive\"\n): Promise {\n if (!GEMINI_API_KEY) {\n return \"AI summary generation unavailable - Gemini API key not configured\";\n }\n\n const genAI = new GoogleGenerativeAI(GEMINI_API_KEY);\n const model = genAI.getGenerativeModel({ model: \"gemini-1.5-flash\" });\n\n // Create context based on focus\n let promptContext = \"\";\n switch (focus) {\n case \"technical\":\n promptContext = \"Create a technical summary focusing on implementation details, code changes, and technical improvements.\";\n break;\n case \"stakeholder\":\n promptContext = \"Create a stakeholder-focused summary emphasizing business value, user benefits, and product improvements.\";\n break;\n default:\n promptContext = \"Create an executive summary highlighting key achievements, metrics, and strategic progress.\";\n }\n\n const prompt = `${promptContext}\n\nBased on these ${summaries.length} pull requests:\n\nStatistics:\n- Total PRs: ${stats.total_prs}\n- Production deployments: ${stats.production_count}\n- Staging deployments: ${stats.staging_count}\n- Code changes: +${stats.total_additions} -${stats.total_deletions} across ${stats.total_files_changed} files\n- Contributors: ${stats.unique_authors}\n\nIndividual PR Summaries:\n${summaries.map(pr => `\nPR #${pr.pr_number}: ${pr.pr_title}\n- Author: ${pr.pr_author}\n- Summary: ${pr.summary}\n- Impact: ${pr.files_changed} files, +${pr.additions} -${pr.deletions}\n`).join('\\n')}\n\nGenerate a concise but comprehensive summary (3-5 paragraphs) that:\n1. Highlights the most significant changes and their impact\n2. Groups related changes into themes\n3. Emphasizes the value delivered\n4. Mentions key contributors\n5. Provides actionable insights\n\nKeep the tone professional and focus on outcomes rather than technical details.`;\n\n try {\n const result = await model.generateContent(prompt);\n const response = await result.response;\n return response.text();\n } catch (error) {\n console.error(\"AI summary generation failed:\", error);\n return \"Failed to generate AI summary. \" + createManualSummary(summaries, stats);\n }\n}\n\n// Fallback manual summary generation\nfunction createManualSummary(summaries: any[], stats: any): string {\n const topAuthors = summaries.reduce((acc, pr) => {\n acc[pr.pr_author] = (acc[pr.pr_author] || 0) + 1;\n return acc;\n }, {} as Record);\n\n const sortedAuthors = Object.entries(topAuthors)\n .sort(([, a], [, b]) => b - a)\n .slice(0, 3)\n .map(([author]) => author);\n\n return `\nDuring this period, the team completed ${stats.total_prs} pull requests, with ${stats.production_count} deployed to production and ${stats.staging_count} to staging.\n\nKey metrics:\n- ${stats.unique_authors} contributors participated\n- ${stats.total_files_changed} files were modified\n- ${stats.total_additions} lines added, ${stats.total_deletions} lines removed\n\nTop contributors: ${sortedAuthors.join(\", \")}\n\nRecent highlights:\n${summaries.slice(0, 5).map(pr => `- ${pr.pr_title}`).join('\\n')}\n `.trim();\n}\n\n// Generate quarterly report\nasync function generateQuarterlyReport(year: number, quarter: number) {\n const summaries = await getQuarterlySummaries(year, quarter);\n const { startDate, endDate } = getQuarterDateRange(year, quarter);\n const stats = await getStats(startDate, endDate);\n const authorStats = await getAuthorStats(startDate, endDate);\n \n const executiveSummary = await generateAISummary(summaries, stats, \"executive\");\n \n const report = {\n year,\n quarter,\n total_prs: stats.total_prs,\n production_count: stats.production_count,\n staging_count: stats.staging_count,\n executive_summary: executiveSummary,\n generated_at: new Date().toISOString(),\n author_breakdown: authorStats,\n key_features: extractKeyFeatures(summaries),\n velocity_trend: calculateVelocityTrend(summaries)\n };\n \n await storeQuarterlySummary(year, quarter, report);\n return report;\n}\n\n// Extract key features from PR titles and summaries\nfunction extractKeyFeatures(summaries: any[]): string[] {\n const features = new Set();\n \n summaries.forEach(pr => {\n // Extract features from PR titles\n if (pr.pr_title.toLowerCase().includes(\"feature\")) {\n features.add(pr.pr_title);\n }\n // Look for Linear issues with feature tags\n if (pr.linear_issues?.length > 0) {\n pr.linear_issues.forEach((issue: any) => {\n if (issue.labels?.some((label: string) => label.toLowerCase().includes(\"feature\"))) {\n features.add(issue.title || pr.pr_title);\n }\n });\n }\n });\n \n return Array.from(features).slice(0, 10);\n}\n\n// Calculate velocity trend\nfunction calculateVelocityTrend(summaries: any[]) {\n // Group by week\n const weeklyData = summaries.reduce((acc, pr) => {\n const week = getWeekNumber(new Date(pr.merged_at));\n acc[week] = (acc[week] || 0) + 1;\n return acc;\n }, {} as Record);\n \n const weeks = Object.keys(weeklyData).sort();\n if (weeks.length < 2) return \"stable\";\n \n const firstHalf = weeks.slice(0, Math.floor(weeks.length / 2));\n const secondHalf = weeks.slice(Math.floor(weeks.length / 2));\n \n const firstAvg = firstHalf.reduce((sum, week) => sum + weeklyData[week], 0) / firstHalf.length;\n const secondAvg = secondHalf.reduce((sum, week) => sum + weeklyData[week], 0) / secondHalf.length;\n \n const change = ((secondAvg - firstAvg) / firstAvg) * 100;\n \n if (change > 20) return \"increasing\";\n if (change < -20) return \"decreasing\";\n return \"stable\";\n}\n\n// Helper function to get ISO week number\nfunction getWeekNumber(date: Date): string {\n const d = new Date(Date.UTC(date.getFullYear(), date.getMonth(), date.getDate()));\n const dayNum = d.getUTCDay() || 7;\n d.setUTCDate(d.getUTCDate() + 4 - dayNum);\n const yearStart = new Date(Date.UTC(d.getUTCFullYear(), 0, 1));\n const weekNo = Math.ceil((((d.getTime() - yearStart.getTime()) / 86400000) + 1) / 7);\n return `${d.getUTCFullYear()}-W${weekNo.toString().padStart(2, '0')}`;\n}\n\n// Helper to get quarter date range\nfunction getQuarterDateRange(year: number, quarter: number) {\n const startMonth = (quarter - 1) * 3;\n const endMonth = startMonth + 2;\n \n const startDate = new Date(year, startMonth, 1);\n const endDate = new Date(year, endMonth + 1, 0, 23, 59, 59, 999);\n \n return {\n startDate: startDate.toISOString(),\n endDate: endDate.toISOString()\n };\n}\n\n// Main HTTP handler for analytics API\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.split(\"/\").pop();\n \n // Add CORS headers for all responses\n const headers = {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\"\n };\n \n // Handle preflight requests\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 200, headers });\n }\n \n try {\n switch (path) {\n case \"rollup\": {\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405, headers });\n }\n \n // Generate custom rollup\n const body = await req.json() as RollupRequest;\n const summaries = await getSummariesByDateRange(body.startDate, body.endDate);\n const stats = await getStats(body.startDate, body.endDate);\n const summary = await generateAISummary(summaries, stats, body.focus);\n \n const response = {\n summary,\n stats,\n period: {\n start: body.startDate,\n end: body.endDate\n },\n pr_count: summaries.length\n };\n \n return new Response(JSON.stringify(response), { headers });\n }\n \n case \"quarterly\": {\n if (req.method !== \"GET\") {\n return new Response(\"Method not allowed\", { status: 405, headers });\n }\n \n // Generate quarterly report\n const year = parseInt(url.searchParams.get(\"year\") || new Date().getFullYear().toString());\n const quarter = parseInt(url.searchParams.get(\"quarter\") || Math.ceil((new Date().getMonth() + 1) / 3).toString());\n \n const report = await generateQuarterlyReport(year, quarter);\n \n return new Response(JSON.stringify(report), { headers });\n }\n \n case \"velocity\": {\n if (req.method !== \"GET\") {\n return new Response(\"Method not allowed\", { status: 405, headers });\n }\n \n // Get velocity metrics\n const weeks = parseInt(url.searchParams.get(\"weeks\") || \"12\");\n const velocityData = await getVelocityData(weeks);\n \n return new Response(JSON.stringify({ velocityData, weeks }), { headers });\n }\n \n case \"authors\": {\n if (req.method !== \"GET\") {\n return new Response(\"Method not allowed\", { status: 405, headers });\n }\n \n // Get author statistics\n const days = parseInt(url.searchParams.get(\"days\") || \"30\");\n const endDate = new Date();\n const startDate = new Date();\n startDate.setDate(startDate.getDate() - days);\n \n const authorStats = await getAuthorStats(\n startDate.toISOString(),\n endDate.toISOString()\n );\n \n return new Response(JSON.stringify({ authorStats, period: days }), { headers });\n }\n \n default:\n return new Response(\n JSON.stringify({ \n error: \"Analytics endpoint not found\",\n available_endpoints: [\"/rollup\", \"/quarterly\", \"/velocity\", \"/authors\"]\n }), \n { status: 404, headers }\n );\n }\n } catch (error) {\n console.error(\"Analytics error:\", error);\n return new Response(\n JSON.stringify({ \n error: \"Analytics generation failed\",\n message: error instanceof Error ? error.message : \"Unknown error\"\n }),\n { \n status: 500,\n headers\n }\n );\n }\n}\n\n// Export utility functions for use in other vals\nexport { generateAISummary, generateQuarterlyReport, getQuarterDateRange };",[],[193],{"_103":201,"_95":202,"_152":203,"_154":-5,"_155":137,"_156":204,"_158":22,"_105":205,"_99":32,"_161":176,"_163":206,"_165":22,"_166":-5,"_167":207,"_98":208},"21c69054-5262-11f0-adf7-f69ea79377d9","prDatabase.ts","21c691a8-5262-11f0-adf7-f69ea79377d9",12,["D",1750924187494],"// Database utilities for PR summaries\n// Shared functions for querying and managing PR data\n\nimport { sqlite } from \"https://esm.sh/@valtown/sqlite\";\n\nexport interface PRSummary {\n id: number;\n pr_number: number;\n pr_title: string;\n pr_author: string;\n summary: string;\n email_subject?: string;\n merged_at: string;\n deployment_status?: string;\n linear_issues?: any[];\n files_changed: number;\n additions: number;\n deletions: number;\n branch_from: string;\n branch_to: string;\n action_run_url?: string;\n commit_sha?: string;\n created_at: string;\n}\n\nexport interface Deployment {\n id: number;\n pr_number: number;\n environment: string;\n deployed_at: string;\n commit_sha?: string;\n action_run_url?: string;\n}\n\nexport interface QuarterlySummary {\n year: number;\n quarter: number;\n total_prs: number;\n production_count: number;\n staging_count: number;\n executive_summary?: string;\n generated_at: string;\n}\n\n// Get recent PR summaries\nexport async function getRecentSummaries(limit: number = 10): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM pr_summaries \n ORDER BY created_at DESC \n LIMIT ?\n `,\n args: [limit]\n });\n \n return result.rows.map(row => ({\n ...row,\n linear_issues: row.linear_issues ? JSON.parse(row.linear_issues) : []\n })) as PRSummary[];\n}\n\n// Get summaries by date range\nexport async function getSummariesByDateRange(\n startDate: string, \n endDate: string\n): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM pr_summaries \n WHERE merged_at >= ? AND merged_at <= ?\n ORDER BY merged_at DESC\n `,\n args: [startDate, endDate]\n });\n \n return result.rows.map(row => ({\n ...row,\n linear_issues: row.linear_issues ? JSON.parse(row.linear_issues) : []\n })) as PRSummary[];\n}\n\n// Get summaries by deployment status\nexport async function getSummariesByStatus(status: string): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM pr_summaries \n WHERE deployment_status = ?\n ORDER BY merged_at DESC\n `,\n args: [status]\n });\n \n return result.rows.map(row => ({\n ...row,\n linear_issues: row.linear_issues ? JSON.parse(row.linear_issues) : []\n })) as PRSummary[];\n}\n\n// Search summaries by text\nexport async function searchSummaries(query: string): Promise {\n const searchTerm = `%${query}%`;\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM pr_summaries \n WHERE pr_title LIKE ? OR summary LIKE ? OR pr_author LIKE ?\n ORDER BY merged_at DESC\n `,\n args: [searchTerm, searchTerm, searchTerm]\n });\n \n return result.rows.map(row => ({\n ...row,\n linear_issues: row.linear_issues ? JSON.parse(row.linear_issues) : []\n })) as PRSummary[];\n}\n\n// Get deployment history\nexport async function getDeploymentHistory(limit: number = 50): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT d.*, p.pr_title, p.pr_author\n FROM deployments d\n JOIN pr_summaries p ON d.pr_number = p.pr_number\n ORDER BY d.deployed_at DESC\n LIMIT ?\n `,\n args: [limit]\n });\n \n return result.rows as Deployment[];\n}\n\n// Get statistics for a date range\nexport async function getStats(startDate?: string, endDate?: string) {\n let sql = `\n SELECT \n COUNT(*) as total_prs,\n SUM(CASE WHEN deployment_status = 'production' THEN 1 ELSE 0 END) as production_count,\n SUM(CASE WHEN deployment_status = 'staging' THEN 1 ELSE 0 END) as staging_count,\n SUM(files_changed) as total_files_changed,\n SUM(additions) as total_additions,\n SUM(deletions) as total_deletions,\n COUNT(DISTINCT pr_author) as unique_authors\n FROM pr_summaries\n `;\n \n const args: any[] = [];\n if (startDate && endDate) {\n sql += ` WHERE merged_at >= ? AND merged_at <= ?`;\n args.push(startDate, endDate);\n }\n \n const result = await sqlite.execute({ sql, args });\n return result.rows[0];\n}\n\n// Get author statistics\nexport async function getAuthorStats(startDate?: string, endDate?: string) {\n let sql = `\n SELECT \n pr_author,\n COUNT(*) as pr_count,\n SUM(additions) as total_additions,\n SUM(deletions) as total_deletions,\n SUM(files_changed) as total_files_changed\n FROM pr_summaries\n `;\n \n const args: any[] = [];\n if (startDate && endDate) {\n sql += ` WHERE merged_at >= ? AND merged_at <= ?`;\n args.push(startDate, endDate);\n }\n \n sql += ` GROUP BY pr_author ORDER BY pr_count DESC`;\n \n const result = await sqlite.execute({ sql, args });\n return result.rows;\n}\n\n// Calculate quarter from date\nexport function getQuarterFromDate(date: Date): { year: number; quarter: number } {\n const year = date.getFullYear();\n const month = date.getMonth();\n const quarter = Math.floor(month / 3) + 1;\n return { year, quarter };\n}\n\n// Get quarter date range\nexport function getQuarterDateRange(year: number, quarter: number) {\n const startMonth = (quarter - 1) * 3;\n const endMonth = startMonth + 2;\n \n const startDate = new Date(year, startMonth, 1);\n const endDate = new Date(year, endMonth + 1, 0, 23, 59, 59, 999);\n \n return {\n startDate: startDate.toISOString(),\n endDate: endDate.toISOString()\n };\n}\n\n// Get summaries for a specific quarter\nexport async function getQuarterlySummaries(year: number, quarter: number): Promise {\n const { startDate, endDate } = getQuarterDateRange(year, quarter);\n return getSummariesByDateRange(startDate, endDate);\n}\n\n// Store quarterly summary\nexport async function storeQuarterlySummary(\n year: number,\n quarter: number,\n summary: QuarterlySummary\n) {\n await sqlite.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS quarterly_summaries (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n year INTEGER NOT NULL,\n quarter INTEGER NOT NULL,\n total_prs INTEGER NOT NULL,\n production_count INTEGER NOT NULL,\n staging_count INTEGER NOT NULL,\n executive_summary TEXT,\n generated_at TIMESTAMP,\n created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,\n UNIQUE(year, quarter)\n )\n `\n });\n\n await sqlite.execute({\n sql: `\n INSERT OR REPLACE INTO quarterly_summaries (\n year, quarter, total_prs, production_count, staging_count, \n executive_summary, generated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n year,\n quarter,\n summary.total_prs,\n summary.production_count,\n summary.staging_count,\n summary.executive_summary,\n summary.generated_at\n ]\n });\n}\n\n// Get all quarterly summaries\nexport async function getAllQuarterlySummaries(): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM quarterly_summaries \n ORDER BY year DESC, quarter DESC\n `\n });\n \n return result.rows as QuarterlySummary[];\n}\n\n// Utility to format date for display\nexport function formatDate(dateString: string): string {\n const date = new Date(dateString);\n return date.toLocaleDateString(\"en-US\", {\n year: \"numeric\",\n month: \"short\",\n day: \"numeric\",\n hour: \"2-digit\",\n minute: \"2-digit\"\n });\n}\n\n// Get PR velocity (PRs per week)\nexport async function getVelocityData(weeks: number = 12) {\n const weeksAgo = new Date();\n weeksAgo.setDate(weeksAgo.getDate() - (weeks * 7));\n \n const result = await sqlite.execute({\n sql: `\n SELECT \n strftime('%Y-%W', merged_at) as week,\n COUNT(*) as pr_count,\n SUM(CASE WHEN deployment_status = 'production' THEN 1 ELSE 0 END) as production_count,\n SUM(CASE WHEN deployment_status = 'staging' THEN 1 ELSE 0 END) as staging_count\n FROM pr_summaries\n WHERE merged_at >= ?\n GROUP BY week\n ORDER BY week DESC\n `,\n args: [weeksAgo.toISOString()]\n });\n \n return result.rows;\n}",[],[202],{"_103":210,"_95":211,"_152":212,"_154":-5,"_155":137,"_156":213,"_158":159,"_105":214,"_99":32,"_161":196,"_163":215,"_165":22,"_166":-5,"_167":216,"_98":217},"21b69c80-5262-11f0-85a9-f69ea79377d9","prWebhook.http.ts","21b69dfc-5262-11f0-85a9-f69ea79377d9",9,["D",1750924187431],"// Val.town webhook receiver for PR summaries from GitHub Actions\n// This val receives webhook data from GitHub Actions and stores it in SQLite\n// with HMAC signature verification for security\n\nimport { sqlite } from \"https://esm.sh/@valtown/sqlite\";\nimport { Buffer } from \"https://deno.land/std@0.208.0/node/buffer.ts\";\nimport crypto from \"node:crypto\";\n\n// Environment variable for webhook secret (set in Val.town dashboard)\nconst WEBHOOK_SECRET = Deno.env.get(\"GITHUB_WEBHOOK_SECRET\") || \"\";\n\ninterface PRWebhookPayload {\n pr_number: number;\n pr_title: string;\n pr_author: string;\n summary: string;\n email_subject?: string;\n merged_at: string;\n files_changed: number;\n additions: number;\n deletions: number;\n branch_from: string;\n branch_to: string;\n linear_issues?: any[];\n deployment_status?: \"staging\" | \"production\";\n action_run_url?: string;\n commit_sha?: string;\n}\n\n// Initialize database tables\nasync function initDatabase() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS pr_summaries (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n pr_number INTEGER NOT NULL,\n pr_title TEXT NOT NULL,\n pr_author TEXT NOT NULL,\n summary TEXT NOT NULL,\n email_subject TEXT,\n merged_at TIMESTAMP,\n deployment_status TEXT,\n linear_issues TEXT,\n files_changed INTEGER DEFAULT 0,\n additions INTEGER DEFAULT 0,\n deletions INTEGER DEFAULT 0,\n branch_from TEXT,\n branch_to TEXT,\n action_run_url TEXT,\n commit_sha TEXT,\n created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,\n UNIQUE(pr_number, deployment_status)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS deployments (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n pr_number INTEGER NOT NULL,\n environment TEXT NOT NULL,\n deployed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,\n commit_sha TEXT,\n action_run_url TEXT,\n FOREIGN KEY (pr_number) REFERENCES pr_summaries(pr_number)\n )\n `);\n\n // Create indexes for better query performance\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_pr_number ON pr_summaries(pr_number)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_merged_at ON pr_summaries(merged_at DESC)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_deployment_status ON pr_summaries(deployment_status)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_created_at ON pr_summaries(created_at DESC)`);\n}\n\n// Verify HMAC signature from GitHub\nfunction verifySignature(payload: string, signature: string): boolean {\n if (!WEBHOOK_SECRET) {\n console.warn(\"No webhook secret configured - skipping signature verification\");\n return true; // Allow in development, but log warning\n }\n\n const hmac = crypto.createHmac(\"sha256\", WEBHOOK_SECRET);\n hmac.update(payload);\n const expectedSignature = `sha256=${hmac.digest(\"hex\")}`;\n \n // Timing-safe comparison\n const signatureBuffer = Buffer.from(signature);\n const expectedBuffer = Buffer.from(expectedSignature);\n \n if (signatureBuffer.length !== expectedBuffer.length) {\n return false;\n }\n \n return crypto.timingSafeEqual(signatureBuffer, expectedBuffer);\n}\n\n// Validate timestamp to prevent replay attacks (5 minute window)\nfunction isTimestampValid(timestamp: string): boolean {\n const webhookTime = new Date(timestamp).getTime();\n const currentTime = Date.now();\n const fiveMinutes = 5 * 60 * 1000;\n \n return Math.abs(currentTime - webhookTime) < fiveMinutes;\n}\n\n// Store PR summary in database\nasync function storePRSummary(data: PRWebhookPayload) {\n // Determine deployment status from branch if not provided\n const deploymentStatus = data.deployment_status || \n (data.branch_to.toLowerCase().includes(\"production\") ? \"production\" : \n data.branch_to.toLowerCase().includes(\"staging\") ? \"staging\" : null);\n\n await sqlite.execute({\n sql: `\n INSERT OR REPLACE INTO pr_summaries (\n pr_number, pr_title, pr_author, summary, email_subject,\n merged_at, deployment_status, linear_issues, files_changed,\n additions, deletions, branch_from, branch_to, action_run_url, commit_sha\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n data.pr_number,\n data.pr_title,\n data.pr_author,\n data.summary,\n data.email_subject || null,\n data.merged_at,\n deploymentStatus,\n data.linear_issues ? JSON.stringify(data.linear_issues) : null,\n data.files_changed,\n data.additions,\n data.deletions,\n data.branch_from,\n data.branch_to,\n data.action_run_url || null,\n data.commit_sha || null\n ]\n });\n\n // If this is a deployment, also log it in the deployments table\n if (deploymentStatus) {\n await sqlite.execute({\n sql: `\n INSERT INTO deployments (pr_number, environment, commit_sha, action_run_url)\n VALUES (?, ?, ?, ?)\n `,\n args: [\n data.pr_number,\n deploymentStatus,\n data.commit_sha || null,\n data.action_run_url || null\n ]\n });\n }\n}\n\n// Main webhook handler\nexport default async function(req: Request): Promise {\n try {\n // Only accept POST requests\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n // Get the raw body for signature verification\n const body = await req.text();\n \n // Verify signature\n const signature = req.headers.get(\"x-hub-signature-256\") || \"\";\n if (!verifySignature(body, signature)) {\n console.error(\"Invalid signature\");\n return new Response(\"Unauthorized\", { status: 401 });\n }\n\n // Parse JSON payload\n let payload: PRWebhookPayload;\n try {\n payload = JSON.parse(body);\n } catch (e) {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n // Validate timestamp\n if (!isTimestampValid(payload.merged_at)) {\n console.error(\"Timestamp validation failed\");\n return new Response(\"Request expired\", { status: 400 });\n }\n\n // Initialize database if needed\n await initDatabase();\n\n // Store the PR summary\n await storePRSummary(payload);\n\n // Log success\n console.log(`Stored PR #${payload.pr_number}: ${payload.pr_title}`);\n\n // Return success response\n return new Response(\n JSON.stringify({ \n success: true, \n pr_number: payload.pr_number,\n deployment_status: payload.deployment_status\n }),\n { \n status: 200,\n headers: { \"Content-Type\": \"application/json\" }\n }\n );\n\n } catch (error) {\n console.error(\"Webhook error:\", error);\n return new Response(\n JSON.stringify({ error: \"Internal server error\" }),\n { \n status: 500,\n headers: { \"Content-Type\": \"application/json\" }\n }\n );\n }\n}",[],[211],"files",[149,170,180,191,200,209],"counts",{"_222":32,"_223":224,"_225":32,"_226":213},"pulls","branches",1,"forks","envVars","contents",[229,232,235,238,241,244],{"_103":150,"_95":151,"_152":153,"_154":-5,"_155":137,"_156":157,"_158":159,"_105":230,"_99":32,"_161":162,"_163":164,"_165":22,"_166":-5,"_98":231},["D",1750924187493],[151],{"_103":171,"_95":172,"_152":173,"_154":-5,"_155":137,"_156":174,"_158":22,"_105":233,"_99":32,"_161":176,"_163":177,"_165":22,"_166":-5,"_98":234},["D",1750924187486],[172],{"_103":181,"_95":182,"_152":183,"_154":-5,"_155":137,"_156":184,"_158":159,"_105":236,"_99":186,"_161":162,"_163":187,"_165":22,"_166":188,"_98":237},["D",1750923196559],[182],{"_103":192,"_95":193,"_152":194,"_154":-5,"_155":137,"_156":100,"_158":159,"_105":239,"_99":32,"_161":196,"_163":197,"_165":22,"_166":-5,"_98":240},["D",1750924187524],[193],{"_103":201,"_95":202,"_152":203,"_154":-5,"_155":137,"_156":204,"_158":22,"_105":242,"_99":32,"_161":176,"_163":206,"_165":22,"_166":-5,"_98":243},["D",1750924187494],[202],{"_103":210,"_95":211,"_152":212,"_154":-5,"_155":137,"_156":213,"_158":159,"_105":245,"_99":32,"_161":196,"_163":215,"_165":22,"_166":-5,"_98":246},["D",1750924187431],[211],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_101":255,"_99":100,"_260":261},{"_103":104,"_95":96,"_105":256,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":257,"_131":258,"_134":259,"_146":22},["D",1749012712601],{"_93":94,"_129":130},{"_93":94,"_133":130},{"_99":136,"_95":43,"_103":137,"_138":104,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},"changes",[262],{"_162":263,"_265":-7,"_98":193},{"_152":194,"_95":193,"_161":196,"_163":197,"_105":264,"_156":100,"_155":137},["D",1750924187524],"previous","actionData","errors"]