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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
use rocket::{get, post, serde::json::Json, Build, Rocket, State};
use rocket_okapi::{
openapi, openapi_get_routes,
rapidoc::{make_rapidoc, GeneralConfig, HideShowConfig, RapiDocConfig},
settings::UrlObject,
swagger_ui::{make_swagger_ui, SwaggerUIConfig},
};
use tracing::warn;
use zone_core::{Container, PartialEqOrDefault};
use zone_zfs::ZFS;
use crate::{Config, Error, Result};
/// # Test endpoint
///
/// Returns a list of containers based on the query.
#[openapi(tag = "Testing")]
#[get("/test")]
pub fn test_endpoint(zfs: &State<zone_zfs::ZFS>) -> Json<String> {
Json(zfs.config.pool_name.to_owned())
}
/// List containers
///
/// Returns a list of containers based on the query.
#[openapi(tag = "Container")]
#[get("/container/list?<container..>")]
pub fn container_list(container: Container) -> Json<Vec<Container>> {
zone_nspawn::get_containers()
.unwrap_or_else(|err| {
warn!("Invalid nspawn container found: {}", err);
Default::default()
})
.into_iter()
.map(|c| {
c.try_into().unwrap_or_else(|err| {
warn!("Invalid nspawn container found: {}", err);
Default::default()
})
})
.filter(|c| container.eq_or_default(c))
.collect::<Vec<Container>>()
.into()
}
/// Create container
///
/// Creates a new container volume from the provided container json data
#[openapi(tag = "Container")]
#[post("/container", data = "<container>")]
fn create_container(
container: Json<Container>,
zfs: &State<zone_zfs::ZFS>,
) -> Result<Json<Container>> {
zfs.clone_from_latest(
format!("{}-{}", container.user, container.id).into(),
container.template.to_owned().into(),
)?
.try_into()
.map_err(Error::from)
.map(Container::into)
}
pub fn build_zfs(config: &Config) -> Result<ZFS> {
zone_zfs::ZFS::custom(&config.zfs_config).map_err(Error::from)
}
pub fn build_rocket(config: &Config) -> Rocket<Build> {
rocket::custom(config.rocket_config.to_owned())
.mount(
"/",
openapi_get_routes![test_endpoint, container_list, create_container,],
)
.mount(
"/swagger-ui/",
make_swagger_ui(&SwaggerUIConfig {
url: "../openapi.json".to_owned(),
..Default::default()
}),
)
.mount(
"/rapidoc/",
make_rapidoc(&RapiDocConfig {
general: GeneralConfig {
spec_urls: vec![UrlObject::new("General", "../openapi.json")],
..Default::default()
},
hide_show: HideShowConfig {
allow_spec_url_load: false,
allow_spec_file_load: false,
..Default::default()
},
..Default::default()
}),
)
}
|
