Implement ots_getInternalOperations

Cargo.toml

@@ -198,7 +198,7 @@ reth-trie-parallel = { path = "crates/trie-parallel" }
 # revm
 revm = { version = "7.2.0", features = ["std", "secp256k1"], default-features = false }
 revm-primitives = { version = "3.1.0", features = ["std"], default-features = false }
-revm-inspectors = { git = "https://github.com/paradigmxyz/evm-inspectors", rev = "2b48b65" }
+revm-inspectors = { git = "https://github.com/paradigmxyz/evm-inspectors", rev = "b3082f3" }
 
 # eth
 alloy-chains = { version = "0.1", feature = ["serde", "rlp", "arbitrary"] }

crates/rpc/rpc-builder/tests/it/http.rs

@@ -297,9 +297,7 @@ where
 
     OtterscanClient::get_api_level(client).await.unwrap();
 
-    assert!(is_unimplemented(
-        OtterscanClient::get_internal_operations(client, tx_hash).await.err().unwrap()
-    ));
+    OtterscanClient::get_internal_operations(client, tx_hash).await.err().unwrap();
 
     OtterscanClient::get_transaction_error(client, tx_hash).await.unwrap();
 

crates/rpc/rpc-types/Cargo.toml

@@ -21,6 +21,7 @@ alloy-rpc-engine-types = { workspace = true, features = ["jsonrpsee-types"] }
 ethereum_ssz_derive = { version = "0.5", optional = true }
 ethereum_ssz = { version = "0.5", optional = true }
 alloy-genesis.workspace = true
+revm-inspectors.workspace = true
 
 # misc
 thiserror.workspace = true

crates/rpc/rpc-types/src/otterscan.rs

@@ -4,6 +4,7 @@ use crate::{
     serde_helpers::u64_hex, Block, BlockTransactions, Rich, Transaction, TransactionReceipt,
 };
 use alloy_primitives::{Address, Bytes, U256};
+use revm_inspectors::transfer::{TransferKind, TransferOperation};
 use serde::{Deserialize, Serialize};
 
 /// Operation type enum for `InternalOperation` struct
@@ -122,3 +123,20 @@ impl From<Rich<Block>> for BlockDetails {
         }
     }
 }
+
+impl From<TransferKind> for OperationType {
+    fn from(kind: TransferKind) -> Self {
+        match kind {
+            TransferKind::Call => Self::OpTransfer,
+            TransferKind::Create => Self::OpCreate,
+            TransferKind::Create2 => Self::OpCreate2,
+            TransferKind::SelfDestruct => Self::OpSelfDestruct,
+        }
+    }
+}
+
+impl From<TransferOperation> for InternalOperation {
+    fn from(op: TransferOperation) -> Self {
+        Self { r#type: op.kind.into(), from: op.from, to: op.to, value: op.value }
+    }
+}

crates/rpc/rpc/src/otterscan.rs

@@ -2,6 +2,7 @@ use alloy_primitives::Bytes;
 use async_trait::async_trait;
 use jsonrpsee::core::RpcResult;
 use revm::inspectors::NoOpInspector;
+use revm_inspectors::transfer::TransferInspector;
 use revm_primitives::ExecutionResult;
 
 use reth_primitives::{Address, BlockId, BlockNumberOrTag, TxHash, B256};
@@ -44,8 +45,16 @@ where
     }
 
     /// Handler for `ots_getInternalOperations`
-    async fn get_internal_operations(&self, _tx_hash: TxHash) -> RpcResult<Vec<InternalOperation>> {
-        Err(internal_rpc_err("unimplemented"))
+    async fn get_internal_operations(&self, tx_hash: TxHash) -> RpcResult<Vec<InternalOperation>> {
+        self.eth
+            .spawn_trace_transaction_in_block_with_inspector(
+                tx_hash,
+                TransferInspector::new(false),
+                |_tx_info, inspector, _, _| Ok(inspector.into_transfers()),
+            )
+            .await?
+            .map(|transfer_operations| transfer_operations.into_iter().map(Into::into).collect())
+            .ok_or_else(|| internal_rpc_err("failed to inspect transaction"))
     }
 
     /// Handler for `ots_getTransactionError`