romm-api 1.0.0

HTTP client and domain logic for the RomM API
Documentation 
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

use crate::error::ApiError;
use reqwest::Response;
use reqwest::StatusCode;
use serde_json::Value;

/// Map a successful HTTP response body to JSON [`Value`].
///
/// Empty or whitespace-only bodies become [`Value::Null`] (e.g. HTTP 204).
/// Non-JSON UTF-8 bodies are wrapped as `{"_non_json_body": "..."}`.
pub(crate) fn decode_json_response_body(bytes: &[u8]) -> Value {
    if bytes.is_empty() || bytes.iter().all(|b| b.is_ascii_whitespace()) {
        return Value::Null;
    }
    serde_json::from_slice(bytes).unwrap_or_else(|_| {
        serde_json::json!({
            "_non_json_body": String::from_utf8_lossy(bytes).to_string()
        })
    })
}

/// Read an error response body without panicking when the stream fails.
pub(crate) async fn read_error_response_text(resp: Response) -> String {
    match resp.text().await {
        Ok(body) => body,
        Err(err) => format!("<failed to read error body: {err}>"),
    }
}

pub(crate) fn api_error_from_response(status: StatusCode, body: &str) -> ApiError {
    ApiError::from_http_response(status, body.to_string())
}

pub(crate) fn api_error_from_response_truncated(
    status: StatusCode,
    body: &str,
    max_chars: usize,
) -> ApiError {
    ApiError::from_http_response(status, body.chars().take(max_chars).collect::<String>())
}

pub(crate) fn version_from_heartbeat_json(v: &Value) -> Option<String> {
    v.get("SYSTEM")?.get("VERSION")?.as_str().map(String::from)
}