Function createRollback

packages/server/src/services/rollbacks.ts:31–102

(
	input: z.infer<typeof createRollbackSchema>,
)

} from "./registry";

export const createRollback = async (
	input: z.infer<typeof createRollbackSchema>,
) => {
	return await db.transaction(async (tx) => {
		const { fullContext, ...other } = input;
		const rollback = await tx
			.insert(rollbacks)
			.values(other)
			.returning()
			.then((res) => res[0]);

		if (!rollback) {
			throw new Error("Failed to create rollback");
		}

		const tagImage = `${input.appName}:v${rollback.version}`;
		const deployment = await findDeploymentById(rollback.deploymentId);

		if (!deployment?.applicationId) {
			throw new Error("Deployment not found");
		}

		const {
			deployments: _,
			bitbucket,
			github,
			gitlab,
			gitea,
			...rest
		} = await findApplicationById(deployment.applicationId);

		const registry = rest.registryId
			? await findRegistryByIdWithCredentials(rest.registryId)
			: rest.registry;
		const buildRegistry = rest.buildRegistryId
			? await findRegistryByIdWithCredentials(rest.buildRegistryId)
			: rest.buildRegistry;
		const rollbackRegistry = rest.rollbackRegistryId
			? await findRegistryByIdWithCredentials(rest.rollbackRegistryId)
			: rest.rollbackRegistry;

		const fullContextWithCredentials = {
			...rest,
			registry,
			buildRegistry,
			rollbackRegistry,
		};

		await tx
			.update(rollbacks)
			.set({
				image: tagImage,
				// eslint-disable-next-line @typescript-eslint/no-explicit-any
				fullContext: fullContextWithCredentials as any,
			})
			.where(eq(rollbacks.rollbackId, rollback.rollbackId));

		// Update the deployment to reference this rollback