import { jsonUtf8Bytes } from "../infra/json-utf8-bytes.js";

import { hasInterSessionUserProvenance } from "../sessions/input-provenance.js";

import { extractAssistantVisibleText } from "../shared/chat-message-content.js";

import {

resolveIntegerOption,

resolveNonNegativeIntegerOption,

} from "../shared/number-coercion.js";

import { escapeRegExp } from "../shared/regexp.js";

import { normalizeLowercaseStringOrEmpty } from "../shared/string-coerce.js";

import { estimateStringChars, estimateTokensFromChars } from "../utils/cjk-chars.js";

record: Record<string, unknown>;

};

function normalizeRecentSessionReadOptions(opts?: Partial<ReadRecentSessionMessagesOptions>) {

const maxMessages = resolveNonNegativeIntegerOption(opts?.maxMessages, 0);

const maxBytes = resolveIntegerOption(opts?.maxBytes, RECENT_SESSION_MESSAGES_DEFAULT_MAX_BYTES, {

min: 1024,

});

const maxLines = resolveIntegerOption(opts?.maxLines, maxMessages * 20 + 20, {

min: maxMessages,

});

return { maxMessages, maxBytes, maxLines };

}

export function readRecentSessionMessages(

sessionId: string,

storePath: string | undefined,

sessionFile?: string,

opts?: ReadRecentSessionMessagesOptions,

): unknown[] {

const maxMessages = Math.max(0, Math.floor(opts?.maxMessages ?? 0));

const { maxMessages, maxBytes, maxLines } = normalizeRecentSessionReadOptions(opts);

if (maxMessages === 0) {

return [];

}

return [];

}

const maxBytes = Math.max(

1024,

Math.floor(opts?.maxBytes ?? RECENT_SESSION_MESSAGES_DEFAULT_MAX_BYTES),

);

const readLen = Math.min(stat.size, maxBytes);

const readStart = Math.max(0, stat.size - readLen);

const maxLines = Math.max(maxMessages, Math.floor(opts?.maxLines ?? maxMessages * 20 + 20));

return (

withOpenTranscriptFd(filePath, (fd) => {

stat: fs.Stats,

opts: ReadRecentSessionMessagesOptions,

): Promise<string[]> {

const maxMessages = Math.max(0, Math.floor(opts.maxMessages));

const maxBytes = Math.max(

1024,

Math.floor(opts.maxBytes ?? RECENT_SESSION_MESSAGES_DEFAULT_MAX_BYTES),

);

const { maxMessages, maxBytes, maxLines } = normalizeRecentSessionReadOptions(opts);

const readLen = Math.min(stat.size, maxBytes);

const readStart = Math.max(0, stat.size - readLen);

const maxLines = Math.max(maxMessages, Math.floor(opts.maxLines ?? maxMessages * 20 + 20));

const handle = await fs.promises.open(filePath, "r");

try {

const buffer = Buffer.alloc(readLen);

sessionFile?: string,

opts?: ReadRecentSessionMessagesOptions,

): Promise<unknown[]> {

const maxMessages = Math.max(0, Math.floor(opts?.maxMessages ?? 0));

const normalized = normalizeRecentSessionReadOptions(opts);

const { maxMessages } = normalized;

if (maxMessages === 0) {

return [];

}

return [];

}

const lines = await readRecentTranscriptTailLinesAsync(filePath, stat, {

...opts,

maxMessages,

...normalized,

});

return parseRecentTranscriptTailMessages(lines, maxMessages);

}