dialtone_axum 0.1.0

Dialtone Axum Back-end
Documentation 
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

use crate::response::response_error::ResponseError;

use dialtone_common::authz::actor::authz_actor_on_host;
use dialtone_common::authz::ap_object::authz_ap_object_on_host;

use dialtone_common::authz::user_authz_info::UserAuthzInfo;
use dialtone_common::rest::users::web_user::SystemRole;

use dialtone_sqlx::db::actor_owner::fetch_authz::fetch_actor_owner_authz;
use dialtone_sqlx::db::ap_object::fetch_authz::fetch_ap_object_authz;
use sqlx::{Executor, Postgres};

pub async fn authz_for_actor(
    exec: impl Executor<'_, Database = Postgres>,
    user_authz: &UserAuthzInfo,
    actor_id: &str,
) -> Result<bool, ResponseError> {
    if authz_actor_on_host(user_authz, &SystemRole::ActorAdmin, &actor_id) {
        return Ok(true);
    }
    let actor_authz = fetch_actor_owner_authz(exec, actor_id, &user_authz.acct).await?;
    Ok(actor_authz)
}

pub async fn authz_actor_for_ap_object(
    exec: impl Executor<'_, Database = Postgres>,
    user_authz: &UserAuthzInfo,
    actor_id: &str,
) -> Result<bool, ResponseError> {
    if authz_actor_on_host(&user_authz, &SystemRole::ContentAdmin, &actor_id) {
        return Ok(true);
    }
    let ap_object_authz = fetch_actor_owner_authz(exec, actor_id, &user_authz.acct).await?;
    Ok(ap_object_authz)
}

pub async fn authz_for_ap_object(
    exec: impl Executor<'_, Database = Postgres>,
    user_authz: &UserAuthzInfo,
    ap_object_id: &str,
) -> Result<bool, ResponseError> {
    if authz_ap_object_on_host(&user_authz, &SystemRole::ContentAdmin, &ap_object_id) {
        return Ok(true);
    }
    let ap_object_authz = fetch_ap_object_authz(exec, ap_object_id, &user_authz.acct).await?;
    Ok(ap_object_authz)
}