/**

* Helper functions for agent attempt execution, Claude CLI transcript probing,

* fallback prompts, and ACP visible-text accumulation.

*/

import fs from "node:fs/promises";

import path from "node:path";

import readline from "node:readline";

return await jsonlFileHasAssistantMessage(sessionFile);

}

/** Resolves the expected Claude CLI transcript JSONL path for a session. */

export function claudeCliSessionTranscriptPath(params: {

sessionId: string | undefined;

workspaceDir: string | undefined;

const CLAUDE_CLI_TRANSCRIPT_FLUSH_GRACE_MS = 250;

const CLAUDE_CLI_ORPHAN_PROBE_TAIL_BYTES = 1024 * 1024;

/** Checks whether Claude CLI has flushed assistant content for a session. */

export async function claudeCliSessionTranscriptHasContent(params: {

sessionId: string | undefined;

workspaceDir: string | undefined;

}

}

/** Checks whether the latest Claude CLI transcript tail has unanswered tool use. */

export async function claudeCliSessionTranscriptHasOrphanedToolUse(params: {

sessionId: string | undefined;

workspaceDir: string | undefined;

return await jsonlFileHasOrphanedTrailingToolUse(expectedPath);

}

/** Builds the retry prompt sent to fallback models after a failed attempt. */

export function resolveFallbackRetryPrompt(params: {

body: string;

isFallbackRetry: boolean;

return formatClaudeCliFallbackPrelude(seed, { charBudget: params.charBudget });

}

/** Creates an accumulator that strips ACP silent-reply prefixes while streaming. */

export function createAcpVisibleTextAccumulator() {

let pendingSilentPrefix = "";

let visibleText = "";