libedgegrid 0.1.0

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

use auth::EdgeGridAuth;
use request;
use request::HttpRequestVerb::*;
use serde_json;
use std::str::FromStr;

#[cfg(feature = "serde_macros")]
include!("req.rs.in");

#[cfg(not(feature = "serde_macros"))]
include!(concat!(env!("OUT_DIR"), "/ccu/req.rs"));

impl PurgeArls {
    pub fn new(arls: Vec<String>) -> PurgeArls {
        PurgeArls { objects: arls }
    }
}

impl PurgeCPCodes {
    pub fn new(cpcodes: Vec<String>) -> PurgeCPCodes {
        let mut codes: Vec<usize> = Vec::new();

        for code in cpcodes.iter() {
            match usize::from_str(code) {
                Ok(c) => { codes.push(c); },
                Err(e) => { error!("{:?}", e); },
            }
        }

        PurgeCPCodes {
            objects: codes,
            action: String::from("remove"),
            purge_type: String::from("cpcode"),
        }
    }
}

const BASE_URL: &'static str = "/ccu/v2/";

fn purge(
    edge_grid_auth: &EdgeGridAuth,
    queue_name: &str,
    json: &str
) -> ::EdgeGridResponse {
    let relurl = &format!("{}queues/{}", BASE_URL, queue_name)[..];
    Ok(try!(request::request(edge_grid_auth, relurl, Some(json), POST)))
}

pub fn purge_by_arl(
    edge_grid_auth: &EdgeGridAuth,
    queue_name: &str,
    body: PurgeArls
) -> ::EdgeGridResponse {
    let json = &try!(serde_json::to_string(&body))[..];
    purge(edge_grid_auth, queue_name, json)
}

pub fn purge_by_cpcode(
    edge_grid_auth: &EdgeGridAuth,
    queue_name: &str,
    body: PurgeCPCodes
) -> ::EdgeGridResponse {
    let json = &try!(serde_json::to_string(&body))[..];
    purge(edge_grid_auth, queue_name, json)
}

pub fn purge_status(
    edge_grid_auth: &EdgeGridAuth,
    purge_id: &str
) -> ::EdgeGridResponse {
    let relurl = &format!("{}purges/{}", BASE_URL, purge_id)[..];
    Ok(try!(request::request(edge_grid_auth, relurl, None, GET)))
}

pub fn queue_length(
    edge_grid_auth: &EdgeGridAuth,
    queue_name: &str
) -> ::EdgeGridResponse {
    let relurl = &format!("{}queues/{}", BASE_URL, queue_name)[..];
    Ok(try!(request::request(edge_grid_auth, relurl, None, GET)))
}