fix: tolerate bookkeeping during compaction and release 1.0.9

Author: ponythewhite

package-lock.json

@@ -49,10 +49,10 @@
 	"engines": {
 		"node": "^22.12.0 || >=23.3.0"
 	},
-	"version": "1.0.8",
+	"version": "1.0.9",
 	"dependencies": {
 		"get-east-asian-width": "^1.6.0",
-		"@ponythewhite/base-context": "1.0.8"
+		"@ponythewhite/base-context": "1.0.9"
 	},
 	"overrides": {
 		"rimraf": "6.1.2",

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@ponythewhite/base-context-agent",
-	"version": "1.0.8",
+	"version": "1.0.9",
 	"description": "Synerise base-context agent runtime with context management and native recovery",
 	"type": "module",
 	"main": "./dist/index.js",
@@ -19,7 +19,7 @@
 		"prepublishOnly": "npm --prefix ../.. run build:source"
 	},
 	"dependencies": {
-		"@ponythewhite/base-context-ai": "1.0.8",
+		"@ponythewhite/base-context-ai": "1.0.9",
 		"typebox": "^1.3.9"
 	},
 	"keywords": [

packages/agent/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@ponythewhite/base-context-ai",
-	"version": "1.0.8",
+	"version": "1.0.9",
 	"description": "Synerise base-context unified LLM API and provider configuration",
 	"type": "module",
 	"main": "./dist/index.js",

packages/ai/package.json

@@ -1,5 +1,10 @@
 # Changelog
 
+## [1.0.9] - 2026-09-19
+
+- Fixed compaction and context checkpoint adoption rejecting concurrent child usage and session bookkeeping updates as branch changes. Real conversation, source, and branch changes still invalidate stale summaries.
+- Fixed repeated automatic summary attempts on unchanged context after a failed threshold compaction. Manual retries and new input remain available.
+
 ## [1.0.8] - 2026-09-18
 
 - Fixed harness-state saves to replace files atomically, preserve failed mutations, and report corrupt state without overwriting it.

packages/coding-agent/CHANGELOG.md

@@ -1,6 +1,6 @@
 {
 	"name": "@ponythewhite/base-context",
-	"version": "1.0.8",
+	"version": "1.0.9",
 	"description": "Synerise base-context: a coding and research agent with durable context and a persistent Python REPL",
 	"type": "module",
 	"bin": {
@@ -42,9 +42,9 @@
 	},
 	"dependencies": {
 		"@agentclientprotocol/sdk": "^1.3.0",
-		"@ponythewhite/base-context-agent": "1.0.8",
-		"@ponythewhite/base-context-ai": "1.0.8",
-		"@ponythewhite/base-context-tui": "1.0.8",
+		"@ponythewhite/base-context-agent": "1.0.9",
+		"@ponythewhite/base-context-ai": "1.0.9",
+		"@ponythewhite/base-context-tui": "1.0.9",
 		"@silvia-odwyer/photon-node": "^0.3.4",
 		"chalk": "^5.5.0",
 		"cli-highlight": "^2.1.11",

packages/coding-agent/package.json

@@ -1244,6 +1244,12 @@ export class AgentSession {
 		tools: Agent["state"]["tools"];
 		settings: string;
 	};
+	private _failedThresholdCompaction?: {
+		isCurrent: BoundCompactionSink["isCurrent"];
+		configuration: string;
+		systemPrompt: string;
+		tools: Agent["state"]["tools"];
+	};
 	private readonly _contextEpochsEnabled: boolean;
 	private readonly _initialContextMode: ContextMode;
 	private _contextMode: ContextMode;
@@ -1748,7 +1754,7 @@ export class AgentSession {
 							acknowledged = { entryId, result };
 							try {
 								assertResourceCurrent(resource);
-								if (this.sessionManager !== epochManager || epochManager.getLeafId() !== entryId)
+								if (this.sessionManager !== epochManager || !compaction.isCurrent())
 									throw new Error("Context epoch source changed before adoption");
 								this.agent.state.messages = prepared.messages;
 								committed = prepared.checkpoint;
@@ -1864,7 +1870,7 @@ export class AgentSession {
 											committedEntry = { sessionId: epochContext.source.sessionId, entryId };
 											requestContract = nextContract;
 											assertResourceCurrent(resource);
-											if (this.sessionManager !== epochManager || epochManager.getLeafId() !== entryId)
+											if (this.sessionManager !== epochManager || !compaction.isCurrent())
 												throw new Error("Context contract source changed before acceptance");
 										}
 										if (!sameSelectedSkills(committed?.selectedSkills, epochContext.selectedSkills))
@@ -1881,6 +1887,7 @@ export class AgentSession {
 									}
 								}
 							: undefined,
+						compaction.isCurrent,
 					);
 				}
 				this._compactionSetupFailure = undefined;
@@ -1909,7 +1916,7 @@ export class AgentSession {
 				!error.source.persistent ||
 				error.source.sessionId !== owner.sessionId ||
 				error.source.sessionFile !== owner.sessionFile ||
-				error.source.leafId !== owner.manager.getLeafId()
+				!(error.isSourceCurrent?.() ?? error.source.leafId === owner.manager.getLeafId())
 			)
 				return false;
 			// Rebase this captured frame before paying for a summary. The replacement still
@@ -2258,7 +2265,7 @@ export class AgentSession {
 				};
 				// ACK is authoritative even if later setup or release fails.
 				this._contextMode = mode;
-				if (this.sessionManager !== manager || manager.getLeafId() !== entryId)
+				if (this.sessionManager !== manager || !compaction.isCurrent())
 					throw new Error("Context mode source changed before adoption");
 				assertResourceCurrent(resource);
 				this.agent.state.messages = prepared.messages;
@@ -4149,6 +4156,28 @@ export class AgentSession {
 		});
 	}
 
