@@ -23,12 +23,24 @@ const legacyWholeStoreAccessNames = new Set([
2323"saveSessionStore",
2424"updateSessionStore",
2525]);
26+const legacyWriterNames = new Set([
27+"applySessionStoreEntryPatch",
28+"saveSessionStore",
29+"updateSessionStore",
30+"updateSessionStoreEntry",
31+]);
26322733export const migratedSessionAccessorFiles = new Set([
2834"src/agents/embedded-agent-runner/compaction-successor-transcript.ts",
35+"src/agents/embedded-agent-runner/run/attempt.ts",
2936"src/agents/embedded-agent-runner/tool-result-truncation.ts",
3037"src/agents/embedded-agent-runner/transcript-rewrite.ts",
3138"src/agents/embedded-agent-runner/transcript-runtime-state.ts",
39+"src/auto-reply/reply/agent-runner-helpers.ts",
40+"src/auto-reply/reply/agent-runner.ts",
41+"src/auto-reply/reply/commands-subagents/action-info.ts",
42+"src/auto-reply/reply/followup-runner.ts",
43+"src/auto-reply/reply/queue/drain.ts",
3244"src/commands/export-trajectory.ts",
3345"src/commands/health.ts",
3446"src/commands/sandbox-explain.ts",
@@ -52,6 +64,30 @@ export const migratedBundledPluginSessionAccessorFiles = new Set([
5264"extensions/telegram/src/bot-handlers.runtime.ts",
5365]);
546667+export const migratedSessionAccessorWriteFiles = new Set([
68+"src/agents/command/attempt-execution.shared.ts",
69+"src/agents/command/session-store.ts",
70+"src/agents/embedded-agent-runner/run.ts",
71+"src/agents/embedded-agent-runner/run/attempt.ts",
72+"src/auto-reply/reply/abort-cutoff.runtime.ts",
73+"src/auto-reply/reply/agent-runner-cli-dispatch.ts",
74+"src/auto-reply/reply/agent-runner-execution.ts",
75+"src/auto-reply/reply/agent-runner-memory.ts",
76+"src/auto-reply/reply/agent-runner.ts",
77+"src/auto-reply/reply/body.ts",
78+"src/auto-reply/reply/commands-acp/lifecycle.ts",
79+"src/auto-reply/reply/commands-reset.ts",
80+"src/auto-reply/reply/directive-handling.impl.ts",
81+"src/auto-reply/reply/directive-handling.persist.ts",
82+"src/auto-reply/reply/dispatch-from-config.runtime.ts",
83+"src/auto-reply/reply/followup-runner.ts",
84+"src/auto-reply/reply/get-reply.ts",
85+"src/auto-reply/reply/model-selection.ts",
86+"src/auto-reply/reply/session-reset-model.ts",
87+"src/auto-reply/reply/session-updates.ts",
88+"src/auto-reply/reply/session-usage.ts",
89+]);
90+5591function normalizeRelativePath(filePath) {
5692return filePath.replaceAll(path.sep, "/");
5793}
@@ -91,9 +127,8 @@ function bindingName(node) {
91127return null;
92128}
9312994-export function findSessionAccessorBoundaryViolations(content, fileName = "source.ts") {
130+function findNamedSessionStoreViolations(content, fileName, legacyNames, legacyKind) {
95131const sourceFile = ts.createSourceFile(fileName, content, ts.ScriptTarget.Latest, true);
96-const legacyNames = legacyNamesForFile(fileName);
97132const violations = [];
9813399134const visit = (node) => {
@@ -105,7 +140,7 @@ export function findSessionAccessorBoundaryViolations(content, fileName = "sourc
105140if (legacyNames.has(importedName)) {
106141violations.push({
107142line: toLine(sourceFile, specifier),
108-reason: `imports legacy session store access "${importedName}"`,
143+reason: `imports legacy session store ${legacyKind} "${importedName}"`,
109144});
110145}
111146}
@@ -117,15 +152,15 @@ export function findSessionAccessorBoundaryViolations(content, fileName = "sourc
117152if (name && legacyNames.has(name)) {
118153violations.push({
119154line: toLine(sourceFile, node),
120-reason: `aliases legacy session store access "${name}"`,
155+reason: `aliases legacy session store ${legacyKind} "${name}"`,
121156});
122157}
123158}
124159125160if (ts.isPropertyAccessExpression(node) && legacyNames.has(node.name.text)) {
126161violations.push({
127162line: toLine(sourceFile, node.name),
128-reason: `references legacy session store access "${node.name.text}"`,
163+reason: `references legacy session store ${legacyKind} "${node.name.text}"`,
129164});
130165}
131166@@ -136,7 +171,7 @@ export function findSessionAccessorBoundaryViolations(content, fileName = "sourc
136171) {
137172violations.push({
138173line: toLine(sourceFile, node.argumentExpression),
139-reason: `references legacy session store access "${node.argumentExpression.text}"`,
174+reason: `references legacy session store ${legacyKind} "${node.argumentExpression.text}"`,
140175});
141176}
142177@@ -149,7 +184,7 @@ export function findSessionAccessorBoundaryViolations(content, fileName = "sourc
149184) {
150185violations.push({
151186line: toLine(sourceFile, node.expression),
152-reason: `calls legacy session store access "${calleeName}"`,
187+reason: `calls legacy session store ${legacyKind} "${calleeName}"`,
153188});
154189}
155190}
@@ -161,21 +196,33 @@ export function findSessionAccessorBoundaryViolations(content, fileName = "sourc
161196return violations;
162197}
163198199+export function findSessionAccessorBoundaryViolations(content, fileName = "source.ts") {
200+const legacyNames = legacyNamesForFile(fileName);
201+const legacyKind = legacyNames === legacyWholeStoreAccessNames ? "access" : "reader";
202+return findNamedSessionStoreViolations(content, fileName, legacyNames, legacyKind);
203+}
204+205+export function findSessionAccessorWriteBoundaryViolations(content, fileName = "source.ts") {
206+return findNamedSessionStoreViolations(content, fileName, legacyWriterNames, "writer");
207+}
208+164209export async function main() {
165210const repoRoot = resolveRepoRoot(import.meta.url);
166-const sourceRoots = resolveSourceRoots(repoRoot, [
211+const readSourceRoots = resolveSourceRoots(repoRoot, [
167212"extensions/discord/src/monitor",
168213"extensions/telegram/src",
169-"src/agents/embedded-agent-runner",
214+"src/agents",
215+"src/auto-reply",
170216"src/commands",
171217"src/config/sessions",
172218"src/cron",
173219"src/gateway",
174220"src/infra",
175221]);
176-const violations = await collectFileViolations({
222+const writeSourceRoots = resolveSourceRoots(repoRoot, ["src/agents", "src/auto-reply"]);
223+const readViolations = await collectFileViolations({
177224 repoRoot,
178- sourceRoots,
225+sourceRoots: readSourceRoots,
179226skipFile: (filePath) => {
180227const relativePath = normalizeRelativePath(path.relative(repoRoot, filePath));
181228return (
@@ -185,18 +232,28 @@ export async function main() {
185232},
186233findViolations: findSessionAccessorBoundaryViolations,
187234});
235+const writeViolations = await collectFileViolations({
236+ repoRoot,
237+sourceRoots: writeSourceRoots,
238+skipFile: (filePath) =>
239+!migratedSessionAccessorWriteFiles.has(
240+normalizeRelativePath(path.relative(repoRoot, filePath)),
241+),
242+findViolations: findSessionAccessorWriteBoundaryViolations,
243+});
244+const violations = [...readViolations, ...writeViolations];
188245189246if (violations.length === 0) {
190247console.log("session accessor boundary guard passed.");
191248return;
192249}
193250194-console.error("Found legacy session store access usage in session-accessor migrated files:");
251+console.error("Found legacy session store usage in session-accessor migrated files:");
195252for (const violation of violations) {
196253console.error(`- ${violation.path}:${violation.line}: ${violation.reason}`);
197254}
198255console.error(
199-"Use src/config/sessions/session-accessor.ts helpers for migrated paths. Expand this ratchet only after a slice migrates more files.",
256+"Use src/config/sessions/session-accessor.ts helpers for migrated read/write paths. Expand this ratchet only after a slice migrates more files.",
200257);
201258process.exit(1);
202259}
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。