graph, node, store: Return eviction stats from clear_stale_call_cache

Return a StaleCallCacheResult struct with effective_ttl_days,
cache_entries_deleted, and contracts_deleted so the graphman command
can report what actually happened to the user.

Author: lutter

graph/src/blockchain/mock.rs

@@ -6,7 +6,7 @@ use crate::{
         network_provider::ChainName,
         store::{
             BlockNumber, ChainHeadStore, ChainIdStore, DeploymentCursorTracker, DeploymentLocator,
-            SourceableStore,
+            SourceableStore, StaleCallCacheResult,
         },
         subgraph::InstanceDSTemplateInfo,
     },
@@ -596,7 +596,7 @@ impl ChainStore for MockChainStore {
         &self,
         _ttl_days: usize,
         _max_contracts: Option<usize>,
-    ) -> Result<(), Error> {
+    ) -> Result<StaleCallCacheResult, Error> {
         unimplemented!()
     }
     async fn chain_identifier(&self) -> Result<ChainIdentifier, Error> {

graph/src/components/store/traits.rs

@@ -530,6 +530,18 @@ pub trait ChainIdStore: Send + Sync + 'static {
 /// configuration can change this for individual chains
 pub const BLOCK_CACHE_SIZE: BlockNumber = i32::MAX;
 
+/// Result of clearing stale call cache entries.
+pub struct StaleCallCacheResult {
+    /// The effective TTL in days that was actually used for deletion.
+    /// This may be larger than the requested TTL if `max_contracts`
+    /// was set and caused the cutoff to be adjusted.
+    pub effective_ttl_days: usize,
+    /// Number of cache entries deleted from the call cache.
+    pub cache_entries_deleted: usize,
+    /// Number of contract entries deleted from call meta.
+    pub contracts_deleted: usize,
+}
+
 /// Common trait for blockchain store implementations.
 #[async_trait]
 pub trait ChainStore: ChainHeadStore {
@@ -664,7 +676,7 @@ pub trait ChainStore: ChainHeadStore {
         &self,
         ttl_days: usize,
         max_contracts: Option<usize>,
-    ) -> Result<(), Error>;
+    ) -> Result<StaleCallCacheResult, Error>;
 
     /// Return the chain identifier for this store.
     async fn chain_identifier(&self) -> Result<ChainIdentifier, Error>;

graph/src/lib.rs

@@ -128,8 +128,8 @@ pub mod prelude {
         EntityCollection, EntityFilter, EntityLink, EntityOperation, EntityOrder,
         EntityOrderByChild, EntityOrderByChildInfo, EntityQuery, EntityRange, EntityWindow,
         EthereumCallCache, ParentLink, PartialBlockPtr, PoolWaitStats, QueryStore,
-        QueryStoreManager, SeqGenerator, StoreError, StoreEvent, StoreEventStreamBox,
-        SubgraphStore, UnfailOutcome, WindowAttribute, BLOCK_NUMBER_MAX,
+        QueryStoreManager, SeqGenerator, StaleCallCacheResult, StoreError, StoreEvent,
+        StoreEventStreamBox, SubgraphStore, UnfailOutcome, WindowAttribute, BLOCK_NUMBER_MAX,
     };
     pub use crate::components::subgraph::{
         BlockState, BlockStateCheckpoint, HostMetrics, InstanceDSTemplateInfo, RuntimeHost,

node/src/manager/commands/chain.rs

@@ -90,9 +90,21 @@ pub async fn clear_stale_call_cache(
         "Removing stale entries from the call cache for `{}`",
         chain_store.chain
     );
-    chain_store
+    let result = chain_store
         .clear_stale_call_cache(ttl_days, max_contracts)
         .await?;
+    if result.effective_ttl_days != ttl_days {
+        println!(
+            "Effective TTL: {} days (adjusted from {} to stay within {} contracts)",
+            result.effective_ttl_days,
+            ttl_days,
+            max_contracts.unwrap()
+        );
+    }
+    println!(
+        "Deleted {} cache entries for {} contracts",
+        result.cache_entries_deleted, result.contracts_deleted
+    );
     Ok(())
 }
 

store/postgres/src/chain_store.rs

@@ -32,7 +32,8 @@ use graph::cheap_clone::CheapClone;
 use graph::components::ethereum::CachedBlock;
 use graph::prelude::{
     serde_json as json, transaction_receipt::LightTransactionReceipt, BlockNumber, BlockPtr,
-    CachedEthereumCall, ChainStore as ChainStoreTrait, Error, EthereumCallCache, StoreError,
+    CachedEthereumCall, ChainStore as ChainStoreTrait, Error, EthereumCallCache,
+    StaleCallCacheResult, StoreError,
 };
 use graph::{ensure, internal_error};
 
@@ -3281,7 +3282,7 @@ impl ChainStoreTrait for ChainStore {
         &self,
         ttl_days: usize,
         max_contracts: Option<usize>,
-    ) -> Result<(), Error> {
+    ) -> Result<StaleCallCacheResult, Error> {
         const LOG_INTERVAL: Duration = Duration::from_mins(5);
 
         let conn = &mut self.pool.get_permitted().await?;
@@ -3357,7 +3358,11 @@ impl ChainStoreTrait for ChainStore {
             batch_count
         );
 
-        Ok(())
+        Ok(StaleCallCacheResult {
+            effective_ttl_days: effective_ttl as usize,
+            cache_entries_deleted: total_deleted,
+            contracts_deleted,
+        })
     }
 
     async fn transaction_receipts_in_block(