Merge pull request #643 from Dokploy/canary

v0.10.9

apps/dokploy/components/dashboard/application/advanced/volumes/update-volume.tsx

@@ -119,7 +119,7 @@ export const UpdateVolume = ({
 			} else if (typeForm === "file") {
 				form.reset({
 					content: data.content || "",
-					mountPath: data.mountPath,
+					mountPath: "/",
 					filePath: data.filePath || "",
 					type: "file",
 				});
@@ -296,15 +296,13 @@ export const UpdateVolume = ({
 							)}
 						</div>
 						<DialogFooter>
-							<DialogClose>
+							<Button
-								<Button
+								isLoading={isLoading}
-									isLoading={isLoading}
+								// form="hook-form-update-volume"
-									form="hook-form-update-volume"
+								type="submit"
-									type="submit"
+							>
-								>
+								Update
-									Update
+							</Button>
-								</Button>
-							</DialogClose>
 						</DialogFooter>
 					</form>
 				</Form>

apps/dokploy/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "dokploy",
-	"version": "v0.10.7",
+	"version": "v0.10.9",
 	"private": true,
 	"license": "Apache-2.0",
 	"type": "module",

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

@@ -132,16 +132,20 @@ export const projectRouter = createTRPCRouter({
 			if (accesedProjects.length === 0) {
 				return [];
 			}
+
 			const query = await db.query.projects.findMany({
-				where: sql`${projects.projectId} IN (${sql.join(
+				where: and(
-					accesedProjects.map((projectId) => sql`${projectId}`),
+					sql`${projects.projectId} IN (${sql.join(
-					sql`, `,
+						accesedProjects.map((projectId) => sql`${projectId}`),
-				)})`,
+						sql`, `,
+					)})`,
+					eq(projects.adminId, ctx.user.adminId),
+				),
 				with: {
 					applications: {
-						where: and(
+						where: buildServiceFilter(
-							buildServiceFilter(applications.applicationId, accesedServices),
+							applications.applicationId,
-							eq(projects.adminId, ctx.user.adminId),
+							accesedServices,
 						),
 						with: { domains: true },
 					},

apps/dokploy/server/wss/docker-container-logs.ts

@@ -63,7 +63,6 @@ export const setupDockerContainerLogsWebSocketServer = (
 							}
 							stream
 								.on("close", () => {
-									console.log("Connection closed ✅ Container Logs");
 									client.end();
 									ws.close();
 								})
@@ -88,7 +87,6 @@ export const setupDockerContainerLogsWebSocketServer = (
 						privateKey: server.sshKey?.privateKey,
 					});
 				ws.on("close", () => {
-					console.log("Connection closed ✅, From Container Logs WS");
 					client.end();
 				});
 			} else {

apps/dokploy/server/wss/terminal.ts

@@ -113,7 +113,6 @@ export const setupTerminalWebSocketServer = (
 						});
 
 						ws.on("close", () => {
-							console.log("Connection closed ✅");
 							stream.end();
 						});
 					},

apps/dokploy/templates/soketi/docker-compose.yml

@@ -1,19 +1,12 @@
-version: '3.3'
+version: "3"
-services:
-  stirling-pdf:
-    image: frooodle/s-pdf:0.30.1
-    ports:
-      - '8080'
-    volumes:
-      - training-data:/usr/share/tessdata #Required for extra OCR languages
-      - extra-configs:/configs
-      # - /location/of/customFiles:/customFiles/
-      # - /location/of/logs:/logs/
-    environment:
-      - DOCKER_ENABLE_SECURITY=false
-      - INSTALL_BOOK_AND_ADVANCED_HTML_OPS=false
-      - LANGS=en_GB
 
-volumes:
+services:
-  training-data: {}
+  soketi:
-  extra-configs: {}
+    image: quay.io/soketi/soketi:1.4-16-debian
+    container_name: soketi
+    environment:
+      SOKETI_DEBUG: "1"
+      SOKETI_HOST: "0.0.0.0"
+      SOKETI_PORT: "6001"
+      SOKETI_METRICS_SERVER_PORT: "9601"
+    restart: unless-stopped

packages/server/src/db/schema/registry.ts

@@ -1,11 +1,10 @@
-import { relations, sql } from "drizzle-orm";
+import { relations } from "drizzle-orm";
-import { boolean, pgEnum, pgTable, text, timestamp } from "drizzle-orm/pg-core";
+import { pgEnum, pgTable, text } from "drizzle-orm/pg-core";
 import { createInsertSchema } from "drizzle-zod";
 import { nanoid } from "nanoid";
 import { z } from "zod";
 import { admins } from "./admin";
 import { applications } from "./application";
-import { auth } from "./auth";
 /**
  * This is an example of how to use the multi-project schema feature of Drizzle ORM. Use the same
  * database instance for multiple projects.
@@ -48,7 +47,7 @@ const createSchema = createInsertSchema(registry, {
 	registryUrl: z.string(),
 	adminId: z.string().min(1),
 	registryId: z.string().min(1),
-	registryType: z.enum(["selfHosted", "cloud"]),
+	registryType: z.enum(["cloud"]),
 	imagePrefix: z.string().nullable().optional(),
 });
 
@@ -59,7 +58,7 @@ export const apiCreateRegistry = createSchema
 		username: z.string().min(1),
 		password: z.string().min(1),
 		registryUrl: z.string(),
-		registryType: z.enum(["selfHosted", "cloud"]),
+		registryType: z.enum(["cloud"]),
 		imagePrefix: z.string().nullable().optional(),
 	})
 	.required()
@@ -72,7 +71,7 @@ export const apiTestRegistry = createSchema.pick({}).extend({
 	username: z.string().min(1),
 	password: z.string().min(1),
 	registryUrl: z.string(),
-	registryType: z.enum(["selfHosted", "cloud"]),
+	registryType: z.enum(["cloud"]),
 	imagePrefix: z.string().nullable().optional(),
 	serverId: z.string().optional(),
 });

packages/server/src/setup/server-setup.ts

@@ -101,7 +101,6 @@ const installRequirements = async (serverId: string, logPath: string) => {
 					}
 					stream
 						.on("close", () => {
-							writeStream.write("Connection closed ✅");
 							client.end();
 							resolve();
 						})

packages/server/src/utils/builders/index.ts

@@ -1,7 +1,8 @@
 import { createWriteStream } from "node:fs";
+import { join } from "node:path";
 import type { InferResultType } from "@dokploy/server/types/with";
 import type { CreateServiceOptions } from "dockerode";
-import { uploadImage } from "../cluster/upload";
+import { uploadImage, uploadImageRemoteCommand } from "../cluster/upload";
 import {
 	calculateResources,
 	generateBindMounts,
@@ -69,19 +70,30 @@ export const getBuildCommand = (
 	application: ApplicationNested,
 	logPath: string,
 ) => {
-	const { buildType } = application;
+	let command = "";
+	const { buildType, registry } = application;
 	switch (buildType) {
 		case "nixpacks":
-			return getNixpacksCommand(application, logPath);
+			command = getNixpacksCommand(application, logPath);
+			break;
 		case "heroku_buildpacks":
-			return getHerokuCommand(application, logPath);
+			command = getHerokuCommand(application, logPath);
+			break;
 		case "paketo_buildpacks":
-			return getPaketoCommand(application, logPath);
+			command = getPaketoCommand(application, logPath);
+			break;
 		case "static":
-			return getStaticCommand(application, logPath);
+			command = getStaticCommand(application, logPath);
+			break;
 		case "dockerfile":
-			return getDockerCommand(application, logPath);
+			command = getDockerCommand(application, logPath);
+			break;
 	}
+	if (registry) {
+		command += uploadImageRemoteCommand(application, logPath);
+	}
+
+	return command;
 };
 
 export const mechanizeDockerContainer = async (
@@ -186,11 +198,11 @@ const getImageName = (application: ApplicationNested) => {
 		return dockerImage || "ERROR-NO-IMAGE-PROVIDED";
 	}
 
-	const registryUrl = registry?.registryUrl || "";
+	if (registry) {
-	const imagePrefix = registry?.imagePrefix ? `${registry.imagePrefix}/` : "";
+		return join(registry.imagePrefix || "", appName);
-	return registry
+	}
-		? `${registryUrl}/${imagePrefix}${appName}`
+
-		: `${appName}:latest`;
+	return `${appName}:latest`;
 };
 
 const getAuthConfig = (application: ApplicationNested) => {

packages/server/src/utils/cluster/upload.ts

@@ -1,4 +1,5 @@
 import type { WriteStream } from "node:fs";
+import { join } from "node:path";
 import type { ApplicationNested } from "../builders";
 import { spawnAsync } from "../process/spawnAsync";
 
@@ -16,23 +17,14 @@ export const uploadImage = async (
 	const { appName } = application;
 	const imageName = `${appName}:latest`;
 
-	const finalURL =
+	const finalURL = registryUrl;
-		registryType === "selfHosted"
-			? process.env.NODE_ENV === "development"
-				? "localhost:5000"
-				: registryUrl
-			: registryUrl;
 
-	const registryTag = imagePrefix
+	const registryTag = join(imagePrefix || "", imageName);
-		? `${finalURL}/${imagePrefix}/${imageName}`
-		: `${finalURL}/${imageName}`;
 
 	try {
-		console.log(finalURL, registryTag);
 		writeStream.write(
 			`📦 [Enabled Registry] Uploading image to ${registry.registryType} | ${registryTag} | ${finalURL}\n`,
 		);
-
 		await spawnAsync(
 			"docker",
 			["login", finalURL, "-u", registry.username, "-p", registry.password],
@@ -59,7 +51,48 @@ export const uploadImage = async (
 		throw error;
 	}
 };
-// docker:
+
-// endpoint: "unix:///var/run/docker.sock"
+export const uploadImageRemoteCommand = (
-// exposedByDefault: false
+	application: ApplicationNested,
-// swarmMode: true
+	logPath: string,
+) => {
+	const registry = application.registry;
+
+	if (!registry) {
+		throw new Error("Registry not found");
+	}
+
+	const { registryUrl, imagePrefix } = registry;
+	const { appName } = application;
+	const imageName = `${appName}:latest`;
+
+	const finalURL = registryUrl;
+
+	const registryTag = join(imagePrefix || "", imageName);
+
+	try {
+		const command = `
+		echo "📦 [Enabled Registry] Uploading image to '${registry.registryType}' | '${registryTag}'" >> ${logPath};
+		docker login ${finalURL} -u ${registry.username} -p ${registry.password} >> ${logPath} 2>> ${logPath} || { 
+			echo "❌ DockerHub Failed" >> ${logPath};
+			exit 1;
+		}
+		echo "✅ DockerHub Login Success" >> ${logPath};
+		docker tag ${imageName} ${registryTag} >> ${logPath} 2>> ${logPath} || { 
+			echo "❌ Error tagging image" >> ${logPath};
+			exit 1;
+		}
+			echo "✅ Image Tagged" >> ${logPath};
+
+		docker push ${registryTag} 2>> ${logPath} || { 
+			echo "❌ Error pushing image" >> ${logPath};
+			exit 1;
+		}
+			echo "✅ Image Pushed" >> ${logPath};
+		`;
+		return command;
+	} catch (error) {
+		console.log(error);
+		throw error;
+	}
+};