Function executeBatch

src/session/parallel_executor.js:73–141

* Execute a single batch of steps concurrently. * * Each step is a mini agent loop: * 1. Build isolated message context (system + step instruction) * 2. Call chatCompletion with that context * 3. Execute any tool calls returned * 4. Return { stepIndex, toolResults, finalContent } * *

(batch, planSteps, systemMessages, chatCompletionFn, executeToolFn, config, ctx)

 * @returns {Promise<Array<{stepIndex: number, content: string, toolResults: object[]}>>}
 */
async function executeBatch(batch, planSteps, systemMessages, chatCompletionFn, executeToolFn, config, ctx) {
  const batchPromises = batch.map(async (stepIdx) => {
    const stepText = planSteps[stepIdx] || `Step ${stepIdx + 1}`;
    const messages = buildStepMessages(systemMessages, stepText);

    const toolResults = [];
    let finalContent = '';
    let iterations = 0;
    const MAX_ITERATIONS = 20; // per-step tool call limit

    try {
      let currentMessages = [...messages];

      while (iterations < MAX_ITERATIONS) {
        iterations++;
        const response = await chatCompletionFn(config, currentMessages);
        if (!response) break;

        const choice = response?.choices?.[0]?.message;
        if (!choice) break;

        // Recover tool calls embedded in text content (qwen2.5-coder etc.).
        // Issue #36 — the agent loop in bin/smallcode.js does the same.
        try {
          const { extractFromMessage } = require('../tools/tool_call_extractor');
          const tools = (typeof ctx?.getAllTools === 'function' ? ctx.getAllTools(config) : null) || [];
          extractFromMessage(choice, tools);
        } catch {}

        finalContent = choice.content || '';

        const toolCalls = choice.tool_calls || [];
        if (toolCalls.length === 0) break; // no more tool calls → step done

        // Execute tool calls sequentially within this step
        for (const tc of toolCalls) {
          const name = tc?.function?.name;
          const argsStr = tc?.function?.arguments || '{}';
          let args = {};
          try { args = JSON.parse(argsStr); } catch {}

          const result = await executeToolFn(name, args, ctx);
          const resultText = result?.result || result?.error || JSON.stringify(result);

          toolResults.push({ toolName: name, args, result: resultText });

          // Add tool call + result to this step's message history
          currentMessages.push({
            role: 'assistant',
            content: choice.content || '',
            tool_calls: toolCalls,
          });
          currentMessages.push({
            role: 'tool',
            tool_call_id: tc.id || String(Date.now()),
            content: resultText,
          });
        }