Init
This commit is contained in:
@@ -26,7 +26,6 @@ impl App {
|
|||||||
let repositories = Repositories::new(db.get_connection(), event_bus.clone());
|
let repositories = Repositories::new(db.get_connection(), event_bus.clone());
|
||||||
|
|
||||||
let state = AppState{db: db.clone(), event_bus: event_bus.clone(), repositories: repositories.clone()};
|
let state = AppState{db: db.clone(), event_bus: event_bus.clone(), repositories: repositories.clone()};
|
||||||
// let state = AppState::new();
|
|
||||||
|
|
||||||
let udp_server = UDPServer::new(config.bind_addr());
|
let udp_server = UDPServer::new(config.bind_addr());
|
||||||
let http_server = HTTPServer::new(config.bind_addr(), state);
|
let http_server = HTTPServer::new(config.bind_addr(), state);
|
||||||
|
|||||||
@@ -16,6 +16,7 @@ pub fn setup_route() -> AppRouter {
|
|||||||
.route("/servers/", post(server_create))
|
.route("/servers/", post(server_create))
|
||||||
.route("/servers/{id}/", put(server_update))
|
.route("/servers/{id}/", put(server_update))
|
||||||
.route("/servers/{id}/", delete(server_delete))
|
.route("/servers/{id}/", delete(server_delete))
|
||||||
|
.route("/servers/{id}/password/", get(server_password))
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn server_list(
|
pub async fn server_list(
|
||||||
@@ -75,3 +76,14 @@ pub async fn server_delete(
|
|||||||
Err(HTTPError::NotFound)
|
Err(HTTPError::NotFound)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn server_password(
|
||||||
|
State(state): State<AppState>,
|
||||||
|
Path(id): Path<Uuid>
|
||||||
|
) -> Result<Json<Option<String>>, HTTPError> {
|
||||||
|
let server = state.repositories.server.get_by_id(id)
|
||||||
|
.await?
|
||||||
|
.ok_or(HTTPError::NotFound)?;
|
||||||
|
|
||||||
|
Ok(Json(server.password))
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user