Function getWebCodexThreadRecentMessages

apps/web/lib/server/queries.ts:998–1019

(
  threadId: string,
  limit = 8,
)

}

export async function getWebCodexThreadRecentMessages(
  threadId: string,
  limit = 8,
): Promise<{
  items: WebCodexThreadMessage[];
  hasMore: boolean;
}> {
  const filePath = getStoredCodexSessionFileMap().get(threadId);
  if (!filePath || !fs.existsSync(filePath)) {
    return {
      items: [],
      hasMore: false,
    };
  }

  const tail = readFileTail(filePath);
  const messages = parseCodexMessagesFromLines(tail.split('\n'));
  return {
    items: messages.slice(Math.max(0, messages.length - limit)),
    hasMore: messages.length > limit,
  };
}

function listWebAutomationsSync(): WebAutomationSummary[] {
  return getStoredAutomationJobs()