feat(rpc) Implement Filecoin.EthMaxPriorityFeePerGas

CHANGELOG.md

@@ -45,6 +45,9 @@
   `forest-cli state compute` method, and a corresponding RPC method
   `Forest.StateCompute`.
 
+- [#4511](https://github.com/ChainSafe/forest/pull/4511) Add support for the
+  `Filecoin.EthMaxPriorityFeePerGas` RPC method.
+
 ### Changed
 
 ### Removed

src/rpc/methods/eth.rs

@@ -1701,6 +1701,27 @@ impl RpcMethod<2> for EthGetTransactionCount {
     }
 }
 
+pub enum EthMaxPriorityFeePerGas {}
+impl RpcMethod<0> for EthMaxPriorityFeePerGas {
+    const NAME: &'static str = "Filecoin.EthMaxPriorityFeePerGas";
+    const PARAM_NAMES: [&'static str; 0] = [];
+    const API_PATHS: ApiPaths = ApiPaths::V1;
+    const PERMISSION: Permission = Permission::Read;
+
+    type Params = ();
+    type Ok = EthBigInt;
+
+    async fn handle(
+        ctx: Ctx<impl Blockstore + Send + Sync + 'static>,
+        (): Self::Params,
+    ) -> Result<Self::Ok, ServerError> {
+        match crate::rpc::gas::estimate_gas_premium(&ctx, 0).await {
+            Ok(gas_premium) => Ok(EthBigInt(gas_premium.atto().clone())),
+            Err(_) => Ok(EthBigInt(num_bigint::BigInt::zero())),
+        }
+    }
+}
+
 pub enum EthProtocolVersion {}
 impl RpcMethod<0> for EthProtocolVersion {
     const NAME: &'static str = "Filecoin.EthProtocolVersion";

src/rpc/mod.rs

@@ -81,6 +81,7 @@ macro_rules! for_each_method {
         $callback!(crate::rpc::eth::EthGetBlockTransactionCountByNumber);
         $callback!(crate::rpc::eth::EthGetMessageCidByTransactionHash);
         $callback!(crate::rpc::eth::EthGetTransactionCount);
+        $callback!(crate::rpc::eth::EthMaxPriorityFeePerGas);
         $callback!(crate::rpc::eth::EthProtocolVersion);
         $callback!(crate::rpc::eth::EthGetTransactionHashByCid);
 

src/tool/subcommands/api_cmd.rs

@@ -1143,6 +1143,7 @@ fn eth_tests() -> Vec<RpcTest> {
             .unwrap(),
         ),
         RpcTest::basic(Web3ClientVersion::request(()).unwrap()),
+        RpcTest::basic(EthMaxPriorityFeePerGas::request(()).unwrap()),
         RpcTest::identity(EthProtocolVersion::request(()).unwrap()),
     ]
 }