Function findLatestCodexSession

packages/cli/src/utils/coding-agents/codex.ts:124–169

(
	dir: string,
	startedAfter: number,
)

 * Polls every 500ms, times out after 10 seconds.
 */
export async function findLatestCodexSession(
	dir: string,
	startedAfter: number,
): Promise<{sessionId: string; filePath: string} | null> {
	// Allow a small buffer in case the file was created just before our timestamp
	const cutoff = startedAfter - 2_000;
	const deadline = Date.now() + 10_000;

	// codex records realpath in session_meta.cwd, but the caller passes the
	// user-supplied symlinked form (e.g. Railway's `/app` → `/mnt/volume/workspace`).
	// Resolve both sides so the match works regardless of which form arrives.
	let targetDir = dir;
	try { targetDir = realpathSync(dir); } catch { /* dir may not exist yet */ }

	async function scan(): Promise<{sessionId: string; filePath: string} | null> {
		for (const {filePath, sessionId} of walkCodexSessions()) {
			let stats;
			try {
				stats = statSync(filePath);
			} catch {
				continue;
			}

			// Stop scanning once files are older than our start time
			if (stats.mtimeMs < cutoff) break;

			const first = await readFirstLine(filePath);
			if (first?.type === 'session_meta') {
				const recordedCwd = (first.payload as any)?.cwd;
				if (typeof recordedCwd !== 'string') continue;
				let cwd = recordedCwd;
				try { cwd = realpathSync(recordedCwd); } catch { /* recorded path may be gone */ }
				if (cwd === targetDir || recordedCwd === dir) return {sessionId, filePath};
			}
		}
		return null;
	}

	while (Date.now() < deadline) {
		const result = await scan();
		if (result) return result;
		await new Promise((resolve) => setTimeout(resolve, 500));
	}

	return null;
}

export function codexEntriesToTurns(entries: SessionEntry[]): ConversationTurn[] {
	const turns: ConversationTurn[] = [];