pubnub-hyper 0.1.0

PubNub async crate based on Tokio and Hyper
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
44
45
46
47
48
49
50
51
52
53
54

//! Common utilities.

use super::error;
use crate::core::json;
use futures_util::stream::StreamExt;
use hyper::{Body, Response, Uri};
use json::{object::Object as JsonObject, JsonValue};
use log::{debug, trace};

use super::Hyper;

pub(super) fn build_uri(hyper: &Hyper, path_and_query: &str) -> Result<Uri, http::Error> {
    let url = Uri::builder()
        .scheme("https")
        .authority(hyper.origin.as_str())
        .path_and_query(path_and_query)
        .build()?;
    debug!("URL: {}", url);
    Ok(url)
}

pub(super) async fn handle_json_response(
    response: Response<Body>,
) -> Result<json::JsonValue, error::Error> {
    let mut body = response.into_body();
    let mut bytes = Vec::new();

    // Receive the response as a byte stream
    while let Some(chunk) = body.next().await {
        bytes.extend(chunk?);
    }

    // Convert the resolved byte stream to JSON.
    let data = std::str::from_utf8(&bytes)?;
    let data_json = json::parse(data)?;

    trace!("Response JSON: {}", data_json);

    Ok(data_json)
}

pub(super) fn json_as_array(val: &JsonValue) -> Option<&Vec<JsonValue>> {
    match val {
        JsonValue::Array(val) => Some(val),
        _ => None,
    }
}

pub(super) fn json_as_object(val: &JsonValue) -> Option<&JsonObject> {
    match val {
        JsonValue::Object(val) => Some(val),
        _ => None,
    }
}