/** * ErrorDetector service - Detects errors from parsed JSONL messages. * * This is the main orchestrator that coordinates between specialized modules: * - ToolSummaryFormatter: Formats tool information for display * - TriggerMatcher: Pattern matching utilities * - ToolResultExtractor: Extracts tool results from messages * - ErrorMessageBuilder: Builds error messages and DetectedError objects * - ErrorTriggerChecker: Checks different trigger types * - ErrorTriggerTester: Testing functionality for trigger preview * * Detection criteria: * - Uses configurable triggers from ConfigManager * - Supports tool_result triggers with requireError, toolName, and matchPattern * - Supports tool_use triggers for future expansion * - Supports token_threshold triggers for monitoring context usage */ import { type ParsedMessage } from '@main/types'; import {  buildToolResultMap,  buildToolUseMap,  type ToolResultInfo,  type ToolUseInfo,} from '../analysis/ToolResultExtractor';import { ConfigManager, type NotificationTrigger } from '../infrastructure/ConfigManager'; import { type DetectedError } from './ErrorMessageBuilder';import {  checkTokenThresholdTrigger,  checkToolResultTrigger,  checkToolUseTrigger,  matchesRepositoryScope,  preResolveRepositoryIds,} from './ErrorTriggerChecker';import { testTrigger as testTriggerImpl } from './ErrorTriggerTester'; // =============================================================================// Error Detector Class// ============================================================================= class ErrorDetector {  // ===========================================================================  // Main Detection Method  // ===========================================================================   /**   * Detects errors from an array of parsed messages using configurable triggers.   *   * @param messages - Array of ParsedMessage objects from a session   * @param sessionId - The session ID   * @param projectId - The project ID (encoded directory name)   * @param filePath - Path to the JSONL file   * @returns Array of DetectedError objects   */  async detectErrors(    messages: ParsedMessage[],    sessionId: string,    projectId: string,    filePath: string  ): Promise<DetectedError[]> {    const errors: DetectedError[] = [];     // Get enabled triggers from config    const configManager = ConfigManager.getInstance();    const triggers = configManager.getEnabledTriggers();     if (triggers.length === 0) {      return errors;    }     // Pre-resolve repository ID for this project to populate cache.    const cwdHint =      messages.find((message) => typeof message.cwd === 'string' && message.cwd.trim().length > 0)        ?.cwd ?? undefined;    await preResolveRepositoryIds([{ projectId, cwdHint }]);     // Build tool_use map for linking results to calls    const toolUseMap = buildToolUseMap(messages);    // Build tool_result map for estimating output tokens    const toolResultMap = buildToolResultMap(messages);     for (let i = 0; i < messages.length; i++) {      const message = messages[i];      const lineNumber = i + 1; // 1-based line numbers for JSONL       // Check each trigger against this message      for (const trigger of triggers) {        const triggerErrors = this.checkTrigger(          message,          trigger,          toolUseMap,          toolResultMap,          sessionId,          projectId,          filePath,          lineNumber        );         // Add all detected errors (can be multiple for token_threshold mode)        errors.push(...triggerErrors);      }    }     return errors;  }   // ===========================================================================  // Trigger Checking (Router)  // ===========================================================================   /**   * Checks if a message matches a specific trigger.   * Routes to the appropriate trigger checker based on trigger configuration.   *   * @param message - The parsed message to check   * @param trigger - The trigger configuration   * @param toolUseMap - Map of tool_use_id to tool_use content for linking results to calls   * @param toolResultMap - Map of tool_use_id to tool_result content for token estimation   * @param sessionId - Session ID   * @param projectId - Project ID   * @param filePath - File path   * @param lineNumber - Line number in JSONL   * @returns Array of DetectedError (can be multiple for token_threshold mode)   */  private checkTrigger(    message: ParsedMessage,    trigger: NotificationTrigger,    toolUseMap: Map<string, ToolUseInfo>,    toolResultMap: Map<string, ToolResultInfo>,    sessionId: string,    projectId: string,    filePath: string,    lineNumber: number  ): DetectedError[] {    // Check repository scope first - if repositoryIds is set, only trigger for matching repositories    if (!matchesRepositoryScope(projectId, trigger.repositoryIds)) {      return [];    }     // Use the mode directly (mode is now required in NotificationTrigger)    const effectiveMode = trigger.mode;     // Handle token_threshold mode - check each tool_use individually    if (effectiveMode === 'token_threshold') {      return checkTokenThresholdTrigger(        message,        trigger,        toolResultMap,        sessionId,        projectId,        filePath,        lineNumber      );    }     // Handle tool_result triggers    if (trigger.contentType === 'tool_result') {      const error = checkToolResultTrigger(        message,        trigger,        toolUseMap,        sessionId,        projectId,        filePath,        lineNumber      );      return error ? [error] : [];    }     // Handle tool_use triggers (for future expansion)    if (trigger.contentType === 'tool_use') {      const error = checkToolUseTrigger(        message,        trigger,        sessionId,        projectId,        filePath,        lineNumber      );      return error ? [error] : [];    }     return [];  }   // ===========================================================================  // Trigger Testing (Preview Feature)  // ===========================================================================   /**   * Tests a trigger configuration against historical session data.   * Returns a list of errors that would have been detected.   *   * Safety features (handled by ErrorTriggerTester):   * - Limits returned errors to 50   * - Caps totalCount at 10,000 to prevent indefinite counting   * - Stops scanning after 100 sessions   * - Aborts after 30 seconds   *   * @param trigger - The trigger configuration to test   * @param limit - Maximum number of results to return (default 50)   */  public async testTrigger(    trigger: NotificationTrigger,    limit: number = 50  ): Promise<{    totalCount: number;    errors: DetectedError[];    /** True if results were truncated due to safety limits */    truncated?: boolean;  }> {    return testTriggerImpl(trigger, limit);  }} // =============================================================================// Singleton Export// ============================================================================= export const errorDetector = new ErrorDetector();