Add refs endpoint

Cargo.toml

@@ -19,7 +19,7 @@ byteorder = "1.3.4"
 dirs = "2.0.2"
 domain = { git = "https://github.com/nlnetlabs/domain", rev="084964", features = ["resolv"] }
 futures = { version = "0.3.4", features = ["compat", "io-compat"] }
-libipld = { git = "https://github.com/ipfs-rust/rust-ipld", features = ["dag-pb"] }
+libipld = { git = "https://github.com/ipfs-rust/rust-ipld", rev = "b2286c53c13f3eeec2a3766387f2926838e8e4c9", features = ["dag-pb", "dag-json"] }
 libp2p = "0.16.2"
 log = "0.4.8"
 multibase = "0.8.0"

examples/Cargo.toml

@@ -10,5 +10,5 @@ async-std = "1.5.0"
 env_logger = "0.7.1"
 futures = "0.3.4"
 ipfs = { path = ".." }
-libipld = { git = "https://github.com/ipfs-rust/rust-ipld", features = ["dag-pb"] }
+libipld = { git = "https://github.com/ipfs-rust/rust-ipld", rev = "b2286c53c13f3eeec2a3766387f2926838e8e4c9", features = ["dag-pb", "dag-json"] }
 multihash = "0.10.1"

http/Cargo.toml

@@ -14,7 +14,7 @@ base64 = "0.12.0"
 env_logger = "0.7.1"
 futures = "0.3.4"
 ipfs = { path = "../" }
-libipld = { git = "https://github.com/ipfs-rust/rust-ipld", features = ["dag-pb", "dag-json"] }
+libipld = { git = "https://github.com/ipfs-rust/rust-ipld", rev = "b2286c53c13f3eeec2a3766387f2926838e8e4c9", features = ["dag-pb", "dag-json"] }
 log = "0.4.8"
 multibase = "0.8.0"
 multihash = "0.10.1"
@@ -28,3 +28,9 @@ structopt = "0.3.12"
 thiserror = "1.0.14"
 tokio = { version = "0.2.16", features = ["full"] }
 warp = "0.2.2"
+async-stream = "0.2.1"
+pin-project = "0.4.8"
+url = "2.1.1"
+
+[dev-dependencies]
+hex = "0.4.2"

http/src/lib.rs

@@ -1,3 +1,5 @@
+#![recursion_limit = "512"]
+
 pub mod v0;
 
 pub mod config;

http/src/main.rs

@@ -182,7 +182,7 @@ fn serve<Types: IpfsTypes>(
     let (shutdown_tx, mut shutdown_rx) = tokio::sync::mpsc::channel::<()>(1);
 
     let routes = v0::routes(ipfs, shutdown_tx);
-    let routes = routes.with(warp::log("rust-ipfs-http-v0"));
+    let routes = routes.with(warp::log(env!("CARGO_PKG_NAME")));
 
     let ipfs = ipfs.clone();
 

http/src/v0.rs

@@ -55,7 +55,7 @@ where
             .or(warp::path!("ping" / ..).and_then(not_implemented))
             .or(pubsub::routes(ipfs))
             .or(refs::local(ipfs))
-            // .or(warp::path!("refs").and_then(refs::of_path))
+            .or(refs::refs(ipfs))
             .or(warp::path!("repo" / ..).and_then(not_implemented))
             .or(warp::path!("stats" / ..).and_then(not_implemented))
             .or(swarm::connect(ipfs))