Function completeJournaledFlip

apps/local/src/db/v1-v2-migration.ts:1442–1464

(
  journalPath: string,
  journal: MigrationJournal,
)

};

const completeJournaledFlip = async (
  journalPath: string,
  journal: MigrationJournal,
): Promise<void> => {
  // The staging base file is the monotonic recovery marker. While it exists,
  // the staged v2 DB has not been installed yet, so it is safe to keep moving
  // any remaining canonical v1 file-set members to the backup and then consume
  // staging. Once the staging base is gone, the install rename already happened
  // and `source` may hold the v2 DB; recovery must never move/delete it again.
  if (fs.existsSync(journal.staging)) {
    await checkpointSqliteFileSetIfBaseExists(journal.source);
    await writeMigrationJournal(journalPath, { ...journal, phase: "canonical-moved" });
    await moveExistingSqliteFileSet(journal.source, journal.backup);
    await pauseMigrationForTest("canonical-moved");
    await moveSqliteFileSet(journal.staging, journal.source);
    await pauseMigrationForTest("staging-consumed");
  }
  await writeMigrationJournal(journalPath, { ...journal, phase: "committed" });
  await removeSqliteFileSetWithRetry(journal.normalizedSource);
  await removeSqliteFileSetWithRetry(journal.staging);
  await cleanupSecretBackups(journal);
  removeMigrationJournal(journalPath);
};

type MigrationRecoveryResult = "missing" | "recovered" | "unreadable";