From e727a25560fa8c9c437e0995a6511e39ae6a10c2 Mon Sep 17 00:00:00 2001
From: incrypto32 <vpkrishnanand@gmail.com>
Date: Thu, 6 Mar 2025 10:34:15 +0400
Subject: [PATCH] graph: change log level for get_block_by_number

---
 chain/ethereum/src/chain.rs     | 7 ++++++-
 chain/ethereum/src/env.rs       | 2 +-
 graph/src/firehose/endpoints.rs | 4 ++--
 3 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/chain/ethereum/src/chain.rs b/chain/ethereum/src/chain.rs
index bca0207430f..876bb5a92b0 100644
--- a/chain/ethereum/src/chain.rs
+++ b/chain/ethereum/src/chain.rs
@@ -789,7 +789,7 @@ async fn fetch_unique_blocks_from_cache(
             "Loading {} block(s) not in the block cache",
             missing_blocks.len()
         );
-        debug!(logger, "Missing blocks {:?}", missing_blocks);
+        trace!(logger, "Missing blocks {:?}", missing_blocks.len());
     }
 
     (blocks, missing_blocks)
@@ -878,6 +878,11 @@ impl TriggersAdapterTrait<Chain> for TriggersAdapter {
                 // even if the firehose is available. If no adapter is available, we will log an error.
                 // And then fallback to the firehose.
                 if ENV_VARS.force_rpc_for_block_ptrs {
+                    trace!(
+                        logger,
+                        "Loading blocks from RPC (force_rpc_for_block_ptrs is set)";
+                        "block_numbers" => format!("{:?}", block_numbers)
+                    );
                     match self.eth_adapters.cheapest_with(&self.capabilities).await {
                         Ok(adapter) => {
                             match load_blocks_with_rpc(
diff --git a/chain/ethereum/src/env.rs b/chain/ethereum/src/env.rs
index df3aa60bd7f..0b46c36ba17 100644
--- a/chain/ethereum/src/env.rs
+++ b/chain/ethereum/src/env.rs
@@ -197,6 +197,6 @@ struct Inner {
     genesis_block_number: u64,
     #[envconfig(from = "GRAPH_ETH_CALL_NO_GAS", default = "421613,421614")]
     eth_call_no_gas: String,
-    #[envconfig(from = "GRAPH_ETHEREUM_FORCE_RPC_FOR_BLOCK_PTRS", default = "false")]
+    #[envconfig(from = "GRAPH_ETHEREUM_FORCE_RPC_FOR_BLOCK_PTRS", default = "true")]
     force_rpc_for_block_ptrs: EnvVarBoolean,
 }
diff --git a/graph/src/firehose/endpoints.rs b/graph/src/firehose/endpoints.rs
index b5592149764..f496a3ea3ce 100644
--- a/graph/src/firehose/endpoints.rs
+++ b/graph/src/firehose/endpoints.rs
@@ -17,7 +17,7 @@ use async_trait::async_trait;
 use futures03::{StreamExt, TryStreamExt};
 use http0::uri::{Scheme, Uri};
 use itertools::Itertools;
-use slog::{error, info, Logger};
+use slog::{error, info, trace, Logger};
 use std::{collections::HashMap, fmt::Display, ops::ControlFlow, sync::Arc, time::Duration};
 use tokio::sync::OnceCell;
 use tonic::codegen::InterceptedService;
@@ -451,7 +451,7 @@ impl FirehoseEndpoint {
     where
         M: prost::Message + BlockchainBlock + Default + 'static,
     {
-        debug!(
+        trace!(
             logger,
             "Connecting to firehose to retrieve block for number {}", number;
             "provider" => self.provider.as_str(),