"updateSessionStore",

"updateSessionStoreEntry",

]);

const legacyTranscriptWriterNames = new Set([

"appendSessionTranscriptMessage",

"emitSessionTranscriptUpdate",

"rewriteTranscriptEntriesInSessionFile",

]);

export const migratedSessionAccessorFiles = new Set([

"src/agents/embedded-agent-runner/compaction-successor-transcript.ts",

"src/auto-reply/reply/session-usage.ts",

]);

export const migratedTranscriptWriterFiles = new Set([

"src/agents/command/attempt-execution.ts",

"src/agents/embedded-agent-runner/context-engine-maintenance.ts",

"src/config/sessions/transcript.ts",

"src/gateway/server-methods/chat.ts",

"src/gateway/server-methods/chat-transcript-inject.ts",

"src/sessions/user-turn-transcript.ts",

]);

function normalizeRelativePath(filePath) {

return filePath.replaceAll(path.sep, "/");

}

return null;

}

function findNamedSessionStoreViolations(content, fileName, legacyNames, legacyKind) {

function findNamedBoundaryViolations(content, fileName, legacyNames, subject) {

const sourceFile = ts.createSourceFile(fileName, content, ts.ScriptTarget.Latest, true);

const violations = [];

if (legacyNames.has(importedName)) {

violations.push({

line: toLine(sourceFile, specifier),

reason: `imports legacy session store ${legacyKind} "${importedName}"`,

reason: `imports ${subject} "${importedName}"`,

});

}

}

if (name && legacyNames.has(name)) {

violations.push({

line: toLine(sourceFile, node),

reason: `aliases legacy session store ${legacyKind} "${name}"`,

reason: `aliases ${subject} "${name}"`,

});

}

}

if (ts.isPropertyAccessExpression(node) && legacyNames.has(node.name.text)) {

violations.push({

line: toLine(sourceFile, node.name),

reason: `references legacy session store ${legacyKind} "${node.name.text}"`,

reason: `references ${subject} "${node.name.text}"`,

});

}

) {

violations.push({

line: toLine(sourceFile, node.argumentExpression),

reason: `references legacy session store ${legacyKind} "${node.argumentExpression.text}"`,

reason: `references ${subject} "${node.argumentExpression.text}"`,

});

}

) {

violations.push({

line: toLine(sourceFile, node.expression),

reason: `calls legacy session store ${legacyKind} "${calleeName}"`,

reason: `calls ${subject} "${calleeName}"`,

});

}

}

return violations;

}

function findNamedSessionStoreViolations(content, fileName, legacyNames, legacyKind) {

return findNamedBoundaryViolations(

content,

fileName,

legacyNames,

`legacy session store ${legacyKind}`,

);

}

export function findSessionAccessorBoundaryViolations(content, fileName = "source.ts") {

const legacyNames = legacyNamesForFile(fileName);

const legacyKind = legacyNames === legacyWholeStoreAccessNames ? "access" : "reader";

return findNamedSessionStoreViolations(content, fileName, legacyWriterNames, "writer");

}

export function findTranscriptWriterBoundaryViolations(content, fileName = "source.ts") {

return findNamedBoundaryViolations(

content,

fileName,

legacyTranscriptWriterNames,

"legacy transcript writer",

);

}

export async function main() {

const repoRoot = resolveRepoRoot(import.meta.url);

const readSourceRoots = resolveSourceRoots(repoRoot, [

"src/infra",

]);

const writeSourceRoots = resolveSourceRoots(repoRoot, ["src/agents", "src/auto-reply"]);

const transcriptWriterSourceRoots = resolveSourceRoots(repoRoot, [

"src/agents/command",

"src/agents/embedded-agent-runner",

"src/config/sessions",

"src/gateway/server-methods",

"src/sessions",

]);

const readViolations = await collectFileViolations({

repoRoot,

sourceRoots: readSourceRoots,

),

findViolations: findSessionAccessorWriteBoundaryViolations,

});

const violations = [...readViolations, ...writeViolations];

const transcriptWriterViolations = await collectFileViolations({

repoRoot,

sourceRoots: transcriptWriterSourceRoots,

skipFile: (filePath) =>

!migratedTranscriptWriterFiles.has(normalizeRelativePath(path.relative(repoRoot, filePath))),

findViolations: findTranscriptWriterBoundaryViolations,

});

const violations = [...readViolations, ...writeViolations, ...transcriptWriterViolations];

if (violations.length === 0) {

console.log("session accessor boundary guard passed.");

console.error(`- ${violation.path}:${violation.line}: ${violation.reason}`);

}

console.error(

"Use src/config/sessions/session-accessor.ts helpers for migrated read/write paths. Expand this ratchet only after a slice migrates more files.",

"Use src/config/sessions/session-accessor.ts helpers for migrated read/write and transcript-writer paths. Expand this ratchet only after a slice migrates more files.",

);

process.exit(1);

}