fix cache config

rpc_configs/ethereum.yml

@@ -1,5 +1,7 @@
 methods:
   - method: eth_blockNumber
+    cache:
+      ttl_seconds: 1
 
   - method: eth_chainId
     cache:
@@ -43,21 +45,29 @@ methods:
         ty: String
 
   - method: eth_sendTransaction
+    cache:
+      size: 0
     params:
       - name: Transaction
         ty: Bytes
 
   - method: eth_sendRawTransaction
+    cache:
+      size: 0
     params:
       - name: transaction
         ty: Bytes
 
   - method: eth_call
+    cache:
+      ttl_seconds: 3
     params:
       - name: transaction
         ty: Bytes
 
   - method: eth_getTransactionCount
+    cache:
+      ttl_seconds: 3
     params:
       - name: address
         ty: Bytes
@@ -102,6 +112,8 @@ methods:
         inject: true
 
   - method: eth_estimateGas
+    cache:
+      ttl_seconds: 3
     params:
       - name: transaction
         ty: Bytes
@@ -131,41 +143,59 @@ methods:
         ty: Bytes
 
   - method: eth_isBlockFinalized
+    cache:
+      ttl_seconds: 3
     params:
       - name: block
         ty: BlockTag
         inject: true
 
   - method: eth_isTransactionFinalized
+    cache:
+      ttl_seconds: 3
     params:
       - name: transactionHash
         ty: Bytes
 
   - method: eth_newFilter
+    cache:
+      size: 0
     params:
       - name: Filter
         ty: Bytes
 
   - method: eth_newBlockFilter
+    cache:
+      size: 0
 
   - method: eth_newPendingTransactionFilter
+    cache:
+      size: 0
 
   - method: eth_getFilterChanges
+    cache:
+      size: 0
     params:
       - name: address
         ty: Bytes
 
   - method: eth_getFilterLogs
+    cache:
+      size: 0
     params:
       - name: address
         ty: Bytes
 
   - method: eth_uninstallFilter
+    cache:
+      size: 0
     params:
       - name: FilterIdentifier
         ty: Bytes
 
   - method: eth_getLogs
+    cache:
+      size: 0
     params:
       - name: Filter
         ty: Bytes

src/config/rpc.rs

@@ -4,9 +4,9 @@ use serde::Deserialize;
 #[derive(Clone, Deserialize, Debug, Eq, PartialEq)]
 pub struct CacheParams {
     #[serde(default)]
-    pub size: Option<u32>,
+    pub size: Option<usize>,
     #[serde(default)]
-    pub ttl_seconds: Option<u32>,
+    pub ttl_seconds: Option<u64>,
 }
 
 #[derive(Clone, Deserialize, Debug, Eq, PartialEq)]

src/extensions/cache.rs

@@ -12,7 +12,7 @@ pub struct CacheConfig {
     // None means no cache expiration
     #[serde(default)]
     pub default_ttl_seconds: Option<u64>,
-    pub default_size: u32,
+    pub default_size: usize,
 }
 
 #[async_trait]

src/middlewares/methods/cache.rs

@@ -7,6 +7,7 @@ use jsonrpsee::{core::JsonValue, types::ErrorObjectOwned};
 use opentelemetry::trace::FutureExt;
 
 use crate::{
+    config::CacheParams,
     extensions::cache::Cache as CacheExtension,
     middleware::{Middleware, MiddlewareBuilder, NextFn, RpcMethod},
     middlewares::{CallRequest, CallResult},
@@ -31,24 +32,27 @@ impl MiddlewareBuilder<RpcMethod, CallRequest, CallResult> for CacheMiddleware {
         method: &RpcMethod,
         extensions: &TypeRegistryRef,
     ) -> Option<Box<dyn Middleware<CallRequest, CallResult>>> {
-        let params = method.cache.as_ref()?;
-        if params.size == Some(0) {
-            return None;
-        }
         let cache_ext = extensions
             .read()
             .await
             .get::<CacheExtension>()
             .expect("Cache extension not found");
 
-        let size =
-            NonZeroUsize::new(params.size.unwrap_or(cache_ext.config.default_size) as usize)?;
+        // do not cache if size is 0, otherwise use default size
+        let size = match method.cache {
+            Some(CacheParams { size: Some(0), .. }) => return None,
+            Some(CacheParams { size, .. }) => size.unwrap_or(cache_ext.config.default_size),
+            None => cache_ext.config.default_size,
+        };
+
+        let ttl_seconds = match method.cache {
+            Some(CacheParams { ttl_seconds, .. }) => ttl_seconds,
+            None => cache_ext.config.default_ttl_seconds,
+        };
 
         let cache = Cache::new(
-            size,
-            params
-                .ttl_seconds
-                .map(|s| std::time::Duration::from_secs(s as u64)),
+            NonZeroUsize::new(size)?,
+            ttl_seconds.map(std::time::Duration::from_secs),
         );
 
         Some(Box::new(Self::new(cache)))