🤖 ${title}

\n \n

\n Quick Legacy Links (GET requests):
\n Model Info & Basic Test\n Test by Use Case\n Test Triage Scenario\n Test All Models\n

\n\n

🧪 Interactive Testing Forms

\n \n

🚀 Custom Model Test

\n \n

\n\n

⚡ Test All Models

\n \n

\n\n

🎯 Test by Use Case

\n \n

\n\n

🔍 Test Triage Scenario

\n \n

\n\n

📊 Available Models

\n ${AI_MODELS.map(model => `\n

${model.name}

by ${model.provider}

${model.useCase}

\n 💰 Input: ${model.costPer1kTokens.input}/1K tokens
\n 💰 Output: ${model.costPer1kTokens.output}/1K tokens
\n 📏 Max tokens: ${model.maxTokens.toLocaleString()}\n

${model.description}

\n
\n \n

\n `).join('')}\n

\n\n

📈 Current Model Selection

\n ${Object.entries({\n 'Fast': getModelByUseCase('fast'),\n 'Balanced': getModelByUseCase('balanced'), \n 'Advanced': getModelByUseCase('advanced'),\n 'Reasoning': getModelByUseCase('reasoning')\n }).map(([useCase, modelId]) => {\n const model = AI_MODELS.find(m => m.id === modelId);\n return model ? `\n

${useCase} → ${model.name}

by ${model.provider}

\n 💰 ${model.costPer1kTokens.input}/${model.costPer1kTokens.output} per 1K tokens
\n 📏 ${model.maxTokens.toLocaleString()} max tokens\n

\n \n

\n ` : '';\n }).join('')}\n

\n\n

📋 Test Results

${JSON.stringify(result, null, 2)}

\n \n

💡 Usage Tips

Quick Test Prompts:

JSON Test: \"Respond with exactly this JSON: {\\\"status\\\": \\\"ok\\\", \\\"model\\\": \\\"your-model-name\\\"}\"
Triage Test: \"Analyze this notification: Critical database timeout in production affecting 500 users. Respond with JSON containing urgency and reasoning.\"
Capability Test: \"What are your key strengths and ideal use cases? Respond in 2-3 sentences.\"
Speed Test: \"Hello! Please respond with just 'OK' to test response time.\"

\n \n

Model Selection Guide:

Fast (GPT-OSS 20B): Simple notifications, quick responses, cost-effective
Balanced (Claude 3.5 Sonnet): Standard triage, good quality/cost balance
Advanced (GPT-4o): Critical issues requiring sophisticated analysis
Reasoning (Kimi K2): Complex scenarios, tool use, coding tasks

