feat(notification): send notification when dokploy update is available

apps/dokploy/__test__/compose/service/sevice-volumes-from.test.ts

@@ -0,0 +1,77 @@
+import type { ComposeSpecification } from "@dokploy/server";
+import { addSuffixToServiceNames, generateRandomHash } from "@dokploy/server";
+import { expect, test } from "vitest";
+import { parse } from "yaml";
+
+test("Generate random hash with 8 characters", () => {
+	const hash = generateRandomHash();
+
+	expect(hash).toBeDefined();
+	expect(hash.length).toBe(8);
+});
+
+const composeFile3 = `
+version: "3.8"
+
+services:
+  web:
+    image: nginx:latest
+    volumes_from:
+      - shared
+
+  api:
+    image: myapi:latest
+    volumes_from:
+      - shared
+
+  shared:
+    image: busybox
+    volumes:
+      - /data
+
+networks:
+  default:
+    driver: bridge
+`;
+
+test("Add suffix to service names with volumes_from in compose file", () => {
+	const composeData = parse(composeFile3) as ComposeSpecification;
+
+	const suffix = generateRandomHash();
+
+	if (!composeData.services) {
+		return;
+	}
+	const updatedComposeData = addSuffixToServiceNames(
+		composeData.services,
+		suffix,
+	);
+	const actualComposeData = { ...composeData, services: updatedComposeData };
+
+	// Verificar que la nueva clave del servicio tiene el prefijo y la vieja clave no existe
+	expect(actualComposeData.services).toHaveProperty(`web-${suffix}`);
+	expect(actualComposeData.services).not.toHaveProperty("web");
+
+	// Verificar que la configuración de la imagen sigue igual
+	expect(actualComposeData.services?.[`web-${suffix}`]?.image).toBe(
+		"nginx:latest",
+	);
+	expect(actualComposeData.services?.[`api-${suffix}`]?.image).toBe(
+		"myapi:latest",
+	);
+
+	// Verificar que los nombres en volumes_from tienen el prefijo
+	expect(actualComposeData.services?.[`web-${suffix}`]?.volumes_from).toContain(
+		`shared-${suffix}`,
+	);
+	expect(actualComposeData.services?.[`api-${suffix}`]?.volumes_from).toContain(
+		`shared-${suffix}`,
+	);
+
+	// Verificar que el servicio shared también tiene el prefijo
+	expect(actualComposeData.services).toHaveProperty(`shared-${suffix}`);
+	expect(actualComposeData.services).not.toHaveProperty("shared");
+	expect(actualComposeData.services?.[`shared-${suffix}`]?.image).toBe(
+		"busybox",
+	);
+});

apps/dokploy/components/dashboard/settings/notifications/handle-notifications.tsx

