Crates.io | api_kit |
lib.rs | api_kit |
version | 0.2.0 |
source | src |
created_at | 2016-08-15 13:29:34.229564 |
updated_at | 2016-08-23 13:48:06.553364 |
description | Rust library for build typesafe web api client. |
homepage | |
repository | https://github.com/pocket7878/api_kit |
max_upload_size | |
id | 5977 |
size | 16,228 |
Rust library for build typesafe web api client.
extern crate api_kit;
extern crate hyper;
extern crate serde_json;
use hyper::client::response::Response;
use api_kit::api_request::{ApiRequest, ApiRequestBuilder};
use api_kit::api_request::HttpMethod;
use api_kit::api_client::ApiClient;
use api_kit::error::ApiError;
use hyper::header::{Headers, Accept, qitem};
use hyper::mime::{Mime, TopLevel, SubLevel, Attr, Value};
use hyper::client::request::Request;
use hyper::net::Fresh;
use std::io::{Read};
use std::rc::Rc;
use std::cell::RefCell;
use api_kit::interceptor::log::LogInterceptor;
struct CircleCi {
}
impl ApiClient for CircleCi {
fn base_url(&self) -> String {
return String::from("https://circleci.com/api/v1.1");
}
}
struct CircleCiMeRequest<'a> {
api_token: &'a str
}
impl<'a> CircleCiMeRequest<'a> {
fn new(token: &'a str) -> CircleCiMeRequest {
CircleCiMeRequest {
api_token: token
}
}
}
impl<'a> ApiRequestBuilder<serde_json::Value> for CircleCiMeRequest<'a> {
fn method(&self) -> HttpMethod {
return HttpMethod::Get;
}
fn path(&self) -> String {
return String::from("/me");
}
fn queryParameters(&self) -> Vec<(String, String)> {
return vec![
(String::from("circle-token"), String::from(self.api_token))
];
}
fn interceptRequest(&self, mut request: Request<Fresh>) -> Result<Request<Fresh>, ApiError> {
request.headers_mut().set(
Accept(vec![
qitem(Mime(TopLevel::Application, SubLevel::Json,
vec![(Attr::Charset, Value::Utf8)])),
])
);
return Ok(request);
}
fn responseFromObject(&self, response: Rc<RefCell<Response>>) -> Result<serde_json::Value, ApiError> {
let mut raw_response = (*response).borrow_mut();
let mut buffer = String::new();
raw_response.read_to_string(&mut buffer).unwrap();
return Ok(serde_json::from_str(&buffer).unwrap());
}
}
fn main() {
let ci = CircleCi {} ;
let me = ci.call(Rc::new(CircleCiMeRequest::new("Your-CircleCi-Token")))
.addInterceptor(Box::new(LogInterceptor {}))
.send();
println!("{}", me.unwrap());
}