*/

const SESSIONS_LIST_YIELD_BATCH_SIZE = 10;

const SESSIONS_LIST_TOP_N_LIMIT = 200;

const SESSIONS_LIST_DEFAULT_LIMIT = 100;

type SessionEntryPair = [string, SessionEntry];

type SessionEntrySelection = {

entries: SessionEntryPair[];

totalCount: number;

limitApplied?: number;

};

function compareSessionEntryPairsByUpdatedAt(a: SessionEntryPair, b: SessionEntryPair): number {

return (b[1]?.updatedAt ?? 0) - (a[1]?.updatedAt ?? 0);

}

function resolveSessionsListLimit(

opts: import("./protocol/index.js").SessionsListParams,

defaultLimit?: number,

): number | undefined {

if (typeof opts.limit !== "number" || !Number.isFinite(opts.limit)) {

return undefined;

return defaultLimit;

}

return Math.max(1, Math.floor(opts.limit));

}

return limit === undefined ? sorted : sorted.slice(0, limit);

}

export function filterAndSortSessionEntries(params: {

function filterSessionEntries(params: {

store: Record<string, SessionEntry>;

opts: import("./protocol/index.js").SessionsListParams;

now: number;

rowContext?: SessionListRowContext;

}): [string, SessionEntry][] {

}): SessionEntryPair[] {

const { store, opts, now } = params;

const rowContext = params.rowContext;

const includeGlobal = opts.includeGlobal === true;

entries = entries.filter(([, entry]) => (entry?.updatedAt ?? 0) >= cutoff);

}

return sortAndLimitSessionEntries(entries, resolveSessionsListLimit(opts));

return entries;

}

function selectSessionEntries(params: {

store: Record<string, SessionEntry>;

opts: import("./protocol/index.js").SessionsListParams;

now: number;

rowContext?: SessionListRowContext;

defaultLimit?: number;

}): SessionEntrySelection {

const filtered = filterSessionEntries(params);

const limit = resolveSessionsListLimit(params.opts, params.defaultLimit);

const entries = sortAndLimitSessionEntries(filtered, limit);

return {

entries,

totalCount: filtered.length,

limitApplied: limit,

};

}

export function filterAndSortSessionEntries(params: {

store: Record<string, SessionEntry>;

opts: import("./protocol/index.js").SessionsListParams;

now: number;

rowContext?: SessionListRowContext;

}): [string, SessionEntry][] {

return selectSessionEntries(params).entries;

}

export function listSessionsFromStore(params: {

const includeLastMessage = opts.includeLastMessage === true;

const hasSpawnedByFilter = typeof opts.spawnedBy === "string" && opts.spawnedBy.length > 0;

const entries = filterAndSortSessionEntries({

const selection = selectSessionEntries({

store,

opts,

now,

rowContext: hasSpawnedByFilter ? getRowContext() : undefined,

defaultLimit: SESSIONS_LIST_DEFAULT_LIMIT,

});

const { entries, totalCount, limitApplied } = selection;

const sessions = entries.map(([key, entry], index) => {

const includeTranscriptFields = index < sessionListTranscriptFieldRows;

ts: now,

path: storePath,

count: sessions.length,

totalCount,

limitApplied,

hasMore: sessions.length < totalCount,

defaults: getSessionDefaults(cfg, params.modelCatalog),

sessions,

};

const includeLastMessage = opts.includeLastMessage === true;

const hasSpawnedByFilter = typeof opts.spawnedBy === "string" && opts.spawnedBy.length > 0;

const entries = filterAndSortSessionEntries({

const selection = selectSessionEntries({

store,

opts,

now,

rowContext: hasSpawnedByFilter ? getRowContext() : undefined,

defaultLimit: SESSIONS_LIST_DEFAULT_LIMIT,

});

const { entries, totalCount, limitApplied } = selection;

const sessions: GatewaySessionRow[] = [];

for (let i = 0; i < entries.length; i++) {

ts: now,

path: storePath,

count: sessions.length,

totalCount,

limitApplied,

hasMore: sessions.length < totalCount,

defaults: getSessionDefaults(cfg, params.modelCatalog),

sessions,

};