Merge pull request #871 from coollabsio/next

v3.12.15

.github/workflows/staging-release.yml

@@ -12,8 +12,8 @@ on:
       - next
 
 jobs:
-  arm64:
+  build:
-    runs-on: [self-hosted, arm64]
+    runs-on: ubuntu-latest
     steps:
       - name: Checkout
         uses: actions/checkout@v3
@@ -28,65 +28,13 @@ jobs:
         with:
           username: ${{ secrets.DOCKERHUB_USERNAME }}
           password: ${{ secrets.DOCKERHUB_TOKEN }}
-      - name: Get current package version
-        uses: martinbeentjes/npm-get-version-action@v1.2.3
-        id: package-version
       - name: Build and push
         uses: docker/build-push-action@v2
-        with:
-          context: .
-          platforms: linux/arm64
-          push: true
-          tags: coollabsio/coolify:next-arm64
-          cache-from: type=registry,ref=coollabsio/coolify:buildcache-next-arm64
-          cache-to: type=registry,ref=coollabsio/coolify:buildcache-next-arm64,mode=max
-  amd64:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v3
-        with:
-          ref: "next"
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-      - name: Login to DockerHub
-        uses: docker/login-action@v2
-        with:
-          username: ${{ secrets.DOCKERHUB_USERNAME }}
-          password: ${{ secrets.DOCKERHUB_TOKEN }}
-      - name: Get current package version
-        uses: martinbeentjes/npm-get-version-action@v1.2.3
-        id: package-version
-      - name: Build and push
-        uses: docker/build-push-action@v3
         with:
           context: .
           platforms: linux/amd64
           push: true
-          tags: coollabsio/coolify:next-amd64
+          tags: coollabsio/coolify:next
-          cache-from: type=registry,ref=coollabsio/coolify:buildcache-next-amd64
-          cache-to: type=registry,ref=coollabsio/coolify:buildcache-next-amd64,mode=max
-  merge-manifest:
-    runs-on: ubuntu-latest
-    needs: [arm64, amd64]
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v3
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-      - name: Login to DockerHub
-        uses: docker/login-action@v2
-        with:
-          username: ${{ secrets.DOCKERHUB_USERNAME }}
-          password: ${{ secrets.DOCKERHUB_TOKEN }}
-      - name: Create & publish manifest
-        run: |
-          docker manifest create coollabsio/coolify:next --amend coollabsio/coolify:next-amd64 --amend coollabsio/coolify:next-arm64
-          docker manifest push coollabsio/coolify:next
       - uses: sarisia/actions-status-discord@v1
         if: always()
         with:

apps/api/src/index.ts

@@ -171,6 +171,11 @@ const host = '0.0.0.0';
 			await cleanupStorage();
 		}, 60000 * 15);
 
+		// Cleanup stucked containers (not defined in Coolify, but still running and managed by Coolify)
+		setInterval(async () => {
+			await cleanupStuckedContainers();
+		}, 60000 * 5);
+
 		// checkProxies, checkFluentBit & refresh templates
 		setInterval(async () => {
 			await checkProxies();
@@ -197,7 +202,13 @@ const host = '0.0.0.0';
 			await copySSLCertificates();
 		}, 10000);
 
-		await Promise.all([getTagsTemplates(), getArch(), getIPAddress(), configureRemoteDockers()]);
+		await Promise.all([
+			getTagsTemplates(),
+			getArch(),
+			getIPAddress(),
+			configureRemoteDockers(),
+			cleanupStuckedContainers()
+		]);
 	} catch (error) {
 		console.error(error);
 		process.exit(1);
@@ -311,6 +322,42 @@ async function getArch() {
 	} catch (error) {}
 }
 
