import type { apiRestoreBackup } from "@dokploy/server/db/schema";import type { Destination } from "@dokploy/server/services/destination";import type { Libsql } from "@dokploy/server/services/libsql";import { quote } from "shell-quote";import type { z } from "zod";import { getS3Credentials, getServiceContainerCommand } from "../backups/utils";import { execAsync, execAsyncRemote } from "../process/execAsync"; export const restoreLibsqlBackup = async ( libsql: Libsql, destination: Destination, backupInput: z.infer<typeof apiRestoreBackup>, emit: (log: string) => void,) => { try { const { appName, serverId } = libsql; const rcloneFlags = getS3Credentials(destination); const bucketPath = `:s3:${destination.bucket}`; const backupPath = `${bucketPath}/${backupInput.backupFile}`; const rcloneCommand = `rclone cat ${rcloneFlags.join(" ")} ${quote([backupPath])}`; const containerSearch = getServiceContainerCommand(appName); const restoreCommand = `docker exec -i $CONTAINER_ID sh -c "tar xzf - -C /var/lib/sqld"`; const command = `CONTAINER_ID=$(${containerSearch}) && ${rcloneCommand} | ${restoreCommand}`; emit("Starting restore..."); emit(`Restoring libsql from ${backupInput.backupFile}`); if (serverId) { await execAsyncRemote(serverId, command); } else { await execAsync(command); } emit("Restore completed successfully!"); } catch (error) { emit( `Error: ${ error instanceof Error ? error.message : "Error restoring libsql backup" }`, ); throw error; }};
import type { apiRestoreBackup } from "@dokploy/server/db/schema";
import type { Destination } from "@dokploy/server/services/destination";
import type { Libsql } from "@dokploy/server/services/libsql";
import { quote } from "shell-quote";
import type { z } from "zod";
import { getS3Credentials, getServiceContainerCommand } from "../backups/utils";
import { execAsync, execAsyncRemote } from "../process/execAsync";
export const restoreLibsqlBackup = async (
libsql: Libsql,
destination: Destination,
backupInput: z.infer<typeof apiRestoreBackup>,
emit: (log: string) => void,
) => {
try {
const { appName, serverId } = libsql;
const rcloneFlags = getS3Credentials(destination);
const bucketPath = `:s3:${destination.bucket}`;
const backupPath = `${bucketPath}/${backupInput.backupFile}`;
const rcloneCommand = `rclone cat ${rcloneFlags.join(" ")} ${quote([backupPath])}`;
const containerSearch = getServiceContainerCommand(appName);
const restoreCommand = `docker exec -i $CONTAINER_ID sh -c "tar xzf - -C /var/lib/sqld"`;
const command = `CONTAINER_ID=$(${containerSearch}) && ${rcloneCommand} | ${restoreCommand}`;
emit("Starting restore...");
emit(`Restoring libsql from ${backupInput.backupFile}`);
if (serverId) {
await execAsyncRemote(serverId, command);
} else {
await execAsync(command);
}
emit("Restore completed successfully!");
} catch (error) {
emit(
`Error: ${
error instanceof Error ? error.message : "Error restoring libsql backup"
}`,
);
throw error;
}
};