Polling file monitor

core/Cargo.toml

@@ -23,10 +23,14 @@ semver = "1.0.12"
 serde = "1.0"
 serde_json = "1.0"
 serde_yaml = "0.8"
-
+# Switch to crates.io once tower 0.5 is released
+tower = { git = "https://github.com/tower-rs/tower.git", features = ["util", "limit"] }
 graph-runtime-wasm = { path = "../runtime/wasm" }
+cid = "0.8.3"
+anyhow = "1.0"
 
 [dev-dependencies]
+tower-test = { git = "https://github.com/tower-rs/tower.git" }
 graph-mock = { path = "../mock" }
 walkdir = "2.3.2"
 test-store = { path = "../store/test-store" }

core/src/lib.rs

@@ -1,3 +1,5 @@
+pub mod polling_monitor;
+
 mod link_resolver;
 mod metrics;
 mod subgraph;

core/src/link_resolver.rs

@@ -192,7 +192,7 @@ impl LinkResolverTrait for LinkResolver {
             .run(move || {
                 let path = req_path.clone();
                 let client = client.clone();
-                async move { Ok(client.cat_all(path.clone(), timeout).await?.to_vec()) }
+                async move { Ok(client.cat_all(&path, timeout).await?.to_vec()) }
             })
             .await?;
 
@@ -262,7 +262,7 @@ impl LinkResolverTrait for LinkResolver {
         let max_file_size = Some(self.env_vars.mappings.max_ipfs_map_file_size as u64);
         restrict_file_size(path, size, &max_file_size)?;
 
-        let mut stream = client.cat(path.to_string()).await?.fuse().boxed().compat();
+        let mut stream = client.cat(path, None).await?.fuse().boxed().compat();
 
         let mut buf = BytesMut::with_capacity(1024);