🤖 ${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}",[],[211],{"_102":221,"_95":222,"_151":223,"_153":-5,"_154":136,"_155":224,"_157":158,"_104":225,"_99":226,"_160":185,"_162":227,"_164":22,"_165":-5,"_166":228,"_98":229},"da4f6062-7f8d-11f0-a4d6-0224a6c84d84","ai-service.ts","acd4aaca-7c45-11f0-bb97-0224a6c84d84",109,["D",1755890767817],8,"/**\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 // Add timeout to prevent webhook timeouts\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), 25000); // 25 second timeout\n\n const response = await fetch(`${this.baseUrl}/chat/completions`, {\n method: 'POST',\n headers,\n body: JSON.stringify(params),\n signal: controller.signal,\n });\n\n clearTimeout(timeoutId);\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 with timing\n const requestDuration = Date.now() - Date.now(); // This will be overridden by timing utils, but keeping for backward compatibility\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 performance: {\n tokensPerSecond: result.usage.totalTokens / Math.max((requestDuration / 1000), 0.1),\n costPerSecond: totalCost / Math.max((requestDuration / 1000), 0.1)\n }\n }, 'OpenRouter Usage & Performance');\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();",[],[222],{"_102":231,"_95":232,"_151":233,"_153":-5,"_154":136,"_155":234,"_157":158,"_104":235,"_99":236,"_160":185,"_162":237,"_164":22,"_165":-5,"_166":238,"_98":239},"3c58e696-7c57-11f0-8fef-0224a6c84d84","citation-context.ts","d564bf04-7c43-11f0-b301-0224a6c84d84",82,["D",1755537456482],1,"/**\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: /^[\\w-]+:\\/\\//.test(id) ? id : `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}",[],[232],{"_102":241,"_95":242,"_151":243,"_153":-5,"_154":136,"_155":244,"_157":158,"_104":245,"_99":32,"_160":185,"_162":246,"_164":22,"_165":-5,"_166":247,"_98":248},"a25a103a-7f8d-11f0-86a2-0224a6c84d84","data-sanitization.ts","a25a113e-7f8d-11f0-86a2-0224a6c84d84",102,["D",1755890673936],"/**\n * Data sanitization utilities\n * \n * This module provides utilities for sanitizing notification data before\n * sending to AI, removing raw/sensitive data while preserving useful context.\n */\n\nimport { NotificationData } from './notification-triage.ts';\nimport { logFormatted } from './stringify-utils.ts';\n\n/**\n * Keys to remove from notification data before AI processing\n * These typically contain raw payload data, sensitive info, or verbose data\n */\nconst SENSITIVE_KEYS = [\n 'rawPayload',\n 'raw',\n 'payload',\n 'webhookData',\n 'originalData',\n 'fullPayload',\n 'credentials',\n 'tokens',\n 'secrets',\n 'apiKeys',\n 'passwords'\n];\n\n/**\n * Keys to remove from nested objects (recursive sanitization)\n */\nconst NESTED_SENSITIVE_KEYS = [\n 'signature',\n 'secret',\n 'token',\n 'key',\n 'credential',\n 'auth',\n 'password',\n 'private'\n];\n\n/**\n * Sanitized notification data for AI processing\n */\nexport interface SanitizedNotificationData extends Omit {\n // Explicitly exclude rawPayload and other sensitive data\n sanitizedAt: string;\n originalKeys?: string[]; // Track what keys were present before sanitization\n}\n\n/**\n * Recursively remove sensitive keys from an object\n */\nfunction sanitizeObject(obj: any, depth = 0, maxDepth = 5): any {\n if (depth > maxDepth) {\n return '[Max depth reached]';\n }\n\n if (obj === null || typeof obj !== 'object') {\n return obj;\n }\n\n if (Array.isArray(obj)) {\n return obj.map(item => sanitizeObject(item, depth + 1, maxDepth));\n }\n\n const sanitized: any = {};\n \n for (const [key, value] of Object.entries(obj)) {\n const lowerKey = key.toLowerCase();\n \n // Skip sensitive keys\n if (NESTED_SENSITIVE_KEYS.some(sensitiveKey => lowerKey.includes(sensitiveKey))) {\n continue;\n }\n\n // Recursively sanitize nested objects\n sanitized[key] = sanitizeObject(value, depth + 1, maxDepth);\n }\n\n return sanitized;\n}\n\n/**\n * Sanitize notification data for AI processing\n * Removes raw payloads, sensitive keys, and limits data size\n */\nexport function sanitizeNotificationData(notification: NotificationData): SanitizedNotificationData {\n const startTime = Date.now();\n \n // Track original keys for debugging\n const originalKeys = Object.keys(notification);\n \n // Create a copy and remove sensitive top-level keys\n const sanitized: any = {};\n \n for (const [key, value] of Object.entries(notification)) {\n const lowerKey = key.toLowerCase();\n \n // Skip sensitive keys entirely\n if (SENSITIVE_KEYS.some(sensitiveKey => lowerKey.includes(sensitiveKey))) {\n continue;\n }\n \n // For nested objects, apply recursive sanitization\n if (typeof value === 'object' && value !== null) {\n sanitized[key] = sanitizeObject(value);\n } else {\n sanitized[key] = value;\n }\n }\n\n // Add sanitization metadata\n sanitized.sanitizedAt = new Date().toISOString();\n sanitized.originalKeys = originalKeys;\n\n const sanitizationTime = Date.now() - startTime;\n\n // Log sanitization details\n logFormatted({\n source: notification.source,\n id: notification.id,\n originalKeyCount: originalKeys.length,\n sanitizedKeyCount: Object.keys(sanitized).length,\n removedKeys: originalKeys.filter(key => !(key in sanitized)),\n sanitizationTimeMs: sanitizationTime\n }, 'Data Sanitization Summary');\n\n return sanitized as SanitizedNotificationData;\n}\n\n/**\n * Create a summary of notification data for enhanced logging\n * This provides a concise view of what data is being processed\n */\nexport function createDataSummary(notification: NotificationData): {\n core: {\n source: string;\n type: string;\n action: string;\n title: string;\n };\n metadata: {\n hasPriority: boolean;\n hasSeverity: boolean;\n hasDescription: boolean;\n hasLabels: boolean;\n hasTeam: boolean;\n hasAssignee: boolean;\n hasUrl: boolean;\n };\n sizes: {\n titleLength: number;\n descriptionLength: number;\n labelCount: number;\n totalKeys: number;\n };\n timestamps: {\n hasCreatedAt: boolean;\n hasUpdatedAt: boolean;\n };\n} {\n return {\n core: {\n source: notification.source,\n type: notification.type,\n action: notification.action,\n title: notification.title\n },\n metadata: {\n hasPriority: notification.priority !== undefined,\n hasSeverity: notification.severity !== undefined,\n hasDescription: !!notification.description,\n hasLabels: !!(notification.labels && notification.labels.length > 0),\n hasTeam: !!notification.team,\n hasAssignee: !!notification.assignee,\n hasUrl: !!notification.url\n },\n sizes: {\n titleLength: notification.title.length,\n descriptionLength: notification.description?.length || 0,\n labelCount: notification.labels?.length || 0,\n totalKeys: Object.keys(notification).length\n },\n timestamps: {\n hasCreatedAt: !!notification.createdAt,\n hasUpdatedAt: !!notification.updatedAt\n }\n };\n}\n\n/**\n * Enhanced logging for notifications that includes both summary and sanitization\n */\nexport function logNotificationProcessing(notification: NotificationData): {\n sanitized: SanitizedNotificationData;\n summary: ReturnType;\n} {\n const summary = createDataSummary(notification);\n const sanitized = sanitizeNotificationData(notification);\n\n logFormatted(summary, 'Notification Data Summary');\n\n return { sanitized, summary };\n}\n",[],[242],{"_102":250,"_95":251,"_151":252,"_153":-5,"_154":136,"_155":253,"_157":158,"_104":254,"_99":32,"_160":161,"_162":255,"_164":22,"_165":-5,"_166":256,"_98":257},"b981da96-7f8c-11f0-a464-0224a6c84d84","deno.json","b981db4a-7f8c-11f0-a464-0224a6c84d84",97,["D",1755890283210],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}",[],[251],{"_102":259,"_95":260,"_151":261,"_153":-5,"_154":136,"_155":262,"_157":158,"_104":263,"_99":264,"_160":216,"_162":265,"_164":22,"_165":-5,"_166":266,"_98":267},"f752ee5a-7f8c-11f0-8cc1-0224a6c84d84","linear-webhook.ts","ca57e836-7c41-11f0-b28e-0224a6c84d84",99,["D",1755890386995],13,"/**\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, type 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 * Process notification asynchronously to avoid webhook timeouts\n */\nasync function processNotificationAsync(notificationData: NotificationData): Promise {\n try {\n // Process through shared triage system (this will handle its own logging)\n await processNotification(notificationData);\n console.log(`✅ Async processing completed for Linear notification: ${notificationData.title}`);\n } catch (error) {\n console.error(`❌ Async processing failed for Linear notification: ${notificationData.title}`, error);\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 // IMPORTANT: Process asynchronously to avoid webhook timeout\n // Don't await this - let it run in the background\n processNotificationAsync(notificationData);\n\n // Return immediately to Linear to prevent timeout\n return new Response('OK - Processing', { status: 200 });\n\n } catch (error) {\n console.error('Error processing webhook:', error);\n return new Response('Internal Server Error', { status: 500 });\n }\n}",[],[260],{"_102":269,"_95":270,"_151":271,"_153":-5,"_154":136,"_155":236,"_157":158,"_104":272,"_99":32,"_160":185,"_162":72,"_164":22,"_165":-5,"_166":273,"_98":274},"34097c3e-7c3f-11f0-bc2e-0224a6c84d84","main.tsx","34097ce8-7c3f-11f0-bc2e-0224a6c84d84",["D",1755527134622],[],[270],{"_102":276,"_95":277,"_151":278,"_153":-5,"_154":136,"_155":135,"_157":158,"_104":279,"_99":280,"_160":185,"_162":281,"_164":22,"_165":-5,"_166":282,"_98":283},"d4be5f02-7f8f-11f0-b611-0224a6c84d84","notification-triage.ts","f2082c72-7c43-11f0-b3d2-0224a6c84d84",["D",1755891617459],23,"/**\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 {\n AI_PROMPTS,\n EMAIL_CONFIG,\n NOTIFICATION_CHANNELS,\n type NotificationChannel,\n} 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\";\nimport { AITimer, globalAITracker, timeAIOperation } from \"./timing-utils.ts\";\nimport { sanitizeNotificationData, logNotificationProcessing, createDataSummary } from \"./data-sanitization.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 * Channel-specific summary for tailored notifications\n */\nexport interface ChannelSpecificSummary {\n summary: string; // Concise one-line summary tailored for this specific channel\n routingReason: string; // Why this notification was sent to this channel (for logging)\n}\n\n/**\n * Create citation context for a notification to improve AI prompting\n */\nfunction createCitationContext(\n notification: NotificationData,\n): 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(\n notification: NotificationData,\n): Promise {\n // Log and sanitize notification data first\n const { sanitized: sanitizedNotification, summary: dataSummary } = logNotificationProcessing(notification);\n \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: ${\n channel.keywords.join(\", \")\n })`\n ).join(\"\\n\");\n\n // https://linear.app/developers/webhooks#data-change-events-payload\n if (notification.action === \"update\") {\n logFormatted({\n reason: \"Skipping generic update action\",\n action: notification.action,\n source: notification.source,\n id: notification.id,\n title: notification.title\n }, \"Early Exit Decision\");\n \n return {\n selectedChannels: [],\n reasoning: \"Ignore generic updates - these typically don't require notifications as they're too frequent and low-value\",\n summary: \"Ignored generic update\",\n citationContext: citationCtx,\n formattedSummary: \"Ignored generic update\",\n urgency: \"low\",\n };\n }\n\n // Use sanitized data for AI processing (removes rawPayload and sensitive keys)\n const notificationContext = {\n source: sanitizedNotification.source,\n id: sanitizedNotification.id,\n type: sanitizedNotification.type,\n action: sanitizedNotification.action,\n title: sanitizedNotification.title,\n description: sanitizedNotification.description || \"No description provided\",\n priority: sanitizedNotification.priority || \"Not specified\",\n severity: sanitizedNotification.severity || \"Not specified\",\n labels: sanitizedNotification.labels || [],\n tags: sanitizedNotification.tags || [],\n team: sanitizedNotification.team || \"Unknown\",\n assignee: sanitizedNotification.assignee?.name || \"Unassigned\",\n project: sanitizedNotification.project || \"Unknown\",\n environment: sanitizedNotification.environment || \"Unknown\",\n hasUrl: !!sanitizedNotification.url,\n additionalUrlCount: Object.keys(sanitizedNotification.additionalUrls || {}).length,\n };\n\n // Prepare the context for LLM consumption (replace IDs with citations)\n const contextString = citationCtx.prepareForLLM(\n stringifyForLogging(notificationContext),\n );\n\n const prompt = `${\n AI_PROMPTS.channelSelection.replace(\"{channels}\", channelsInfo)\n }\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 // 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 to avoid timeouts\n if (sanitizedNotification.severity === \"low\" && !sanitizedNotification.description) {\n useCase = \"fast\";\n } // Use fast model for critical issues to ensure quick response\n else if (\n sanitizedNotification.severity === \"critical\" || sanitizedNotification.priority === 1\n ) {\n useCase = \"fast\"; // Changed from 'advanced' to 'fast' to avoid timeouts\n } // Use balanced model for complex scenarios\n else if (\n sanitizedNotification.labels?.length > 3 || sanitizedNotification.tags?.length > 3 ||\n (sanitizedNotification.description && sanitizedNotification.description.length > 500)\n ) {\n useCase = \"balanced\"; // Changed from 'reasoning' to 'balanced'\n }\n\n // Log AI triage input with model selection reasoning\n logFormatted({\n notificationSummary: dataSummary,\n selectedModel: aiService.getModelForUseCase(useCase),\n modelUseCase: useCase,\n modelSelectionReason: {\n severity: sanitizedNotification.severity || 'not specified',\n hasDescription: !!sanitizedNotification.description,\n labelCount: sanitizedNotification.labels?.length || 0,\n descriptionLength: sanitizedNotification.description?.length || 0\n },\n citationEntries: citationCtx.entries(),\n promptLength: prompt.length\n }, \"AI Triage Input & Model Selection\");\n\n // Time the AI operation with enhanced logging\n const { result: triageResult, timing } = await timeAIOperation(\n 'notification_triage',\n async () => {\n return 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: 400, // Reduced from 800 to speed up response\n temperature: 0.1,\n },\n );\n },\n aiService.getModelForUseCase(useCase)\n );\n\n // Add timing to global tracker\n globalAITracker.add(timing);\n\n // Create formatted summary with proper links\n const formattedSummary = citationCtx.linkify(\n triageResult.summary,\n \"[key](uri)\",\n );\n\n // Log detailed AI triage result with reasoning explanation\n logFormatted({\n aiDecision: {\n selectedChannels: triageResult.selectedChannels,\n urgency: triageResult.urgency,\n channelNames: NOTIFICATION_CHANNELS\n .filter(ch => triageResult.selectedChannels.includes(ch.id))\n .map(ch => ch.name)\n },\n reasoning: triageResult.reasoning,\n summary: triageResult.summary,\n suggestedActions: triageResult.suggestedActions || [],\n performance: {\n durationMs: timing.durationMs,\n modelUsed: timing.modelId,\n success: timing.success\n },\n dataProcessed: {\n source: sanitizedNotification.source,\n type: sanitizedNotification.type,\n priority: sanitizedNotification.priority,\n severity: sanitizedNotification.severity,\n hasLabels: (sanitizedNotification.labels?.length || 0) > 0,\n descriptionLength: sanitizedNotification.description?.length || 0\n }\n }, \"AI Triage Decision & Reasoning\");\n\n return {\n ...triageResult,\n citationContext: citationCtx,\n formattedSummary,\n };\n } catch (error) {\n console.error(\"Error in AI triage:\", error);\n\n // Log the AI failure with timing information\n const failureTimer = new AITimer('notification_triage_fallback');\n const fallbackTiming = failureTimer.end(false, error.message);\n globalAITracker.add(fallbackTiming);\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 using sanitized notification data\n if (\n sanitizedNotification.severity === \"critical\" || sanitizedNotification.priority === 1 ||\n sanitizedNotification.priority === \"high\"\n ) {\n fallbackChannels = [\"engineering-critical\"];\n fallbackUrgency = \"critical\";\n } else if (\n sanitizedNotification.source === \"sentry\" ||\n sanitizedNotification.environment === \"production\"\n ) {\n fallbackChannels = [\"engineering-general\", \"devops\"];\n fallbackUrgency = \"high\";\n }\n\n // Log the fallback decision with detailed reasoning\n logFormatted({\n fallbackTrigger: {\n error: error.message,\n errorType: error.constructor.name\n },\n fallbackDecision: {\n selectedChannels: fallbackChannels,\n urgency: fallbackUrgency,\n channelNames: NOTIFICATION_CHANNELS\n .filter(ch => fallbackChannels.includes(ch.id))\n .map(ch => ch.name)\n },\n fallbackReasoning: {\n severity: sanitizedNotification.severity,\n priority: sanitizedNotification.priority,\n source: sanitizedNotification.source,\n environment: sanitizedNotification.environment || 'unknown'\n },\n performance: {\n aiFailureTime: fallbackTiming.durationMs,\n totalProcessingAttempted: true\n }\n }, \"AI Triage Fallback Decision\");\n\n return {\n selectedChannels: fallbackChannels,\n reasoning:\n `AI triage failed (${error.message}). Applied fallback routing: ${sanitizedNotification.severity === \"critical\" ? \"Critical severity\" : sanitizedNotification.source === \"sentry\" ? \"Sentry source\" : \"Default routing\"} → ${fallbackChannels.join(\", \")}`,\n summary:\n `${sanitizedNotification.source} ${sanitizedNotification.action}: ${sanitizedNotification.title}`,\n urgency: fallbackUrgency,\n citationContext: citationCtx,\n formattedSummary:\n `${sanitizedNotification.source} ${sanitizedNotification.action}: ${sanitizedNotification.title}`,\n };\n }\n}\n\n/**\n * Generate a channel-specific summary tailored for the target audience\n */\nasync function generateChannelSpecificSummary(\n notification: NotificationData,\n triageResult: EnhancedTriageResult,\n channel: NotificationChannel,\n): Promise {\n try {\n // Create a concise context for the AI to work with\n const notificationContext = {\n title: notification.title,\n source: notification.source,\n type: notification.type,\n action: notification.action,\n severity: notification.severity || \"medium\",\n team: notification.team,\n assignee: notification.assignee?.name,\n // Only include description if it's reasonably short to avoid token bloat\n description: notification.description && notification.description.length <= 200 \n ? notification.description \n : notification.description?.substring(0, 200) + \"...\" || undefined,\n labels: notification.labels?.slice(0, 5), // Limit labels to prevent token bloat\n };\n\n const prompt = `You are writing a notification summary specifically for the \"${channel.name}\" team.\n\nChannel Context:\n- Name: ${channel.name}\n- Description: ${channel.description} \n- Keywords: ${channel.keywords.join(\", \")}\n\nNotification:\n${stringifyForLogging(notificationContext)}\n\nWrite an extremely concise, actionable summary tailored for ${channel.name}. This will be the ONLY content in an email, so it must be complete but brief.\n\nRespond with JSON containing:\n- summary: A single, complete sentence (15-20 words max) that tells ${channel.name} exactly what happened and what they need to know\n- routingReason: Why this notification is relevant to ${channel.name} (for logging only)\n\nExample good summaries:\n- \"Critical payment bug in production affecting checkout flow - needs immediate investigation\" \n- \"New feature request for mobile app dashboard from Product team\"\n- \"Database performance degradation detected on staging environment\"`;\n\n // Use fast model for channel-specific summaries to avoid delays\n const result = await timeAIOperation(\n 'channel_summary',\n async () => {\n return await aiService.completeJSON(\n prompt,\n `You are a notification summarizer. Create ultra-concise, one-line summaries. Always respond with valid JSON only.`,\n {\n useCase: \"fast\", // Use fast model for quick summaries\n maxTokens: 100, // Ultra-concise summaries\n temperature: 0.1,\n },\n );\n },\n aiService.getModelForUseCase(\"fast\")\n );\n\n globalAITracker.add(result.timing);\n\n // Log the channel-specific summary generation\n logFormatted({\n channel: {\n name: channel.name,\n description: channel.description.substring(0, 100) + \"...\",\n },\n summary: result.result,\n performance: {\n durationMs: result.timing.durationMs,\n modelUsed: result.timing.modelId,\n },\n }, `Channel-Specific Summary for ${channel.name}`);\n\n return result.result;\n\n } catch (error) {\n console.error(`Error generating channel-specific summary for ${channel.name}:`, error);\n \n // Fallback to generic summary if AI fails\n return {\n summary: triageResult.formattedSummary,\n routingReason: triageResult.reasoning,\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 // Handle zero channels case\n if (selectedChannels.length === 0) {\n logFormatted({\n notification: {\n source: notification.source,\n id: notification.id,\n title: notification.title,\n },\n decision: \"No channels selected - notification will not be sent\",\n reasoning: triageResult.reasoning,\n }, \"Zero Channel Decision\");\n \n console.log(`📭 No channels selected for ${notification.source} notification: ${notification.title}`);\n return;\n }\n\n logFormatted({\n notification: {\n source: notification.source,\n id: notification.id,\n title: notification.title,\n },\n selectedChannels: selectedChannels.map((c) => c.name),\n reasoning: triageResult.reasoning,\n }, \"Sending Notifications\");\n\n for (const channel of selectedChannels) {\n try {\n // Generate channel-specific summary\n const channelSpecificSummary = await generateChannelSpecificSummary(\n notification, \n triageResult, \n channel\n );\n\n const urgencyPrefix = triageResult.urgency === \"critical\"\n ? \"[CRITICAL] \"\n : triageResult.urgency === \"high\"\n ? \"[HIGH] \"\n : \"\";\n\n const subject =\n `${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 = `${channelSpecificSummary.summary}\n${formattedLinks}`;\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(\n `❌ Failed to send notification to ${channel.name}:`,\n error,\n );\n }\n }\n}\n\n/**\n * Main triage function that processes any notification data\n */\nexport async function processNotification(\n notification: NotificationData,\n): Promise {\n const processingStartTime = Date.now();\n \n try {\n logFormatted(\n notification,\n `${notification.source.toUpperCase()} Notification Data`,\n );\n\n // Triage the notification (with built-in timing and sanitization)\n const triageResult = await triageNotification(notification);\n \n // Send notifications to selected channels\n await sendNotifications(notification, triageResult);\n\n const totalProcessingTime = Date.now() - processingStartTime;\n\n // Log final processing summary with performance metrics\n logFormatted({\n notification: {\n source: notification.source,\n id: notification.id,\n title: notification.title,\n severity: notification.severity\n },\n result: {\n channelsSelected: triageResult.selectedChannels.length,\n channelNames: NOTIFICATION_CHANNELS\n .filter(ch => triageResult.selectedChannels.includes(ch.id))\n .map(ch => ch.name),\n urgency: triageResult.urgency\n },\n performance: {\n totalProcessingTimeMs: totalProcessingTime,\n aiOperationsCount: globalAITracker.getStats().totalOperations\n }\n }, \"Final Processing Summary\");\n\n // Optionally log AI performance statistics periodically\n if (globalAITracker.getStats().totalOperations % 5 === 0) {\n globalAITracker.logStats();\n }\n\n console.log(\n `✅ Successfully processed ${notification.source} notification: ${notification.title} (${totalProcessingTime}ms total)`,\n );\n } catch (error) {\n const totalProcessingTime = Date.now() - processingStartTime;\n \n logFormatted({\n error: error.message,\n errorType: error.constructor.name,\n notification: {\n source: notification.source,\n id: notification.id,\n title: notification.title\n },\n performance: {\n failureTimeMs: totalProcessingTime,\n aiOperationsAttempted: globalAITracker.getStats().totalOperations\n }\n }, \"Processing Failure Summary\");\n \n console.error(\n `❌ Error processing ${notification.source} notification (${totalProcessingTime}ms):`,\n error,\n );\n throw error;\n }\n}",[],[277],{"_102":285,"_95":286,"_151":287,"_153":-5,"_154":136,"_155":205,"_157":158,"_104":288,"_99":236,"_160":216,"_162":289,"_164":22,"_165":-5,"_166":290,"_98":291},"b21c4002-7c44-11f0-b4ef-0224a6c84d84","sentry-webhook.ts","ad82ab8a-7c44-11f0-84ff-0224a6c84d84",["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.

colel

slack-notification-triage-webhook

Branches1

Branches
1