Function commit

packages/cli/src/commands/migrate.ts:813–864

()

    // (session_id, sequence) is UNIQUE on compartments — a new Pi session uuid
    // means no conflict.
    const commit = () => {
        const insertCompartment = stmt(
            args.cortexkitDb,
            `INSERT INTO compartments (
       session_id, sequence, start_message, end_message,
       start_message_id, end_message_id, title, content,
       p1, p2, p3, p4, importance, episode_type, legacy,
       created_at, harness
     ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'pi')`,
        );
        const insertFact = stmt(
            args.cortexkitDb,
            `INSERT INTO session_facts (
       session_id, category, content, created_at, updated_at, harness
     ) VALUES (?, ?, ?, ?, ?, 'pi')`,
        );
        args.cortexkitDb.exec("BEGIN IMMEDIATE");
        try {
            for (const c of remappedCompartments) {
                insertCompartment.run(
                    args.piSessionId,
                    c.sequence,
                    c.start_message,
                    c.end_message,
                    c.start_message_id,
                    c.end_message_id,
                    c.title,
                    c.content,
                    c.p1,
                    c.p2,
                    c.p3,
                    c.p4,
                    // Preserve v2 metadata so the decay renderer tiers/decays
                    // migrated history. Without these, rows land legacy=0 + NULL
                    // tiers and the renderer falls back to full `content` for every
                    // tier (no decay, prompt bloat). importance mirrors the schema
                    // default when absent.
                    typeof c.importance === "number" ? c.importance : 50,
                    c.episode_type,
                    c.legacy,
                    args.now,
                );
            }
            for (const f of sourceFacts) {
                insertFact.run(args.piSessionId, f.category, f.content, f.created_at, f.updated_at);
            }
            args.cortexkitDb.exec("COMMIT");
        } catch (error) {
            args.cortexkitDb.exec("ROLLBACK");
            throw error;
        }
    };

    return { ...result, commit };
}