Function copyMagicContextState

packages/cli/src/commands/migrate.ts:716–867

* Copy compartments + session_facts from the source OpenCode session * into a new Pi session keyed by the migrated session UUID. Boundary * IDs are remapped from OpenCode message ids to Pi entry ids (the * runtime path also stores entry.id; see read-session-pi.ts and * inject-compartments-pi.ts

(args: {
    cortexkitDb: DatabaseLike;
    sourceSessionId: string;
    piSessionId: string;
    messageIdToLastPiEntryId: Map<string, string>;
    orderedSourceMessageIds: readonly string[];
    now: number;
    dryRun: boolean;
})

 * result counts are accurate, but we don't write anything to the DB.
 */
function copyMagicContextState(args: {
    cortexkitDb: DatabaseLike;
    sourceSessionId: string;
    piSessionId: string;
    messageIdToLastPiEntryId: Map<string, string>;
    orderedSourceMessageIds: readonly string[];
    now: number;
    dryRun: boolean;
}): CopyMagicContextStatePlan {
    const sourceCompartments = stmt<CortexkitCompartmentRow>(
        args.cortexkitDb,
        `SELECT sequence, start_message, end_message, start_message_id, end_message_id,
              title, content, created_at,
              p1, p2, p3, p4, importance, episode_type, legacy
         FROM compartments
        WHERE session_id = ? AND harness = 'opencode'
     ORDER BY sequence ASC`,
    ).all(args.sourceSessionId);

    const sourceFacts = stmt<CortexkitSessionFactRow>(
        args.cortexkitDb,
        `SELECT category, content, created_at, updated_at
         FROM session_facts
        WHERE session_id = ? AND harness = 'opencode'
     ORDER BY category ASC, id ASC`,
    ).all(args.sourceSessionId);

    let boundariesApproximated = 0;
    const remappedCompartments: Array<{
        sequence: number;
        start_message: number;
        end_message: number;
        start_message_id: string;
        end_message_id: string;
        title: string;
        content: string;
        p1: string | null;
        p2: string | null;
        p3: string | null;
        p4: string | null;
        importance: number | null;
        episode_type: string | null;
        legacy: number;
    }> = [];

    for (const c of sourceCompartments) {
        const startRemap = remapBoundaryId(
            c.start_message_id,
            args.messageIdToLastPiEntryId,
            args.orderedSourceMessageIds,
        );
        const endRemap = remapBoundaryId(
            c.end_message_id,
            args.messageIdToLastPiEntryId,
            args.orderedSourceMessageIds,
        );
        // If either boundary doesn't translate (precedes our migrated
        // range entirely), skip that compartment. The remaining compartments