refactor(cloud): add is cloud flag to cluters

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

@@ -2,10 +2,18 @@ import { getPublicIpWithFallback } from "@/server/wss/terminal";
 import { TRPCError } from "@trpc/server";
 import { z } from "zod";
 import { createTRPCRouter, protectedProcedure } from "../trpc";
-import { execAsync, docker, type DockerNode } from "@dokploy/builders";
+import {
+	execAsync,
+	docker,
+	type DockerNode,
+	IS_CLOUD,
+} from "@dokploy/builders";
 
 export const clusterRouter = createTRPCRouter({
 	getNodes: protectedProcedure.query(async () => {
+		if (IS_CLOUD) {
+			return [];
+		}
 		const workers: DockerNode[] = await docker.listNodes();
 
 		return workers;
@@ -17,6 +25,12 @@ export const clusterRouter = createTRPCRouter({
 			}),
 		)
 		.mutation(async ({ input }) => {
+			if (IS_CLOUD) {
+				throw new TRPCError({
+					code: "UNAUTHORIZED",
+					message: "Functionality not available in cloud version",
+				});
+			}
 			try {
 				await execAsync(
 					`docker node update --availability drain ${input.nodeId}`,
@@ -32,6 +46,12 @@ export const clusterRouter = createTRPCRouter({
 			}
 		}),
 	addWorker: protectedProcedure.query(async ({ input }) => {
+		if (IS_CLOUD) {
+			return {
+				command: "",
+				version: "",
+			};
+		}
 		const result = await docker.swarmInspect();
 		const docker_version = await docker.version();
 
@@ -43,6 +63,12 @@ export const clusterRouter = createTRPCRouter({
 		};
 	}),
 	addManager: protectedProcedure.query(async ({ input }) => {
+		if (IS_CLOUD) {
+			return {
+				command: "",
+				version: "",
+			};
+		}
 		const result = await docker.swarmInspect();
 		const docker_version = await docker.version();
 		return {