zerobyte/app/server/modules/lifecycle/migration.ts

import { eq } from "drizzle-orm";
import { db } from "../../db/db";
import { repositoriesTable } from "../../db/schema";
import { logger } from "../../utils/logger";
import { hasMigrationCheckpoint, recordMigrationCheckpoint } from "./checkpoint";
import { toMessage } from "~/server/utils/errors";
import { safeSpawn } from "~/server/utils/spawn";
import { addCommonArgs, buildEnv, buildRepoUrl, cleanupTemporaryKeys } from "~/server/utils/restic";

const MIGRATION_VERSION = "v0.21.0";

interface MigrationResult {
	success: boolean;
	errors: Array<{ name: string; error: string }>;
}

export class MigrationError extends Error {
	version: string;
	failedItems: Array<{ name: string; error: string }>;

	constructor(version: string, failedItems: Array<{ name: string; error: string }>) {
		const itemNames = failedItems.map((e) => e.name).join(", ");
		super(`Migration ${version} failed for: ${itemNames}`);
		this.version = version;
		this.failedItems = failedItems;
		this.name = "MigrationError";
	}
}

export const retagSnapshots = async () => {
	const alreadyMigrated = await hasMigrationCheckpoint(MIGRATION_VERSION);
	if (alreadyMigrated) {
		logger.debug(`Migration ${MIGRATION_VERSION} already completed, skipping.`);
		return;
	}

	logger.info(`Starting snapshots retagging migration (${MIGRATION_VERSION})...`);

	const result = await migrateSnapshotsToShortIdTag();
	const allErrors = [...result.errors];

	if (allErrors.length > 0) {
		for (const err of allErrors) {
			logger.error(`Migration failure - ${err.name}: ${err.error}`);
		}
		throw new MigrationError(MIGRATION_VERSION, allErrors);
	}

	await recordMigrationCheckpoint(MIGRATION_VERSION);

	logger.info(`Snapshots retagging migration (${MIGRATION_VERSION}) complete.`);
};

const migrateSnapshotsToShortIdTag = async (): Promise<MigrationResult> => {
	const errors: Array<{ name: string; error: string }> = [];
	const backupSchedules = await db.query.backupSchedulesTable.findMany({});

	for (const schedule of backupSchedules) {
		const oldTag = schedule.id.toString();
		const newTag = schedule.shortId;

		const repository = await db.query.repositoriesTable.findFirst({
			where: eq(repositoriesTable.id, schedule.repositoryId),
		});

		if (!repository) {
			errors.push({ name: `schedule:${schedule.name}`, error: `Associated repository not found` });
			continue;
		}

		const repoUrl = buildRepoUrl(repository.config);
		const env = await buildEnv(repository.config);

		const args = ["--repo", repoUrl, "tag", "--tag", oldTag, "--add", newTag, "--remove", oldTag];

		addCommonArgs(args, env);

		logger.info(`Migrating snapshots for schedule '${schedule.name}' from tag '${oldTag}' to '${newTag}'`);
		const res = await safeSpawn({ command: "restic", args, env });
		await cleanupTemporaryKeys(repository.config, env);

		if (res.exitCode !== 0) {
			logger.error(`Restic tag failed: ${res.stderr}`);
			errors.push({ name: `schedule:${schedule.name}`, error: `Restic tag command failed: ${toMessage(res.stderr)}` });
			continue;
		}

		logger.info(`Migrated snapshots for schedule '${schedule.name}' from tag '${oldTag}' to '${newTag}'`);
	}

	return { success: errors.length === 0, errors };
};