use axum::headers::HeaderMap; use axum::http::StatusCode; use axum::Json; use axum::response::{IntoResponse, Response}; use serde::{Deserialize, Serialize}; use std::error::Error; use serde_json::{json, Value}; use tracing::error; use crate::auth::{auth, AuthError}; use crate::config::SETTINGS; use crate::wol::{create_buffer, send_packet}; pub async fn start(headers: HeaderMap, Json(payload): Json) -> Result, StartError> { let secret = headers.get("authorization"); if auth(secret).map_err(StartError::Auth)? { let bind_addr = SETTINGS .get_string("bindaddr") .map_err(|err| StartError::Server(Box::new(err)))?; let broadcast_addr = SETTINGS .get_string("broadcastaddr") .map_err(|err| StartError::Server(Box::new(err)))?; let _ = send_packet( &bind_addr.parse().map_err(|err| StartError::Server(Box::new(err)))?, &broadcast_addr.parse().map_err(|err| StartError::Server(Box::new(err)))?, // TODO: MAC saved in DB create_buffer(std::env::var("MAC").unwrap().as_str()).map_err(|err| StartError::Server(Box::new(err)))? ).map_err(|err| StartError::Server(Box::new(err))); Ok(Json(json!(StartResponse { id: payload.id, boot: true }))) } else { Err(StartError::Generic) } } #[derive(Deserialize)] pub struct StartPayload { id: String, _test: Option, } #[derive(Serialize)] struct StartResponse { id: String, boot: bool, } pub enum StartError { Auth(AuthError), Generic, Server(Box), } impl IntoResponse for StartError { fn into_response(self) -> Response { let (status, error_message) = match self { StartError::Auth(err) => err.get(), StartError::Generic => (StatusCode::INTERNAL_SERVER_ERROR, ""), StartError::Server(err) => { error!("server error: {}", err.to_string()); (StatusCode::INTERNAL_SERVER_ERROR, "Server Error") }, }; let body = Json(json!({ "error": error_message, })); (status, body).into_response() } }