Skip to main content

jax_daemon/http_server/api/v0/mounts/
delete_mount.rs

1//! Delete mount API endpoint
2
3use axum::extract::{Path, State};
4use axum::response::{IntoResponse, Response};
5use axum::Json;
6use reqwest::{Client, RequestBuilder, Url};
7use serde::{Deserialize, Serialize};
8use uuid::Uuid;
9
10use crate::http_server::api::client::ApiRequest;
11use crate::ServiceState;
12
13/// Request to delete a mount
14#[derive(Debug, Clone, Serialize, Deserialize)]
15pub struct DeleteMountRequest {
16    pub mount_id: Uuid,
17}
18
19/// Response indicating mount was deleted
20#[derive(Debug, Clone, Serialize, Deserialize)]
21pub struct DeleteMountResponse {
22    pub deleted: bool,
23}
24
25pub async fn handler(
26    State(state): State<ServiceState>,
27    Path(id): Path<Uuid>,
28) -> Result<impl IntoResponse, DeleteMountError> {
29    let mount_manager = state.mount_manager().read().await;
30    let mount_manager = mount_manager
31        .as_ref()
32        .ok_or(DeleteMountError::MountManagerUnavailable)?;
33
34    let deleted = mount_manager.delete(&id).await?;
35
36    Ok((http::StatusCode::OK, Json(DeleteMountResponse { deleted })).into_response())
37}
38
39#[derive(Debug, thiserror::Error)]
40pub enum DeleteMountError {
41    #[error("Mount manager unavailable")]
42    MountManagerUnavailable,
43    #[error("Mount error: {0}")]
44    Mount(#[from] crate::fuse::MountError),
45}
46
47impl IntoResponse for DeleteMountError {
48    fn into_response(self) -> Response {
49        match self {
50            DeleteMountError::MountManagerUnavailable => (
51                http::StatusCode::SERVICE_UNAVAILABLE,
52                "Mount manager not available",
53            )
54                .into_response(),
55            DeleteMountError::Mount(e) => (
56                http::StatusCode::INTERNAL_SERVER_ERROR,
57                format!("Mount error: {}", e),
58            )
59                .into_response(),
60        }
61    }
62}
63
64impl ApiRequest for DeleteMountRequest {
65    type Response = DeleteMountResponse;
66
67    fn build_request(self, base_url: &Url, client: &Client) -> RequestBuilder {
68        let full_url = base_url
69            .join(&format!("/api/v0/mounts/{}", self.mount_id))
70            .unwrap();
71        client.delete(full_url)
72    }
73}