feat(#529): add first basic cluster-endpoint

Added new create-endpoint for cluster with connection
to the parser for the cluster-templates. Also added
database-tables for cluster.

Signed-off-by: Tobias Anker <tobias.anker@kitsunemimi.moe>

Author: kitsudaiki

Cargo.lock

@@ -6,8 +6,6 @@ edition = "2024"
 [dependencies]
 # web-server
 actix-web = "4"
-futures = "0.3"
-bytes = "1"
 # openapi-generator
 schemars = { package = "apistos-schemars", version = "0.8", features = ["chrono", "uuid1", "url", "rust_decimal"] }
 apistos = "0.5"
@@ -23,16 +21,20 @@ once_cell = "1.18"
 # logger
 log = "0.4"
 env_logger = "0.10"
-# sqlite-database
+# database
 diesel = { version = "2.2", features = ["sqlite"] }
-lazy_static = "1.4"
-# timestamps
-chrono = "0.4.40"
-# randomizer
-rand = "0.9.0"
 # hash
 sha2 = "0.10.8"
 hex = "0.4"
 # parser-generator
 pest = "2"
 pest_derive = "2"
+# common stuff
+rand = "0.9.0"
+lazy_static = "1.4"
+chrono = "0.4.40"
+futures = "0.3"
+bytes = "1"
+uuid = { version = "1.16.0", features = ["v4"] }
+
+

src/hanami/Cargo.toml

@@ -0,0 +1,45 @@
+// Copyright 2022 Tobias Anker <tobias.anker@kitsunemimim.moe>
+
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+
+//     http://www.apache.org/licenses/LICENSE-2.0
+
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+use apistos::ApiComponent;
+use serde::{Deserialize, Serialize};
+use schemars::JsonSchema;
+
+#[derive(Serialize, Deserialize, Debug, Clone, JsonSchema, ApiComponent)]
+pub struct ClusterCreateReq {
+    pub name: String,
+    pub template: String,
+}
+
+#[derive(Serialize, Deserialize, Debug, Clone, JsonSchema, ApiComponent)]
+pub struct ClusterResp {
+    pub uuid: String,
+    pub name: String,
+    pub template: String,
+    pub created_at: String,
+    pub created_by: String,
+    pub updated_at: String,
+    pub updated_by: String,
+}
+
+#[derive(Serialize, Deserialize, Debug, Clone, JsonSchema, ApiComponent)]
+pub struct ClusterBasicResp {
+    pub uuid: String,
+    pub name: String,
+}
+
+#[derive(Serialize, Deserialize, Debug, Clone, JsonSchema, ApiComponent)]
+pub struct ClusterListResp {
+    pub clusters: Vec<ClusterBasicResp>
+}

src/hanami/src/api/http_endpoints/cluster/cluster_structs.rs

@@ -0,0 +1,86 @@
+// Copyright 2022 Tobias Anker <tobias.anker@kitsunemimim.moe>
+
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+
+//     http://www.apache.org/licenses/LICENSE-2.0
+
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+use apistos::actix::CreatedJson;
+use actix_web::web::Json;
+use apistos::api_operation;
+use log::error;
+use uuid::Uuid;
+
+use crate::api::user_context::UserContext;
+use crate::api::errors::ErrorResponse;
+use crate::database::cluster_table;
+use crate::core::cluster::parser::cluster_parser;
+
+use super::cluster_structs::{ClusterCreateReq, ClusterResp};
+
+#[api_operation(
+    tag = "cluster",
+    summary = "Create new cluster",
+    description = r###"Create new cluster based on a cluster-template."###,
+    error_code = 401,
+    error_code = 500
+)]
+pub async fn create_cluster(body: Json<ClusterCreateReq>, context: UserContext) -> Result<CreatedJson<ClusterResp>, ErrorResponse> {
+    let cluster_uuid = Uuid::new_v4().to_string();
+
+    // parse cluster
+    match cluster_parser::parse_cluster_template(&body.template) {
+        Ok(parsed) => {
+            // TODO
+        }
+        Err(e) => {
+            let msg = format!("Failed to parse cluster-template with error: '{}'", e);
+            return Err(ErrorResponse::InternalError(msg));
+        }
+    }    
+
+    // add new cluster to datbase
+    match cluster_table::add_new_cluster(
+        &cluster_uuid, 
+        &body.name, 
+        &body.template, 
+        &context.user_id) 
+    {
+        Ok(_) => {},
+        Err(_) => {
+            let msg = format!("Failed to add cluster with ID '{}' to database.", cluster_uuid);
+            error!("{}", msg);
+            return Err(ErrorResponse::InternalError("".to_string()));
+        }
+    };
+
+    // get new created cluster from database to get addtional information
+    match cluster_table::get_cluster(&cluster_uuid) {
+        Ok(cluster) => {
+            let resp = ClusterResp {
+                uuid: cluster.uuid.clone(),
+                name: cluster.name.clone(),
+                template: cluster.template.clone(),
+                created_by: cluster.created_by.clone(),
+                created_at: cluster.created_at.clone(),
+                updated_by: cluster.updated_by.clone(),
+                updated_at: cluster.updated_at.clone(),
+            };
+        
+            return Ok(CreatedJson(resp));
+        },
+        Err(_) => 
+        {
+            let msg = format!("Failed to get cluster with ID '{}' from database, even the cluster should exist.", cluster_uuid);
+            error!("{}", msg);
+            return Err(ErrorResponse::InternalError("".to_string()));
+        }
+    };
+}

src/hanami/src/api/http_endpoints/cluster/create_cluster_v1_0.rs

@@ -0,0 +1,2 @@
+pub mod create_cluster_v1_0;
+pub mod cluster_structs;

src/hanami/src/api/http_endpoints/cluster/delete_cluster_v1_0.rs

@@ -13,4 +13,5 @@
 // limitations under the License.
 
 pub mod auth;
-pub mod user;
+pub mod user;
+pub mod cluster;

src/hanami/src/api/http_endpoints/cluster/mod.rs

@@ -36,7 +36,6 @@ pub async fn authorization_middleware(
         debug!("Check token for request against {}", req.uri());
         // get token from header
         let token: &str;
-        println!("middleware poi1");
         match req.headers().get("Authorization") {
             Some(value) => {
                 match split_bearer_token(value.to_str().unwrap()) {
@@ -60,9 +59,9 @@ pub async fn authorization_middleware(
             }
         }
     }
-    else {
-        debug!("skip token-check");
-    }
+    //else {
+    //    debug!("skip token-check");
+    //}
 
     info!("Api-call against URI: {}", req.uri());
 

src/hanami/src/api/http_endpoints/mod.rs

@@ -18,7 +18,6 @@ use actix_web::{FromRequest, HttpRequest};
 use apistos::ApiSecurity;
 use futures::future::{ready, Ready};
 use serde::{Deserialize, Serialize};
-use jsonwebtoken::{decode, DecodingKey, Validation, Algorithm};
 use log::debug;
 
 use crate::common::functions::split_bearer_token;