Function spawnPiHistorianRun

packages/pi-plugin/src/context-handler.ts:2828–2936

(args: {
	ctx: ExtensionContext;
	sessionId: string;
	db: ContextDatabase;
	historian: PiHistorianOptions;
	provider: { readMessages: () => ReturnType<typeof readPiSessionMessages> };
	unregister: () => void;
	boundarySnapshot: ProtectedTailBoundarySnapshot;
	refreshBoundarySnapshot?: () => ProtectedTailBoundarySnapshot;
	currentContextLimit: number;
})

}

function spawnPiHistorianRun(args: {
	ctx: ExtensionContext;
	sessionId: string;
	db: ContextDatabase;
	historian: PiHistorianOptions;
	provider: { readMessages: () => ReturnType<typeof readPiSessionMessages> };
	unregister: () => void;
	boundarySnapshot: ProtectedTailBoundarySnapshot;
	refreshBoundarySnapshot?: () => ProtectedTailBoundarySnapshot;
	currentContextLimit: number;
}): void {
	const {
		ctx,
		sessionId,
		db,
		historian,
		provider,
		unregister,
		boundarySnapshot,
		refreshBoundarySnapshot,
		currentContextLimit,
	} = args;
	const holderId = crypto.randomUUID();
	const runPromise = (async () => {
		const lease = acquireCompartmentLease(db, sessionId, holderId);
		if (!lease) {
			sessionLog(
				sessionId,
				"historian skipped: compartment lease held by another process",
			);
			return;
		}
		const renewal = startPiCompartmentLeaseRenewal(db, sessionId, holderId);
		try {
			await runPiHistorian({
				db,
				sessionId,
				directory: ctx.cwd,
				provider,
				appendCompaction: resolvePiAppendCompaction(ctx),
				readBranchEntries: resolvePiReadBranchEntries(ctx),
				runner: historian.runner,
				historianModel: historian.model,
				fallbackModels: historian.fallbackModels,
				historianChunkTokens: historian.historianChunkTokens,
				boundarySnapshot,
				refreshBoundarySnapshot,
				currentContextLimit,
				historianTimeoutMs: historian.timeoutMs,
				twoPass: historian.twoPass,
				thinkingLevel: historian.thinkingLevel,
				memoryEnabled: historian.memoryEnabled,
				autoPromote: historian.autoPromote,
				userMemoriesEnabled: historian.userMemoriesEnabled,
				language: historian.language,
				compartmentLeaseHolderId: holderId,
				onPublished: () => {
					const sessionStillActive = isContextHandlerSessionActive(sessionId);