} from "../routing/session-key.js";

import { normalizeSessionKeyPreservingOpaquePeerIds } from "../sessions/session-key-utils.js";

import type { DB as OpenClawStateKyselyDatabase } from "../state/openclaw-state-db.generated.js";

import { runOpenClawStateWriteTransaction } from "../state/openclaw-state-db.js";

import {

detectOpenClawStateDatabaseSchemaMigrations,

repairOpenClawStateDatabaseSchema,

runOpenClawStateWriteTransaction,

} from "../state/openclaw-state-db.js";

import { expandHomePrefix } from "./home-dir.js";

import {

executeSqliteQuerySync,

sourcePath: string;

hasLegacy: boolean;

};

stateSchema: {

hasLegacy: boolean;

preview: string[];

};

taskStateSidecars: {

taskRunsPath: string;

flowRunsPath: string;

const hasPluginStateSidecar = fileExists(pluginStateSidecarPath);

const pluginInstallIndexPath = resolveLegacyInstalledPluginIndexStorePath({ stateDir });

const hasPluginInstallIndex = fileExists(pluginInstallIndexPath);

const stateSchemaMigrations = detectOpenClawStateDatabaseSchemaMigrations({

env: { ...env, OPENCLAW_STATE_DIR: stateDir },

});

const taskRunsSidecarPath = resolveLegacyTaskRunsSidecarPath(stateDir);

const flowRunsSidecarPath = resolveLegacyFlowRunsSidecarPath(stateDir);

const hasTaskStateSidecars = fileExists(taskRunsSidecarPath) || fileExists(flowRunsSidecarPath);

stateDir,

oauthDir,

});

const pluginPlans = await collectPluginDoctorStateMigrationPlans({

cfg: params.cfg,

env,

stateDir,

oauthDir,

});

const pluginPlans =

stateSchemaMigrations.length > 0

? []

: await collectPluginDoctorStateMigrationPlans({

cfg: params.cfg,

env,

stateDir,

oauthDir,

});

const preview: string[] = [];

if (hasLegacySessions) {

if (hasPluginInstallIndex) {

preview.push(`- Plugin install index: ${pluginInstallIndexPath} → shared SQLite state`);

}

if (stateSchemaMigrations.length > 0) {

preview.push("- Shared SQLite schema: agent database registry primary key → agent_id,path");

preview.push(

"- Rerun doctor after shared SQLite schema repair to detect plugin state migrations",

);

}

if (fileExists(taskRunsSidecarPath)) {

preview.push(`- Task registry sidecar: ${taskRunsSidecarPath} → shared SQLite state`);

}

sourcePath: pluginInstallIndexPath,

hasLegacy: hasPluginInstallIndex,

},

stateSchema: {

hasLegacy: stateSchemaMigrations.length > 0,

preview: stateSchemaMigrations.map((migration) => migration.path),

},

taskStateSidecars: {

taskRunsPath: taskRunsSidecarPath,

flowRunsPath: flowRunsSidecarPath,

return { changes, warnings };

}

function migrateLegacyStateSchema(detected: LegacyStateDetection): {

changes: string[];

warnings: string[];

} {

return repairOpenClawStateDatabaseSchema({

env: { ...process.env, OPENCLAW_STATE_DIR: detected.stateDir },

});

}

export async function runLegacyStateMigrations(params: {

detected: LegacyStateDetection;

config?: OpenClawConfig;

}): Promise<{ changes: string[]; warnings: string[] }> {

const now = params.now ?? (() => Date.now());

const detected = params.detected;

const stateSchema = migrateLegacyStateSchema(detected);

if (detected.stateSchema.hasLegacy && stateSchema.warnings.length > 0) {

return stateSchema;

}

const pluginStateSidecar = await migrateLegacyPluginStateSidecar({

stateDir: detected.stateDir,

});

const preSessionChannelPlans = await runLegacyMigrationPlans(

detected.channelPlans.plans.filter((plan) => plan.kind === "plugin-state-import"),

);

const pluginPlans = await runPluginDoctorStateMigrationPlans({

detected,

config: params.config ?? ({} as OpenClawConfig),

});

const pluginPlans = detected.stateSchema.hasLegacy

? { changes: [], warnings: [] }

: await runPluginDoctorStateMigrationPlans({

detected,

config: params.config ?? ({} as OpenClawConfig),

});

const sessions = await migrateLegacySessions(detected, now, {

recoverCorruptTargetStore: params.recoverCorruptTargetStore,

});

);

return {

changes: [

...stateSchema.changes,

...pluginStateSidecar.changes,

...pluginInstallIndex.changes,

...taskStateSidecars.changes,

...channelPlans.changes,

],

warnings: [

...stateSchema.warnings,

...pluginStateSidecar.warnings,

...pluginInstallIndex.warnings,

...taskStateSidecars.warnings,

homedir: params.homedir,

log: params.log,

});

const stateDir = resolveStateDir(env, params.homedir ?? os.homedir);

const stateSchema = repairOpenClawStateDatabaseSchema({

env: { ...env, OPENCLAW_STATE_DIR: stateDir },

});

// Canonicalize orphaned session keys regardless of whether legacy migration

// is needed — the orphan-key bug (#29683) affects all installs with

});

const changes = [

...stateDirResult.changes,

...stateSchema.changes,

...orphanKeys.changes,

...acpSessionMetadata.changes,

...pluginStateSidecar.changes,

];

const warnings = [

...stateDirResult.warnings,

...stateSchema.warnings,

...orphanKeys.warnings,

...acpSessionMetadata.warnings,

...pluginStateSidecar.warnings,

return {

migrated:

stateDirResult.migrated ||

stateSchema.changes.length > 0 ||

orphanKeys.changes.length > 0 ||

acpSessionMetadata.changes.length > 0 ||

pluginStateSidecar.changes.length > 0 ||

!detected.pluginPlans?.hasLegacy &&

!detected.pluginStateSidecar.hasLegacy &&

!detected.pluginInstallIndex.hasLegacy &&

!detected.stateSchema.hasLegacy &&

!detected.taskStateSidecars.hasLegacy &&

!detected.deliveryQueues.hasLegacy

) {

const changes = [

...stateDirResult.changes,

...stateSchema.changes,

...orphanKeys.changes,

...acpSessionMetadata.changes,

];

const warnings = [

...stateDirResult.warnings,

...stateSchema.warnings,

...orphanKeys.warnings,

...acpSessionMetadata.warnings,

];

logMigrationResults(changes, warnings);

return {

migrated:

stateDirResult.migrated ||

stateSchema.changes.length > 0 ||

orphanKeys.changes.length > 0 ||

acpSessionMetadata.changes.length > 0,

skipped: false,

);

const changes = [

...stateDirResult.changes,

...stateSchema.changes,

...orphanKeys.changes,

...acpSessionMetadata.changes,

...pluginStateSidecar.changes,

];

const warnings = [

...stateDirResult.warnings,

...stateSchema.warnings,

...orphanKeys.warnings,

...acpSessionMetadata.warnings,

...pluginStateSidecar.warnings,