feat: add genesis export

Author: ibrizsabin

contracts/cosmwasm-vm/cw-icon-light-client/src/context.rs

@@ -153,7 +153,7 @@ impl<'a> IContext for CwContext<'a> {
         QueryHandler::get_processed_blocknumber_at_height(self.storage, client_id, height)
     }
 
-    fn ensure_ibc_host(&self, caller: cosmwasm_std::Addr) -> Result<(), ContractError> {
+    fn ensure_ibc_host(&self, caller: &cosmwasm_std::Addr) -> Result<(), ContractError> {
         let config = self.get_config()?;
         if caller != config.ibc_host {
             return Err(ContractError::Unauthorized {});

contracts/cosmwasm-vm/cw-wasm-light-client/src/contract.rs

@@ -8,7 +8,7 @@ use cw_light_client_common::traits::IQueryHandler;
 use crate::mock_client::MockClient;
 use crate::query_handler::QueryHandler;
 
-use common::icon::icon::types::v1::{MerkleNode, MerkleProofs, SignedHeader};
+use common::icon::icon::types::v1::{MerkleProofs, SignedHeader};
 
 #[cfg(not(feature = "library"))]
 use cosmwasm_std::entry_point;
@@ -19,7 +19,7 @@ use cw_common::raw_types::Any;
 
 use crate::context::CwContext;
 use crate::light_client::IconClient;
-use crate::msg::{ContractResult, ExecuteMsg, InstantiateMsg, QueryMsg};
+use crate::msg::{ContractResult, ExecuteMsg, InstantiateMsg, QueryMsg, QueryResponse};
 use crate::traits::{IContext, ILightClient};
 use crate::ContractError;
 use prost::Message;
@@ -71,9 +71,9 @@ fn process_message(
             let client_id = "08-wasm-0";
             let proofs_decoded =
                 MerkleProofs::decode(msg.proof.as_slice()).map_err(ContractError::DecodeError)?;
-            let path = hex::decode(&msg.path.key_path.join("")).unwrap();
+            let path = hex::decode(msg.path.key_path.join("")).unwrap();
 
-            let ok = QueryHandler::verify_membership(
+            let _ok = QueryHandler::verify_membership(
                 deps_mut.as_ref(),
                 client_id,
                 height,
@@ -92,7 +92,7 @@ fn process_message(
             let client_id = "08-wasm-0";
             let proofs_decoded =
                 MerkleProofs::decode(msg.proof.as_slice()).map_err(ContractError::DecodeError)?;
-            let path = hex::decode(&msg.path.key_path.join("")).unwrap();
+            let path = hex::decode(msg.path.key_path.join("")).unwrap();
 
             let _ok = QueryHandler::verify_non_membership(
                 deps_mut.as_ref(),
@@ -166,11 +166,15 @@ pub fn any_from_byte(bytes: &[u8]) -> Result<Any, ContractError> {
 }
 
 #[cfg_attr(not(feature = "library"), entry_point)]
-pub fn query(_deps: Deps, _env: Env, msg: QueryMsg) -> StdResult<Binary> {
+pub fn query(deps: Deps, _env: Env, msg: QueryMsg) -> StdResult<Binary> {
+    let client_id = "08-wasm-0";
     match msg {
         QueryMsg::ClientTypeMsg(_) => todo!(),
         QueryMsg::GetLatestHeightsMsg(_) => todo!(),
-        QueryMsg::ExportMetadata(_) => todo!(),
+        QueryMsg::ExportMetadata(_) => {
+            let res = QueryHandler::get_genesis_metadata(deps.storage, client_id);
+            to_binary(&QueryResponse::genesis_metadata(Some(res)))
+        }
         QueryMsg::Status(_) => todo!(),
     }
 }

contracts/cosmwasm-vm/cw-wasm-light-client/src/query_handler.rs

@@ -1,11 +1,61 @@
 use common::ibc::Height;
-use cw_light_client_common::{traits::IQueryHandler, ContractError};
+use cosmwasm_std::{Order, StdResult};
+use cw_light_client_common::{constants::PROCESSED_HEIGHTS, traits::IQueryHandler, ContractError};
+use cw_storage_plus::Endian;
 
-use crate::utils::{
-    decode_client_state, decode_consensus_state, get_client_state_key, get_consensus_state_key,
+use crate::{
+    msg::GenesisMetadata,
+    utils::{
+        decode_client_state, decode_consensus_state, get_client_state_key, get_consensus_state_key,
+    },
 };
 
 pub struct QueryHandler;
+
+impl QueryHandler {
+    pub fn processed_time_key(height: &Height, prefix: &mut Vec<u8>) -> Vec<u8> {
+        prefix.append(&mut "consensusStates/".to_string().into_bytes());
+        prefix.append(&mut format!("{height}").into_bytes());
+        prefix.append(&mut "/processedTime".to_string().into_bytes());
+        prefix.clone()
+    }
+
+    pub fn processed_height_key(height: &Height, prefix: &mut Vec<u8>) -> Vec<u8> {
+        prefix.append(&mut "consensusStates/".to_string().into_bytes());
+        prefix.append(&mut format!("{height}").into_bytes());
+        prefix.append(&mut "/processedHeight".to_string().into_bytes());
+        prefix.clone()
+    }
+    pub fn get_genesis_metadata(
+        storage: &dyn cosmwasm_std::Storage,
+        client_id: &str,
+    ) -> Vec<GenesisMetadata> {
+        let heights = PROCESSED_HEIGHTS
+            .prefix(client_id.to_string())
+            .keys(storage, None, None, Order::Ascending)
+            .collect::<StdResult<Vec<u64>>>()
+            .unwrap();
+        let mut gm: Vec<GenesisMetadata> = Vec::<GenesisMetadata>::new();
+        for h in heights {
+            let processed_height =
+                Self::get_processed_blocknumber_at_height(storage, client_id, h).unwrap();
+            let processed_time = Self::get_processed_time_at_height(storage, client_id, h).unwrap();
+            let ibc_height = Height::new(0, h).unwrap();
+            let processed_height_key = Self::processed_height_key(&ibc_height, &mut Vec::new());
+            let processed_time_key = Self::processed_time_key(&ibc_height, &mut Vec::new());
+            gm.push(GenesisMetadata {
+                key: processed_height_key.clone(),
+                value: processed_height.to_be_bytes().to_vec(),
+            });
+
+            gm.push(GenesisMetadata {
+                key: processed_time_key.clone(),
+                value: processed_time.to_be_bytes().to_vec(),
+            });
+        }
+        gm
+    }
+}
 impl IQueryHandler for QueryHandler {
     fn get_client_state(
         storage: &dyn cosmwasm_std::Storage,