Sentry MCP

import { z } from "zod"; import { setTag } from "@sentry/core"; import { defineTool } from "../internal/tool-helpers/define"; import { apiServiceFromContext } from "../internal/tool-helpers/api"; import { parseIssueParams } from "../internal/tool-helpers/issue"; import { getStatusDisplayName, isTerminalStatus, getHumanInterventionGuidance, getOutputForAutofixStep, SEER_POLLING_INTERVAL, SEER_TIMEOUT, SEER_MAX_RETRIES, SEER_INITIAL_RETRY_DELAY, } from "../internal/tool-helpers/seer"; import { retryWithBackoff } from "../internal/fetch-utils"; import type { ServerContext } from "../types"; import { ApiError, ApiServerError } from "../api-client/index"; import { ParamOrganizationSlug, ParamRegionUrl, ParamIssueShortId, ParamIssueUrl, } from "../schema"; export default defineTool({ name: "analyze_issue_with_seer", requiredScopes: ["seer"], description: [ "Use Seer to analyze production errors and get detailed root cause analysis with specific code fixes.", "", "Use this tool when you need:", "- Detailed AI-powered root cause analysis", "- Specific code fixes and implementation guidance", "- Step-by-step troubleshooting for complex issues", "- Understanding why an error is happening in production", "", "What this tool provides:", "- Root cause analysis with code-level explanations", "- Specific file locations and line numbers where errors occur", "- Concrete code fixes you can apply", "- Step-by-step implementation guidance", "", "This tool automatically:", "1. Checks if analysis already exists (instant results)", "2. Starts new AI analysis if needed (~2-5 minutes)", "3. Returns complete fix recommendations", "", "<examples>", '### User: "What\'s causing this error? https://my-org.sentry.io/issues/PROJECT-1Z43"', "", "```", "analyze_issue_with_seer(issueUrl='https://my-org.sentry.io/issues/PROJECT-1Z43')", "```", "", '### User: "Can you help me understand why this is failing in production?"', "", "```", "analyze_issue_with_seer(organizationSlug='my-organization', issueId='ERROR-456')", "```", "</examples>", "", "<hints>", "- Use this tool when you need deeper analysis beyond basic issue details", "- If the user provides an issueUrl, extract it and use that parameter alone", "- The analysis includes actual code snippets and fixes, not just error descriptions", "- Results are cached - subsequent calls return instantly", "</hints>", ].join("\n"), inputSchema: { organizationSlug: ParamOrganizationSlug.optional(), regionUrl: ParamRegionUrl.optional(), issueId: ParamIssueShortId.optional(), issueUrl: ParamIssueUrl.optional(), instruction: z .string() .describe("Optional custom instruction for the AI analysis") .optional(), }, async handler(params, context: ServerContext) { const apiService = apiServiceFromContext(context, { regionUrl: params.regionUrl, }); const { organizationSlug: orgSlug, issueId: parsedIssueId } = parseIssueParams({ organizationSlug: params.organizationSlug, issueId: params.issueId, issueUrl: params.issueUrl, }); setTag("organization.slug", orgSlug); let output = `# Seer Analysis for Issue ${parsedIssueId}\n\n`; // Step 1: Check if analysis already exists let autofixState = await retryWithBackoff( () => apiService.getAutofixState({ organizationSlug: orgSlug, issueId: parsedIssueId!, }), { maxRetries: SEER_MAX_RETRIES, initialDelay: SEER_INITIAL_RETRY_DELAY, shouldRetry: (error) => { // Retry on server errors (5xx) or non-API errors (network issues) return ( error instanceof ApiServerError || !(error instanceof ApiError) ); }, }, ); // Step 2: Start analysis if none exists if (!autofixState.autofix) { output += `Starting new analysis...\n\n`; const startResult = await apiService.startAutofix({ organizationSlug: orgSlug, issueId: parsedIssueId, instruction: params.instruction, }); output += `Analysis started with Run ID: ${startResult.run_id}\n\n`; // Give it a moment to initialize await new Promise((resolve) => setTimeout(resolve, 1000)); // Refresh state with retry logic autofixState = await retryWithBackoff( () => apiService.getAutofixState({ organizationSlug: orgSlug, issueId: parsedIssueId!, }), { maxRetries: SEER_MAX_RETRIES, initialDelay: SEER_INITIAL_RETRY_DELAY, shouldRetry: (error) => { // Retry on server errors (5xx) or non-API errors (network issues) return ( error instanceof ApiServerError || !(error instanceof ApiError) ); }, }, ); } else { output += `Found existing analysis (Run ID: ${autofixState.autofix.run_id})\n\n`; // Check if existing analysis is already complete const existingStatus = autofixState.autofix.status; if (isTerminalStatus(existingStatus)) { // Return results immediately, no polling needed output += `## Analysis ${getStatusDisplayName(existingStatus)}\n\n`; for (const step of autofixState.autofix.steps) { output += getOutputForAutofixStep(step); output += "\n"; } if (existingStatus !== "COMPLETED") { output += `\n**Status**: ${existingStatus}\n`; output += getHumanInterventionGuidance(existingStatus); output += "\n"; } return output; } } // Step 3: Poll until complete or timeout (only for non-terminal states) const startTime = Date.now(); let lastStatus = ""; let consecutiveErrors = 0; while (Date.now() - startTime < SEER_TIMEOUT) { if (!autofixState.autofix) { output += `Error: Analysis state lost. Please try again by running:\n`; output += `\`\`\`\n`; output += params.issueUrl ? `analyze_issue_with_seer(issueUrl="${params.issueUrl}")` : `analyze_issue_with_seer(organizationSlug="${orgSlug}", issueId="${parsedIssueId}")`; output += `\n\`\`\`\n`; return output; } const status = autofixState.autofix.status; // Check if completed (terminal state) if (isTerminalStatus(status)) { output += `## Analysis ${getStatusDisplayName(status)}\n\n`; // Add all step outputs for (const step of autofixState.autofix.steps) { output += getOutputForAutofixStep(step); output += "\n"; } if (status !== "COMPLETED") { output += `\n**Status**: ${status}\n`; output += getHumanInterventionGuidance(status); } return output; } // Update status if changed if (status !== lastStatus) { const activeStep = autofixState.autofix.steps.find( (step) => step.status === "PROCESSING" || step.status === "IN_PROGRESS", ); if (activeStep) { output += `Processing: ${activeStep.title}...\n`; } lastStatus = status; } // Wait before next poll await new Promise((resolve) => setTimeout(resolve, SEER_POLLING_INTERVAL), ); // Refresh state with error handling try { autofixState = await retryWithBackoff( () => apiService.getAutofixState({ organizationSlug: orgSlug, issueId: parsedIssueId!, }), { maxRetries: SEER_MAX_RETRIES, initialDelay: SEER_INITIAL_RETRY_DELAY, shouldRetry: (error) => { // Retry on server errors (5xx) or non-API errors (network issues) return ( error instanceof ApiServerError || !(error instanceof ApiError) ); }, }, ); consecutiveErrors = 0; // Reset error counter on success } catch (error) { consecutiveErrors++; // If we've had too many consecutive errors, give up if (consecutiveErrors >= 3) { output += `\n## Error During Analysis\n\n`; output += `Unable to retrieve analysis status after multiple attempts.\n`; output += `Error: ${error instanceof Error ? error.message : String(error)}\n\n`; output += `You can check the status later by running the same command again:\n`; output += `\`\`\`\n`; output += params.issueUrl ? `analyze_issue_with_seer(issueUrl="${params.issueUrl}")` : `analyze_issue_with_seer(organizationSlug="${orgSlug}", issueId="${parsedIssueId}")`; output += `\n\`\`\`\n`; return output; } // Log the error but continue polling output += `Temporary error retrieving status (attempt ${consecutiveErrors}/3), retrying...\n`; } } // Show current progress if (autofixState.autofix) { output += `**Current Status**: ${getStatusDisplayName(autofixState.autofix.status)}\n\n`; for (const step of autofixState.autofix.steps) { output += getOutputForAutofixStep(step); output += "\n"; } } // Timeout reached output += `\n## Analysis Timed Out\n\n`; output += `The analysis is taking longer than expected (>${SEER_TIMEOUT / 1000}s).\n\n`; output += `\nYou can check the status later by running the same command again:\n`; output += `\`\`\`\n`; output += params.issueUrl ? `analyze_issue_with_seer(issueUrl="${params.issueUrl}")` : `analyze_issue_with_seer(organizationSlug="${orgSlug}", issueId="${parsedIssueId}")`; output += `\n\`\`\`\n`; return output; }, });