+async function cleanupStuckedContainers() {
+	try {
+		const destinationDockers = await prisma.destinationDocker.findMany();
+		let enginesDone = new Set();
+		for (const destination of destinationDockers) {
+			if (enginesDone.has(destination.engine) || enginesDone.has(destination.remoteIpAddress))
+				return;
+			if (destination.engine) {
+				enginesDone.add(destination.engine);
+			}
+			if (destination.remoteIpAddress) {
+				if (!destination.remoteVerified) continue;
+				enginesDone.add(destination.remoteIpAddress);
+			}
+			const { stdout: containers } = await executeCommand({
+				dockerId: destination.id,
+				command: `docker container ps -a --filter "label=coolify.managed=true" --format '{{ .Names}}'`
+			});
+			if (containers) {
+				const containersArray = containers.trim().split('\n');
+				if (containersArray.length > 0) {
+					for (const container of containersArray) {
+						const application = await prisma.application.findFirst({ where: { id: container } });
+						const service = await prisma.service.findFirst({ where: { id: container } });
+						const database = await prisma.database.findFirst({ where: { id: container } });
+						if (!application && !service && !database) {
+							await executeCommand({ command: `docker container rm -f ${container}` });
+						}
+					}
+				}
+			}
+		}
+	} catch (error) {
+		console.log(error);
+	}
+}
 async function configureRemoteDockers() {
 	try {
 		const remoteDocker = await prisma.destinationDocker.findMany({
@@ -543,9 +590,13 @@ async function cleanupStorage() {
 	let enginesDone = new Set();
 	for (const destination of destinationDockers) {
 		if (enginesDone.has(destination.engine) || enginesDone.has(destination.remoteIpAddress)) return;
-		if (destination.engine) enginesDone.add(destination.engine);
+		if (destination.engine) {
-		if (destination.remoteIpAddress) enginesDone.add(destination.remoteIpAddress);
+			enginesDone.add(destination.engine);
-		let force = false;
+		}
+		if (destination.remoteIpAddress) {
+			if (!destination.remoteVerified) continue;
+			enginesDone.add(destination.remoteIpAddress);
+		}
 		let lowDiskSpace = false;
 		try {
 			let stdout = null;
@@ -591,6 +642,8 @@ async function cleanupStorage() {
 				}
 			}
 		} catch (error) {}
-		await cleanupDockerStorage(destination.id, lowDiskSpace, force);
+		if (lowDiskSpace) {
+			await cleanupDockerStorage(destination.id);
+		}
 	}
 }

apps/api/src/lib/common.ts

@@ -19,7 +19,7 @@ import { saveBuildLog, saveDockerRegistryCredentials } from './buildPacks/common
 import { scheduler } from './scheduler';
 import type { ExecaChildProcess } from 'execa';
 
-export const version = '3.12.14';
+export const version = '3.12.15';
 export const isDev = process.env.NODE_ENV === 'development';
 export const sentryDSN =
 	'https://409f09bcb7af47928d3e0f46b78987f3@o1082494.ingest.sentry.io/4504236622217216';
@@ -1714,78 +1714,24 @@ export function convertTolOldVolumeNames(type) {
 	}
 }
 
-export async function cleanupDockerStorage(dockerId, lowDiskSpace, force) {
+export async function cleanupDockerStorage(dockerId) {
-	// Cleanup old coolify images
+	// Cleanup images that are not used by any container
 	try {
-		let { stdout: images } = await executeCommand({
+		await executeCommand({ dockerId, command: `docker image prune -af` });
-			dockerId,
-			command: `docker images coollabsio/coolify --filter before="coollabsio/coolify:${version}" -q | xargs -r`,
-			shell: true
-		});
-
-		images = images.trim();
-		if (images) {
-			await executeCommand({
-				dockerId,
-				command: `docker rmi -f ${images}" -q | xargs -r`,
-				shell: true
-			});
-		}
 	} catch (error) {}
-	if (lowDiskSpace || force) {
-		// Cleanup images that are not used
-		try {
-			await executeCommand({ dockerId, command: `docker image prune -f` });
-		} catch (error) {}
 
-		const { numberOfDockerImagesKeptLocally } = await prisma.setting.findUnique({
+	// Prune coolify managed containers
-			where: { id: '0' }
+	try {
-		});
+		await executeCommand({
-		const { stdout: images } = await executeCommand({
 			dockerId,
-			command: `docker images|grep -v "<none>"|grep -v REPOSITORY|awk '{print $1, $2}'`,
+			command: `docker container prune -f --filter "label=coolify.managed=true"`
-			shell: true
 		});
-		const imagesArray = images.trim().replaceAll(' ', ':').split('\n');
+	} catch (error) {}
-		const imagesSet = new Set(imagesArray.map((image) => image.split(':')[0]));
-		let deleteImage = [];
-		for (const image of imagesSet) {
-			let keepImage = [];
-			for (const image2 of imagesArray) {
-				if (image2.startsWith(image)) {
-					if (force) {
-						deleteImage.push(image2);
-						continue;
-					}
-					if (keepImage.length >= numberOfDockerImagesKeptLocally) {
-						deleteImage.push(image2);
-					} else {
-						keepImage.push(image2);
-					}
-				}
-			}
-		}
-		for (const image of deleteImage) {
-			try {
-				await executeCommand({ dockerId, command: `docker image rm -f ${image}` });
-			} catch (error) {
-				console.log(error);
-			}
-		}
 
-		// Prune coolify managed containers
+	// Cleanup build caches
-		try {
+	try {
-			await executeCommand({
+		await executeCommand({ dockerId, command: `docker builder prune -af` });
-				dockerId,
+	} catch (error) {}
-				command: `docker container prune -f --filter "label=coolify.managed=true"`
-			});
-		} catch (error) {}
-
-		// Cleanup build caches
-		try {
-			await executeCommand({ dockerId, command: `docker builder prune -a -f` });
-		} catch (error) {}
-	}
 }
 
 export function persistentVolumes(id, persistentStorage, config) {

apps/api/src/routes/api/v1/applications/handlers.ts

@@ -732,14 +732,15 @@ export async function deleteApplication(
 ) {
 	try {
 		const { id } = request.params;
-		const { force } = request.body;
-
 		const { teamId } = request.user;
 		const application = await prisma.application.findUnique({
 			where: { id },
-			include: { destinationDocker: true }
+			include: { destinationDocker: true, teams: true }
 		});
-		if (!force && application?.destinationDockerId && application.destinationDocker?.network) {
+		if (!application.teams.find((team) => team.id === teamId) || teamId !== '0') {
+			throw { status: 403, message: 'You are not allowed to delete this application.' };
+		}
+		if (application?.destinationDocker?.id && application.destinationDocker?.network) {
 			const { stdout: containers } = await executeCommand({
 				dockerId: application.destinationDocker.id,
 				command: `docker ps -a --filter network=${application.destinationDocker.network} --filter name=${id} --format '{{json .}}'`

apps/api/src/routes/api/v1/databases/handlers.ts

@@ -427,19 +427,15 @@ export async function deleteDatabase(request: FastifyRequest<DeleteDatabase>) {
 	try {
 		const teamId = request.user.teamId;
 		const { id } = request.params;
-		const { force } = request.body;
 		const database = await prisma.database.findFirst({
 			where: { id, teams: { some: { id: teamId === '0' ? undefined : teamId } } },
 			include: { destinationDocker: true, settings: true }
 		});
-		if (!force) {
+		if (database.dbUserPassword) database.dbUserPassword = decrypt(database.dbUserPassword);
-			if (database.dbUserPassword) database.dbUserPassword = decrypt(database.dbUserPassword);
+		if (database.rootUserPassword) database.rootUserPassword = decrypt(database.rootUserPassword);
-			if (database.rootUserPassword) database.rootUserPassword = decrypt(database.rootUserPassword);
+		if (database.destinationDockerId) {
-			if (database.destinationDockerId) {
+			const everStarted = await stopDatabaseContainer(database);
-				const everStarted = await stopDatabaseContainer(database);
+			if (everStarted) await stopTcpHttpProxy(id, database.destinationDocker, database.publicPort);
-				if (everStarted)
-					await stopTcpHttpProxy(id, database.destinationDocker, database.publicPort);
-			}
 		}
 		await prisma.databaseSettings.deleteMany({ where: { databaseId: id } });
 		await prisma.databaseSecret.deleteMany({ where: { databaseId: id } });

apps/api/src/routes/api/v1/databases/types.ts

@@ -4,7 +4,7 @@ export interface SaveDatabaseType extends OnlyId {
     Body: { type: string }
 }
 export interface DeleteDatabase extends OnlyId {
-    Body: { force: string }
+    Body: { }
 }
 export interface SaveVersion extends OnlyId {
     Body: {

apps/api/src/routes/api/v1/handlers.ts

@@ -59,7 +59,7 @@ export async function cleanupManually(request: FastifyRequest) {
 		const destination = await prisma.destinationDocker.findUnique({
 			where: { id: serverId }
 		});
-		await cleanupDockerStorage(destination.id, true, true);
+		await cleanupDockerStorage(destination.id);
 		return {};
 	} catch ({ status, message }) {
 		return errorHandler({ status, message });

apps/api/src/routes/api/v1/services/handlers.ts

@@ -617,6 +617,29 @@ export async function getServiceLogs(request: FastifyRequest<GetServiceLogs>) {
 export async function deleteService(request: FastifyRequest<OnlyId>) {
 	try {
 		const { id } = request.params;
+		const teamId = request.user.teamId;
+		const { destinationDockerId } = await getServiceFromDB({ id, teamId });
+		if (destinationDockerId) {
+			const { stdout: containers } = await executeCommand({
+				dockerId: destinationDockerId,
+				command: `docker ps -a --filter 'label=com.docker.compose.project=${id}' --format {{.ID}}`
+			});
+			if (containers) {
+				const containerArray = containers.split('\n');
+				if (containerArray.length > 0) {
+					for (const container of containerArray) {
+						await executeCommand({
+							dockerId: destinationDockerId,
+							command: `docker stop -t 0 ${container}`
+						});
+						await executeCommand({
+							dockerId: destinationDockerId,
+							command: `docker rm --force ${container}`
+						});
+					}
+				}
+			}
+		}
 		await removeService({ id });
 		return {};
 	} catch ({ status, message }) {

apps/server/src/trpc/routers/services/index.ts

@@ -827,6 +827,29 @@ export const servicesRouter = router({
 		.mutation(async ({ input }) => {
 			// todo: check if user is allowed to delete service
 			const { id } = input;
+			const teamId = ctx.user?.teamId;
+			const { destinationDockerId } = await getServiceFromDB({ id, teamId });
+			if (destinationDockerId) {
+				const { stdout: containers } = await executeCommand({
+					dockerId: destinationDockerId,
+					command: `docker ps -a --filter 'label=com.docker.compose.project=${id}' --format {{.ID}}`
+				});
+				if (containers) {
+					const containerArray = containers.split('\n');
+					if (containerArray.length > 0) {
+						for (const container of containerArray) {
+							await executeCommand({
+								dockerId: destinationDockerId,
+								command: `docker stop -t 0 ${container}`
+							});
+							await executeCommand({
+								dockerId: destinationDockerId,
+								command: `docker rm --force ${container}`
+							});
+						}
+					}
+				}
+			}
 			await prisma.serviceSecret.deleteMany({ where: { serviceId: id } });
 			await prisma.serviceSetting.deleteMany({ where: { serviceId: id } });
 			await prisma.servicePersistentStorage.deleteMany({ where: { serviceId: id } });

apps/ui/src/routes/applications/[id]/__layout.svelte

@@ -89,7 +89,7 @@
 		const sure = confirm($t('application.confirm_to_delete', { name }));
 		if (sure) {
 			try {
-				await del(`/applications/${id}`, { id, force });
+				await del(`/applications/${id}`, {});
 				return await goto('/');
 			} catch (error) {
 				if (error.message.startsWith(`Command failed: SSH_AUTH_SOCK=/tmp/coolify-ssh-agent.pid`)) {

apps/ui/src/routes/applications/[id]/danger.svelte

@@ -34,7 +34,7 @@
 		if (sure) {
 			$status.application.initialLoading = true;
 			try {
-				await del(`/applications/${id}`, { id, force });
+				await del(`/applications/${id}`,{});
 				return await goto('/')
 			} catch (error) {
 				if (error.message.startsWith(`Command failed: SSH_AUTH_SOCK=/tmp/coolify-ssh-agent.pid`)) {

apps/ui/src/routes/databases/[id]/__layout.svelte

@@ -75,7 +75,7 @@
 		if (sure) {
 			$status.database.initialLoading = true;
 			try {
-				await del(`/databases/${database.id}`, { id: database.id, force });
+				await del(`/databases/${database.id}`, {});
 				return await window.location.assign('/');
 			} catch (error) {
 				return errorNotification(error);

apps/ui/src/routes/index.svelte

@@ -437,7 +437,7 @@
 		try {
 			const sure = confirm('Are you sure? This will delete this application!');
 			if (sure) {
-				await del(`/applications/${id}`, { force: true });
+				await del(`/applications/${id}`, {});
 				return window.location.reload();
 			}
 		} catch (error) {
@@ -459,7 +459,7 @@
 		try {
 			const sure = confirm('Are you sure? This will delete this database!');
 			if (sure) {
-				await del(`/databases/${id}`, { force: true });
+				await del(`/databases/${id}`, {  });
 				return window.location.reload();
 			}
 		} catch (error) {
@@ -784,11 +784,11 @@
 											</a>
 										{/if}
 										{#if $appSession.isAdmin}
-										<button
+											<button
-											class="icons hover:bg-green-500"
+												class="icons hover:bg-green-500"
-											on:click|stopPropagation|preventDefault={() =>
+												on:click|stopPropagation|preventDefault={() =>
-												deleteApplication(application.id)}><DeleteIcon /></button
+													deleteApplication(application.id)}><DeleteIcon /></button
-										>
+											>
 										{/if}
 									</div>
 								</div>
@@ -899,11 +899,11 @@
 										</a>
 									{/if}
 									{#if $appSession.isAdmin}
-									<button
+										<button
-										class="icons hover:bg-green-500"
+											class="icons hover:bg-green-500"
-										on:click|stopPropagation|preventDefault={() =>
+											on:click|stopPropagation|preventDefault={() =>
-											deleteApplication(application.id)}><DeleteIcon /></button
+												deleteApplication(application.id)}><DeleteIcon /></button
-									>
+										>
 									{/if}
 								</div>
 							</div>
@@ -996,11 +996,11 @@
 												</a>
 											{/if}
 											{#if $appSession.isAdmin}
-											<button
+												<button
-												class="icons hover:bg-pink-500"
+													class="icons hover:bg-pink-500"
-												on:click|stopPropagation|preventDefault={() => deleteService(service.id)}
+													on:click|stopPropagation|preventDefault={() => deleteService(service.id)}
-												><DeleteIcon /></button
+													><DeleteIcon /></button
-											>
+												>
 											{/if}
 										</div>
 									</div>
@@ -1084,11 +1084,11 @@
 											</a>
 										{/if}
 										{#if $appSession.isAdmin}
-										<button
+											<button
-											class="icons hover:bg-pink-500"
+												class="icons hover:bg-pink-500"
-											on:click|stopPropagation|preventDefault={() => deleteService(service.id)}
+												on:click|stopPropagation|preventDefault={() => deleteService(service.id)}
-											><DeleteIcon /></button
+												><DeleteIcon /></button
-										>
+											>
 										{/if}
 									</div>
 								</div>
@@ -1182,11 +1182,11 @@
 												</div>
 											{/if}
 											{#if $appSession.isAdmin}
-											<button
+												<button
-												class="icons hover:bg-databases-100"
+													class="icons hover:bg-databases-100"
-												on:click|stopPropagation|preventDefault={() => deleteDatabase(database.id)}
+													on:click|stopPropagation|preventDefault={() =>
-												><DeleteIcon /></button
+														deleteDatabase(database.id)}><DeleteIcon /></button
-											>
+												>
 											{/if}
 										</div>
 									</div>
@@ -1270,11 +1270,11 @@
 											</div>
 										{/if}
 										{#if $appSession.isAdmin}
-										<button
+											<button
-											class="icons hover:bg-databases"
+												class="icons hover:bg-databases"
-											on:click|stopPropagation|preventDefault={() => deleteDatabase(database.id)}
+												on:click|stopPropagation|preventDefault={() => deleteDatabase(database.id)}
-											><DeleteIcon /></button
+												><DeleteIcon /></button
-										>
+											>
 										{/if}
 									</div>
 								</div>

apps/ui/src/routes/services/[id]/__layout.svelte

@@ -85,9 +85,7 @@
 		if (sure) {
 			$status.service.initialLoading = true;
 			try {
-				if (service.type && $status.service.isRunning)
+				await del(`/services/${service.id}`, {});
-					await post(`/services/${service.id}/stop`, {});
-				await del(`/services/${service.id}`, { id: service.id });
 				return await goto('/');
 			} catch (error) {
 				return errorNotification(error);

apps/ui/src/routes/services/[id]/danger.svelte

@@ -28,16 +28,12 @@
 	import { goto } from '$app/navigation';
 	const { id } = $page.params;
 
-	let forceDelete = false;
 	async function deleteService() {
 		const sure = confirm($t('application.confirm_to_delete', { name: service.name }));
 		if (sure) {
 			$status.service.initialLoading = true;
 			try {
-				if (service.type && $status.service.overallStatus !== 'stopped') {
+				await del(`/services/${service.id}`, {});
-					await post(`/services/${service.id}/stop`, {});
-				}
-				await del(`/services/${service.id}`, { id: service.id });
 				return await goto('/');
 			} catch (error) {
 				return errorNotification(error);

package.json

@@ -1,7 +1,7 @@
 {
   "name": "coolify",
   "description": "An open-source & self-hostable Heroku / Netlify alternative.",
-  "version": "3.12.14",
+  "version": "3.12.15",
   "license": "Apache-2.0",
   "repository": "github:coollabsio/coolify",
   "scripts": {