ipfsapi 0.4.0

Crate for interfacing with the IPFS api
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::io::{BufReader, BufRead};

use serde_json;
use serde_json::Value;

impl IpfsApi {
    /// Returns an iterator to the log stream. Since the log entries are
    /// flexible, a dynamic Serde value is returned.
    pub fn log_tail(&self) -> Result<impl Iterator<Item=Value>, Error> {
        let mut url = self.get_url()?;
        url.set_path("api/v0/log/tail");
        let resp = reqwest::get(url)?;

        let messages = BufReader::new(resp).lines()
            .filter(|x|x.is_ok())
            .map(|x|x.unwrap())
            .map(|x|serde_json::from_str(&x))
            .filter(|x|x.is_ok())
            .map(|x|x.unwrap());

        Ok(messages)
    }
}