activitystreams/src/lib.rs
2018-05-12 14:51:54 -05:00

66 lines
1.6 KiB
Rust

#[macro_use]
extern crate activitystreams_derive;
extern crate chrono;
#[macro_use]
extern crate failure;
extern crate mime;
extern crate serde;
#[macro_use]
extern crate serde_derive;
#[macro_use]
extern crate serde_json;
pub fn context() -> serde_json::Value {
json!({
"one": "two",
})
}
pub trait Properties {
fn get_value<F, I>(&self, f: F) -> error::Result<I>
where
F: FnOnce(&Self) -> &serde_json::Value,
I: serde::de::DeserializeOwned,
{
serde_json::from_value(f(self).clone()).map_err(|_| error::Error::Deserialize)
}
fn get_item<F, I>(&self, f: F) -> error::Result<I>
where
F: FnOnce(&Self) -> &Option<serde_json::Value>,
I: serde::de::DeserializeOwned,
{
if let &Some(ref item) = f(self) {
serde_json::from_value(item.clone()).map_err(|_| error::Error::Deserialize)
} else {
Err(error::Error::NotFound)
}
}
fn get_vec<F, I>(&self, f: F) -> error::Result<Vec<I>>
where
F: FnOnce(&Self) -> &Vec<serde_json::Value>,
I: serde::de::DeserializeOwned,
{
let item = f(self);
item.iter().fold(Ok(Vec::new()), |acc, item| match acc {
Ok(mut acc) => match serde_json::from_value(item.clone()) {
Ok(item) => {
acc.push(item);
Ok(acc)
}
Err(_) => Err(error::Error::Deserialize),
},
Err(e) => Err(e),
})
}
}
pub mod activity;
pub mod actor;
pub mod collection;
pub mod error;
pub mod link;
pub mod object;