Deployment removal and activation

Author: Su5eD

sql/20250609211200_deployments.sql

@@ -28,16 +28,19 @@ $$ LANGUAGE plpgsql;
 
 CREATE TABLE deployment
 (
-    id          varchar(28) PRIMARY KEY,
-    project_id  text                                   NOT NULL REFERENCES project (id) ON DELETE CASCADE,
-    revision    jsonb,
-    status      varchar(255)                           NOT NULL,
-    user_id     text references user_ (id),
-    created_at  timestamp(3) default CURRENT_TIMESTAMP NOT NULL
+    id         varchar(28) PRIMARY KEY,
+    project_id text         NOT NULL REFERENCES project (id) ON DELETE CASCADE,
+    revision   jsonb,
+    status     varchar(255) NOT NULL,
+    active     bool         NOT NULL DEFAULT FALSE,
+    user_id    text references user_ (id),
+    created_at timestamp(3)          default CURRENT_TIMESTAMP NOT NULL
 );
 
 CREATE OR REPLACE TRIGGER deployment_set_id
     BEFORE INSERT
     ON deployment
     FOR EACH ROW
-EXECUTE FUNCTION set_random_id(28);
+EXECUTE FUNCTION set_random_id(28);
+
+CREATE UNIQUE INDEX single_active_deployment ON deployment (project_id, active) WHERE active;

src/api/v1/projects.cc

@@ -370,11 +370,7 @@ namespace api::v1 {
 
         co_await global::storage->invalidateProject(project);
 
-        Json::Value root;
-        root["message"] = "Project deleted successfully";
-        const auto resp = HttpResponse::newHttpJsonResponse(root);
-        resp->setStatusCode(k200OK);
-        callback(resp);
+        callback(simpleResponse("Project deleted successfully"));
     }
 
     Task<> ProjectsController::redeployProject(const HttpRequestPtr req, const std::function<void(const HttpResponsePtr &)> callback,
@@ -470,8 +466,29 @@ namespace api::v1 {
     Task<> ProjectsController::getDeployments(const HttpRequestPtr req, const std::function<void(const HttpResponsePtr &)> callback,
                                               const std::string id) const {
         const auto project = co_await BaseProjectController::getUserProject(req, id);
-        const auto deployments = co_await global::database->getDeployments(project.getValueOfId(), getTableQueryParams(req).page);
+        auto deployments = co_await global::database->getDeployments(project.getValueOfId(), getTableQueryParams(req).page);
 
         callback(jsonResponse(deployments));
     }
+
+    Task<> ProjectsController::deleteDeployment(const HttpRequestPtr req, const std::function<void(const HttpResponsePtr &)> callback,
+                                                const std::string id) const {
+        const auto deployment(co_await global::database->getDeployment(id));
+        if (!deployment) {
+            throw ApiException(Error::ErrBadRequest, "not_found");
+        }
+        const auto project(co_await BaseProjectController::getUserProject(req, deployment->getValueOfProjectId()));
+
+        if (const auto error = co_await global::database->deleteDeployment(id); error != Error::Ok) {
+            logger.error("Failed to delete deployment {} in database", id);
+            throw ApiException(Error::ErrInternal, "internal");
+        }
+
+        if (deployment->getValueOfActive()) {
+            logger.debug("Invalidating project after active deployment was removed");
+            co_await global::storage->invalidateProject(project);
+        }
+
+        callback(simpleResponse("Deployment deleted successfully"));
+    }
 }

src/api/v1/projects.h

@@ -36,6 +36,8 @@ namespace api::v1 {
         ADD_METHOD_TO(ProjectsController::getRecipes,       "/api/v1/dev/projects/{1:id}/content/recipes",      drogon::Get,    "AuthFilter");
         ADD_METHOD_TO(ProjectsController::getVersions,      "/api/v1/dev/projects/{1:id}/versions",             drogon::Get,    "AuthFilter");
         ADD_METHOD_TO(ProjectsController::getDeployments,   "/api/v1/dev/projects/{1:id}/deployments",          drogon::Get,    "AuthFilter");
+        // TODO Deployment controller
+        ADD_METHOD_TO(ProjectsController::deleteDeployment, "/api/v1/dev/deployments/{1:id}",                   drogon::Delete, "AuthFilter");
         // Dev content
         METHOD_LIST_END
         // clang-format on
@@ -82,6 +84,9 @@ namespace api::v1 {
         drogon::Task<> getDeployments(drogon::HttpRequestPtr req, std::function<void(const drogon::HttpResponsePtr &)> callback,
                                       std::string id) const;
 
+        drogon::Task<> deleteDeployment(drogon::HttpRequestPtr req, std::function<void(const drogon::HttpResponsePtr &)> callback,
+                                        std::string id) const;
+
     private:
         nlohmann::json processPlatforms(const nlohmann::json &metadata) const;
 
@@ -93,6 +98,6 @@ namespace api::v1 {
                                                                std::function<void(const drogon::HttpResponsePtr &)> callback,
                                                                bool checkExisting) const;
 
-        void enqueueDeploy(const Project &project, const std::string userId) const;
+        void enqueueDeploy(const Project &project, std::string userId) const;
     };
 }