libedgegrid 0.1.1

This library implements an Authentication handler for the Akamai OPEN EdgeGrid Authentication scheme in Rust
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use curl::http;
use serde::Deserialize;
use serde_json;
use std::fmt;

pub fn parse_response<S, F>(resp: http::Response, on_success: S, on_failure: F) -> ::EdgeGridResult
    where S: Fn(String) -> ::EdgeGridResult,
          F: Fn(String) -> ::EdgeGridResult
{
    let body_vec = Vec::from(resp.get_body());
    let body = try!(String::from_utf8(body_vec));
    match resp.get_code() {
        c @ 200...299 => {
            debug!("Successful 2xx: {}", c);
            debug!("Content-Length Check: {}", check_content_length(&resp));
            debug!("Content-Type Check: {}", check_content_type_json(&resp));
            on_success(body)
        }
        c @ 300...399 => {
            debug!("Redirection 3xx: {}", c);
            debug!("Content-Length Check: {}", check_content_length(&resp));
            debug!("Content-Type Check: {}",
                   check_content_type_problem_json(&resp));
            on_failure(body)
        }
        c @ 400...499 => {
            debug!("Client Error 4xx: {}", c);
            debug!("Content-Length Check: {}", check_content_length(&resp));
            debug!("Content-Type Check: {}",
                   check_content_type_problem_json(&resp));
            on_failure(body)
        }
        c @ 500...599 => {
            debug!("Server Error 5xx: {}", c);
            debug!("Content-Length Check: {}", check_content_length(&resp));
            debug!("Content-Type Check: {}",
                   check_content_type_problem_json(&resp));
            on_failure(body)
        }
        c @ _ => {
            Err(::EdgeGridError {
                title: Some(format!("Unknown Error: {}", c)),
                detail: Some(body),
                ..Default::default()
            })
        }
    }
}

pub fn gen_error_output(body: String) -> ::EdgeGridResult {
    debug!("{}", body);
    let json: ::EdgeGridError = try!(serde_json::from_str(&body));
    debug!("{:?}", json);
    Err(json)
}

pub fn gen_output<T>(body: String) -> ::EdgeGridResult
    where T: fmt::Display + fmt::Debug + Deserialize
{
    debug!("{}", body);
    let json = try!(serde_json::from_str::<T>(&body));
    debug!("{:?}", json);
    Ok(format!("{}", json))
}

pub fn check_content_length(resp: &http::Response) -> bool {
    let given: usize = match resp.get_header("content-length")[0].parse() {
        Ok(g) => g,
        Err(_) => return false,
    };
    given == resp.get_body().len()
}

pub fn check_content_type_json(resp: &http::Response) -> bool {
    let ref given: String = resp.get_header("content-type")[0];
    given.starts_with("application/json")
}

pub fn check_content_type_problem_json(resp: &http::Response) -> bool {
    let ref given: String = resp.get_header("content-type")[0];
    given == "application/problem+json"
}