jax_daemon/http_server/api/v0/mounts/
delete_mount.rs1use 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#[derive(Debug, Clone, Serialize, Deserialize)]
15pub struct DeleteMountRequest {
16 pub mount_id: Uuid,
17}
18
19#[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}