summaryrefslogtreecommitdiffstats
path: root/ipfs-api/examples
diff options
context:
space:
mode:
authorFerris Tseng <ferristseng@fastmail.fm>2017-11-24 16:21:51 -0500
committerFerris Tseng <ferristseng@fastmail.fm>2017-11-24 16:21:51 -0500
commit488617996748464a546d1c036802e27ec0e975dc (patch)
treed0c2ff3b84a154881a53a8f638ddb98f050c8510 /ipfs-api/examples
parent6a0af36df9a57f80d18fdcd33474e88d7dc1e29c (diff)
add tar commands
Diffstat (limited to 'ipfs-api/examples')
-rw-r--r--ipfs-api/examples/add_tar.rs52
1 files changed, 52 insertions, 0 deletions
diff --git a/ipfs-api/examples/add_tar.rs b/ipfs-api/examples/add_tar.rs
new file mode 100644
index 0000000..a6328af
--- /dev/null
+++ b/ipfs-api/examples/add_tar.rs
@@ -0,0 +1,52 @@
+// Copyright 2017 rust-ipfs-api Developers
+//
+// Licensed under the Apache License, Version 2.0, <LICENSE-APACHE or
+// http://apache.org/licenses/LICENSE-2.0> or the MIT license <LICENSE-MIT or
+// http://opensource.org/licenses/MIT>, at your option. This file may not be
+// copied, modified, or distributed except according to those terms.
+//
+
+extern crate ipfs_api;
+extern crate tar;
+extern crate tokio_core;
+
+use ipfs_api::IpfsClient;
+use std::io::Cursor;
+use tar::Builder;
+use tokio_core::reactor::Core;
+
+// Creates an Ipfs client, and adds this source file to Ipfs.
+//
+fn main() {
+ println!("note: this must be run in the root of the project repository");
+ println!("connecting to localhost:5001...");
+
+ let mut core = Core::new().expect("expected event loop");
+ let client = IpfsClient::default(&core.handle());
+
+ let mut buf = Vec::new();
+
+ // Create a in-memory tar file with this source file as its contents.
+ //
+ {
+ let mut builder = Builder::new(&mut buf);
+
+ builder.append_path(file!()).expect(
+ "failed to create tar file",
+ );
+ builder.finish().expect("failed to create tar file");
+ }
+
+ let cursor = Cursor::new(buf);
+ let req = client.tar_add(cursor);
+ let add = core.run(req).expect("expected a valid response");
+
+ println!("added tar file: {:?}", add);
+ println!("");
+
+ let req = client.tar_cat(&add.hash[..]);
+ let cat = core.run(req).expect("expected a valid response");
+
+ println!("{}", String::from_utf8_lossy(&cat[..]));
+ println!("");
+}