@@ -59,6 +59,7 @@ const notificationBaseSchema = z.object({
 	dokployRestart: z.boolean().default(false),
 	dockerCleanup: z.boolean().default(false),
 	serverThreshold: z.boolean().default(false),
+	dokployUpdate: z.boolean().default(false),
 });
 
 export const notificationSchema = z.discriminatedUnion("type", [
@@ -364,6 +365,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					type: notification.notificationType,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "telegram") {
 				form.reset({
@@ -380,6 +382,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "discord") {
 				form.reset({
@@ -395,6 +398,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "email") {
 				form.reset({
@@ -414,6 +418,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "resend") {
 				form.reset({
@@ -430,6 +435,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "gotify") {
 				form.reset({
@@ -446,6 +452,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					serverUrl: notification.gotify?.serverUrl,
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "ntfy") {
 				form.reset({
@@ -463,6 +470,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "mattermost") {
 				form.reset({
@@ -479,6 +487,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "lark") {
 				form.reset({
@@ -493,6 +502,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					dockerCleanup: notification.dockerCleanup,
 					volumeBackup: notification.volumeBackup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "teams") {
 				form.reset({
@@ -507,6 +517,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "custom") {
 				form.reset({
@@ -529,6 +540,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					volumeBackup: notification.volumeBackup,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			} else if (notification.notificationType === "pushover") {
 				form.reset({
@@ -547,6 +559,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 					name: notification.name,
 					dockerCleanup: notification.dockerCleanup,
 					serverThreshold: notification.serverThreshold,
+					dokployUpdate: notification.dokployUpdate,
 				});
 			}
 		} else {
@@ -579,6 +592,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 			volumeBackup,
 			dockerCleanup,
 			serverThreshold,
+			dokployUpdate,
 		} = data;
 		let promise: Promise<unknown> | null = null;
 		if (data.type === "slack") {
@@ -596,6 +610,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				slackId: notification?.slackId || "",
 				notificationId: notificationId || "",
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "telegram") {
 			promise = telegramMutation.mutateAsync({
@@ -613,6 +628,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				notificationId: notificationId || "",
 				telegramId: notification?.telegramId || "",
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "discord") {
 			promise = discordMutation.mutateAsync({
@@ -629,6 +645,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				notificationId: notificationId || "",
 				discordId: notification?.discordId || "",
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "email") {
 			promise = emailMutation.mutateAsync({
@@ -649,6 +666,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				notificationId: notificationId || "",
 				emailId: notification?.emailId || "",
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "resend") {
 			promise = resendMutation.mutateAsync({
@@ -666,6 +684,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				notificationId: notificationId || "",
 				resendId: notification?.resendId || "",
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "gotify") {
 			promise = gotifyMutation.mutateAsync({
@@ -683,6 +702,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				decoration: data.decoration,
 				notificationId: notificationId || "",
 				gotifyId: notification?.gotifyId || "",
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "ntfy") {
 			promise = ntfyMutation.mutateAsync({
@@ -700,6 +720,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				dockerCleanup: dockerCleanup,
 				notificationId: notificationId || "",
 				ntfyId: notification?.ntfyId || "",
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "mattermost") {
 			promise = mattermostMutation.mutateAsync({
@@ -717,6 +738,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				notificationId: notificationId || "",
 				mattermostId: notification?.mattermostId || "",
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "lark") {
 			promise = larkMutation.mutateAsync({
@@ -732,6 +754,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				notificationId: notificationId || "",
 				larkId: notification?.larkId || "",
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "teams") {
 			promise = teamsMutation.mutateAsync({
@@ -747,6 +770,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				notificationId: notificationId || "",
 				teamsId: notification?.teamsId || "",
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 			});
 		} else if (data.type === "custom") {
 			// Convert headers array to object
@@ -773,6 +797,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				name: data.name,
 				dockerCleanup: dockerCleanup,
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 				notificationId: notificationId || "",
 				customId: notification?.customId || "",
 			});
@@ -796,6 +821,7 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 				name: data.name,
 				dockerCleanup: dockerCleanup,
 				serverThreshold: serverThreshold,
+				dokployUpdate: dokployUpdate,
 				notificationId: notificationId || "",
 				pushoverId: notification?.pushoverId || "",
 			});
@@ -1992,6 +2018,30 @@ export const HandleNotifications = ({ notificationId }: Props) => {
 										)}
 									/>
 								)}
+
+								{!isCloud && (
+									<FormField
+										control={form.control}
+										name="dokployUpdate"
+										render={({ field }) => (
+											<FormItem className="flex flex-row items-center justify-between rounded-lg border p-3 shadow-sm gap-2">
+												<div className="">
+													<FormLabel>Dokploy Updates</FormLabel>
+													<FormDescription>
+														Get notified when a new Dokploy version is
+														available.
+													</FormDescription>
+												</div>
+												<FormControl>
+													<Switch
+														checked={field.value}
+														onCheckedChange={field.onChange}
+													/>
+												</FormControl>
+											</FormItem>
+										)}
+									/>
+								)}
 							</div>
 						</div>
 					</form>

apps/dokploy/drizzle/0166_lethal_karnak.sql

@@ -0,0 +1,2 @@
+ALTER TABLE "organization" ADD COLUMN "lastNotifiedUpdateVersion" text;--> statement-breakpoint
+ALTER TABLE "notification" ADD COLUMN "dokployUpdate" boolean DEFAULT false NOT NULL;