fix formatting

graphprotocol · Apr 5, 2024 · 4fe81c1 · 4fe81c1
1 parent 4218250
commit 4fe81c1
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 19 deletions.
diff --git a/chain/ethereum/examples/firehose.rs b/chain/ethereum/examples/firehose.rs
@@ -45,16 +45,19 @@ async fn main() -> Result<(), Error> {
         println!("Connecting to the stream!");
         let mut stream: Streaming<firehose::Response> = match firehose
             .clone()
-            .stream_blocks(firehose::Request {
-                start_block_num: 12369739,
-                stop_block_num: 12369739,
-                cursor: match &cursor {
-                    Some(c) => c.clone(),
-                    None => String::from(""),
+            .stream_blocks(
+                firehose::Request {
+                    start_block_num: 12369739,
+                    stop_block_num: 12369739,
+                    cursor: match &cursor {
+                        Some(c) => c.clone(),
+                        None => String::from(""),
+                    },
+                    final_blocks_only: false,
+                    ..Default::default()
                 },
-                final_blocks_only: false,
-                ..Default::default()
-            }, &firehose::ConnectionHeaders::new())
+                &firehose::ConnectionHeaders::new(),
+            )
             .await
         {
             Ok(s) => s,

diff --git a/graph/src/blockchain/firehose_block_ingestor.rs b/graph/src/blockchain/firehose_block_ingestor.rs
@@ -192,14 +192,17 @@ where
 
             let result = endpoint
                 .clone()
-                .stream_blocks(firehose::Request {
-                    // Starts at current HEAD block of the chain (viewed from Firehose side)
-                    start_block_num: -1,
-                    cursor: latest_cursor.clone(),
-                    final_blocks_only: false,
-                    transforms: self.default_transforms.iter().map(|t| t.into()).collect(),
-                    ..Default::default()
-                }, &firehose::ConnectionHeaders::new())
+                .stream_blocks(
+                    firehose::Request {
+                        // Starts at current HEAD block of the chain (viewed from Firehose side)
+                        start_block_num: -1,
+                        cursor: latest_cursor.clone(),
+                        final_blocks_only: false,
+                        transforms: self.default_transforms.iter().map(|t| t.into()).collect(),
+                        ..Default::default()
+                    },
+                    &firehose::ConnectionHeaders::new(),
+                )
                 .await;
 
             match result {

diff --git a/graph/src/firehose/endpoints.rs b/graph/src/firehose/endpoints.rs
@@ -26,10 +26,10 @@ use std::{
 };
 use tonic::codegen::InterceptedService;
 use tonic::{
-    Request,
     codegen::CompressionEncoding,
     metadata::{Ascii, MetadataKey, MetadataValue},
     transport::{Channel, ClientTlsConfig},
+    Request,
 };
 
 use super::{codec as firehose, interceptors::MetricsInterceptor, stream_client::StreamClient};
@@ -63,7 +63,8 @@ impl ConnectionHeaders {
     }
     pub fn with_deployment(mut self, deployment: DeploymentHash) -> Self {
         if let Ok(deployment) = deployment.parse() {
-            self.0.insert("x-deployment-id".parse().unwrap(), deployment);
+            self.0
+                .insert("x-deployment-id".parse().unwrap(), deployment);
         }
         self
     }