keeper

func (Keeper) BlockedAddr ¶ added in v3.1.0

func (k Keeper) BlockedAddr(addr string) bool

func (Keeper) EpochIdentifier ¶ added in v3.1.0

func (k Keeper) EpochIdentifier(ctx sdk.Context) (res string)

func (Keeper) ExtractChainIDFromChannel ¶

func (k Keeper) ExtractChainIDFromChannel(ctx sdk.Context, portID string, channelID string) (string, error)

func (Keeper) FinalizeRollappPackets ¶ added in v3.1.0

func (k Keeper) FinalizeRollappPackets(ctx sdk.Context, ibc porttypes.IBCModule, rollappID string, stateEndHeight uint64) error

FinalizeRollappPackets finalizes the packets for the given rollapp until the given height which is the end height of the latest finalized state

func (Keeper) GetAllRollappPackets ¶ added in v3.1.0

func (k Keeper) GetAllRollappPackets(ctx sdk.Context) (list []commontypes.RollappPacket)

func (*Keeper) GetAppVersion ¶

func (k *Keeper) GetAppVersion(
	ctx sdk.Context,
	portID,
	channelID string,
) (string, bool)

GetAppVersion wraps IBC ICS4Wrapper GetAppVersion function.

func (Keeper) GetClientState ¶

func (k Keeper) GetClientState(ctx sdk.Context, portID string, channelID string) (exported.ClientState, error)

GetClientState retrieves the client state for a given packet.

func (Keeper) GetConnectionEnd ¶ added in v3.1.0

func (k Keeper) GetConnectionEnd(ctx sdk.Context, portID string, channelID string) (connectiontypes.ConnectionEnd, error)

func (Keeper) GetEIBCHooks ¶ added in v3.1.0

func (k Keeper) GetEIBCHooks() eibctypes.EIBCHooks

func (Keeper) GetEpochHooks ¶ added in v3.1.0

func (k Keeper) GetEpochHooks() epochstypes.EpochHooks

func (*Keeper) GetHooks ¶ added in v3.1.0

func (k *Keeper) GetHooks() types.MultiDelayedAckHooks

func (Keeper) GetParams ¶ added in v3.1.0

func (k Keeper) GetParams(ctx sdk.Context) types.Params

GetParams get all parameters as types.Params

func (Keeper) GetRollapp ¶

func (k Keeper) GetRollapp(ctx sdk.Context, chainID string) (rollapptypes.Rollapp, bool)

func (Keeper) GetRollappFinalizedHeight ¶

func (k Keeper) GetRollappFinalizedHeight(ctx sdk.Context, chainID string) (uint64, error)

func (Keeper) GetRollappPacket ¶ added in v3.1.0

func (k Keeper) GetRollappPacket(ctx sdk.Context, rollappPacketKey string) (*commontypes.RollappPacket, error)

GetRollappPacket retrieves a rollapp packet from the KVStore.

func (Keeper) HandleFraud ¶ added in v3.1.0

func (k Keeper) HandleFraud(ctx sdk.Context, rollappID string, ibc porttypes.IBCModule) error

func (Keeper) IsRollappsEnabled ¶

func (k Keeper) IsRollappsEnabled(ctx sdk.Context) bool

func (Keeper) ListRollappPackets ¶ added in v3.1.0

func (k Keeper) ListRollappPackets(ctx sdk.Context, listFilter types.RollappPacketListFilter) (list []commontypes.RollappPacket)

ListRollappPackets retrieves a list rollapp packets from the KVStore by applying the given filter

func (Keeper) Logger ¶

func (k Keeper) Logger(ctx sdk.Context) log.Logger

func (*Keeper) LookupModuleByChannel ¶

func (k *Keeper) LookupModuleByChannel(ctx sdk.Context, portID, channelID string) (string, *capabilitytypes.Capability, error)

LookupModuleByChannel wraps ChannelKeeper LookupModuleByChannel function.

