mycelium-api 8.3.1-rc.1

Provide API ports to the mycelium project.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

use crate::dtos::MyceliumProfileData;

use actix_web::{get, web, HttpResponse, Responder};
use myc_core::domain::dtos::profile::{LicensedResources, TenantsOwnership};
use myc_http_tools::{
    settings::MYCELIUM_AI_AWARE, utils::HttpJsonResponse, Profile,
};
use serde::Deserialize;
use utoipa::IntoParams;

// ? ---------------------------------------------------------------------------
// ? Configure application
// ? ---------------------------------------------------------------------------

pub fn configure(config: &mut web::ServiceConfig) {
    config.service(fetch_profile_url);
}

// ? ---------------------------------------------------------------------------
// ? Define API paths
//
// Account
//
// ? ---------------------------------------------------------------------------

#[derive(Deserialize, IntoParams)]
#[serde(rename_all = "camelCase")]
pub struct ProfileParams {
    with_url: Option<bool>,
}

/// Fetch a user's profile.
#[utoipa::path(
    get,
    operation_id = "fetch_my_mycelium_profile",
    params(ProfileParams),
    responses(
        (
            status = 500,
            description = "Unknown internal server error.",
            body = HttpJsonResponse,
        ),
        (
            status = 403,
            description = "Forbidden.",
            body = HttpJsonResponse,
        ),
        (
            status = 401,
            description = "Unauthorized.",
            body = HttpJsonResponse,
        ),
        (
            status = 400,
            description = "Bad request.",
            body = HttpJsonResponse,
        ),
        (
            status = 204,
            description = "Not found.",
        ),
        (
            status = 200,
            description = "Profile fetching done.",
            body = Profile,
        ),
    ),
    tag = MYCELIUM_AI_AWARE
)]
#[get("")]
pub async fn fetch_profile_url(
    query: web::Query<ProfileParams>,
    mut profile: MyceliumProfileData,
) -> impl Responder {
    match query.with_url.unwrap_or(true) {
        true => {
            //
            // Try to set the licensed resources as a string list
            //
            if let Some(licensed_resources) = profile.licensed_resources {
                let resources = match licensed_resources {
                    LicensedResources::Urls(urls) => urls,
                    LicensedResources::Records(records) => records
                        .iter()
                        .map(|r| r.to_string())
                        .collect::<Vec<String>>(),
                };

                profile.licensed_resources = match resources.is_empty() {
                    true => None,
                    false => Some(LicensedResources::Urls(resources)),
                }
            };

            //
            // Try to set the tenant ownership as a string list
            //
            if let Some(tenants_ownership) = profile.tenants_ownership {
                let ownerships = match tenants_ownership {
                    TenantsOwnership::Urls(urls) => urls,
                    TenantsOwnership::Records(records) => records
                        .iter()
                        .map(|r| r.to_string())
                        .collect::<Vec<String>>(),
                };

                profile.tenants_ownership = match ownerships.is_empty() {
                    true => None,
                    false => Some(TenantsOwnership::Urls(ownerships)),
                };
            };

            HttpResponse::Ok().json(profile.to_profile())
        }
        _ => HttpResponse::Ok().json(profile.to_profile()),
    }
}