feat(e2e): native token transfer from cosmos to starknet (#172)

* fix ack type

* rm redundant todo comment

* relay cosmos ics20 packet to starknet

* log client states

* use simd ibc v9 with wasm

* use cosmos_to_starknet_relay

* infallible cosmos packet conversion to cairo packet

* fix packet timeout logic in cairo

* add crypto-bigint dep

* refactor ibc packet to cairo packet conversion

* ics20 transfer from cosmos to starknet

* use cosmos.nix main branch

* return all ibc token addresses

* query starknet balance

* add new wiring

* add IbcTransferSendMessage

* impl Display traits

* fix sender receiver parsing

* transfer back to cosmos from starknet

* fix typo

* 0x1 for ics20 ack success

* fix trace prefix

* fix sec nanosec conversion

* consistent receipt with cosmos

* use Vec<Felt> for ack

* add asserts after transfer back

* cairo consistent ics20 type names

cairo-contracts/packages/apps/src/transfer/components/transfer.cairo

@@ -11,7 +11,7 @@ pub mod TokenTransferComponent {
     use starknet::ContractAddress;
     use starknet::storage::{
         Map, StorageMapReadAccess, StorageMapWriteAccess, StoragePointerReadAccess,
-        StoragePointerWriteAccess
+        StoragePointerWriteAccess, Vec, VecTrait, MutableVecTrait
     };
     use starknet::{get_contract_address, get_caller_address};
     use starknet_ibc_apps::transfer::types::{
@@ -36,6 +36,7 @@ pub mod TokenTransferComponent {
         salt: felt252,
         ibc_token_key_to_address: Map<felt252, ContractAddress>,
         ibc_token_address_to_key: Map<ContractAddress, felt252>,
+        token_addresses: Vec<ContractAddress>,
     }
 
     #[event]
@@ -282,6 +283,10 @@ pub mod TokenTransferComponent {
 
             address
         }
+
+        fn ibc_token_addresses(self: @ComponentState<TContractState>) -> Array<ContractAddress> {
+            self.read_ibc_token_addresses()
+        }
     }
 
     // -----------------------------------------------------------
@@ -776,6 +781,8 @@ pub mod TokenTransferComponent {
         ) {
             let denom_key = denom.key();
 
+            self.append_ibc_token_address(token_address);
+
             self.write_ibc_token_key_to_address(denom_key, token_address);
 
             self.write_ibc_token_address_to_key(token_address, denom_key);
@@ -839,6 +846,19 @@ pub mod TokenTransferComponent {
             self.ibc_token_key_to_address.read(token_key)
         }
 
+        fn read_ibc_token_addresses(
+            self: @ComponentState<TContractState>
+        ) -> Array<ContractAddress> {
+            let mut addresses = array![];
+            for i in 0
+                ..self
+                    .token_addresses
+                    .len() {
+                        addresses.append(self.token_addresses.at(i).read());
+                    };
+            addresses
+        }
+
         fn read_ibc_token_key(
             self: @ComponentState<TContractState>, token_address: ContractAddress
         ) -> felt252 {
@@ -860,6 +880,12 @@ pub mod TokenTransferComponent {
             self.salt.write(salt);
         }
 
+        fn append_ibc_token_address(
+            ref self: ComponentState<TContractState>, token_address: ContractAddress,
+        ) {
+            self.token_addresses.append().write(token_address);
+        }
+
         fn write_ibc_token_key_to_address(
             ref self: ComponentState<TContractState>,
             token_key: felt252,

cairo-contracts/packages/apps/src/transfer/interfaces/transfer.cairo

@@ -25,5 +25,8 @@ pub trait ITransferQuery<TContractState> {
     /// ```
     /// Hashing the denom is delegated to the client as it is more cost-efficient.
     fn ibc_token_address(self: @TContractState, token_key: felt252) -> ContractAddress;
+
+    /// Return the contract addresses of all IBC tokens.
+    fn ibc_token_addresses(self: @TContractState) -> Array<ContractAddress>;
 }
 

cairo-contracts/packages/core/src/channel/types.cairo

@@ -30,8 +30,9 @@ pub impl PacketImpl of PacketTrait {
 
     /// Checks if the packet is timed out.
     fn is_timed_out(self: @Packet, latest_height: @Height, latest_timestamp: @Timestamp) -> bool {
-        !(self.timeout_height_on_b > latest_height
-            && self.timeout_timestamp_on_b > latest_timestamp)
+        !((self.timeout_height_on_b.is_zero() || self.timeout_height_on_b > latest_height)
+            && (self.timeout_timestamp_on_b.is_zero()
+                || self.timeout_timestamp_on_b > latest_timestamp))
     }
 }
 

flake.nix

@@ -59,7 +59,7 @@
 
           rust-1_79 = nixpkgs.rust-bin.fromRustupToolchainFile ./rust-toolchain-1.79.toml;
 
-          wasm-simapp = cosmos-nix.ibc-go-v8-wasm-simapp;
+          wasm-simapp = cosmos-nix.ibc-go-v9-wasm-simapp;
 
           osmosis = cosmos-nix.osmosis;
 

relayer/crates/cairo-encoding-components/src/components/encode_mut.rs

@@ -18,6 +18,8 @@ cgp_preset! {
         (ViaCairo, Felt): EncodeFelt,
         (ViaCairo, u128): EncodeU128,
         (ViaCairo, U256): EncodeU256,
+        // TODO(rano): ByteArray and Array<u8> are different types in Cairo
+        // for now, we CANNOT use Vec<u8> to deserialize to Array<u8>
         (ViaCairo, Vec<u8>): EncodeByteArray,
         (ViaCairo, Vec<Felt>): EncodeList,
         (ViaCairo, bool): EncodeBool,

relayer/crates/starknet-chain-components/Cargo.toml

@@ -35,3 +35,4 @@ serde                       = { workspace = true }
 serde_json                  = { workspace = true }
 starknet                    = { workspace = true }
 tonic                       = { workspace = true }
+crypto-bigint               = "0.5.5"

relayer/crates/starknet-chain-components/src/components/chain.rs

@@ -41,10 +41,14 @@ pub use hermes_relayer_components::transaction::traits::submit_tx::TxSubmitterCo
 pub use hermes_relayer_components::transaction::traits::types::transaction::TransactionTypeComponent;
 pub use hermes_relayer_components::transaction::traits::types::tx_hash::TransactionHashTypeComponent;
 pub use hermes_relayer_components::transaction::traits::types::tx_response::TxResponseTypeComponent;
+use hermes_test_components::chain::impls::ibc_transfer::SendIbcTransferMessage;
 use hermes_test_components::chain::traits::queries::balance::BalanceQuerierComponent;
+use hermes_test_components::chain::traits::transfer::ibc_transfer::TokenIbcTransferrerComponent;
+use hermes_test_components::chain::traits::transfer::string_memo::ProvideStringMemoType;
 pub use hermes_test_components::chain::traits::types::address::AddressTypeComponent;
 pub use hermes_test_components::chain::traits::types::amount::AmountTypeComponent;
 pub use hermes_test_components::chain::traits::types::denom::DenomTypeComponent;
+use hermes_test_components::chain::traits::types::memo::MemoTypeComponent;
 
 use crate::components::types::StarknetChainTypes;
 use crate::impls::commitment_prefix::GetStarknetCommitmentPrefix;
@@ -146,6 +150,10 @@ cgp_preset! {
             ProvideU256Amount,
         DenomTypeComponent:
             ProvideTokenAddressDenom,
+        MemoTypeComponent:
+            ProvideStringMemoType,
+        TokenIbcTransferrerComponent:
+            SendIbcTransferMessage,
         TransactionTypeComponent:
             ProvideCallTransaction,
         TransactionHashTypeComponent:

relayer/crates/starknet-chain-components/src/components/encoding/cairo.rs

@@ -51,7 +51,8 @@ use crate::types::messages::ibc::denom::{
     Denom, EncodeDenom, EncodePrefixedDenom, EncodeTracePrefix, PrefixedDenom, TracePrefix,
 };
 use crate::types::messages::ibc::ibc_transfer::{
-    EncodeIbcTransferMessage, EncodeParticipant, IbcTransferMessage, Participant,
+    EncodeMsgTransfer, EncodeParticipant, EncodeTransferPacketData, MsgTransfer, Participant,
+    TransferPacketData,
 };
 use crate::types::messages::ibc::packet::{
     AckStatus, Acknowledgement, EncodeAckStatus, EncodeAcknowledgement, EncodeMsgAckPacket,
@@ -107,7 +108,8 @@ delegate_components! {
         (ViaCairo, Vec<TracePrefix>): EncodeList,
         (ViaCairo, PrefixedDenom): EncodePrefixedDenom,
         (ViaCairo, Participant): EncodeParticipant,
-        (ViaCairo, IbcTransferMessage): EncodeIbcTransferMessage,
+        (ViaCairo, TransferPacketData): EncodeTransferPacketData,
+        (ViaCairo, MsgTransfer): EncodeMsgTransfer,
         (ViaCairo, Height): EncodeHeight,
         (ViaCairo, Timestamp): EncodeTimestamp,
         (ViaCairo, Packet): EncodePacket,

relayer/crates/starknet-chain-components/src/impls/events/ack.rs

@@ -56,8 +56,11 @@ where
         })
     }
 
-    fn write_acknowledgement(_ack: &WriteAcknowledgementEvent) -> impl AsRef<Vec<u8>> + Send {
-        // TODO(rano): ack.acknowledgement.ack is Vec<Felt>
-        vec![0x1]
+    fn write_acknowledgement(ack: &WriteAcknowledgementEvent) -> impl AsRef<Vec<u8>> + Send {
+        ack.acknowledgement
+            .ack
+            .iter()
+            .map(|&felt| felt.try_into().unwrap())
+            .collect::<Vec<_>>()
     }
 }