chore(deps): remove dependency on toolshed crate (#993)

Signed-off-by: Lorenzo Delgado <[email protected]>

Cargo.toml

@@ -66,7 +66,6 @@ tokio = { version = "1.38.0", features = [
     "sync",
     "time",
 ] }
-toolshed = { git = "https://github.com/edgeandnode/toolshed", tag = "toolshed-v0.6.0" }
 tower = "0.5.1"
 tower-http = { version = "0.6.1", features = ["cors"] }
 tracing = { version = "0.1", default-features = false }
@@ -81,6 +80,5 @@ url = "2.5.0"
 assert_matches = "1.5.0"
 http-body-util = "0.1.1"
 hyper = "1.3.1"
-test-with = { version = "0.14.0", default-features = false }
 tokio-test = "0.4.4"
 tower-test = "0.4.0"

src/bytes.rs

@@ -0,0 +1,14 @@
+// See https://doc.rust-lang.org/std/macro.concat_bytes.html
+#[macro_export]
+macro_rules! concat_bytes {
+    ($len:expr, [$($slices:expr),* $(,)?]) => {
+        {
+            let mut cursor = std::io::Cursor::new([0_u8; $len]);
+            $(
+                std::io::Write::write(&mut cursor, $slices).unwrap();
+            )*
+            assert!(cursor.position() == $len);
+            cursor.into_inner()
+        }
+    }
+}

src/chain.rs

@@ -113,9 +113,9 @@ mod tests {
         rngs::SmallRng, seq::SliceRandom as _, thread_rng, Rng as _, RngCore as _, SeedableRng,
     };
     use thegraph_core::{Address, BlockHash, IndexerId};
-    use toolshed::concat_bytes;
 
     use super::{Block, Chain, MAX_LEN};
+    use crate::concat_bytes;
 
     #[test]
     fn chain() {

src/main.rs

@@ -2,6 +2,7 @@ mod auth;
 mod block_constraints;
 mod blocks;
 mod budgets;
+mod bytes;
 mod chain;
 mod chains;
 mod client_query;

src/reports.rs

@@ -3,9 +3,8 @@ use ordered_float::NotNan;
 use prost::Message;
 use thegraph_core::{Address, AllocationId, DeploymentId, IndexerId};
 use tokio::sync::mpsc;
-use toolshed::concat_bytes;
 
-use crate::{errors, indexer_client::IndexerResponse, receipts::Receipt};
+use crate::{concat_bytes, errors, indexer_client::IndexerResponse, receipts::Receipt};
 
 pub struct ClientRequest {
     pub id: String,