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
|
use serde::{Deserialize, Serialize};
use service::ServiceHandles;
pub use crate::error::{Error, Result};
pub mod api;
pub mod error;
pub mod service;
pub mod sse;
pub fn router() -> axum::Router<ServiceHandles> {
axum::Router::new()
.nest("/api", api::router())
.nest("/sse", sse::router())
}
#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Serialize, Deserialize)]
#[serde(rename_all = "lowercase", tag = "status", content = "output")]
pub enum Status {
Ok,
Error(Option<String>),
}
impl Default for Status {
fn default() -> Self {
Status::Error(Some("Unknown".to_string()))
}
}
impl Status {
pub fn update(&mut self, status: Status) -> bool {
let modif = *self != status;
if modif {
*self = status;
}
modif
}
}
impl<T: std::error::Error> From<T> for Status {
fn from(value: T) -> Self {
Status::Error(Some(value.to_string()))
}
}
impl axum::response::IntoResponse for Status {
fn into_response(self) -> axum::response::Response {
axum::Json(self).into_response()
}
}
|
