application.rs

use crate::models::app::AppState;
use crate::models::application::{Application, ApplicationStatus};
use crate::models::auth::{ApplicationAdmin, AuthUser};
use crate::models::error::ChaosError;
use crate::models::transaction::DBTransaction;
use axum::extract::{Json, Path, State};
use axum::http::StatusCode;
use axum::response::IntoResponse;

pub struct ApplicationHandler;

impl ApplicationHandler {
    pub async fn get(
        Path(application_id): Path<i64>,
        _admin: ApplicationAdmin,
        mut transaction: DBTransaction<'_>,
    ) -> Result<impl IntoResponse, ChaosError> {
        let application = Application::get(application_id, &mut transaction.tx).await?;
        transaction.tx.commit().await?;
        Ok((StatusCode::OK, Json(application)))
    }

    pub async fn set_status(
        State(state): State<AppState>,
        Path(application_id): Path<i64>,
        _admin: ApplicationAdmin,
        Json(data): Json<ApplicationStatus>,
    ) -> Result<impl IntoResponse, ChaosError> {
        Application::set_status(application_id, data, &state.db).await?;
        Ok((StatusCode::OK, "Status successfully updated"))
    }

    pub async fn set_private_status(
        State(state): State<AppState>,
        Path(application_id): Path<i64>,
        _admin: ApplicationAdmin,
        Json(data): Json<ApplicationStatus>,
    ) -> Result<impl IntoResponse, ChaosError> {
        Application::set_private_status(application_id, data, &state.db).await?;
        Ok((StatusCode::OK, "Private Status successfully updated"))
    }

    pub async fn get_from_curr_user(
        user: AuthUser,
        mut transaction: DBTransaction<'_>,
    ) -> Result<impl IntoResponse, ChaosError> {
        let applications = Application::get_from_user_id(user.user_id, &mut transaction.tx).await?;
        transaction.tx.commit().await?;
        Ok((StatusCode::OK, Json(applications)))
    }
}