eth: add experimental kimap_get function

Author: barraguda

Cargo.lock

@@ -8,7 +8,9 @@ homepage = "https://kinode.org"
 repository = "https://github.com/kinode-dao/process_lib"
 
 [dependencies]
-alloy-primitives = "0.7.0"
+alloy-primitives = "0.7.5"
+alloy-sol-macro = "0.7.5"
+alloy-sol-types = "0.7.5"
 alloy = { version = "0.1.1", features = [
     "json-rpc",
     "rpc-types",

Cargo.toml

@@ -6,9 +6,13 @@ pub use alloy::rpc::types::{
     Block, BlockId, BlockNumberOrTag, FeeHistory, Filter, FilterBlockOption, Log, Transaction,
     TransactionReceipt,
 };
+use alloy_primitives::FixedBytes;
 pub use alloy_primitives::{Address, BlockHash, BlockNumber, Bytes, TxHash, U128, U256, U64, U8};
+use alloy_sol_macro::sol;
+use alloy_sol_types::SolCall;
 use serde::{Deserialize, Serialize};
 use std::collections::{HashMap, HashSet};
+use std::str::FromStr;
 
 //
 //  types mirrored from runtime module
@@ -180,6 +184,20 @@ impl std::cmp::PartialEq<str> for NodeOrRpcUrl {
     }
 }
 
+/// KiMap address. (simulation mode flag in process_lib?)
+const KIMAP: &str = "0x0165878A594ca255338adfa4d48449f69242Eb8F";
+
+// Sol structures for KiMap requests
+sol! {
+    function get (
+        bytes32 entryhash
+    ) external view returns (
+        address tokenBoundAccount,
+        address tokenOwner,
+        bytes memory note
+    );
+}
+
 /// An EVM chain provider. Create this object to start making RPC calls.
 /// Set the chain_id to determine which chain to call: requests will fail
 /// unless the node this process is running on has access to a provider
@@ -554,6 +572,38 @@ impl Provider {
         self.send_request_and_parse_response::<Bytes>(action)
     }
 
+    /// Gets an entry from the KiMap.
+    ///
+    /// # Parameters
+    /// - `entryhash`: The entry to get from the KiMap.
+    /// # Returns
+    /// A `Result<(Address, Address, Option<Bytes>), EthError>` representing the TBA, owner, and value if the entry is a note.
+    pub fn get(&self, entryhash: &str) -> Result<(Address, Address, Option<Bytes>), EthError> {
+        let get_call = getCall {
+            entryhash: FixedBytes::<32>::from_str(entryhash)
+                .map_err(|_| EthError::InvalidParams)?,
+        }
+        .abi_encode();
+
+        let tx_req = TransactionRequest::default()
+            .input(TransactionInput::new(get_call.into()))
+            .to(Address::from_str(KIMAP).unwrap());
+
+        let res_bytes = self.call(tx_req, None)?;
+
+        // note need new EthErrors for this! :)
+        let res = getCall::abi_decode_returns(&res_bytes, false)
+            .map_err(|_| EthError::RpcMalformedResponse)?;
+
+        let note_data = if res.note == Bytes::default() {
+            None
+        } else {
+            Some(res.note)
+        };
+
+        Ok((res.tokenBoundAccount, res.tokenOwner, note_data))
+    }
+
     /// Sends a raw transaction to the network.
     ///
     /// # Parameters