getActiveSessionMaintenanceWarning,

pruneStaleEntries,

rotateSessionFile,

shouldRunSessionEntryMaintenance,

type ResolvedSessionMaintenanceConfig,

type SessionMaintenanceWarning,

} from "./store-maintenance.js";

: { ...resolveMaintenanceConfig(), ...opts?.maintenanceOverride };

const shouldWarnOnly = maintenance.mode === "warn";

const beforeCount = Object.keys(store).length;

const forceMaintenance = opts?.maintenanceOverride !== undefined;

const shouldRunEntryMaintenance = shouldRunSessionEntryMaintenance({

entryCount: beforeCount,

maxEntries: maintenance.maxEntries,

force: forceMaintenance,

});

if (shouldWarnOnly) {

const activeSessionKey = opts?.activeSessionKey?.trim();

if (activeSessionKey) {

if (activeSessionKey && shouldRunEntryMaintenance) {

const warning = getActiveSessionMaintenanceWarning({

store,

activeSessionKey,

},

preserveKeys: preserveSessionKeys,

});

const capped = capEntryCount(store, maintenance.maxEntries, {

onCapped: ({ entry }) => {

rememberRemovedSessionFile(removedSessionFiles, entry);

},

preserveKeys: preserveSessionKeys,

});

const countAfterPrune = Object.keys(store).length;

const shouldRunCapMaintenance =

forceMaintenance ||

shouldRunSessionEntryMaintenance({

entryCount: countAfterPrune,

maxEntries: maintenance.maxEntries,

});

const capped = shouldRunCapMaintenance

? capEntryCount(store, maintenance.maxEntries, {

onCapped: ({ entry }) => {

rememberRemovedSessionFile(removedSessionFiles, entry);

},

preserveKeys: preserveSessionKeys,

})

: 0;

const archivedDirs = new Set<string>();

const referencedSessionIds = new Set(

Object.values(store)

): Promise<T> {

return await withSessionStoreLock(storePath, async () => {

// Always re-read inside the lock to avoid clobbering concurrent writers.

const store = loadSessionStore(storePath, { skipCache: true });

const store = loadSessionStore(storePath, { skipCache: true, clone: false });

const previousAcpByKey = collectAcpMetadataSnapshot(store);

const result = await mutator(store);

preserveExistingAcpMetadata({

}): Promise<SessionEntry | null> {

const { storePath, sessionKey, update } = params;

return await withSessionStoreLock(storePath, async () => {

const store = loadSessionStore(storePath, { skipCache: true });

const store = loadSessionStore(storePath, { skipCache: true, clone: false });

const resolved = resolveSessionStoreEntry({ store, sessionKey });

const existing = resolved.existing;

if (!existing) {