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
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

use axum::{
    extract::{Extension, Query},
    response::IntoResponse,
    Json,
};
use dialtone_common::{
    ap::id::{parse_actors_host, parse_actors_pun},
    rest::ap_objects::ap_object_exchanges::{
        ApObjectIdResponse, GetApObject, PostApObject, PutApObject,
    },
};
use dialtone_sqlx::{
    control::ap_object::{create_owned::create_owned_ap_object, update::update_owned_ap_object},
    db::ap_object::fetch_owned::fetch_owned_ap_object,
};
use sqlx::{Pool, Postgres};

use crate::{
    authz::authz_ap_object::{
        authz_owner_or_contentadmin_for_actor, authz_owner_or_contentadmin_for_ap_object,
    },
    err_not_found,
    response::response_error::ResponseError,
    start_server::{Claims, SharedState},
};

pub async fn post_owned_ap_object_handler(
    Json(request): Json<PostApObject>,
    _claims: Claims,
    Extension(state): Extension<SharedState>,
    Extension(pool): Extension<Pool<Postgres>>,
) -> Result<impl IntoResponse, ResponseError> {
    authz_owner_or_contentadmin_for_actor(&pool, &state, &request.actor_id).await?;
    let host_name = parse_actors_host(&request.actor_id)?;
    let pun = parse_actors_pun(&request.actor_id)?;
    let ap_object_id = create_owned_ap_object(
        &pool,
        &host_name,
        &pun,
        &request.actor_id,
        &request.create_ap_object,
    )
    .await?;
    Ok(Json(ApObjectIdResponse { ap_object_id }))
}

pub async fn put_owned_ap_object_handler(
    Json(request): Json<PutApObject>,
    _claims: Claims,
    Extension(state): Extension<SharedState>,
    Extension(pool): Extension<Pool<Postgres>>,
) -> Result<impl IntoResponse, ResponseError> {
    authz_owner_or_contentadmin_for_ap_object(&pool, &state, &request.ap_object_id).await?;
    let ap_object_id =
        update_owned_ap_object(&pool, &request.ap_object_id, request.update_ap_object).await?;
    ap_object_id.map_or_else(
        || err_not_found!(),
        |id| Ok(Json(ApObjectIdResponse { ap_object_id: id })),
    )
}

pub async fn get_owned_ap_object_handler(
    Query(params): Query<GetApObject>,
    _claims: Claims,
    Extension(state): Extension<SharedState>,
    Extension(pool): Extension<Pool<Postgres>>,
) -> Result<impl IntoResponse, ResponseError> {
    authz_owner_or_contentadmin_for_ap_object(&pool, &state, &params.ap_object_id).await?;
    fetch_owned_ap_object(&pool, &params.ap_object_id)
        .await?
        .map_or_else(|| err_not_found!(), |v| Ok(Json(v)))
}