func (Keeper) PacketsFinalizationCorrespondsToFinalizationHeight ¶ added in v3.1.0

func (k Keeper) PacketsFinalizationCorrespondsToFinalizationHeight(ctx sdk.Context) (string, bool)

PacketsFinalizationCorrespondsToFinalizationHeight checks that all rollapp packets stored are set to finalized status for all heights up to the latest height. Skip the check if the rollapp is frozen

func (Keeper) PacketsFromRevertedHeightsAreReverted ¶ added in v3.1.0

func (k Keeper) PacketsFromRevertedHeightsAreReverted(ctx sdk.Context) (string, bool)

PacketsFromRevertedHeightsAreReverted checks that all rollapp packets stored are set to reverted status for all heights up to the latest height Check if the rollapp is frozen

func (Keeper) RegisterInvariants ¶ added in v3.1.0

func (k Keeper) RegisterInvariants(ir sdk.InvariantRegistry)

RegisterInvariants registers the delayedack module invariants

func (Keeper) SendPacket ¶

func (k Keeper) SendPacket(
	ctx sdk.Context,
	chanCap *capabilitytypes.Capability,
	sourcePort string, sourceChannel string,
	timeoutHeight clienttypes.Height,
	timeoutTimestamp uint64,
	data []byte,
) (sequence uint64, err error)

SendPacket wraps IBC ChannelKeeper's SendPacket function

func (*Keeper) SetHooks ¶ added in v3.1.0

func (k *Keeper) SetHooks(hooks types.MultiDelayedAckHooks)

func (Keeper) SetParams ¶ added in v3.1.0

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams set the params

func (Keeper) SetRollappPacket ¶

func (k Keeper) SetRollappPacket(ctx sdk.Context, rollappPacket commontypes.RollappPacket)

SetRollappPacket stores a rollapp packet in the KVStore. It logs the saving of the packet and marshals the packet into bytes before storing. The key for the packet is generated using the rollappID, proofHeight and the packet itself.

func (Keeper) UpdateRollappPacketTransferAddress ¶ added in v3.1.0

func (k Keeper) UpdateRollappPacketTransferAddress(
	ctx sdk.Context,
	rollappPacketKey string,
	address string,
) error

UpdateRollappPacketTransferAddress updates the recipient of the underlying packet. Only pending packets can be updated.

func (*Keeper) UpdateRollappPacketWithStatus ¶ added in v3.1.0

func (k *Keeper) UpdateRollappPacketWithStatus(ctx sdk.Context, rollappPacket commontypes.RollappPacket, newStatus commontypes.Status) (commontypes.RollappPacket, error)

UpdateRollappPacketWithStatus deletes the current rollapp packet and creates a new one with and updated status under a new key. Updating the status should be called only with this method as it effects the key of the packet. The assumption is that the passed rollapp packet status field is not updated directly.

func (*Keeper) ValidateRollappId ¶ added in v3.1.0

func (k *Keeper) ValidateRollappId(ctx sdk.Context, rollappID, rollappPortOnHub string, rollappChannelOnHub string) error

ValidateRollappId checks that the rollapp id from the ibc connection matches the rollapp, checking the sequencer registered with the consensus state validator set

func (*Keeper) WriteAcknowledgement ¶

func (k *Keeper) WriteAcknowledgement(ctx sdk.Context, chanCap *capabilitytypes.Capability, packet exported.PacketI, acknowledgement exported.Acknowledgement) error

WriteAcknowledgement wraps IBC ICS4Wrapper WriteAcknowledgement function. ICS29 WriteAcknowledgement is used for asynchronous acknowledgements.

func (Querier) GetPackets ¶ added in v3.1.0

func (q Querier) GetPackets(goCtx context.Context, req *types.QueryRollappPacketsRequest) (*types.QueryRollappPacketListResponse, error)

GetPackets implements types.QueryServer.

func (Querier) Params ¶ added in v3.1.0

func (q Querier) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)