Merge pull request #33 from Virtual-Finland-Development/VFD-245-profiilin-poiston-reititys-testbed-apille

user deletion (users-api)

Author: LauriGofore

.gitignore

@@ -15,4 +15,7 @@ infra/build/*
 .cargo_home
 
 # idea
-.idea
+.idea
+
+# vscode settings
+.vscode

src/lib/api_app/src/api/routes/mod.rs

@@ -10,6 +10,7 @@ use app::{
 pub mod application;
 pub mod jmf;
 pub mod testbed;
+pub mod users_api;
 
 #[derive(OpenApi, OpenApiRouter)]
 #[openapi(
@@ -40,6 +41,7 @@ pub mod testbed;
         testbed::productizers::nsg::non_listed_company::beneficial_owners::get_beneficial_owners,
         testbed::productizers::nsg::non_listed_company::signatory_rights::get_signatory_rights,
         testbed::productizers::nsg::basic_information::get_nsg_basic_information,
+        users_api::delete_user
     ),
     components(schemas( // @TODO: would be very nice to auto-generate schemas
         testbed::ProxyRequestInput,

src/lib/api_app/src/api/routes/users_api/mod.rs

@@ -0,0 +1,33 @@
+use std::env;
+
+use app::{
+    helpers::parse_request_headers, requests::engage_json_request, responses::APIResponse,
+    router::ParsedRequest,
+};
+use http::Method;
+use serde_json::{json, Value as JSONValue};
+
+#[utoipa::path(
+    delete,
+    path = "/users-api/user",
+    responses((
+        status = 200,
+        description = "Deletion response",
+    ))
+)]
+pub async fn delete_user(request: ParsedRequest) -> APIResponse {
+    let users_api_origin =
+        env::var("USERS_API_ENDPOINT_ORIGIN").expect("USERS_API_ENDPOINT_ORIGIN must be set");
+    let endpoint_url = format!("{}/user", users_api_origin);
+    let request_input = json!({});
+    let request_headers = parse_request_headers(request)?;
+
+    let response = engage_json_request::<JSONValue, JSONValue>(
+        Method::DELETE,
+        endpoint_url,
+        &request_input,
+        request_headers,
+    )
+    .await?;
+    Ok(response)
+}

src/lib/api_app/src/lib/app/src/helpers.rs

@@ -0,0 +1,40 @@
+use http::{HeaderMap, HeaderValue};
+
+use crate::{responses::APIRoutingError, router::ParsedRequest};
+/**
+ * Parses the authorization headers from the input request
+ */
+pub fn parse_request_headers(request: ParsedRequest) -> Result<HeaderMap, APIRoutingError> {
+    // Prep auth header forwarding
+    let mut request_headers = HeaderMap::new();
+    request_headers.insert("Content-Type", HeaderValue::from_static("application/json"));
+
+    if request.headers.contains_key("authorization") {
+        request_headers.insert(
+            "authorization",
+            request
+                .headers
+                .get("authorization")
+                .ok_or_else(|| {
+                    APIRoutingError::UnprocessableEntity("No authorization header".to_string())
+                })?
+                .clone(),
+        );
+    }
+
+    if request.headers.contains_key("x-consent-token") {
+        request_headers.insert(
+            "x-consent-token",
+            request
+                .headers
+                .get("x-consent-token")
+                .ok_or_else(|| {
+                    APIRoutingError::UnprocessableEntity(
+                        "No x-consent-token header".to_string(),
+                    )
+                })?
+                .clone(),
+        );
+    }
+    Ok(request_headers)
+}

src/lib/api_app/src/lib/app/src/lib.rs

@@ -1,3 +1,4 @@
+pub mod helpers;
 pub mod requests;
 pub mod responses;
 pub mod router;

src/lib/api_app/src/lib/utils/src/api.rs

@@ -19,7 +19,7 @@ pub fn get_cors_response_headers() -> HeaderMap {
 
     headers.insert(
         HeaderName::from_static("access-control-allow-methods"),
-        HeaderValue::from_static("GET, POST, OPTIONS"),
+        HeaderValue::from_static("GET, POST, DELETE, OPTIONS"),
     );
 
     headers.insert(