+	private _thresholdCompactionConfiguration(): string {
+		return JSON.stringify({
+			model: this.model,
+			thinkingLevel: this.thinkingLevel,
+			settings: this.settingsManager.getCompactionSettings(),
+		});
+	}
+
+	private _hasFailedThresholdCompaction(): boolean {
+		const failed = this._failedThresholdCompaction;
+		if (!failed) return false;
+		if (
+			failed.isCurrent() &&
+			failed.configuration === this._thresholdCompactionConfiguration() &&
+			failed.systemPrompt === this.agent.state.systemPrompt &&
+			failed.tools === this.agent.state.tools
+		)
+			return true;
+		this._failedThresholdCompaction = undefined;
+		return false;
+	}
+
 	private async _thresholdCompactionNeeded(
 		context: ShouldStopAfterTurnContext,
 		owner = this._captureCompactionOwner(),
@@ -4167,6 +4196,7 @@ export class AgentSession {
 		if (compactionTimestamp !== undefined && context.message.timestamp <= compactionTimestamp) return false;
 		const contextTokens = this._getThresholdContextTokens(context.message, compactionTimestamp);
 		if (contextTokens === undefined || !shouldCompact(contextTokens, contextWindow, settings)) return false;
+		if (this._hasFailedThresholdCompaction()) return false;
 		// Keep the existing threshold-specific goal winner; do not import W74's natural wait policy here.
 		if (!this._isGoalContinuationOwnerCurrent(goalOwner)) return true;
 		if (!(await this._queueGoalContinuationForThresholdCompaction(context.message, goalOwner))) {
@@ -5546,6 +5576,7 @@ export class AgentSession {
 	 */
 	async disposeAsync(options?: { kernelSnapshot?: boolean }): Promise<void> {
 		this._failedAutomaticCompaction = undefined;
+		this._failedThresholdCompaction = undefined;
 		this._contextCompiler.clear();
 		this._nativeRecoveryCursors.clear();
 		for (const admission of this._rlmChildAdmissions) admission.cancel("Parent session disposed");
@@ -5751,6 +5782,7 @@ export class AgentSession {
 
 	dispose(): void {
 		this._failedAutomaticCompaction = undefined;
+		this._failedThresholdCompaction = undefined;
 		this._contextCompiler.clear();
 		this._nativeRecoveryCursors.clear();
 		if (this._disposed) {
@@ -11015,6 +11047,7 @@ export class AgentSession {
 		const contextTokens = this._getThresholdContextTokens(assistantMessage, compactionTimestamp);
 		if (contextTokens === undefined) return false;
 		if (shouldCompact(contextTokens, contextWindow, settings)) {
+			if (this._hasFailedThresholdCompaction()) return false;
 			if (!this._pendingCheckpoint && queueAutonomousContinuation) {
 				if (
 					!(await this._queueGoalContinuationForThresholdCompaction(assistantMessage, goalOwner)) &&
@@ -11146,6 +11179,24 @@ export class AgentSession {
 		let compaction: BoundCompactionSink | undefined;
 		let committed: CompactionCommit | undefined;
 		let failure: unknown;
+		const thresholdConfiguration =
+			reason === "threshold" && !resumeInPlace
+				? {
+						configuration: this._thresholdCompactionConfiguration(),
+						systemPrompt: this.agent.state.systemPrompt,
+						tools: this.agent.state.tools,
+					}
+				: undefined;
+		const rememberThresholdFailure = () => {
+			if (
+				thresholdConfiguration &&
+				!abort.signal.aborted &&
+				this._isCompactionOwnerCurrent(owner) &&
+				compaction?.isCurrent()
+			) {
+				this._failedThresholdCompaction = { ...thresholdConfiguration, isCurrent: compaction.isCurrent };
+			}
+		};
 		try {
 			const selected = this._resolveCompactionModel();
 			const model = selected?.model;
@@ -11170,6 +11221,7 @@ export class AgentSession {
 					reason === "threshold" && shouldContinueAfterCompaction,
 					queuedAutonomousContinuationsForThisCompaction,
 				);
+				rememberThresholdFailure();
 				resumeAfterFailure();
 				return false;
 			}
@@ -11262,6 +11314,7 @@ export class AgentSession {
 					{ customInstructions, owner },
 				);
 			}
+			rememberThresholdFailure();
 			resumeAfterFailure();
 			return false;
 		} finally {

packages/coding-agent/src/core/agent-session.ts

@@ -397,11 +397,12 @@ export class InferenceCoordinator {
 		commit: RequestViewCommit,
 		validate?: RequestViewValidate,
 		fixedPrepare?: RequestViewFixedPrepare,
+		isSourceCurrent?: () => boolean,
 	): void {
 		this.assertAdmission();
 		if (!this.capturedSink) throw new Error("Request view boundary requires a captured inference owner");
 		if (this.requestViewBoundary) throw new Error("Request view boundary is already bound");
-		this.requestViewBoundary = captureRequestViewBoundary(messages, commit, validate, fixedPrepare);
+		this.requestViewBoundary = captureRequestViewBoundary(messages, commit, validate, fixedPrepare, isSourceCurrent);
 	}
 
 	/** Read through an explicit capture, never by recapturing the mutable current session. */

packages/coding-agent/src/core/inference-coordinator.ts

@@ -43,6 +43,7 @@ export class PublicContextBudgetError extends RequestTokenBudgetError {
 		readonly taskFrameRebaseAvailable = false,
 		compactionKey?: string,
 		summaryCapacity?: (retained: ReadonlySet<string>, wrapper: string) => number | undefined,
+		readonly isSourceCurrent?: () => boolean,
 	) {
 		super(assessment);
 		this.name = "PublicContextBudgetError";
@@ -93,13 +94,15 @@ export interface CapturedRequestViewBoundary extends CanonicalViewSelectionSourc
 	readonly commit: RequestViewCommit;
 	readonly validate?: RequestViewValidate;
 	readonly fixedPrepare?: RequestViewFixedPrepare;
+	readonly isSourceCurrent?: () => boolean;
 }
 
 export function captureRequestViewBoundary(
 	messages: readonly AgentMessage[],
 	commit: RequestViewCommit,
 	validate?: RequestViewValidate,
 	fixedPrepare?: RequestViewFixedPrepare,
+	isSourceCurrent?: () => boolean,
 ): CapturedRequestViewBoundary {
 	const source = getCanonicalViewSelectionSource(messages);
 	if (!source) throw new Error("Request view boundary requires compiled canonical messages");
@@ -118,6 +121,7 @@ export function captureRequestViewBoundary(
 		commit,
 		validate,
 		fixedPrepare,
+		isSourceCurrent,
 	};
 }
 
@@ -255,7 +259,16 @@ function publicBudgetFailure(
 	const body = JSON.parse(request.body!) as Record<string, unknown>;
 	const input = body[inputKey];
 	if (!Array.isArray(input) || input.length !== projection.messageIndices.length)
-		return new PublicContextBudgetError(boundary.source, assessment, original);
+		return new PublicContextBudgetError(
+			boundary.source,
+			assessment,
+			original,
+			undefined,
+			false,
+			undefined,
+			undefined,
+			boundary.isSourceCurrent,
+		);
 	const graph = prepareViewSelection(source.units, boundary.limits);
 	const retainedInput = (retained: ReadonlySet<string>) => {
 		const roots = source.units
@@ -302,6 +315,7 @@ function publicBudgetFailure(
 				? undefined
 				: Math.floor(measured.availableInputTokens - measured.estimatedInputTokens);
 		},
+		boundary.isSourceCurrent,
 	);
 }