use axum::response::sse::Event; use serde::{Deserialize, Serialize}; #[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Serialize, Deserialize)] #[serde(rename_all = "lowercase", tag = "status", content = "output")] pub enum Status { Ok, Error(Option), } impl Default for Status { fn default() -> Self { Status::Error(None) } } impl Status { pub fn update(&mut self, status: Status) -> bool { let modif = *self != status; if modif { *self = status; } modif } } impl From> for Status { fn from(value: Result) -> Self { match value { Ok(_) => Status::Ok, Err(err) => Status::Error(Some(err.to_string())), } } } impl axum::response::IntoResponse for Status { fn into_response(self) -> axum::response::Response { axum::Json(self).into_response() } } impl From for Event { fn from(value: Status) -> Self { match value { Status::Ok => Event::default().event("ok"), Status::Error(None) => Event::default().event("error"), Status::Error(Some(msg)) => Event::default().event("error").data(msg), } } }