refactor(dokploy): add flag to prevent run commands when is cloud

apps/dokploy/server/api/routers/destination.ts

@@ -12,9 +12,10 @@ import {
 	destinations,
 } from "@/server/db/schema";
 import {
+	IS_CLOUD,
 	createDestintation,
 	execAsync,
-	findAdmin,
+	execAsyncRemote,
 	findDestinationById,
 	removeDestinationById,
 	updateDestinationById,
@@ -53,11 +54,26 @@ export const destinationRouter = createTRPCRouter({
 				];
 				const rcloneDestination = `:s3:${bucket}`;
 				const rcloneCommand = `rclone ls ${rcloneFlags.join(" ")} "${rcloneDestination}"`;
-				await execAsync(rcloneCommand);
+
+				if (IS_CLOUD && !input.serverId) {
+					throw new TRPCError({
+						code: "NOT_FOUND",
+						message: "Server not found",
+					});
+				}
+
+				if (IS_CLOUD) {
+					await execAsyncRemote(input.serverId || "", rcloneCommand);
+				} else {
+					await execAsync(rcloneCommand);
+				}
 			} catch (error) {
 				throw new TRPCError({
 					code: "BAD_REQUEST",
-					message: "Error to connect to bucket",
+					message:
+						error instanceof Error
+							? error?.message
+							: "Error to connect to bucket",
 					cause: error,
 				});
 			}

apps/dokploy/server/api/routers/registry.ts

@@ -1,6 +1,5 @@
 import {
 	apiCreateRegistry,
-	apiEnableSelfHostedRegistry,
 	apiFindOneRegistry,
 	apiRemoveRegistry,
 	apiTestRegistry,
@@ -13,8 +12,6 @@ import {
 	execAsyncRemote,
 	findAllRegistryByAdminId,
 	findRegistryById,
-	initializeRegistry,
-	manageRegistry,
 	removeRegistry,
 	updateRegistry,
 } from "@dokploy/server";
@@ -84,6 +81,13 @@ export const registryRouter = createTRPCRouter({
 			try {
 				const loginCommand = `echo ${input.password} | docker login ${input.registryUrl} --username ${input.username} --password-stdin`;
 
+				if (IS_CLOUD && !input.serverId) {
+					throw new TRPCError({
+						code: "NOT_FOUND",
+						message: "Select a server to test the registry",
+					});
+				}
+
 				if (input.serverId && input.serverId !== "none") {
 					await execAsyncRemote(input.serverId, loginCommand);
 				} else {
@@ -96,34 +100,4 @@ export const registryRouter = createTRPCRouter({
 				return false;
 			}
 		}),
-
-	enableSelfHostedRegistry: adminProcedure
-		.input(apiEnableSelfHostedRegistry)
-		.mutation(async ({ input, ctx }) => {
-			if (IS_CLOUD) {
-				throw new TRPCError({
-					code: "UNAUTHORIZED",
-					message: "Self Hosted Registry is not available in the cloud version",
-				});
-			}
-			const selfHostedRegistry = await createRegistry(
-				{
-					...input,
-					registryName: "Self Hosted Registry",
-					registryType: "selfHosted",
-					registryUrl:
-						process.env.NODE_ENV === "production"
-							? input.registryUrl
-							: "dokploy-registry.docker.localhost",
-					imagePrefix: null,
-					serverId: undefined,
-				},
-				ctx.user.adminId,
-			);
-
-			await manageRegistry(selfHostedRegistry);
-			await initializeRegistry(input.username, input.password);
-
-			return selfHostedRegistry;
-		}),
 });

apps/dokploy/server/api/routers/settings.ts

@@ -510,7 +510,7 @@ export const settingsRouter = createTRPCRouter({
 			if (input?.serverId) {
 				const result = await execAsyncRemote(input.serverId, command);
 				stdout = result.stdout;
-			} else {
+			} else if (!IS_CLOUD) {
 				const result = await execAsync(
 					"docker service inspect --format='{{json .Endpoint.Ports}}' dokploy-traefik",
 				);