\n\n`;\n\n return new Response(html, {\n headers: { 'Content-Type': 'text/html' }\n });\n\n } catch (error) {\n return new Response(JSON.stringify({\n error: error.message,\n stack: error.stack\n }, null, 2), {\n status: 500,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n}",[],[99],{"_104":203,"_95":204,"_153":205,"_155":-5,"_156":138,"_157":206,"_159":22,"_106":207,"_100":208,"_162":163,"_164":209,"_166":22,"_167":-5,"_168":210,"_98":211},"780942c0-7c49-11f0-a113-0224a6c84d84","ai-service.ts","acd4aaca-7c45-11f0-bb97-0224a6c84d84",80,["D",1755531543675],6,"/**\n * AI Service using OpenRouter\n * \n * This module provides a unified interface for AI operations using OpenRouter\n * as the provider, with configurable models and fallback support.\n */\n\nimport { AI_CONFIG, AI_MODELS, getModelConfig, getModelByUseCase } from './CONFIGURATION.ts';\nimport { logFormatted } from './stringify-utils.ts';\n\nexport interface ChatMessage {\n role: 'system' | 'user' | 'assistant';\n content: string;\n}\n\nexport interface ChatCompletionRequest {\n messages: ChatMessage[];\n model?: string;\n temperature?: number;\n maxTokens?: number;\n topP?: number;\n useCase?: 'fast' | 'balanced' | 'advanced' | 'reasoning';\n provider?: 'groq' | 'openai' | 'anthropic' | 'auto';\n}\n\nexport interface ChatCompletionResponse {\n id: string;\n model: string;\n choices: Array<{\n message: {\n role: string;\n content: string;\n };\n finishReason: string;\n }>;\n usage: {\n promptTokens: number;\n completionTokens: number;\n totalTokens: number;\n };\n}\n\n/**\n * OpenRouter AI Service\n */\nexport class OpenRouterService {\n private apiKey: string;\n private baseUrl: string;\n private siteName: string;\n private siteUrl: string;\n\n constructor() {\n this.apiKey = AI_CONFIG.openRouter.apiKey;\n this.baseUrl = AI_CONFIG.openRouter.baseUrl;\n this.siteName = AI_CONFIG.openRouter.siteName;\n this.siteUrl = AI_CONFIG.openRouter.siteUrl;\n\n if (!this.apiKey) {\n throw new Error('OPENROUTER_API_KEY environment variable is required');\n }\n }\n\n /**\n * Make a chat completion request to OpenRouter\n */\n async chatCompletion(request: ChatCompletionRequest): Promise {\n // Determine which model to use\n let modelId = request.model;\n if (!modelId && request.useCase) {\n modelId = getModelByUseCase(request.useCase);\n }\n if (!modelId) {\n modelId = AI_CONFIG.modelSelection.default;\n }\n\n const modelConfig = getModelConfig(modelId);\n if (!modelConfig) {\n throw new Error(`Unknown model: ${modelId}`);\n }\n\n // Prepare request parameters\n const params = {\n model: modelId,\n messages: request.messages,\n temperature: request.temperature ?? AI_CONFIG.defaultParams.temperature,\n max_tokens: Math.min(\n request.maxTokens ?? AI_CONFIG.defaultParams.maxTokens,\n modelConfig.maxTokens\n ),\n top_p: request.topP ?? AI_CONFIG.defaultParams.topP,\n // Set provider - use requested provider or default to groq\n provider: request.provider ? \n AI_CONFIG.providers[request.provider] : \n AI_CONFIG.defaultProvider\n };\n\n const headers = {\n 'Authorization': `Bearer ${this.apiKey}`,\n 'Content-Type': 'application/json',\n 'HTTP-Referer': this.siteUrl,\n 'X-Title': this.siteName,\n };\n\n logFormatted({\n model: modelId,\n modelConfig: {\n name: modelConfig.name,\n provider: modelConfig.provider,\n useCase: modelConfig.useCase\n },\n requestParams: {\n temperature: params.temperature,\n maxTokens: params.max_tokens,\n messageCount: params.messages.length,\n requestedProvider: request.provider || 'groq (default)',\n providerConfig: params.provider\n }\n }, 'OpenRouter Request');\n\n try {\n const response = await fetch(`${this.baseUrl}/chat/completions`, {\n method: 'POST',\n headers,\n body: JSON.stringify(params),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(`OpenRouter API error (${response.status}): ${errorText}`);\n }\n\n const result = await response.json() as ChatCompletionResponse;\n \n // Log usage information\n if (result.usage) {\n const inputCost = (result.usage.promptTokens / 1000) * modelConfig.costPer1kTokens.input;\n const outputCost = (result.usage.completionTokens / 1000) * modelConfig.costPer1kTokens.output;\n const totalCost = inputCost + outputCost;\n\n logFormatted({\n model: modelId,\n usage: result.usage,\n estimatedCost: {\n input: `$${inputCost.toFixed(6)}`,\n output: `$${outputCost.toFixed(6)}`,\n total: `$${totalCost.toFixed(6)}`\n }\n }, 'OpenRouter Usage');\n }\n\n return result;\n\n } catch (error) {\n console.error(`Error with model ${modelId}:`, error);\n \n // Try fallback models if enabled\n if (AI_CONFIG.fallback.enabled && !request.model) {\n for (const fallbackModel of AI_CONFIG.fallback.models) {\n if (fallbackModel === modelId) continue; // Skip the model that just failed\n \n console.log(`Trying fallback model: ${fallbackModel}`);\n try {\n return await this.chatCompletion({\n ...request,\n model: fallbackModel\n });\n } catch (fallbackError) {\n console.error(`Fallback model ${fallbackModel} also failed:`, fallbackError);\n }\n }\n }\n \n throw error;\n }\n }\n\n /**\n * Simple text completion helper\n */\n async complete(\n prompt: string, \n systemMessage?: string,\n options?: Partial\n ): Promise {\n const messages: ChatMessage[] = [];\n \n if (systemMessage) {\n messages.push({ role: 'system', content: systemMessage });\n }\n \n messages.push({ role: 'user', content: prompt });\n\n const response = await this.chatCompletion({\n messages,\n ...options\n });\n\n return response.choices[0]?.message?.content || '';\n }\n\n /**\n * JSON completion helper - ensures valid JSON response\n */\n async completeJSON(\n prompt: string,\n systemMessage?: string,\n options?: Partial\n ): Promise {\n const fullSystemMessage = systemMessage \n ? `${systemMessage}\\n\\nIMPORTANT: Always respond with valid JSON only. Do not include any text before or after the JSON object. Do not wrap the JSON in markdown code blocks.`\n : 'Always respond with valid JSON only. Do not include any text before or after the JSON object. Do not wrap the JSON in markdown code blocks.';\n\n const response = await this.complete(prompt, fullSystemMessage, options);\n \n // Clean the response to handle markdown code blocks\n let cleanedResponse = response.trim();\n \n // Remove markdown code block formatting if present\n if (cleanedResponse.startsWith('```json')) {\n cleanedResponse = cleanedResponse.replace(/^```json\\s*/, '').replace(/\\s*```$/, '');\n } else if (cleanedResponse.startsWith('```')) {\n cleanedResponse = cleanedResponse.replace(/^```\\s*/, '').replace(/\\s*```$/, '');\n }\n \n // Remove any leading/trailing whitespace again\n cleanedResponse = cleanedResponse.trim();\n \n try {\n return JSON.parse(cleanedResponse) as T;\n } catch (error) {\n console.error('Failed to parse JSON response:', response);\n console.error('Cleaned response:', cleanedResponse);\n throw new Error(`Invalid JSON response from AI: ${error.message}`);\n }\n }\n\n /**\n * Get available models\n */\n getAvailableModels(): typeof AI_MODELS {\n return AI_MODELS;\n }\n\n /**\n * Get model by use case\n */\n getModelForUseCase(useCase: 'fast' | 'balanced' | 'advanced' | 'reasoning'): string {\n return getModelByUseCase(useCase);\n }\n}\n\n// Export singleton instance\nexport const aiService = new OpenRouterService();",[],[204],{"_104":213,"_95":214,"_153":215,"_155":-5,"_156":138,"_157":216,"_159":22,"_106":217,"_100":32,"_162":163,"_164":218,"_166":22,"_167":-5,"_168":219,"_98":220},"d564bde2-7c43-11f0-b301-0224a6c84d84","citation-context.ts","d564bf04-7c43-11f0-b301-0224a6c84d84",19,["D",1755529123314],"/**\n * Citation Context for AI Prompting\n * \n * This module provides utilities for generating and linking citation keys\n * in AI prompts, making it easier to reference specific events, resources,\n * and data points in a structured way.\n */\n\nconst warn = console.warn.bind(console, \"[citation context]\");\n\nconst ID_REGEX =\n /^\\b[0-9a-fA-F]{16,32}\\b|\\b[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}\\b$/;\n\n/** Internal structure used by `CitationContext`. */\ntype CitationRecord = {\n uri: string; // stable URI pointing to resource in backend (could be uuid scheme)\n contentSnippet: string; // optional preview/content\n uniqueId?: string; // optional UUID/GUID/etc for replacing keys into another text map\n};\n\n/**\n * CitationContext is a utility class for generating and linking citation keys.\n * It helps track and format references to specific events, runs, or other resources.\n *\n * @example\n * ```ts\n * const citationCtx = new CitationContext();\n * const key = citationCtx.generate('event', '123', ['Event 1', 'Event 2']);\n * const linkedText = citationCtx.linkify('[#event_1, #event_2]', '[key](uri)');\n * // linkedText: [event_1](ch-event://123) | [event_2](ch-event://123)\n * ```\n */\nexport class CitationContext {\n private counters = new Map();\n readonly map = new Map();\n\n /**\n * Generate a citation key and register its mapping.\n * Example output: [#event_3]\n * @param prefix Logical prefix e.g. 'event', 'run'\n * @param uri Stable URI/identifier (can be UUID) for backend lookup\n * @param contentSnippet Optional short snippet for output files/debugging\n */\n generate(prefix: string, id: string, contentSnippet: string[]): string {\n const idx = (this.counters.get(prefix) ?? 0) + 1;\n this.counters.set(prefix, idx);\n const key = `${prefix}_${idx}`;\n this.map.set(key, {\n uri: `ch-${prefix}://${id}`,\n contentSnippet: contentSnippet.join(' | '),\n // If the id is likely a completely unique ID, use it as the uniqueId\n uniqueId: id.match(ID_REGEX)?.[0],\n });\n return `[#${key}]`;\n }\n\n /**\n * Prepare text for LLM consumption by replacing unique IDs with citation keys.\n *\n * @param text - The text to process\n * @returns The text with unique IDs replaced by citation keys\n */\n prepareForLLM(text: string): string {\n for (const [key, citation] of this.map.entries()) {\n if (citation.uniqueId) {\n text = text.replace(\n new RegExp(`\\\\b${citation.uniqueId}\\\\b`, 'g'),\n `[${key}]`\n );\n }\n }\n return text;\n }\n\n /**\n * Convert inline citation keys inside text to markdown links.\n * Transforms patterns like [#event_1, #event_2] to markdown links.\n *\n * @param text - The text containing citation keys to linkify\n * @param format - The output format for the links\n * @returns The text with citation keys converted to markdown links\n */\n linkify(text: string, format: '[key](uri)' | '[key](uri \"snippet\")'): string {\n return text.replace(\n /(:?\\[#([a-zA-Z]+_\\d+)(?:(?:,\\s*|\\s*[-––|]\\s*)#([a-zA-Z]+_\\d+))*\\])+/g,\n (match) => {\n // Extract all citation keys from the match\n const keys: string[] = match.match(/[a-zA-Z]+_\\d+/g) || [];\n\n // Transform each key into a markdown link\n return keys\n .map((k) => {\n const citation = this.map.get(k);\n if (!citation) {\n const matchedFormat = /^(\\w+)_(\\d+)$/.exec(k);\n let keys = [...this.map.keys()];\n let emptyMessage = 'none';\n if (matchedFormat) {\n const [, prefix] = matchedFormat;\n keys = keys.filter((a) => a.startsWith(prefix));\n emptyMessage = `no ${prefix} citations`;\n }\n warn(\n new Error(\n `Citation (${k}) did not exist from [${keys.join(', ') || emptyMessage}]`\n ),\n 'Citation key not found in map'\n );\n return `[#${k}]`; // Handle case where key doesn't exist in map\n }\n\n switch (format) {\n case '[key](uri)':\n return `[${k}](${citation.uri})`;\n case '[key](uri \"snippet\")':\n default:\n return `[${k}](${citation.uri} \"${citation.contentSnippet?.replace(/[\"\\n]+/g, '')}\")`;\n }\n })\n .join(', ');\n }\n );\n }\n\n /**\n * Get all citation entries as an array of key-value pairs.\n *\n * @returns Array of [key, CitationRecord] tuples\n */\n entries(): [string, CitationRecord][] {\n return Array.from(this.map.entries());\n }\n}",[],[214],{"_104":222,"_95":223,"_153":224,"_155":-5,"_156":138,"_157":189,"_159":22,"_106":225,"_100":226,"_162":198,"_164":227,"_166":22,"_167":-5,"_168":228,"_98":229},"6a830550-7c44-11f0-b94a-0224a6c84d84","linear-webhook.ts","ca57e836-7c41-11f0-b28e-0224a6c84d84",["D",1755529373497],11,"/**\n * Linear Webhook Handler\n * \n * Receives webhooks from Linear, validates the signature, and processes\n * the notification data for triage.\n */\n\nimport { WEBHOOK_CONFIG } from './CONFIGURATION.ts';\nimport { logFormatted } from './stringify-utils.ts';\nimport { processNotification, NotificationData } from './notification-triage.ts';\n\ninterface LinearWebhookPayload {\n action: string;\n type: string;\n data: {\n id: string;\n title?: string;\n description?: string;\n state?: {\n name: string;\n type: string;\n };\n priority?: number;\n labels?: Array<{\n name: string;\n }>;\n team?: {\n name: string;\n };\n assignee?: {\n name: string;\n email: string;\n };\n url?: string;\n createdAt?: string;\n updatedAt?: string;\n };\n url: string;\n createdAt: string;\n}\n\n/**\n * Verify Linear webhook signature\n */\nasync function verifyLinearSignature(\n payload: string,\n signature: string,\n secret: string\n): Promise {\n if (!secret) {\n console.warn('Linear webhook secret not configured');\n return false;\n }\n\n try {\n const encoder = new TextEncoder();\n const key = await crypto.subtle.importKey(\n 'raw',\n encoder.encode(secret),\n { name: 'HMAC', hash: 'SHA-256' },\n false,\n ['sign']\n );\n\n const expectedSignature = await crypto.subtle.sign(\n 'HMAC',\n key,\n encoder.encode(payload)\n );\n\n const expectedHex = Array.from(new Uint8Array(expectedSignature))\n .map(b => b.toString(16).padStart(2, '0'))\n .join('');\n\n // Linear sends signature as \"sha256=\"\n const receivedHex = signature.replace('sha256=', '');\n \n return expectedHex === receivedHex;\n } catch (error) {\n console.error('Error verifying signature:', error);\n return false;\n }\n}\n\n/**\n * Convert Linear webhook payload to standardized notification data\n */\nfunction convertLinearToNotificationData(payload: LinearWebhookPayload): NotificationData {\n // Determine severity based on priority and labels\n let severity: 'low' | 'medium' | 'high' | 'critical' = 'medium';\n const labels = payload.data.labels?.map(l => l.name.toLowerCase()) || [];\n \n if (payload.data.priority === 1 || labels.includes('critical') || labels.includes('urgent')) {\n severity = 'critical';\n } else if (payload.data.priority === 2 || labels.includes('high')) {\n severity = 'high';\n } else if (payload.data.priority === 4 || labels.includes('low')) {\n severity = 'low';\n }\n \n return {\n source: 'linear',\n id: payload.data.id,\n type: payload.type.toLowerCase(),\n action: payload.action,\n title: payload.data.title || 'Untitled Linear Item',\n description: payload.data.description,\n priority: payload.data.priority,\n severity,\n labels: payload.data.labels?.map(l => l.name) || [],\n team: payload.data.team?.name,\n assignee: payload.data.assignee ? {\n name: payload.data.assignee.name,\n email: payload.data.assignee.email\n } : undefined,\n url: payload.data.url || payload.url,\n createdAt: payload.data.createdAt || payload.createdAt,\n updatedAt: payload.data.updatedAt,\n rawPayload: payload\n };\n}\n\n/**\n * Main webhook handler\n */\nexport default async function(req: Request): Promise {\n // Handle GET requests with configuration instructions\n if (req.method === 'GET') {\n const url = new URL(req.url);\n const webhookUrl = url.origin + url.pathname;\n \n const html = `\n\n\n\n Linear Webhook Configuration\n \n\n\n

Linear Webhook Setup

\n \n

Webhook URL:

${webhookUrl}

\n\n

\n ⚠️ Important: Set the LINEAR_WEBHOOK_SECRET environment variable in Val Town with your webhook signing secret before testing.\n

\n\n

Configuration Steps:

Go to Linear → Settings → API → Webhooks
Click \"Create webhook\"
Paste the URL above
Copy the signing secret and add it to Val Town as LINEAR_WEBHOOK_SECRET
Select your desired events (Issues, Comments recommended)
Save and test by creating/updating an issue

\n\n

The webhook uses AI to analyze notifications and route them to appropriate email channels based on content and priority.

\n\n`;\n\n return new Response(html, {\n headers: { 'Content-Type': 'text/html' }\n });\n }\n\n if (req.method !== 'POST') {\n return new Response('Method not allowed', { status: 405 });\n }\n\n try {\n // Get the raw body and signature\n const body = await req.text();\n const signature = req.headers.get('linear-signature') || '';\n\n // Verify the webhook signature\n if (!await verifyLinearSignature(body, signature, WEBHOOK_CONFIG.linear.signingSecret)) {\n console.error('Invalid webhook signature');\n return new Response('Unauthorized', { status: 401 });\n }\n\n // Parse the payload\n const payload: LinearWebhookPayload = JSON.parse(body);\n \n // Log the full webhook payload for debugging\n logFormatted(payload, \"Linear Webhook Received\");\n \n console.log(`Processing Linear ${payload.action} on ${payload.type}: ${payload.data.title || 'Untitled'}`);\n\n // Skip certain actions that don't need notifications\n const skipActions = ['view', 'read'];\n if (skipActions.includes(payload.action)) {\n return new Response('OK - Skipped', { status: 200 });\n }\n\n // Convert to standardized notification format\n const notificationData = convertLinearToNotificationData(payload);\n \n // Process through shared triage system (this will handle its own logging)\n await processNotification(notificationData);\n\n return new Response('OK', { status: 200 });\n\n } catch (error) {\n console.error('Error processing webhook:', error);\n return new Response('Internal Server Error', { status: 500 });\n }\n}",[],[223],{"_104":231,"_95":232,"_153":233,"_155":-5,"_156":138,"_157":234,"_159":176,"_106":235,"_100":32,"_162":163,"_164":72,"_166":22,"_167":-5,"_168":236,"_98":237},"34097c3e-7c3f-11f0-bc2e-0224a6c84d84","main.tsx","34097ce8-7c3f-11f0-bc2e-0224a6c84d84",1,["D",1755527134622],[],[232],{"_104":239,"_95":240,"_153":241,"_155":-5,"_156":138,"_157":242,"_159":22,"_106":243,"_100":244,"_162":163,"_164":245,"_166":22,"_167":-5,"_168":246,"_98":247},"c4faa80c-7c45-11f0-aea3-0224a6c84d84","notification-triage.ts","f2082c72-7c43-11f0-b3d2-0224a6c84d84",41,["D",1755529954771],3,"/**\n * Shared Notification Triage System\n * \n * This module provides a unified interface for triaging notifications from\n * various sources (Linear, Sentry, billing, etc.) using AI to determine\n * appropriate routing channels.\n */\n\nimport { NOTIFICATION_CHANNELS, AI_PROMPTS, EMAIL_CONFIG } from './CONFIGURATION.ts';\nimport { aiService } from './ai-service.ts';\nimport { email } from \"https://esm.town/v/std/email\";\nimport { logFormatted, stringifyForLogging } from './stringify-utils.ts';\nimport { CitationContext } from './citation-context.ts';\n\n/**\n * Standardized notification data structure that all webhook sources\n * should convert their payloads into before triaging\n */\nexport interface NotificationData {\n // Core identification\n source: string; // e.g., 'linear', 'sentry', 'billing'\n id: string; // unique identifier from source system\n type: string; // e.g., 'issue', 'error', 'payment_failed'\n action: string; // e.g., 'created', 'updated', 'resolved'\n \n // Content\n title: string;\n description?: string;\n \n // Metadata\n priority?: number | string; // source-specific priority\n severity?: 'low' | 'medium' | 'high' | 'critical';\n labels?: string[];\n tags?: string[];\n \n // Context\n team?: string;\n assignee?: {\n name: string;\n email?: string;\n };\n project?: string;\n environment?: string; // e.g., 'production', 'staging'\n \n // Links and references\n url?: string; // primary link to the item\n additionalUrls?: { [key: string]: string }; // other relevant links\n \n // Timestamps\n createdAt?: string;\n updatedAt?: string;\n \n // Raw data for debugging\n rawPayload?: any;\n}\n\n/**\n * Result of AI triage analysis\n */\nexport interface TriageResult {\n selectedChannels: string[];\n reasoning: string;\n summary: string;\n urgency: 'low' | 'medium' | 'high' | 'critical';\n suggestedActions?: string[];\n}\n\n/**\n * Enhanced triage result with citation context\n */\nexport interface EnhancedTriageResult extends TriageResult {\n citationContext: CitationContext;\n formattedSummary: string; // summary with proper links\n}\n\n/**\n * Create citation context for a notification to improve AI prompting\n */\nfunction createCitationContext(notification: NotificationData): CitationContext {\n const ctx = new CitationContext();\n \n // Generate citation for the main notification\n const mainCitation = ctx.generate(\n notification.source,\n notification.id,\n [notification.title, notification.type, notification.action]\n );\n \n // Add citations for related URLs if they exist\n if (notification.url) {\n ctx.generate(\n 'link',\n notification.url,\n [`${notification.source} link`, notification.title]\n );\n }\n \n // Add citations for additional URLs\n if (notification.additionalUrls) {\n Object.entries(notification.additionalUrls).forEach(([key, url]) => {\n ctx.generate('link', url, [key, notification.title]);\n });\n }\n \n return ctx;\n}\n\n/**\n * Use AI to determine which channels should receive the notification\n */\nexport async function triageNotification(notification: NotificationData): Promise {\n const citationCtx = createCitationContext(notification);\n \n // Prepare channel information\n const channelsInfo = NOTIFICATION_CHANNELS.map(channel => \n `${channel.id}: ${channel.name} - ${channel.description} (Priority: ${channel.priority}, Keywords: ${channel.keywords.join(', ')})`\n ).join('\\n');\n \n // Create structured notification context with citations\n const notificationContext = {\n source: notification.source,\n id: notification.id,\n type: notification.type,\n action: notification.action,\n title: notification.title,\n description: notification.description || 'No description provided',\n priority: notification.priority || 'Not specified',\n severity: notification.severity || 'Not specified',\n labels: notification.labels || [],\n tags: notification.tags || [],\n team: notification.team || 'Unknown',\n assignee: notification.assignee?.name || 'Unassigned',\n project: notification.project || 'Unknown',\n environment: notification.environment || 'Unknown',\n hasUrl: !!notification.url,\n additionalUrlCount: Object.keys(notification.additionalUrls || {}).length\n };\n \n // Prepare the context for LLM consumption (replace IDs with citations)\n const contextString = citationCtx.prepareForLLM(stringifyForLogging(notificationContext));\n \n const prompt = `${AI_PROMPTS.channelSelection.replace('{channels}', channelsInfo)}\n\nNotification to triage:\n${contextString}\n\nPlease analyze this notification and respond with a JSON object containing:\n- selectedChannels: array of channel IDs that should receive this notification\n- reasoning: brief explanation of why these channels were selected\n- summary: a concise summary tailored for the selected audience\n- urgency: one of 'low', 'medium', 'high', 'critical'\n- suggestedActions: array of specific actions that recipients should consider (optional)\n\nConsider the notification's source, type, priority, and content when making routing decisions.`;\n\n try {\n // Log what's going into the AI prompt for debugging\n logFormatted({ \n notificationContext: notificationContext,\n citationEntries: citationCtx.entries(),\n promptPreview: contextString\n }, \"AI Prompt Input\");\n \n // Determine which model to use based on notification complexity\n let useCase: 'fast' | 'balanced' | 'advanced' | 'reasoning' = 'balanced';\n \n // Use fast model for simple notifications\n if (notification.severity === 'low' && !notification.description) {\n useCase = 'fast';\n }\n // Use advanced model for critical issues\n else if (notification.severity === 'critical' || notification.priority === 1) {\n useCase = 'advanced';\n }\n // Use reasoning model for complex scenarios with multiple factors\n else if (notification.labels?.length > 3 || notification.tags?.length > 3 || \n (notification.description && notification.description.length > 500)) {\n useCase = 'reasoning';\n }\n\n const triageResult = await aiService.completeJSON(\n prompt,\n \"You are a notification triage system. Always respond with valid JSON only. Consider urgency, technical domain, and team context when routing notifications.\",\n {\n useCase,\n maxTokens: 800,\n temperature: 0.1\n }\n );\n \n // Create formatted summary with proper links\n const formattedSummary = citationCtx.linkify(triageResult.summary, '[key](uri)');\n \n return {\n ...triageResult,\n citationContext: citationCtx,\n formattedSummary\n };\n \n } catch (error) {\n console.error('Error in AI triage:', error);\n \n // Fallback logic based on notification characteristics\n let fallbackChannels = ['general'];\n let fallbackUrgency: 'low' | 'medium' | 'high' | 'critical' = 'medium';\n \n // Simple fallback routing logic\n if (notification.severity === 'critical' || notification.priority === 1 || notification.priority === 'high') {\n fallbackChannels = ['engineering-critical'];\n fallbackUrgency = 'critical';\n } else if (notification.source === 'sentry' || notification.environment === 'production') {\n fallbackChannels = ['engineering-general', 'devops'];\n fallbackUrgency = 'high';\n }\n \n return {\n selectedChannels: fallbackChannels,\n reasoning: `AI triage failed (${error.message}), using fallback routing based on source and priority`,\n summary: `${notification.source} ${notification.action}: ${notification.title}`,\n urgency: fallbackUrgency,\n citationContext: citationCtx,\n formattedSummary: `${notification.source} ${notification.action}: ${notification.title}`\n };\n }\n}\n\n/**\n * Format and send notification to selected channels\n */\nexport async function sendNotifications(\n notification: NotificationData, \n triageResult: EnhancedTriageResult\n): Promise {\n const selectedChannels = NOTIFICATION_CHANNELS.filter(\n channel => triageResult.selectedChannels.includes(channel.id)\n );\n\n logFormatted({ \n notification: { source: notification.source, id: notification.id, title: notification.title },\n selectedChannels: selectedChannels.map(c => c.name),\n reasoning: triageResult.reasoning \n }, \"Sending Notifications\");\n\n for (const channel of selectedChannels) {\n try {\n const urgencyPrefix = triageResult.urgency === 'critical' ? '[CRITICAL] ' : \n triageResult.urgency === 'high' ? '[HIGH] ' : '';\n \n const subject = `${EMAIL_CONFIG.subjectPrefix} ${urgencyPrefix}${notification.title}`;\n \n // Create formatted links using citation context\n const formattedLinks = triageResult.citationContext.linkify(\n notification.url ? `[#link_1]` : 'No direct link available',\n '[key](uri \"snippet\")'\n );\n \n const emailBody = `\n

${notification.source.charAt(0).toUpperCase() + notification.source.slice(1)} Notification

\n\n

Summary: ${triageResult.formattedSummary}

Urgency: ${triageResult.urgency.toUpperCase()}

\n\n

Details:

Source: ${notification.source}
Type: ${notification.type}
Action: ${notification.action}
Priority: ${notification.priority || 'Not specified'}
Severity: ${notification.severity || 'Not specified'}
Team: ${notification.team}
Assignee: ${notification.assignee.name}
Project: ${notification.project}
Environment: ${notification.environment}
Labels: ${notification.labels.join(', ')}
Tags: ${notification.tags.join(', ')}

\n\n${notification.description ? `

Description:

${notification.description}

` : ''}\n\n${triageResult.suggestedActions?.length ? `\n

Suggested Actions:

${action}

\n` : ''}\n\n

Links: ${formattedLinks}

\n\n

Routed to ${channel.name} because: ${triageResult.reasoning}

\n `.trim();\n\n await email({\n to: channel.email,\n subject: subject,\n html: emailBody,\n text: emailBody.replace(/<[^>]*>/g, '') // Strip HTML for text version\n });\n\n console.log(`✅ Notification sent to ${channel.name} (${channel.email})`);\n } catch (error) {\n console.error(`❌ Failed to send notification to ${channel.name}:`, error);\n }\n }\n}\n\n/**\n * Main triage function that processes any notification data\n */\nexport async function processNotification(notification: NotificationData): Promise {\n try {\n logFormatted(notification, `${notification.source.toUpperCase()} Notification Data`);\n \n // Triage the notification\n const triageResult = await triageNotification(notification);\n logFormatted(triageResult, \"Enhanced Triage Result\");\n \n // Send notifications to selected channels\n await sendNotifications(notification, triageResult);\n \n console.log(`✅ Successfully processed ${notification.source} notification: ${notification.title}`);\n } catch (error) {\n console.error(`❌ Error processing ${notification.source} notification:`, error);\n throw error;\n }\n}",[],[240],{"_104":249,"_95":250,"_153":251,"_155":-5,"_156":138,"_157":252,"_159":176,"_106":253,"_100":234,"_162":198,"_164":254,"_166":22,"_167":-5,"_168":255,"_98":256},"b21c4002-7c44-11f0-b4ef-0224a6c84d84","sentry-webhook.ts","ad82ab8a-7c44-11f0-84ff-0224a6c84d84",31,["D",1755529493620],"/**\n * Sentry Webhook Handler\n * \n * Receives webhooks from Sentry, validates the signature, and processes\n * the notification data for triage.\n */\n\nimport { WEBHOOK_CONFIG } from './CONFIGURATION.ts';\nimport { logFormatted } from './stringify-utils.ts';\nimport { processNotification, NotificationData } from './notification-triage.ts';\n\ninterface SentryWebhookPayload {\n action: string;\n installation: {\n uuid: string;\n };\n data: {\n error?: {\n id: string;\n title: string;\n culprit?: string;\n type: string;\n value: string;\n url: string;\n project: string;\n release?: {\n version: string;\n };\n environment?: string;\n platform?: string;\n exception?: {\n values: Array<{\n type: string;\n value: string;\n stacktrace?: {\n frames: Array<{\n filename: string;\n function: string;\n lineno: number;\n }>;\n };\n }>;\n };\n tags?: Array<{\n key: string;\n value: string;\n }>;\n level: 'debug' | 'info' | 'warning' | 'error' | 'fatal';\n logger?: string;\n server_name?: string;\n timestamp: string;\n event_id: string;\n };\n issue?: {\n id: string;\n title: string;\n culprit?: string;\n permalink: string;\n short_id: string;\n status: string;\n substatus?: string;\n type: string;\n metadata: {\n type?: string;\n value?: string;\n filename?: string;\n function?: string;\n };\n level: 'debug' | 'info' | 'warning' | 'error' | 'fatal';\n assignee?: {\n name: string;\n email: string;\n };\n logger?: string;\n platform?: string;\n project: string;\n release?: {\n version: string;\n };\n environment?: string;\n tags?: Array<{\n key: string;\n value: string;\n }>;\n first_seen: string;\n last_seen: string;\n count: string;\n user_count: number;\n };\n };\n actor: {\n type: string;\n id: string;\n name: string;\n };\n url: string;\n}\n\n/**\n * Verify Sentry webhook signature\n */\nasync function verifySentrySignature(\n payload: string,\n signature: string,\n secret: string\n): Promise {\n if (!secret) {\n console.warn('Sentry webhook secret not configured');\n return false;\n }\n\n try {\n const encoder = new TextEncoder();\n const key = await crypto.subtle.importKey(\n 'raw',\n encoder.encode(secret),\n { name: 'HMAC', hash: 'SHA-256' },\n false,\n ['sign']\n );\n\n const expectedSignature = await crypto.subtle.sign(\n 'HMAC',\n key,\n encoder.encode(payload)\n );\n\n const expectedHex = Array.from(new Uint8Array(expectedSignature))\n .map(b => b.toString(16).padStart(2, '0'))\n .join('');\n\n // Sentry sends signature as hex without prefix\n return expectedHex === signature;\n } catch (error) {\n console.error('Error verifying signature:', error);\n return false;\n }\n}\n\n/**\n * Convert Sentry webhook payload to standardized notification data\n */\nfunction convertSentryToNotificationData(payload: SentryWebhookPayload): NotificationData {\n const isError = !!payload.data.error;\n const isIssue = !!payload.data.issue;\n \n // Use error data if available, otherwise use issue data\n const data = payload.data.error || payload.data.issue;\n \n if (!data) {\n throw new Error('No error or issue data found in Sentry payload');\n }\n\n // Determine severity based on Sentry level\n let severity: 'low' | 'medium' | 'high' | 'critical' = 'medium';\n switch (data.level) {\n case 'fatal':\n severity = 'critical';\n break;\n case 'error':\n severity = 'high';\n break;\n case 'warning':\n severity = 'medium';\n break;\n case 'info':\n case 'debug':\n severity = 'low';\n break;\n }\n\n // Extract tags as labels\n const labels = data.tags?.map(tag => `${tag.key}:${tag.value}`) || [];\n \n // Add environment and platform as labels if available\n if (data.environment) labels.push(`env:${data.environment}`);\n if (data.platform) labels.push(`platform:${data.platform}`);\n if (data.logger) labels.push(`logger:${data.logger}`);\n\n // Determine the primary URL\n const primaryUrl = isError ? data.url : (payload.data.issue?.permalink || payload.url);\n\n // Create description from available data\n let description = '';\n if (isError && data.exception?.values?.[0]) {\n const exc = data.exception.values[0];\n description = `${exc.type}: ${exc.value}`;\n if (exc.stacktrace?.frames?.[0]) {\n const frame = exc.stacktrace.frames[0];\n description += `\\n\\nLocation: ${frame.filename}:${frame.lineno} in ${frame.function}`;\n }\n } else if (data.culprit) {\n description = `Culprit: ${data.culprit}`;\n }\n\n return {\n source: 'sentry',\n id: data.id,\n type: isError ? 'error' : 'issue',\n action: payload.action,\n title: data.title,\n description,\n severity,\n labels,\n team: data.project, // Use project as team\n assignee: data.assignee ? {\n name: data.assignee.name,\n email: data.assignee.email\n } : undefined,\n project: data.project,\n environment: data.environment,\n url: primaryUrl,\n additionalUrls: {\n sentry: primaryUrl,\n ...(payload.url !== primaryUrl && { webhook: payload.url })\n },\n createdAt: isError ? data.timestamp : payload.data.issue?.first_seen,\n updatedAt: isIssue ? payload.data.issue?.last_seen : undefined,\n rawPayload: payload\n };\n}\n\n/**\n * Main webhook handler\n */\nexport default async function(req: Request): Promise {\n // Handle GET requests with configuration instructions\n if (req.method === 'GET') {\n const url = new URL(req.url);\n const webhookUrl = url.origin + url.pathname;\n \n const html = `\n\n\n\n Sentry Webhook Configuration\n \n\n\n

Sentry Webhook Setup

\n \n

Webhook URL:

${webhookUrl}

\n\n

\n ⚠️ Important: Set the SENTRY_WEBHOOK_SECRET environment variable in Val Town with your webhook client secret before testing.\n

\n\n

Configuration Steps:

Go to Sentry → Settings → Developer Settings → Internal Integrations
Create a new internal integration or edit existing one
Add webhook URL above to \"Webhook URL\" field
Copy the \"Client Secret\" and add it to Val Town as SENTRY_WEBHOOK_SECRET
Enable desired permissions (Issue & Event: Read recommended)
Subscribe to events (Error, Issue recommended)
Save and test by triggering an error

\n\n

The webhook uses AI to analyze error notifications and route them to appropriate engineering channels based on severity and context.

\n\n`;\n\n return new Response(html, {\n headers: { 'Content-Type': 'text/html' }\n });\n }\n\n if (req.method !== 'POST') {\n return new Response('Method not allowed', { status: 405 });\n }\n\n try {\n // Get the raw body and signature\n const body = await req.text();\n const signature = req.headers.get('sentry-hook-signature') || '';\n\n // Verify the webhook signature\n if (!await verifySentrySignature(body, signature, WEBHOOK_CONFIG.sentry.signingSecret)) {\n console.error('Invalid webhook signature');\n return new Response('Unauthorized', { status: 401 });\n }\n\n // Parse the payload\n const payload: SentryWebhookPayload = JSON.parse(body);\n \n // Log the full webhook payload for debugging\n logFormatted(payload, \"Sentry Webhook Received\");\n \n const dataType = payload.data.error ? 'error' : 'issue';\n const dataTitle = payload.data.error?.title || payload.data.issue?.title || 'Unknown';\n console.log(`Processing Sentry ${payload.action} on ${dataType}: ${dataTitle}`);\n\n // Skip certain actions that don't need notifications\n const skipActions = ['resolved', 'ignored'];\n if (skipActions.includes(payload.action)) {\n return new Response('OK - Skipped', { status: 200 });\n }\n\n // Convert to standardized notification format\n const notificationData = convertSentryToNotificationData(payload);\n \n // Process through shared triage system (this will handle its own logging)\n await processNotification(notificationData);\n\n return new Response('OK', { status: 200 });\n\n } catch (error) {\n console.error('Error processing webhook:', error);\n return new Response('Internal Server Error', { status: 500 });\n }\n}",[],[250],{"_104":258,"_95":259,"_153":260,"_155":-5,"_156":138,"_157":226,"_159":176,"_106":261,"_100":32,"_162":163,"_164":262,"_166":22,"_167":-5,"_168":263,"_98":264},"bd6dacfe-7c42-11f0-9764-0224a6c84d84","stringify-utils.ts","bd6dadb2-7c42-11f0-9764-0224a6c84d84",["D",1755528653617],"/**\n * Utility functions for formatting and stringifying objects\n * \n * This module provides functions to convert JavaScript objects into\n * human-readable formats, particularly useful for logging webhook\n * payloads and debugging complex data structures.\n */\n\nimport { llml } from \"https://esm.sh/@zenbase/llml\";\n\n/**\n * Converts a JavaScript object into a nicely formatted XML-like string\n * using the llml library. This is particularly useful for logging\n * webhook payloads and complex nested objects in a readable format.\n * \n * @param obj - The object to stringify\n * @returns A formatted XML-like string representation of the object\n * \n * @example\n * ```typescript\n * const data = { user: { name: \"John\", age: 30 }, items: [\"a\", \"b\"] };\n * const formatted = stringifyForLogging(data);\n * console.log(formatted);\n * // Output: Nicely formatted XML-like structure\n * ```\n */\nexport function stringifyForLogging(obj: any): string {\n try {\n return llml(obj);\n } catch (error) {\n console.error('Error formatting object with llml:', error);\n // Fallback to JSON.stringify with pretty printing\n return JSON.stringify(obj, null, 2);\n }\n}\n\n/**\n * Logs an object in a formatted way with an optional label\n * \n * @param obj - The object to log\n * @param label - Optional label to prefix the log output\n * \n * @example\n * ```typescript\n * logFormatted(webhookPayload, \"Linear Webhook Received\");\n * ```\n */\nexport function logFormatted(obj: any, label?: string): void {\n const formatted = stringifyForLogging(obj);\n \n if (label) {\n console.log(`\\n=== ${label} ===`);\n }\n \n console.log(formatted);\n \n if (label) {\n console.log(`=== End ${label} ===\\n`);\n }\n}\n\n/**\n * Creates a truncated version of the formatted string for cases\n * where the full object might be too large for logging\n * \n * @param obj - The object to stringify\n * @param maxLength - Maximum length of the output string (default: 2000)\n * @returns Truncated formatted string\n */\nexport function stringifyTruncated(obj: any, maxLength: number = 2000): string {\n const formatted = stringifyForLogging(obj);\n \n if (formatted.length <= maxLength) {\n return formatted;\n }\n \n return formatted.substring(0, maxLength) + '\\n... [truncated]';\n}",[],[259],"files",[150,171,183,193,202,212,221,230,238,248,257],"counts",{"_269":32,"_270":234,"_271":32,"_272":273},"pulls","branches","forks","envVars",2,"contents",[],{"_104":194,"_95":99,"_153":195,"_155":-5,"_156":138,"_157":101,"_159":176,"_106":277,"_100":197,"_162":198,"_164":199,"_166":22,"_167":-5,"_98":278},["D",1755531551351],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":287,"_148":292,"_265":326,"_179":327,"_274":329,"_330":-5,"_331":22,"_332":-5,"_333":-5,"_334":-5,"_335":336},{"_104":105,"_95":96,"_106":288,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":289,"_132":290,"_135":291,"_147":22},["D",1755527134608],{"_93":94,"_130":131},{"_93":94,"_134":131},{"_100":137,"_95":43,"_104":138,"_139":105,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},[293,296,299,302,305,308,311,314,317,320,323],{"_104":151,"_95":152,"_153":154,"_155":-5,"_156":138,"_157":158,"_159":22,"_106":160,"_100":161,"_162":163,"_164":165,"_166":22,"_167":-5,"_168":294,"_98":295},[],[152],{"_104":172,"_95":173,"_153":174,"_155":-5,"_156":138,"_157":175,"_159":176,"_106":177,"_100":178,"_162":179,"_164":180,"_166":22,"_167":-5,"_168":297,"_98":298},[],[173],{"_104":184,"_95":185,"_153":186,"_155":-5,"_156":138,"_157":187,"_159":22,"_106":188,"_100":189,"_162":179,"_164":190,"_166":22,"_167":-5,"_168":300,"_98":301},[],[185],{"_104":194,"_95":99,"_153":195,"_155":-5,"_156":138,"_157":101,"_159":176,"_106":196,"_100":197,"_162":198,"_164":199,"_166":22,"_167":-5,"_168":303,"_98":304},[],[99],{"_104":203,"_95":204,"_153":205,"_155":-5,"_156":138,"_157":206,"_159":22,"_106":207,"_100":208,"_162":163,"_164":209,"_166":22,"_167":-5,"_168":306,"_98":307},[],[204],{"_104":213,"_95":214,"_153":215,"_155":-5,"_156":138,"_157":216,"_159":22,"_106":217,"_100":32,"_162":163,"_164":218,"_166":22,"_167":-5,"_168":309,"_98":310},[],[214],{"_104":222,"_95":223,"_153":224,"_155":-5,"_156":138,"_157":189,"_159":22,"_106":225,"_100":226,"_162":198,"_164":227,"_166":22,"_167":-5,"_168":312,"_98":313},[],[223],{"_104":231,"_95":232,"_153":233,"_155":-5,"_156":138,"_157":234,"_159":176,"_106":235,"_100":32,"_162":163,"_164":72,"_166":22,"_167":-5,"_168":315,"_98":316},[],[232],{"_104":239,"_95":240,"_153":241,"_155":-5,"_156":138,"_157":242,"_159":22,"_106":243,"_100":244,"_162":163,"_164":245,"_166":22,"_167":-5,"_168":318,"_98":319},[],[240],{"_104":249,"_95":250,"_153":251,"_155":-5,"_156":138,"_157":252,"_159":176,"_106":253,"_100":234,"_162":198,"_164":254,"_166":22,"_167":-5,"_168":321,"_98":322},[],[250],{"_104":258,"_95":259,"_153":260,"_155":-5,"_156":138,"_157":226,"_159":176,"_106":261,"_100":32,"_162":163,"_164":262,"_166":22,"_167":-5,"_168":324,"_98":325},[],[259],[293,296,299,302,305,308,311,314,317,320,323],{"_104":194,"_95":99,"_153":195,"_155":-5,"_156":138,"_157":101,"_159":176,"_106":277,"_100":197,"_162":198,"_164":199,"_166":22,"_167":-5,"_98":328},[99],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]

colel

slack-notification-triage-webhook