Function migrateOpenCodeSessionToPi

packages/cli/src/commands/migrate.ts:894–1028

(
    opts: MigrateOpenCodeSessionToPiOptions,
)

}

export function migrateOpenCodeSessionToPi(
    opts: MigrateOpenCodeSessionToPiOptions,
): MigrationResult {
    const fs = opts.fs ?? defaultFs();
    const now = opts.now ?? new Date();
    const opencodeDbPath = opts.opencodeDbPath ?? defaultOpenCodeDbPath();
    const piSessionsRoot = opts.piSessionsRoot ?? defaultPiSessionsRoot();
    const ownsDb = !opts.db;
    const db = opts.db ?? new Database(opencodeDbPath, { readonly: true });

    // Cortexkit DB: when not provided explicitly, open the canonical
    // shared DB read-write (we'll INSERT into compartments + session_facts).
    // Pass null to skip the cortexkit copy entirely (legacy V1 behavior).
    let cortexkitDb: DatabaseLike | null;
    let ownsCortexkitDb = false;
    if (opts.cortexkitDb === null) {
        cortexkitDb = null;
    } else if (opts.cortexkitDb !== undefined) {
        cortexkitDb = opts.cortexkitDb;
    } else {
        try {
            cortexkitDb = new Database(defaultCortexkitDbPath());
            ownsCortexkitDb = true;
        } catch {
            // If the cortexkit DB doesn't exist yet (Magic Context never
            // loaded on this machine), skip the copy gracefully — the
            // migration still produces a usable Pi JSONL.
            cortexkitDb = null;
        }
    }

    try {
        const { session, sourceMessageCount, messages, parts } = fetchRows(
            db,
            opts.sessionId,
            opts.maxMessages,
        );
        const model = extractModel(messages);
        const provider = opts.provider ?? model.provider;
        const modelId = opts.modelId ?? model.modelId;
        const cwd = session.directory ?? session.path ?? process.cwd();
        const outputDir = join(piSessionsRoot, projectPathToPiDirSlug(cwd));
        const buildResult = buildPiEntries({
            session,
            messages,
            parts,
            now,
            provider,
            modelId,
        });
        // Copy magic-context durable state (compartments + facts) to the
        // new Pi session_id when the cortexkit DB is reachable.
        let copyResult: CopyMagicContextStateResult = {
            compartmentsCopied: 0,
            factsCopied: 0,
            boundariesApproximated: 0,
        };
        let commitMagicContextState: (() => void) | null = null;