feat(repositories): rclone backends

apps/server/src/modules/repositories/repositories.controller.ts

@@ -7,6 +7,7 @@ import {
 	doctorRepositoryDto,
 	getRepositoryDto,
 	getSnapshotDetailsDto,
+	listRcloneRemotesDto,
 	listRepositoriesDto,
 	listSnapshotFilesDto,
 	listSnapshotFilesQuery,
@@ -24,6 +25,7 @@ import {
 	type RestoreSnapshotDto,
 } from "./repositories.dto";
 import { repositoriesService } from "./repositories.service";
+import { getRcloneRemoteInfo, listRcloneRemotes } from "../../utils/rclone";
 
 export const repositoriesController = new Hono()
 	.get("/", listRepositoriesDto, async (c) => {
@@ -125,4 +127,19 @@ export const repositoriesController = new Hono()
 		const result = await repositoriesService.doctorRepository(name);
 
 		return c.json<DoctorRepositoryDto>(result, 200);
+	})
+	.get("/rclone-remotes", listRcloneRemotesDto, async (c) => {
+		const remoteNames = await listRcloneRemotes();
+
+		const remotes = await Promise.all(
+			remoteNames.map(async (name) => {
+				const info = await getRcloneRemoteInfo(name);
+				return {
+					name,
+					type: info?.type ?? "unknown",
+				};
+			}),
+		);
+
+		return c.json(remotes);
 	});

apps/server/src/modules/repositories/repositories.dto.ts

@@ -305,3 +305,29 @@ export const doctorRepositoryDto = describeRoute({
 		},
 	},
 });
+
+/**
+ * List rclone available remotes
+ */
+const rcloneRemoteSchema = type({
+	name: "string",
+	type: "string",
+});
+
+const listRcloneRemotesResponse = rcloneRemoteSchema.array();
+
+export const listRcloneRemotesDto = describeRoute({
+	description: "List all configured rclone remotes on the host system",
+	tags: ["Rclone"],
+	operationId: "listRcloneRemotes",
+	responses: {
+		200: {
+			description: "List of rclone remotes",
+			content: {
+				"application/json": {
+					schema: resolver(listRcloneRemotesResponse),
+				},
+			},
+		},
+	},
+});

apps/server/src/utils/rclone.ts

@@ -0,0 +1,81 @@
+import { $ } from "bun";
+import { logger } from "./logger";
+
+/**
+ * List all configured rclone remotes
+ * @returns Array of remote names
+ */
+export async function listRcloneRemotes(): Promise<string[]> {
+	try {
+		const result = await $`rclone listremotes`.quiet();
+
+		if (result.exitCode !== 0) {
+			logger.error(`Failed to list rclone remotes: ${result.stderr}`);
+			return [];
+		}
+
+		// Parse output - each line is a remote name ending with ":"
+		const remotes = result.stdout
+			.toString()
+			.split("\n")
+			.map((line) => line.trim())
+			.filter((line) => line.endsWith(":"))
+			.map((line) => line.slice(0, -1)); // Remove trailing ":"
+
+		return remotes;
+	} catch (error) {
+		logger.error(`Error listing rclone remotes: ${error}`);
+		return [];
+	}
+}
+
+/**
+ * Get information about a specific rclone remote
+ * @param remote Remote name
+ * @returns Remote type and configuration info
+ */
+export async function getRcloneRemoteInfo(
+	remote: string,
+): Promise<{ type: string; config: Record<string, string> } | null> {
+	try {
+		const result = await $`rclone config show ${remote}`.quiet();
+
+		if (result.exitCode !== 0) {
+			logger.error(`Failed to get info for remote ${remote}: ${result.stderr}`);
+			return null;
+		}
+
+		// Parse the output to extract type and config
+		const output = result.stdout.toString();
+		const lines = output
+			.split("\n")
+			.map((l) => l.trim())
+			.filter((l) => l);
+
+		const config: Record<string, string> = {};
+		let type = "unknown";
+
+		for (const line of lines) {
+			if (line.includes("=")) {
+				const parts = line.split("=");
+				const key = parts[0];
+				if (!key) continue;
+
+				const valueParts = parts.slice(1);
+				const value = valueParts.join("=").trim();
+				const cleanKey = key.trim();
+
+				if (cleanKey === "type") {
+					type = value;
+				}
+
+				config[cleanKey] = value;
+			}
+		}
+
+		return { type, config };
+	} catch (error) {
+		logger.error(`Error getting remote info for ${remote}: ${error}`);
+		return null;
+	}
+}

apps/server/src/utils/restic.ts

@@ -78,6 +78,8 @@ const buildRepoUrl = (config: RepositoryConfig): string => {
 			return `gs:${config.bucket}:/`;
 		case "azure":
 			return `azure:${config.container}:/`;
+		case "rclone":
+			return `rclone:${config.remote}:${config.path}`;
 		default: {
 			throw new Error(`Unsupported repository backend: ${JSON.stringify(config)}`);
 		}