add block put command

2 files changed, 25 insertions, 3 deletions

diff --git a/ipfs-api/src/client.rs b/ipfs-api/src/client.rs
index 04e1f99..c583f35 100644
--- a/ipfs-api/src/client.rs
+++ b/ipfs-api/src/client.rs
@@ -363,9 +363,19 @@ impl IpfsClient {
         self.request_bytes(&request::BlockGet { hash }, None)
     }
 
-    // TODO
-    // pub fn block_put(&self, ...) -> AsyncResponse<response::BlockPutResponse> {
-    // }
+    /// Store input as an IPFS block.
+    ///
+    #[inline]
+    pub fn block_put<R>(&self, data: R) -> AsyncResponse<response::BlockPutResponse>
+    where
+        R: 'static + Read + Send,
+    {
+        let mut form = multipart::Form::default();
+
+        form.add_reader("data", data);
+
+        self.request(&request::BlockPut, Some(form))
+    }
 
     /// Removes an IPFS block.
     ///
diff --git a/ipfs-api/src/request/block.rs b/ipfs-api/src/request/block.rs
index 87cfe54..8409e0f 100644
--- a/ipfs-api/src/request/block.rs
+++ b/ipfs-api/src/request/block.rs
@@ -23,6 +23,18 @@ impl<'a> ApiRequest for BlockGet<'a> {
 }
 
 
+pub struct BlockPut;
+
+impl_skip_serialize!(BlockPut);
+
+impl ApiRequest for BlockPut {
+    #[inline]
+    fn path() -> &'static str {
+        "/block/put"
+    }
+}
+
+
 #[derive(Serialize)]
 pub struct BlockRm<'a> {
     #[serde(rename = "arg")]