Function runAgentLoop

bin/smallcode.js:511–1882

(userMessage, config)

}

async function runAgentLoop(userMessage, config) {
  // Reset early-stop state for new turn
  earlyStop.newTurn();
  // Reset quality monitor's consecutive-correction window for the new turn.
  qualityMonitor.reset();

  // Reset per-turn idempotent-write dedup. PURE_TOOLS dedup uses a sliding
  // window across turns; this set is *per-turn* and stops `memory_remember`
  // (and friends) from being called with identical args repeatedly in a
  // single turn. See src/tools/dedup.js for the full rationale.
  try {
    const { newTurnIdempotentWriteSet } = require('../src/tools/dedup');
    newTurnIdempotentWriteSet();
  } catch {}

  // Start trace recording for this turn
  traceRecorder.start(userMessage, config.model.name);

  // Mark new turn in token monitor (next recordCall will start a new turn entry)
  tokenMonitor._nextCallIsNewTurn = true;

  // Feature 3: rate limiting — assert within budget before starting turn
  try {
    if (assertWithinBudget) assertWithinBudget('run_turn', {});
  } catch (e) {
    const msg = e.message || String(e);
    if (_fullscreenRef) _fullscreenRef.addTool('policy', 'err', msg);
    else console.log(`  \x1b[33m⚠ ${msg}\x1b[0m`);
    // Still proceed — rate limiting is advisory for local use
  }

  // Clarification loop — detect vague prompts before wasting tool calls.
  // MarrowScript Feature #1: uses compiled intent_clarifier (LLM-based, cached 30m)
  // with automatic fallback to regex when the model is unavailable.
  // Only fires on short messages (< 80 chars) — long messages are almost never vague
  // and we don't want to add 2s latency to every detailed task description.
  const { getClarificationInstruction } = require('../src/session/clarify');
  let _needsClarification = false;
  // Skip clarifier when the message is clearly actionable even if short:
  // - Looks like a file path (quoted, contains slash/backslash, has extension)
  // - Pure number or "option N" / "work on N" — context-reference to prior options
  // - Affirmation in continuation context (yes/ok/sure/proceed)
  // - ROOT CAUSE FIX: assistant's last turn ended with a question — user reply is an answer,
  //   not a new task. Evaluate messages in context, not in isolation.
  const lastAssistantMsg = [...conversationHistory].reverse().find(m => m.role === 'assistant');
  const assistantAskedQuestion = typeof lastAssistantMsg?.content === 'string' && lastAssistantMsg.content.trimEnd().endsWith('?');
  const looksLikePath = /[\\\/]|\.\w{1,5}\s*$|^["'].*["']$/.test(userMessage.trim());
  const looksLikeOptionRef = /^(option\s+\d|work\s+on\s+\d|do\s+\d|start\s+with\s+\d|^\d+\.?\s*$|first|second|third|fourth)\b/i.test(userMessage.trim());
  // Multi-number selection (e.g. "1 and 2", "1, 2", "both 1 and 2")
  const looksLikeMultiSelect = /^(both\s+)?\d+(\s*,\s*|\s+and\s+)\d+$/i.test(userMessage.trim());
  const looksLikeAffirmation = (
    /^(yes|y|yep|yeah|sure|ok|okay|go|proceed|do it|continue|please|alright|👍|✅)\b\s*\.?\s*$/i.test(userMessage.trim()) ||
    // Multi-word continuations: "go ahead", "go ahead and read it", "read it", "do that", "that one"
    /^(go ahead|go for it|just do it|do that|do both|read it|show me|that one|sounds good|let's do it|let's go|that works)\b/i.test(userMessage.trim())
  );
  if (userMessage.length < 80 && !assistantAskedQuestion && !looksLikePath && !looksLikeOptionRef && !looksLikeMultiSelect && !looksLikeAffirmation) {
    try {
      const { checkNeedsClarification } = require('./features_adapter');