dokploy/apps/dokploy/server/utils/cluster/upload.ts

import type { WriteStream } from "node:fs";
import type { ApplicationNested } from "../builders";
import { spawnAsync } from "../process/spawnAsync";

export const uploadImage = async (
	application: ApplicationNested,
	writeStream: WriteStream,
) => {
	const registry = application.registry;

	if (!registry) {
		throw new Error("Registry not found");
	}

	const { registryUrl, imagePrefix, registryType } = registry;
	const { appName } = application;
	const imageName = `${appName}:latest`;

	const finalURL =
		registryType === "selfHosted"
			? process.env.NODE_ENV === "development"
				? "localhost:5000"
				: registryUrl
			: registryUrl;

	const registryTag = imagePrefix
		? `${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],
			(data) => {
				if (writeStream.writable) {
					writeStream.write(data);
				}
			},
		);

		await spawnAsync("docker", ["tag", imageName, registryTag], (data) => {
			if (writeStream.writable) {
				writeStream.write(data);
			}
		});

		await spawnAsync("docker", ["push", registryTag], (data) => {
			if (writeStream.writable) {
				writeStream.write(data);
			}
		});
	} catch (error) {
		console.log(error);
		throw error;
	}
};
// docker:
// endpoint: "unix:///var/run/docker.sock"
// exposedByDefault: false
// swarmMode: true