Function runMigrateCli

packages/cli/src/commands/migrate.ts:1079–1122

(args: string[])

}

export async function runMigrateCli(args: string[]): Promise<number> {
    try {
        const parsed = parseMigrateArgs(args);
        ensureValidOptions(parsed);
        const result = migrateOpenCodeSessionToPi({
            sessionId: parsed.session,
            maxMessages: parsed.maxMessages,
            dryRun: parsed.dryRun,
        });
        const action = result.dryRun ? "Would write" : "Wrote";
        console.log(`${action} Pi session JSONL:`);
        console.log(`  path: ${result.outputPath}`);
        console.log(`  pi session id: ${result.piSessionId}`);
        console.log(`  source messages: ${result.sourceMessageCount}`);
        console.log(`  migrated entries: ${result.messageCount}`);
        console.log(`  bytes: ${result.byteCount}`);
        console.log(`  compartments copied: ${result.compartmentsCopied}`);
        console.log(`  session facts copied: ${result.factsCopied}`);
        console.log(
            `  compaction marker: ${result.compactionMarkerWritten ? "yes" : "no"}${
                result.compactionMarkerWritten
                    ? ` (boundary: ${result.compactionBoundaryEntryId}, first kept: ${result.compactionFirstKeptEntryId})`
                    : ""
            }`,
        );
        if (result.boundariesApproximated > 0) {
            console.log(
                `  boundaries approximated: ${result.boundariesApproximated} (nearest-at-or-before)`,
            );
        }
        if (!result.dryRun) {
            console.log("Pi may need to be restarted to pick up the new session file.");
        }
        return 0;
    } catch (error) {
        if (error instanceof Error && error.message === "HELP") {
            printMigrateHelp();
            return 0;
        }
        console.error(error instanceof Error ? error.message : String(error));
        console.error("Run `doctor migrate --help` for usage.");
        return 1;
    }
}