(
State(state): State<AppState>,
headers: HeaderMap,
Json(request): Json<PruneServersRequest>,
)
| 697 | ) |
| 698 | )] |
| 699 | async fn observe_server( |
| 700 | State(state): State<AppState>, |
| 701 | headers: HeaderMap, |
| 702 | Path(server_id): Path<String>, |
| 703 | Json(request): Json<ObserveServerRequest>, |
| 704 | ) -> Result<Json<DirectoryServerRecord>, (StatusCode, String)> { |
| 705 | require_admin_api_key(&state, &headers)?; |
| 706 | let observed_unix_ms = request.observed_unix_ms.unwrap_or_else(current_time_millis); |
| 707 | state |
| 708 | .service |
| 709 | .observe(&server_id, observed_unix_ms, request.reachable) |
| 710 | .await |
| 711 | .map_err(|error| internal_error(&error))? |
| 712 | .map_or_else( |
| 713 | || { |
| 714 | Err(( |
nothing calls this directly
no test coverage detected