Method _executeTool

src/api/index.js:277–436

(name, args)

  }

  async _executeTool(name, args) {
    const fs = require('fs');
    const { execSync } = require('child_process');
    const cwd = this.config.cwd;

    switch (name) {
      case 'read_file': {
        const safe = safeResolvePath(args.path, cwd);
        if (!safe.ok) return { error: `read_file rejected: ${safe.reason}` };
        const filePath = safe.fullPath;
        if (!fs.existsSync(filePath)) return { error: `File not found: ${args.path}` };
        const content = fs.readFileSync(filePath, 'utf-8');
        const lines = content.split('\n');
        const start = (args.start_line || 1) - 1;
        const end = args.end_line || lines.length;
        const numbered = lines.slice(start, end).map((l, i) => `${String(start + i + 1).padStart(4)}│ ${sanitizeToolOutput(l)}`).join('\n');
        return { result: `${args.path} (${lines.length} lines):\n${numbered}` };
      }

      case 'write_file': {
        const safe = safeResolvePath(args.path, cwd);
        if (!safe.ok) return { error: `write_file rejected: ${safe.reason}` };
        const filePath = safe.fullPath;
        const dir = path.dirname(filePath);
        if (!fs.existsSync(dir)) fs.mkdirSync(dir, { recursive: true });
        const existed = fs.existsSync(filePath);
        fs.writeFileSync(filePath, args.content);
        const action = existed ? 'Updated' : 'Created';
        return { result: `${action} ${args.path} (${args.content.split('\n').length} lines)`, action, path: args.path };
      }

      case 'patch': {
        const safe = safeResolvePath(args.path, cwd);
        if (!safe.ok) return { error: `patch rejected: ${safe.reason}` };
        const filePath = safe.fullPath;
        if (!fs.existsSync(filePath)) return { error: `File not found: ${args.path}` };
        let content = fs.readFileSync(filePath, 'utf-8');
        const count = content.split(args.old_str).length - 1;
        if (count === 0) return { error: `old_str not found in ${args.path}` };
        if (count > 1) return { error: `old_str matches ${count} locations. Be more specific.` };
        content = content.replace(args.old_str, args.new_str);
        fs.writeFileSync(filePath, content);
        return { result: `Patched ${args.path}`, action: 'Edited', path: args.path };
      }

      case 'bash': {
        let command = args.command;
        if (process.platform === 'win32') {
          command = command.replace(/^ls\b/, 'dir').replace(/^cat /, 'type ');
        }
        try {
          const output = execSync(command, { encoding: 'utf-8', timeout: 30000, cwd, maxBuffer: 1024 * 1024 });
          return { result: sanitizeToolOutput(output).slice(0, 3000) || '(no output)', command };
        } catch (e) {
          const output = (e.stdout || '') + (e.stderr || '');
          return { result: sanitizeToolOutput(output).slice(0, 2000) || sanitizeToolOutput(e.message || ''), error: `Exit code ${e.status || 'unknown'}`, command };
        }
      }