});

let stdoutTail: Buffer = Buffer.alloc(0);

let stdoutParseBuffer: Buffer = Buffer.alloc(0);

let stdoutBytes = 0;

const stdoutHash = crypto.createHash("sha256");

let stdoutParseExceeded = false;

let stderrTail: Buffer = Buffer.alloc(0);

let stderrParseBuffer: Buffer = Buffer.alloc(0);

let stderrBytes = 0;

const stderrHash = crypto.createHash("sha256");

let stderrParseExceeded = false;

params.onExecutionPhase?.({

input: stdinPayload,

captureOutput: false,

onStdout: (chunk: string) => {

stdoutBytes += Buffer.byteLength(chunk);

stdoutHash.update(chunk);

stdoutTail = appendCliOutputTail(stdoutTail, chunk);

if (!stdoutParseExceeded) {

const nextStdoutParse = appendCliOutputParseBuffer(stdoutParseBuffer, chunk);

streamingParser?.push(chunk);

},

onStderr: (chunk: string) => {

stderrBytes += Buffer.byteLength(chunk);

stderrHash.update(chunk);

stderrTail = appendCliOutputTail(stderrTail, chunk);

if (!stderrParseExceeded) {

const nextStderrParse = appendCliOutputParseBuffer(stderrParseBuffer, chunk);

const stdoutDiagnostic = stdoutTail.toString("utf8").trim();

const stderr = stderrParseBuffer.toString("utf8").trim();

const stderrDiagnostic = stderrTail.toString("utf8").trim();

const processDiagnostics = {

backendId: context.backendResolved.id,

processReason: result.reason,

exitCode: result.exitCode,

exitSignal: result.exitSignal,

durationMs: result.durationMs,

stdoutBytes,

stdoutHash: stdoutHash.digest("hex").slice(0, 12),

stderrBytes,

stderrHash: stderrHash.digest("hex").slice(0, 12),

useResume,

};

if (logOutputText) {

if (stdoutDiagnostic) {

cliBackendLog.info(`cli stdout:\n${stdoutDiagnostic}`);

);

runOutput = {

...parsed,

diagnostics: {

...(parsed.diagnostics ?? {}),

process: processDiagnostics,

},

rawText,

finalPromptText: prompt,

text: applyPluginTextReplacements(