diff --git a/modules/src/core/ics04_channel/handler/acknowledgement.rs b/modules/src/core/ics04_channel/handler/acknowledgement.rs index 897f93d0dc..87b37b72d2 100644 --- a/modules/src/core/ics04_channel/handler/acknowledgement.rs +++ b/modules/src/core/ics04_channel/handler/acknowledgement.rs @@ -1,6 +1,7 @@ use crate::core::ics03_connection::connection::State as ConnectionState; use crate::core::ics04_channel::channel::State; use crate::core::ics04_channel::channel::{Counterparty, Order}; +use crate::core::ics04_channel::context::ChannelCapabilityReader; use crate::core::ics04_channel::events::AcknowledgePacket; use crate::core::ics04_channel::handler::verify::verify_packet_acknowledgement_proofs; use crate::core::ics04_channel::msgs::acknowledgement::MsgAcknowledgement; @@ -20,8 +21,8 @@ pub struct AckPacketResult { pub seq_number: Option, } -pub fn process( - ctx: &dyn ChannelReader, +pub(crate) fn process( + ctx: &Ctx, msg: &MsgAcknowledgement, channel_cap: ChannelCapability, ) -> HandlerResult { diff --git a/modules/src/core/ics04_channel/handler/chan_close_confirm.rs b/modules/src/core/ics04_channel/handler/chan_close_confirm.rs index c8a04b384c..b8130cb4f3 100644 --- a/modules/src/core/ics04_channel/handler/chan_close_confirm.rs +++ b/modules/src/core/ics04_channel/handler/chan_close_confirm.rs @@ -1,7 +1,7 @@ //! Protocol logic specific to ICS4 messages of type `MsgChannelCloseConfirm`. use crate::core::ics03_connection::connection::State as ConnectionState; use crate::core::ics04_channel::channel::{ChannelEnd, Counterparty, State}; -use crate::core::ics04_channel::context::ChannelReader; +use crate::core::ics04_channel::context::{ChannelCapabilityReader, ChannelReader}; use crate::core::ics04_channel::error::Error; use crate::core::ics04_channel::events::Attributes; use crate::core::ics04_channel::handler::verify::verify_channel_proofs; @@ -12,8 +12,8 @@ use crate::events::IbcEvent; use crate::handler::{HandlerOutput, HandlerResult}; use crate::prelude::*; -pub(crate) fn process( - ctx: &dyn ChannelReader, +pub(crate) fn process( + ctx: &Ctx, msg: &MsgChannelCloseConfirm, channel_cap: ChannelCapability, ) -> HandlerResult { diff --git a/modules/src/core/ics04_channel/handler/chan_close_init.rs b/modules/src/core/ics04_channel/handler/chan_close_init.rs index 7ff8c3f4b1..78eba89df9 100644 --- a/modules/src/core/ics04_channel/handler/chan_close_init.rs +++ b/modules/src/core/ics04_channel/handler/chan_close_init.rs @@ -1,7 +1,7 @@ //! Protocol logic specific to ICS4 messages of type `MsgChannelCloseInit`. use crate::core::ics03_connection::connection::State as ConnectionState; use crate::core::ics04_channel::channel::State; -use crate::core::ics04_channel::context::ChannelReader; +use crate::core::ics04_channel::context::{ChannelCapabilityReader, ChannelReader}; use crate::core::ics04_channel::error::Error; use crate::core::ics04_channel::events::Attributes; use crate::core::ics04_channel::handler::{ChannelIdState, ChannelResult}; @@ -10,8 +10,8 @@ use crate::core::ics05_port::capabilities::ChannelCapability; use crate::events::IbcEvent; use crate::handler::{HandlerOutput, HandlerResult}; -pub(crate) fn process( - ctx: &dyn ChannelReader, +pub(crate) fn process( + ctx: &Ctx, msg: &MsgChannelCloseInit, channel_cap: ChannelCapability, ) -> HandlerResult { diff --git a/modules/src/core/ics04_channel/handler/chan_open_ack.rs b/modules/src/core/ics04_channel/handler/chan_open_ack.rs index f1ef06ca64..6985895228 100644 --- a/modules/src/core/ics04_channel/handler/chan_open_ack.rs +++ b/modules/src/core/ics04_channel/handler/chan_open_ack.rs @@ -1,7 +1,7 @@ //! Protocol logic specific to ICS4 messages of type `MsgChannelOpenAck`. use crate::core::ics03_connection::connection::State as ConnectionState; use crate::core::ics04_channel::channel::{ChannelEnd, Counterparty, State}; -use crate::core::ics04_channel::context::ChannelReader; +use crate::core::ics04_channel::context::{ChannelCapabilityReader, ChannelReader}; use crate::core::ics04_channel::error::Error; use crate::core::ics04_channel::events::Attributes; use crate::core::ics04_channel::handler::verify::verify_channel_proofs; @@ -12,8 +12,8 @@ use crate::events::IbcEvent; use crate::handler::{HandlerOutput, HandlerResult}; use crate::prelude::*; -pub(crate) fn process( - ctx: &dyn ChannelReader, +pub(crate) fn process( + ctx: &Ctx, msg: &MsgChannelOpenAck, channel_cap: ChannelCapability, ) -> HandlerResult { diff --git a/modules/src/core/ics04_channel/handler/chan_open_confirm.rs b/modules/src/core/ics04_channel/handler/chan_open_confirm.rs index edf5330935..cfd75d6c80 100644 --- a/modules/src/core/ics04_channel/handler/chan_open_confirm.rs +++ b/modules/src/core/ics04_channel/handler/chan_open_confirm.rs @@ -1,7 +1,7 @@ //! Protocol logic specific to ICS4 messages of type `MsgChannelOpenConfirm`. use crate::core::ics03_connection::connection::State as ConnectionState; use crate::core::ics04_channel::channel::{ChannelEnd, Counterparty, State}; -use crate::core::ics04_channel::context::ChannelReader; +use crate::core::ics04_channel::context::{ChannelCapabilityReader, ChannelReader}; use crate::core::ics04_channel::error::Error; use crate::core::ics04_channel::events::Attributes; use crate::core::ics04_channel::handler::verify::verify_channel_proofs; @@ -12,8 +12,8 @@ use crate::events::IbcEvent; use crate::handler::{HandlerOutput, HandlerResult}; use crate::prelude::*; -pub(crate) fn process( - ctx: &dyn ChannelReader, +pub(crate) fn process( + ctx: &Ctx, msg: &MsgChannelOpenConfirm, channel_cap: ChannelCapability, ) -> HandlerResult { diff --git a/modules/src/core/ics04_channel/handler/chan_open_init.rs b/modules/src/core/ics04_channel/handler/chan_open_init.rs index 04fe14fb23..6716096e19 100644 --- a/modules/src/core/ics04_channel/handler/chan_open_init.rs +++ b/modules/src/core/ics04_channel/handler/chan_open_init.rs @@ -1,19 +1,19 @@ //! Protocol logic specific to ICS4 messages of type `MsgChannelOpenInit`. use crate::core::ics04_channel::channel::{ChannelEnd, State}; -use crate::core::ics04_channel::context::ChannelReader; +use crate::core::ics04_channel::context::{ChannelCapabilityReader, ChannelReader}; use crate::core::ics04_channel::error::Error; use crate::core::ics04_channel::events::Attributes; use crate::core::ics04_channel::handler::{ChannelIdState, ChannelResult}; use crate::core::ics04_channel::msgs::chan_open_init::MsgChannelOpenInit; use crate::core::ics05_port::capabilities::PortCapability; -use crate::core::ics05_port::context::PortReader; +use crate::core::ics05_port::context::PortCapabilityReader; use crate::core::ics24_host::identifier::ChannelId; use crate::events::IbcEvent; use crate::handler::{HandlerOutput, HandlerResult}; use crate::prelude::*; -pub(crate) fn process( +pub(crate) fn process( ctx: &Ctx, msg: &MsgChannelOpenInit, port_cap: PortCapability, diff --git a/modules/src/core/ics04_channel/handler/chan_open_try.rs b/modules/src/core/ics04_channel/handler/chan_open_try.rs index 56711ac988..733384bf81 100644 --- a/modules/src/core/ics04_channel/handler/chan_open_try.rs +++ b/modules/src/core/ics04_channel/handler/chan_open_try.rs @@ -2,20 +2,20 @@ use crate::core::ics03_connection::connection::State as ConnectionState; use crate::core::ics04_channel::channel::{ChannelEnd, Counterparty, State}; -use crate::core::ics04_channel::context::ChannelReader; +use crate::core::ics04_channel::context::{ChannelCapabilityReader, ChannelReader}; use crate::core::ics04_channel::error::Error; use crate::core::ics04_channel::events::Attributes; use crate::core::ics04_channel::handler::verify::verify_channel_proofs; use crate::core::ics04_channel::handler::{ChannelIdState, ChannelResult}; use crate::core::ics04_channel::msgs::chan_open_try::MsgChannelOpenTry; use crate::core::ics05_port::capabilities::PortCapability; -use crate::core::ics05_port::context::PortReader; +use crate::core::ics05_port::context::PortCapabilityReader; use crate::core::ics24_host::identifier::ChannelId; use crate::events::IbcEvent; use crate::handler::{HandlerOutput, HandlerResult}; use crate::prelude::*; -pub(crate) fn process( +pub(crate) fn process( ctx: &Ctx, msg: &MsgChannelOpenTry, port_cap: PortCapability, diff --git a/modules/src/core/ics04_channel/handler/recv_packet.rs b/modules/src/core/ics04_channel/handler/recv_packet.rs index 7b705b1506..70caddaf41 100644 --- a/modules/src/core/ics04_channel/handler/recv_packet.rs +++ b/modules/src/core/ics04_channel/handler/recv_packet.rs @@ -1,6 +1,6 @@ use crate::core::ics03_connection::connection::State as ConnectionState; use crate::core::ics04_channel::channel::{Counterparty, Order, State}; -use crate::core::ics04_channel::context::ChannelReader; +use crate::core::ics04_channel::context::{ChannelCapabilityReader, ChannelReader}; use crate::core::ics04_channel::error::Error; use crate::core::ics04_channel::events::ReceivePacket; use crate::core::ics04_channel::handler::verify::verify_packet_recv_proofs; @@ -28,8 +28,8 @@ pub enum RecvPacketResult { NoOp, } -pub fn process( - ctx: &dyn ChannelReader, +pub(crate) fn process( + ctx: &Ctx, msg: &MsgRecvPacket, channel_cap: ChannelCapability, ) -> HandlerResult { diff --git a/modules/src/core/ics04_channel/handler/timeout.rs b/modules/src/core/ics04_channel/handler/timeout.rs index 2ac1536813..0c09ab637b 100644 --- a/modules/src/core/ics04_channel/handler/timeout.rs +++ b/modules/src/core/ics04_channel/handler/timeout.rs @@ -1,12 +1,13 @@ use crate::core::ics04_channel::channel::State; use crate::core::ics04_channel::channel::{ChannelEnd, Counterparty, Order}; +use crate::core::ics04_channel::context::{ChannelCapabilityReader, ChannelReader}; +use crate::core::ics04_channel::error::Error; use crate::core::ics04_channel::events::TimeoutPacket; use crate::core::ics04_channel::handler::verify::{ verify_next_sequence_recv, verify_packet_receipt_absence, }; use crate::core::ics04_channel::msgs::timeout::MsgTimeout; use crate::core::ics04_channel::packet::{PacketResult, Sequence}; -use crate::core::ics04_channel::{context::ChannelReader, error::Error}; use crate::core::ics05_port::capabilities::ChannelCapability; use crate::core::ics24_host::identifier::{ChannelId, PortId}; use crate::events::IbcEvent; @@ -22,8 +23,8 @@ pub struct TimeoutPacketResult { pub channel: Option, } -pub fn process( - ctx: &dyn ChannelReader, +pub(crate) fn process( + ctx: &Ctx, msg: &MsgTimeout, channel_cap: ChannelCapability, ) -> HandlerResult { diff --git a/modules/src/core/ics04_channel/handler/timeout_on_close.rs b/modules/src/core/ics04_channel/handler/timeout_on_close.rs index 3fc11cd718..9e510c2310 100644 --- a/modules/src/core/ics04_channel/handler/timeout_on_close.rs +++ b/modules/src/core/ics04_channel/handler/timeout_on_close.rs @@ -8,15 +8,17 @@ use crate::core::ics04_channel::handler::verify::{ use crate::core::ics04_channel::msgs::timeout_on_close::MsgTimeoutOnClose; use crate::core::ics04_channel::packet::PacketResult; use crate::core::ics04_channel::{ - context::ChannelReader, error::Error, handler::timeout::TimeoutPacketResult, + context::{ChannelCapabilityReader, ChannelReader}, + error::Error, + handler::timeout::TimeoutPacketResult, }; use crate::core::ics05_port::capabilities::ChannelCapability; use crate::events::IbcEvent; use crate::handler::{HandlerOutput, HandlerResult}; use crate::prelude::*; -pub fn process( - ctx: &dyn ChannelReader, +pub(crate) fn process( + ctx: &Ctx, msg: &MsgTimeoutOnClose, channel_cap: ChannelCapability, ) -> HandlerResult {