Struct OverflowReceiveMiddleware

pub struct OverflowReceiveMiddleware<M> { /* private fields */ }

Overflow receive middleware entrypoint, which intercepts compatible ICS-20 packets and sends funds to a new address in case they exceed some specified amount.

Implementations

impl<M> OverflowReceiveMiddleware<M>

pub fn next(&self) -> &M

Return an immutable ref to the next middleware.

pub fn next_mut(&mut self) -> &mut M

Return a mutable ref to the next middleware.

pub const fn wrap(next: M) -> Self

Wrap an existing middleware in the ORM.

Trait Implementations

impl<M: Debug> Debug for OverflowReceiveMiddleware<M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<M> MiddlewareModule for OverflowReceiveMiddleware<M>

where M: IbcCoreModule + OverflowRecvContext,

type NextMiddleware = M

fn next_middleware(&self) -> &M

fn next_middleware_mut(&mut self) -> &mut M

fn middleware_on_recv_packet_execute( &mut self, packet: &Packet, relayer: &Signer, ) -> (ModuleExtras, Option<Acknowledgement>)

fn middleware_on_chan_open_init_validate( &self, order: Order, connection_hops: &[ConnectionId], port_id: &PortId, channel_id: &ChannelId, counterparty: &Counterparty, version: &Version, ) -> Result<Version, ChannelError>

fn middleware_on_chan_open_init_execute( &mut self, order: Order, connection_hops: &[ConnectionId], port_id: &PortId, channel_id: &ChannelId, counterparty: &Counterparty, version: &Version, ) -> Result<(ModuleExtras, Version), ChannelError>

fn middleware_on_chan_open_try_validate( &self, order: Order, connection_hops: &[ConnectionId], port_id: &PortId, channel_id: &ChannelId, counterparty: &Counterparty, counterparty_version: &Version, ) -> Result<Version, ChannelError>

fn middleware_on_chan_open_try_execute( &mut self, order: Order, connection_hops: &[ConnectionId], port_id: &PortId, channel_id: &ChannelId, counterparty: &Counterparty, counterparty_version: &Version, ) -> Result<(ModuleExtras, Version), ChannelError>

fn middleware_on_chan_open_ack_validate( &self, port_id: &PortId, channel_id: &ChannelId, counterparty_version: &Version, ) -> Result<(), ChannelError>

fn middleware_on_chan_open_ack_execute( &mut self, port_id: &PortId, channel_id: &ChannelId, counterparty_version: &Version, ) -> Result<ModuleExtras, ChannelError>

fn middleware_on_chan_open_confirm_validate( &self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<(), ChannelError>

fn middleware_on_chan_open_confirm_execute( &mut self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<ModuleExtras, ChannelError>

fn middleware_on_chan_close_init_validate( &self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<(), ChannelError>

fn middleware_on_chan_close_init_execute( &mut self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<ModuleExtras, ChannelError>

fn middleware_on_chan_close_confirm_validate( &self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<(), ChannelError>

fn middleware_on_chan_close_confirm_execute( &mut self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<ModuleExtras, ChannelError>

fn middleware_on_acknowledgement_packet_validate( &self, packet: &Packet, acknowledgement: &Acknowledgement, relayer: &Signer, ) -> Result<(), ChannelError>

fn middleware_on_acknowledgement_packet_execute( &mut self, packet: &Packet, acknowledgement: &Acknowledgement, relayer: &Signer, ) -> (ModuleExtras, Result<(), ChannelError>)

fn middleware_on_timeout_packet_validate( &self, packet: &Packet, relayer: &Signer, ) -> Result<(), ChannelError>

fn middleware_on_timeout_packet_execute( &mut self, packet: &Packet, relayer: &Signer, ) -> (ModuleExtras, Result<(), ChannelError>)

impl<M> Module for OverflowReceiveMiddleware<M>

where M: IbcCoreModule + OverflowRecvContext,

fn on_chan_open_init_validate( &self, order: Order, connection_hops: &[ConnectionId], port_id: &PortId, channel_id: &ChannelId, counterparty: &Counterparty, version: &Version, ) -> Result<Version, ChannelError>

fn on_chan_open_init_execute( &mut self, order: Order, connection_hops: &[ConnectionId], port_id: &PortId, channel_id: &ChannelId, counterparty: &Counterparty, version: &Version, ) -> Result<(ModuleExtras, Version), ChannelError>

fn on_chan_open_try_validate( &self, order: Order, connection_hops: &[ConnectionId], port_id: &PortId, channel_id: &ChannelId, counterparty: &Counterparty, counterparty_version: &Version, ) -> Result<Version, ChannelError>

fn on_chan_open_try_execute( &mut self, order: Order, connection_hops: &[ConnectionId], port_id: &PortId, channel_id: &ChannelId, counterparty: &Counterparty, counterparty_version: &Version, ) -> Result<(ModuleExtras, Version), ChannelError>

fn on_chan_open_ack_validate( &self, port_id: &PortId, channel_id: &ChannelId, counterparty_version: &Version, ) -> Result<(), ChannelError>

fn on_chan_open_ack_execute( &mut self, port_id: &PortId, channel_id: &ChannelId, counterparty_version: &Version, ) -> Result<ModuleExtras, ChannelError>

fn on_chan_open_confirm_validate( &self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<(), ChannelError>

fn on_chan_open_confirm_execute( &mut self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<ModuleExtras, ChannelError>

fn on_chan_close_init_validate( &self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<(), ChannelError>

fn on_chan_close_init_execute( &mut self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<ModuleExtras, ChannelError>

fn on_chan_close_confirm_validate( &self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<(), ChannelError>

fn on_chan_close_confirm_execute( &mut self, port_id: &PortId, channel_id: &ChannelId, ) -> Result<ModuleExtras, ChannelError>

fn on_recv_packet_execute( &mut self, packet: &Packet, relayer: &Signer, ) -> (ModuleExtras, Option<Acknowledgement>)

ICS-26 onRecvPacket callback implementation.

fn on_acknowledgement_packet_validate( &self, packet: &Packet, acknowledgement: &Acknowledgement, relayer: &Signer, ) -> Result<(), ChannelError>

fn on_acknowledgement_packet_execute( &mut self, packet: &Packet, acknowledgement: &Acknowledgement, relayer: &Signer, ) -> (ModuleExtras, Result<(), ChannelError>)

fn on_timeout_packet_validate( &self, packet: &Packet, relayer: &Signer, ) -> Result<(), ChannelError>

Note: MsgTimeout and MsgTimeoutOnClose use the same callback

fn on_timeout_packet_execute( &mut self, packet: &Packet, relayer: &Signer, ) -> (ModuleExtras, Result<(), ChannelError>)

Note: MsgTimeout and MsgTimeoutOnClose use the same callback