From a37c8e81d20075c0980e50a039cb580bcaaa85d1 Mon Sep 17 00:00:00 2001
From: Joseph Livesey <joseph@semiotic.ai>
Date: Fri, 18 Oct 2024 16:49:45 -0400
Subject: [PATCH] fix(firehose-client): fix chain specification in client

---
 crates/firehose-client/src/client.rs | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/crates/firehose-client/src/client.rs b/crates/firehose-client/src/client.rs
index 35b6babc..c86940fa 100644
--- a/crates/firehose-client/src/client.rs
+++ b/crates/firehose-client/src/client.rs
@@ -71,6 +71,7 @@ impl FirehoseClient {
     ) -> Result<impl futures::Stream<Item = FirehoseBeaconBlock>, ClientError> {
         let (tx, rx) = tokio::sync::mpsc::channel::<FirehoseBeaconBlock>(8192);
 
+        let chain = self.chain;
         let client = self.get_streaming_client().await?;
 
         tokio::spawn(async move {
@@ -81,7 +82,7 @@ impl FirehoseClient {
             while blocks < total {
                 let mut client = client.clone();
                 let request = create_blocks_streaming_request(
-                    Chain::Ethereum,
+                    chain,
                     start + blocks,
                     start + total - 1,
                     BlocksRequested::All,
@@ -139,6 +140,7 @@ impl FirehoseClient {
     ) -> Result<impl futures::Stream<Item = FirehoseEthBlock>, ClientError> {
         let (tx, rx) = tokio::sync::mpsc::channel::<FirehoseEthBlock>(8192);
 
+        let chain = self.chain;
         let client = self.get_streaming_client().await?;
 
         tokio::spawn(async move {
@@ -147,7 +149,7 @@ impl FirehoseClient {
             while blocks < total {
                 let mut client = client.clone();
                 let request = create_blocks_streaming_request(
-                    Chain::Ethereum,
+                    chain,
                     start + blocks,
                     start + total - 1,
                     BlocksRequested::All,