diff options
Diffstat (limited to 'ipfs-api/src')
60 files changed, 126 insertions, 423 deletions
diff --git a/ipfs-api/src/header.rs b/ipfs-api/src/header.rs index 460af2b..aec3c0a 100644 --- a/ipfs-api/src/header.rs +++ b/ipfs-api/src/header.rs @@ -10,7 +10,6 @@ use hyper; use hyper::header::{self, Header, Raw}; use std::fmt; - /// Header that is returned for streaming calls. /// /// A `Trailer` header indicates that after a streaming call, there will @@ -51,7 +50,6 @@ impl Header for Trailer { } } - /// This header is included while streaming if an error occured /// while streaming the data. /// @@ -69,7 +67,9 @@ impl Header for XStreamError { if let Some(bytes) = raw.one() { let value = String::from_utf8_lossy(bytes); - Ok(XStreamError { error: value.into_owned() }) + Ok(XStreamError { + error: value.into_owned(), + }) } else { Err(hyper::Error::Header) } diff --git a/ipfs-api/src/read.rs b/ipfs-api/src/read.rs index 5f60c69..5a37b08 100644 --- a/ipfs-api/src/read.rs +++ b/ipfs-api/src/read.rs @@ -20,7 +20,6 @@ use std::marker::PhantomData; use tokio_io::AsyncRead; use tokio_io::codec::Decoder; - /// A decoder for a response where each line is a full json object. /// pub struct JsonLineDecoder<T> { @@ -71,14 +70,14 @@ where if self.parse_stream_error { match slice.iter().position(|&x| x == b':') { Some(colon) - if &slice[..colon] == XStreamError::header_name().as_bytes() => { + if &slice[..colon] == XStreamError::header_name().as_bytes() => + { let raw = Raw::from(&slice[colon + 2..]); match XStreamError::parse_header(&raw) { - Ok(stream_error) => Err( - ErrorKind::StreamError(stream_error.error) - .into(), - ), + Ok(stream_error) => { + Err(ErrorKind::StreamError(stream_error.error).into()) + } Err(_) => Err(e.into()), } } @@ -95,7 +94,6 @@ where } } - /// A decoder that reads a line at a time. /// pub struct LineDecoder; @@ -115,8 +113,7 @@ impl Decoder for LineDecoder { let slice = src.split_to(pos + 1); Ok(Some( - String::from_utf8_lossy(&slice[..slice.len() - 1]) - .into_owned(), + String::from_utf8_lossy(&slice[..slice.len() - 1]).into_owned(), )) } else { Ok(None) @@ -124,7 +121,6 @@ impl Decoder for LineDecoder { } } - /// The state of a stream returning Chunks. /// enum ReadState { @@ -137,7 +133,6 @@ enum ReadState { NotReady, } - /// Reads from a stream of chunks asynchronously. /// pub struct StreamReader<S> { diff --git a/ipfs-api/src/request/add.rs b/ipfs-api/src/request/add.rs index 037e57a..666041d 100644 --- a/ipfs-api/src/request/add.rs +++ b/ipfs-api/src/request/add.rs @@ -8,7 +8,6 @@ use request::ApiRequest; - pub struct Add; impl_skip_serialize!(Add); diff --git a/ipfs-api/src/request/bitswap.rs b/ipfs-api/src/request/bitswap.rs index 45230cb..1f795bb 100644 --- a/ipfs-api/src/request/bitswap.rs +++ b/ipfs-api/src/request/bitswap.rs @@ -8,18 +8,15 @@ use request::ApiRequest; - #[derive(Serialize)] pub struct BitswapLedger<'a> { - #[serde(rename = "arg")] - pub peer: &'a str, + #[serde(rename = "arg")] pub peer: &'a str, } impl<'a> ApiRequest for BitswapLedger<'a> { const PATH: &'static str = "/bitswap/ledger"; } - pub struct BitswapStat; impl_skip_serialize!(BitswapStat); @@ -28,18 +25,15 @@ impl ApiRequest for BitswapStat { const PATH: &'static str = "/bitswap/stat"; } - #[derive(Serialize)] pub struct BitswapUnwant<'a> { - #[serde(rename = "arg")] - pub key: &'a str, + #[serde(rename = "arg")] pub key: &'a str, } impl<'a> ApiRequest for BitswapUnwant<'a> { const PATH: &'static str = "/bitswap/stat"; } - #[derive(Serialize)] pub struct BitswapWantlist<'a> { pub peer: Option<&'a str>, diff --git a/ipfs-api/src/request/block.rs b/ipfs-api/src/request/block.rs index b525109..4dca973 100644 --- a/ipfs-api/src/request/block.rs +++ b/ipfs-api/src/request/block.rs @@ -8,18 +8,15 @@ use request::ApiRequest; - #[derive(Serialize)] pub struct BlockGet<'a> { - #[serde(rename = "arg")] - pub hash: &'a str, + #[serde(rename = "arg")] pub hash: &'a str, } impl<'a> ApiRequest for BlockGet<'a> { const PATH: &'static str = "/block/get"; } - pub struct BlockPut; impl_skip_serialize!(BlockPut); @@ -28,22 +25,18 @@ impl ApiRequest for BlockPut { const PATH: &'static str = "/block/put"; } - #[derive(Serialize)] pub struct BlockRm<'a> { - #[serde(rename = "arg")] - pub hash: &'a str, + #[serde(rename = "arg")] pub hash: &'a str, } impl<'a> ApiRequest for BlockRm<'a> { const PATH: &'static str = "/block/rm"; } - #[derive(Serialize)] pub struct BlockStat<'a> { - #[serde(rename = "arg")] - pub hash: &'a str, + #[serde(rename = "arg")] pub hash: &'a str, } impl<'a> ApiRequest for BlockStat<'a> { diff --git a/ipfs-api/src/request/bootstrap.rs b/ipfs-api/src/request/bootstrap.rs index c60072a..bc632f4 100644 --- a/ipfs-api/src/request/bootstrap.rs +++ b/ipfs-api/src/request/bootstrap.rs @@ -8,7 +8,6 @@ use request::ApiRequest; - pub struct BootstrapAddDefault; impl_skip_serialize!(BootstrapAddDefault); @@ -17,7 +16,6 @@ impl ApiRequest for BootstrapAddDefault { const PATH: &'static str = "/bootstrap/add/default"; } - pub struct BootstrapList; impl_skip_serialize!(BootstrapList); @@ -26,7 +24,6 @@ impl ApiRequest for BootstrapList { const PATH: &'static str = "/bootstrap/list"; } - pub struct BootstrapRmAll; impl_skip_serialize!(BootstrapRmAll); diff --git a/ipfs-api/src/request/cat.rs b/ipfs-api/src/request/cat.rs index 6b958d4..f672fed 100644 --- a/ipfs-api/src/request/cat.rs +++ b/ipfs-api/src/request/cat.rs @@ -8,11 +8,9 @@ use request::ApiRequest; - #[derive(Serialize)] pub struct Cat<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, } impl<'a> ApiRequest for Cat<'a> { diff --git a/ipfs-api/src/request/commands.rs b/ipfs-api/src/request/commands.rs index 8dcfdee..11879f2 100644 --- a/ipfs-api/src/request/commands.rs +++ b/ipfs-api/src/request/commands.rs @@ -8,7 +8,6 @@ use request::ApiRequest; - pub struct Commands; impl_skip_serialize!(Commands); diff --git a/ipfs-api/src/request/config.rs b/ipfs-api/src/request/config.rs index 13e0670..41f9ba7 100644 --- a/ipfs-api/src/request/config.rs +++ b/ipfs-api/src/request/config.rs @@ -8,7 +8,6 @@ use request::ApiRequest; - pub struct ConfigEdit; impl_skip_serialize!(ConfigEdit); @@ -17,7 +16,6 @@ impl ApiRequest for ConfigEdit { const PATH: &'static str = "/config/edit"; } - pub struct ConfigReplace; impl_skip_serialize!(ConfigReplace); @@ -26,7 +24,6 @@ impl ApiRequest for ConfigReplace { const PATH: &'static str = "/config/replace"; } - pub struct ConfigShow; impl_skip_serialize!(ConfigShow); diff --git a/ipfs-api/src/request/dag.rs b/ipfs-api/src/request/dag.rs index cc5cf08..fc39872 100644 --- a/ipfs-api/src/request/dag.rs +++ b/ipfs-api/src/request/dag.rs @@ -8,18 +8,15 @@ use request::ApiRequest; - #[derive(Serialize)] pub struct DagGet<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, } impl<'a> ApiRequest for DagGet<'a> { const PATH: &'static str = "/dag/get"; } - pub struct DagPut; impl_skip_serialize!(DagPut); diff --git a/ipfs-api/src/request/dht.rs b/ipfs-api/src/request/dht.rs index dfafbc4..5d772a9 100644 --- a/ipfs-api/src/request/dht.rs +++ b/ipfs-api/src/request/dht.rs @@ -8,69 +8,56 @@ use request::ApiRequest; - #[derive(Serialize)] pub struct DhtFindPeer<'a> { - #[serde(rename = "arg")] - pub peer: &'a str, + #[serde(rename = "arg")] pub peer: &'a str, } impl<'a> ApiRequest for DhtFindPeer<'a> { const PATH: &'static str = "/dht/findpeer"; } - #[derive(Serialize)] pub struct DhtFindProvs<'a> { - #[serde(rename = "arg")] - pub key: &'a str, + #[serde(rename = "arg")] pub key: &'a str, } impl<'a> ApiRequest for DhtFindProvs<'a> { const PATH: &'static str = "/dht/findprovs"; } - #[derive(Serialize)] pub struct DhtGet<'a> { - #[serde(rename = "arg")] - pub key: &'a str, + #[serde(rename = "arg")] pub key: &'a str, } impl<'a> ApiRequest for DhtGet<'a> { const PATH: &'static str = "/dht/get"; } - #[derive(Serialize)] pub struct DhtProvide<'a> { - #[serde(rename = "arg")] - pub key: &'a str, + #[serde(rename = "arg")] pub key: &'a str, } impl<'a> ApiRequest for DhtProvide<'a> { const PATH: &'static str = "/dht/provide"; } - #[derive(Serialize)] pub struct DhtPut<'a> { - #[serde(rename = "arg")] - pub key: &'a str, + #[serde(rename = "arg")] pub key: &'a str, - #[serde(rename = "arg")] - pub value: &'a str, + #[serde(rename = "arg")] pub value: &'a str, } impl<'a> ApiRequest for DhtPut<'a> { const PATH: &'static str = "/dht/put"; } - #[derive(Serialize)] pub struct DhtQuery<'a> { - #[serde(rename = "arg")] - pub peer: &'a str, + #[serde(rename = "arg")] pub peer: &'a str, } impl<'a> ApiRequest for DhtQuery<'a> { diff --git a/ipfs-api/src/request/diag.rs b/ipfs-api/src/request/diag.rs index 2091e0d..d3fda10 100644 --- a/ipfs-api/src/request/diag.rs +++ b/ipfs-api/src/request/diag.rs @@ -8,7 +8,6 @@ use request::ApiRequest; - pub struct DiagCmdsClear; impl_skip_serialize!(DiagCmdsClear); @@ -17,18 +16,15 @@ impl ApiRequest for DiagCmdsClear { const PATH: &'static str = "/diag/cmds/clear"; } - #[derive(Serialize)] pub struct DiagCmdsSetTime<'a> { - #[serde(rename = "arg")] - pub time: &'a str, + #[serde(rename = "arg")] pub time: &'a str, } impl<'a> ApiRequest for DiagCmdsSetTime<'a> { const PATH: &'static str = "/diag/cmds/set-time"; } - pub struct DiagSys; impl_skip_serialize!(DiagSys); diff --git a/ipfs-api/src/request/dns.rs b/ipfs-api/src/request/dns.rs index 8657e7d..90870bf 100644 --- a/ipfs-api/src/request/dns.rs +++ b/ipfs-api/src/request/dns.rs @@ -8,11 +8,9 @@ use request::ApiRequest; - #[derive(Serialize)] pub struct Dns<'a> { - #[serde(rename = "arg")] - pub link: &'a str, + #[serde(rename = "arg")] pub link: &'a str, pub recursive: bool, } diff --git a/ipfs-api/src/request/file.rs b/ipfs-api/src/request/file.rs index ff995fc..ff55e02 100644 --- a/ipfs-api/src/request/file.rs +++ b/ipfs-api/src/request/file.rs @@ -8,11 +8,9 @@ use request::ApiRequest; - #[derive(Serialize)] pub struct FileLs<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, } impl<'a> ApiRequest for FileLs<'a> { diff --git a/ipfs-api/src/request/files.rs b/ipfs-api/src/request/files.rs index cbe07d7..f40c434 100644 --- a/ipfs-api/src/request/files.rs +++ b/ipfs-api/src/request/files.rs @@ -8,47 +8,38 @@ use request::ApiRequest; - #[derive(Serialize)] pub struct FilesCp<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, - #[serde(rename = "arg")] - pub dest: &'a str, + #[serde(rename = "arg")] pub dest: &'a str, } impl<'a> ApiRequest for FilesCp<'a> { const PATH: &'static str = "/files/cp"; } - #[derive(Serialize)] pub struct FilesFlush<'a> { - #[serde(rename = "arg")] - pub path: &'a Option<&'a str>, + #[serde(rename = "arg")] pub path: &'a Option<&'a str>, } impl<'a> ApiRequest for FilesFlush<'a> { const PATH: &'static str = "/files/flush"; } - #[derive(Serialize)] pub struct FilesLs<'a> { - #[serde(rename = "arg")] - pub path: &'a Option<&'a str>, + #[serde(rename = "arg")] pub path: &'a Option<&'a str>, } impl<'a> ApiRequest for FilesLs<'a> { const PATH: &'static str = "/files/ls"; } - #[derive(Serialize)] pub struct FilesMkdir<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, pub parents: bool, } @@ -57,36 +48,29 @@ impl<'a> ApiRequest for FilesMkdir<'a> { const PATH: &'static str = "/files/mkdir"; } - #[derive(Serialize)] pub struct FilesMv<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, - #[serde(rename = "arg")] - pub dest: &'a str, + #[serde(rename = "arg")] pub dest: &'a str, } impl<'a> ApiRequest for FilesMv<'a> { const PATH: &'static str = "/files/mv"; } - #[derive(Serialize)] pub struct FilesRead<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, } impl<'a> ApiRequest for FilesRead<'a> { const PATH: &'static str = "/files/read"; } - #[derive(Serialize)] pub struct FilesRm<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, pub recursive: bool, } @@ -95,22 +79,18 @@ impl<'a> ApiRequest for FilesRm<'a> { const PATH: &'static str = "/files/rm"; } - #[derive(Serialize)] pub struct FilesStat<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, } impl<'a> ApiRequest for FilesStat<'a> { const PATH: &'static str = "/files/stat"; } - #[derive(Serialize)] pub struct FilesWrite<'a> { - #[serde(rename = "arg")] - pub path: &'a str, + #[serde(rename = "arg")] pub path: &'a str, pub create: bool, diff --git a/ipfs-api/src/request/filestore.rs b/ipfs-api/src/request/filestore.rs index 082b999..63e9c2d 100644 --- a/ipfs-api/src/request/filestore.rs +++ b/ipfs-api/src/request/filestore.rs @@ -8,7 +8,6 @@ use request::ApiRequest; - pub struct FilestoreDups; impl_skip_serialize!(FilestoreDups); @@ -17,22 +16,18 @@ impl ApiRequest for FilestoreDups { const PATH: &'static str = "/filestore/dups"; } - #[derive(Serialize)] pub struct FilestoreLs<'a> { - #[serde(rename = "arg")] - pub cid: &'a Option<&'a str>, + #[serde(rename = "arg")] pub cid: &'a Option<&'a str>, } impl<'a> ApiRequest for FilestoreLs<'a> { const PATH: &'static str = "/filestore/ls"; } - #[derive(Serialize)] pub struct FilestoreVerify<'a> { - #[serde(rename = "arg")] - pub cid: &'a Option<&'a str>, + #[serde(rename = "arg")] pub cid: &'a Option<&'a str>, } impl<'a> ApiRequest for FilestoreVerify<'a> { diff --git a/ipfs-api/src/request/get.rs b/ipfs-api/src/request/get.rs index 959e70a..65fef0f 100644 --- a/ipfs-api/src/request/get.rs +++ b/ |