import type { BackupSchedule } from "@dokploy/server/services/backup";import {	createDeploymentBackup,	updateDeploymentStatus,} from "@dokploy/server/services/deployment";import { findDestinationById } from "@dokploy/server/services/destination";import { findEnvironmentById } from "@dokploy/server/services/environment";import type { Libsql } from "@dokploy/server/services/libsql";import { findProjectById } from "@dokploy/server/services/project";import { sendDatabaseBackupNotifications } from "../notifications/database-backup";import { execAsync, execAsyncRemote } from "../process/execAsync";import {	getBackupCommand,	getBackupTimestamp,	getS3Credentials,	normalizeS3Path,} from "./utils"; export const runLibsqlBackup = async (	libsql: Libsql,	backup: BackupSchedule,) => {	const { name, environmentId, appName } = libsql;	const environment = await findEnvironmentById(environmentId);	const project = await findProjectById(environment.projectId); 	const deployment = await createDeploymentBackup({		backupId: backup.backupId,		title: "Initializing Backup",		description: "Initializing Backup",	});	const { prefix } = backup;	const destination = await findDestinationById(backup.destinationId);	const backupFileName = `${getBackupTimestamp()}.sql.gz`;	const bucketDestination = `${appName}/${normalizeS3Path(prefix)}${backupFileName}`;	try {		const rcloneFlags = getS3Credentials(destination);		const rcloneDestination = `:s3:${destination.bucket}/${bucketDestination}`; 		const rcloneCommand = `rclone rcat ${rcloneFlags.join(" ")} "${rcloneDestination}"`; 		const backupCommand = getBackupCommand(			backup,			rcloneCommand,			deployment.logPath,		);		if (libsql.serverId) {			await execAsyncRemote(libsql.serverId, backupCommand);		} else {			await execAsync(backupCommand, {				shell: "/bin/bash",			});		} 		await sendDatabaseBackupNotifications({			applicationName: name,			projectName: project.name,			databaseType: "libsql",			type: "success",			organizationId: project.organizationId,			databaseName: backup.database,		}); 		await updateDeploymentStatus(deployment.deploymentId, "done");	} catch (error) {		await sendDatabaseBackupNotifications({			applicationName: name,			projectName: project.name,			databaseType: "libsql",			type: "error",			// @ts-ignore			errorMessage: error?.message || "Error message not provided",			organizationId: project.organizationId,			databaseName: backup.database,		}); 		await updateDeploymentStatus(deployment.deploymentId, "error"); 		throw error;	}};