coolify/app/Http/Controllers/Api/Deploy.php

<?php

namespace App\Http\Controllers\Api;

use App\Actions\Database\StartClickhouse;
use App\Actions\Database\StartDragonfly;
use App\Actions\Database\StartKeydb;
use App\Actions\Database\StartMariadb;
use App\Actions\Database\StartMongodb;
use App\Actions\Database\StartMysql;
use App\Actions\Database\StartPostgresql;
use App\Actions\Database\StartRedis;
use App\Actions\Service\StartService;
use App\Http\Controllers\Controller;
use App\Models\ApplicationDeploymentQueue;
use App\Models\Server;
use App\Models\Tag;
use Illuminate\Http\Request;
use Visus\Cuid2\Cuid2;

class Deploy extends Controller
{
    public function deployments(Request $request)
    {
        $teamId = get_team_id_from_token();
        if (is_null($teamId)) {
            return invalid_token();
        }
        $servers = Server::whereTeamId($teamId)->get();
        $deployments_per_server = ApplicationDeploymentQueue::whereIn("status", ["in_progress", "queued"])->whereIn("server_id", $servers->pluck("id"))->get([
            "id",
            "application_id",
            "application_name",
            "deployment_url",
            "pull_request_id",
            "server_name",
            "server_id",
            "status"
        ])->sortBy('id')->toArray();
        return response()->json($deployments_per_server, 200);
    }
    public function deploy(Request $request)
    {
        $teamId = get_team_id_from_token();
        $uuids = $request->query->get('uuid');
        $tags = $request->query->get('tag');
        $force = $request->query->get('force') ?? false;

        if ($uuids && $tags) {
            return response()->json(['error' => 'You can only use uuid or tag, not both.', 'docs' => 'https://coolify.io/docs/api-reference/deploy-webhook'], 400);
        }
        if (is_null($teamId)) {
            return invalid_token();
        }
        if ($tags) {
            return $this->by_tags($tags, $teamId, $force);
        } else if ($uuids) {
            return $this->by_uuids($uuids, $teamId, $force);
        }
        return response()->json(['error' => 'You must provide uuid or tag.', 'docs' => 'https://coolify.io/docs/api-reference/deploy-webhook'], 400);
    }
    private function by_uuids(string $uuid, int $teamId, bool $force = false)
    {
        $uuids = explode(',', $uuid);
        $uuids = collect(array_filter($uuids));

        if (count($uuids) === 0) {
            return response()->json(['error' => 'No UUIDs provided.', 'docs' => 'https://coolify.io/docs/api-reference/deploy-webhook'], 400);
        }
        $deployments = collect();
        $payload = collect();
        foreach ($uuids as $uuid) {
            $resource = getResourceByUuid($uuid, $teamId);
            if ($resource) {
                ['message' => $return_message, 'deployment_uuid' => $deployment_uuid] = $this->deploy_resource($resource, $force);
                if ($deployment_uuid) {
                    $deployments->push(['message' => $return_message, 'resource_uuid' => $uuid, 'deployment_uuid' => $deployment_uuid->toString()]);
                } else {
                    $deployments->push(['message' => $return_message, 'resource_uuid' => $uuid]);
                }
            }
        }
        if ($deployments->count() > 0) {
            $payload->put('deployments', $deployments->toArray());
            return response()->json($payload->toArray(), 200);
        }
        return response()->json(['error' => "No resources found.", 'docs' => 'https://coolify.io/docs/api-reference/deploy-webhook'], 404);
    }
    public function by_tags(string $tags, int $team_id, bool $force = false)
    {
        $tags = explode(',', $tags);
        $tags = collect(array_filter($tags));

        if (count($tags) === 0) {
            return response()->json(['error' => 'No TAGs provided.', 'docs' => 'https://coolify.io/docs/api-reference/deploy-webhook'], 400);
        }
        $message = collect([]);
        $deployments = collect();
        $payload = collect();
        foreach ($tags as $tag) {
            $found_tag = Tag::where(['name' => $tag, 'team_id' => $team_id])->first();
            if (!$found_tag) {
                // $message->push("Tag {$tag} not found.");
                continue;
            }
            $applications = $found_tag->applications()->get();
            $services = $found_tag->services()->get();
            if ($applications->count() === 0 && $services->count() === 0) {
                $message->push("No resources found for tag {$tag}.");
                continue;
            }
            foreach ($applications as $resource) {
                ['message' => $return_message, 'deployment_uuid' => $deployment_uuid] = $this->deploy_resource($resource, $force);
                if ($deployment_uuid) {
                    $deployments->push(['resource_uuid' => $resource->uuid, 'deployment_uuid' => $deployment_uuid->toString()]);
                }
                $message = $message->merge($return_message);
            }
            foreach ($services as $resource) {
                ['message' => $return_message] = $this->deploy_resource($resource, $force);
                $message = $message->merge($return_message);
            }
        }
        ray($message);
        if ($message->count() > 0) {
            $payload->put('message', $message->toArray());
            if ($deployments->count() > 0) {
                $payload->put('details', $deployments->toArray());
            }
            return response()->json($payload->toArray(), 200);
        }

        return response()->json(['error' => "No resources found with this tag.", 'docs' => 'https://coolify.io/docs/api-reference/deploy-webhook'], 404);
    }
    public function deploy_resource($resource, bool $force = false): array
    {
        $message = null;
        $deployment_uuid = null;
        if (gettype($resource) !== 'object') {
            return ['message' => "Resource ($resource) not found.", 'deployment_uuid' => $deployment_uuid];
        }
        $type = $resource?->getMorphClass();
        if ($type === 'App\Models\Application') {
            $deployment_uuid = new Cuid2(7);
            queue_application_deployment(
                application: $resource,
                deployment_uuid: $deployment_uuid,
                force_rebuild: $force,
            );
            $message = "Application {$resource->name} deployment queued.";
        } else if ($type === 'App\Models\StandalonePostgresql') {
            StartPostgresql::run($resource);
            $resource->update([
                'started_at' => now(),
            ]);
            $message = "Database {$resource->name} started.";
        } else if ($type === 'App\Models\StandaloneRedis') {
            StartRedis::run($resource);
            $resource->update([
                'started_at' => now(),
            ]);
            $message = "Database {$resource->name} started.";
        } else if ($type === 'App\Models\StandaloneKeydb') {
            StartKeydb::run($resource);
            $resource->update([
                'started_at' => now(),
            ]);
            $message = "Database {$resource->name} started.";
        } else if ($type === 'App\Models\StandaloneDragonfly') {
            StartDragonfly::run($resource);
            $resource->update([
                'started_at' => now(),
            ]);
            $message = "Database {$resource->name} started.";
        } else if ($type === 'App\Models\StandaloneClickhouse') {
            StartClickhouse::run($resource);
            $resource->update([
                'started_at' => now(),
            ]);
            $message = "Database {$resource->name} started.";
        } else if ($type === 'App\Models\StandaloneMongodb') {
            StartMongodb::run($resource);
            $resource->update([
                'started_at' => now(),
            ]);
            $message = "Database {$resource->name} started.";
        } else if ($type === 'App\Models\StandaloneMysql') {
            StartMysql::run($resource);
            $resource->update([
                'started_at' => now(),
            ]);
            $message = "Database {$resource->name} started.";
        } else if ($type === 'App\Models\StandaloneMariadb') {
            StartMariadb::run($resource);
            $resource->update([
                'started_at' => now(),
            ]);
            $message = "Database {$resource->name} started.";
        } else if ($type === 'App\Models\Service') {
            StartService::run($resource);
            $message = "Service {$resource->name} started. It could take a while, be patient.";
        }
        return ['message' => $message, 'deployment_uuid' => $deployment_uuid];
    }
}