backend/controller/
base_layer_image.rs

//! `BaseLayerImage` endpoints.

use actix_web::{
    delete, get, patch, post,
    web::{Json, Path},
    HttpResponse, Result,
};
use uuid::Uuid;

use crate::config::data::{SharedBroadcaster, SharedPool};
use crate::{
    config::auth::user_info::UserInfo,
    model::dto::{
        actions::{
            Action, ActionType, CreateBaseLayerImageActionPayload,
            DeleteBaseLayerImageActionPayload, UpdateBaseLayerImageActionPayload,
        },
        core::{
            ActionDtoWrapper, ActionDtoWrapperDeleteBaseLayerImage,
            ActionDtoWrapperNewBaseLayerImage, ActionDtoWrapperUpdateBaseLayerImage,
        },
    },
    service::base_layer_images,
};

/// Endpoint for listing and filtering `BaseLayerImage`.
///
/// # Errors
/// * If the connection to the database could not be established.
#[utoipa::path(
    context_path = "/api/maps/{map_id}/layers/base/{layer_id}/images",
    params(
        ("map_id" = i32, Path, description = "The id of the map the layer is on"),
        ("layer_id" = i32, Path, description = "The id of the layer"),
    ),
    responses(
        (status = 200, description = "Find base layer images", body = Vec<BaseLayerImageDto>)
    ),
    security(
        ("oauth2" = [])
    )
)]
#[get("")]
pub async fn find(path: Path<(i32, Uuid)>, pool: SharedPool) -> Result<HttpResponse> {
    let (_map_id, layer_id) = path.into_inner();
    let response = base_layer_images::find(&pool, layer_id).await?;
    Ok(HttpResponse::Ok().json(response))
}

/// Endpoint for creating a new `BaseLayerImage`.
///
/// # Errors
/// * If the connection to the database could not be established.
#[utoipa::path(
    context_path = "/api/maps/{map_id}/layers/base/images",
    params(
        ("map_id" = i32, Path, description = "The id of the map the layer is on"),
    ),
    request_body = ActionDtoWrapperNewBaseLayerImage,
    responses(
        (status = 201, description = "Create a planting", body = BaseLayerImageDto)
    ),
    security(
        ("oauth2" = [])
    )
)]
#[post("")]
pub async fn create(
    path: Path<i32>,
    json: Json<ActionDtoWrapperNewBaseLayerImage>,
    user_info: UserInfo,
    pool: SharedPool,
    broadcaster: SharedBroadcaster,
) -> Result<HttpResponse> {
    let ActionDtoWrapper { action_id, dto } = json.into_inner();

    let dto = base_layer_images::create(dto.clone(), &pool).await?;

    broadcaster
        .broadcast(
            path.into_inner(),
            Action {
                action_id,
                user_id: user_info.id,
                action: ActionType::CreateBaseLayerImage(CreateBaseLayerImageActionPayload::new(
                    dto.clone(),
                )),
            },
        )
        .await;

    Ok(HttpResponse::Created().json(dto))
}

/// Endpoint for updating a `BaseLayerImage`.
///
/// # Errors
/// * If the connection to the database could not be established.
#[utoipa::path(
    context_path = "/api/maps/{map_id}/layers/base/images",
    params(
        ("map_id" = i32, Path, description = "The id of the map the layer is on"),
        ("base_layer_image_id" = Uuid, Path, description = "The id of the BaseLayerImage to update"),
    ),
    request_body = ActionDtoWrapperUpdateBaseLayerImage,
    responses(
        (status = 200, description = "Update a planting", body = BaseLayerImageDto)
    ),
    security(
        ("oauth2" = [])
    )
)]
#[patch("/{base_layer_image_id}")]
pub async fn update(
    path: Path<(i32, Uuid)>,
    json: Json<ActionDtoWrapperUpdateBaseLayerImage>,
    user_info: UserInfo,
    pool: SharedPool,
    broadcaster: SharedBroadcaster,
) -> Result<HttpResponse> {
    let (map_id, base_layer_image_id) = path.into_inner();
    let ActionDtoWrapper { action_id, dto } = json.into_inner();

    let dto = base_layer_images::update(base_layer_image_id, dto.clone(), &pool).await?;

    broadcaster
        .broadcast(
            map_id,
            Action {
                action_id,
                user_id: user_info.id,
                action: ActionType::UpdateBaseLayerImage(UpdateBaseLayerImageActionPayload::new(
                    dto.clone(),
                )),
            },
        )
        .await;

    Ok(HttpResponse::Ok().json(dto))
}

/// Endpoint for deleting a `BaseLayerImage`.
///
/// # Errors
/// * If the connection to the database could not be established.
#[utoipa::path(
    context_path = "/api/maps/{map_id}/layers/base/images",
    params(
        ("map_id" = i32, Path, description = "The id of the map the layer is on"),
    ),
    responses(
        (status = 200, description = "Delete a planting")
    ),
    security(
        ("oauth2" = [])
    )
)]
#[delete("")]
pub async fn delete(
    path: Path<i32>,
    json: Json<ActionDtoWrapperDeleteBaseLayerImage>,
    user_info: UserInfo,
    pool: SharedPool,
    broadcaster: SharedBroadcaster,
) -> Result<HttpResponse> {
    let map_id = path.into_inner();
    let ActionDtoWrapper { action_id, dto } = json.into_inner();

    let id = dto.id;
    base_layer_images::delete_by_id(id, &pool).await?;

    broadcaster
        .broadcast(
            map_id,
            Action {
                action_id,
                user_id: user_info.id,
                action: ActionType::DeleteBaseLayerImage(DeleteBaseLayerImageActionPayload::new(
                    id,
                )),
            },
        )
        .await;

    Ok(HttpResponse::Ok().finish())
}
backend/controller/base_layer_image.rs

backend/controller/
base_layer_image.rs
