utils

Documentation

Index

• func ConcatBytes(margin int, bzs ...[]byte) []byte
• func DenomFromRequestKey(query []byte, accAddr sdk.AccAddress) (string, error)
• func DeriveIbcDenom(port, channel, denom string) string
• func DeriveIbcDenomTrace(port, channel, denom string) ibctransfertypes.DenomTrace
• func GatherAllKeysFromStore(storeObj store.KVStore) []string
• func GatherValuesFromStore[T any](storeObj store.KVStore, keyStart, keyEnd []byte, ...) ([]T, error)
• func GatherValuesFromStorePrefix[T any](storeObj store.KVStore, prefix []byte, parseValue func([]byte) (T, error)) ([]T, error)
• func GetFirstValueAfterPrefixInclusive[T any](storeObj store.KVStore, keyStart []byte, parseValue func([]byte) (T, error)) (T, error)
• func GetFirstValueInRange[T any](storeObj store.KVStore, keyStart, keyEnd []byte, reverseIterate bool, ...) (T, error)
• func GetIterValuesWithStop[T any](storeObj store.KVStore, keyStart []byte, keyEnd []byte, reverse bool, ...) ([]T, error)
• func GetValuesUntilDerivedStop[T any](storeObj store.KVStore, keyStart []byte, stopFn func([]byte) bool, ...) ([]T, error)
• func Keys[V interface{}](in map[string]V) []string
• func LengthPrefixString(s string) []byte
• func MockProofOps(_ sdk.Context, _ *ibckeeper.Keeper, _, _ string, _ int64, _ string, ...) error
• func MockSelfProofOps(_ sdk.Context, _ ClaimsManagerKeeper, _, _ string, _, _ []byte, ...) error
• func MustGet(storeObj store.KVStore, key []byte, result proto.Message)
• func MustGetDec(storeObj store.KVStore, key []byte) sdk.Dec
• func MustSet(storeObj store.KVStore, key []byte, value proto.Message)
• func MustSetDec(storeObj store.KVStore, key []byte, value sdk.Dec)
• func SortSlice[T constraints.Ordered](s []T)
• func StringSliceToMap(in []string) map[string]bool
• func Unique[V interface{}](in []V) []V
• func ValidateProofOps(ctx sdk.Context, ibcKeeper *ibckeeper.Keeper, connectionID, chainID string, ...) error
• func ValidateSelfProofOps(ctx sdk.Context, claimsKeeper ClaimsManagerKeeper, ...) error
• func Verify(trustedHeader *types.SignedHeader, trustedVals *types.ValidatorSet, ...) error
• func VerifyAdjacent(trustedHeader *types.SignedHeader, untrustedHeader *types.SignedHeader, ...) error
• func VerifyNonAdjacent(trustedHeader *types.SignedHeader, trustedVals *types.ValidatorSet, ...) error
• type ClaimsManagerKeeper
• type ContextKey
  • func (c ContextKey) String() string
• type ProofOpsFn
• type SelfProofOpsFn

Functions

func ConcatBytes

func ConcatBytes(margin int, bzs ...[]byte) []byte

ConcatBytes creates a new slice by merging list of bytes and leaving empty amount of margin bytes at the end.

func DenomFromRequestKey

func DenomFromRequestKey(query []byte, accAddr sdk.AccAddress) (string, error)

func DeriveIbcDenom

func DeriveIbcDenom(port, channel, denom string) string

func DeriveIbcDenomTrace

func DeriveIbcDenomTrace(port, channel, denom string) ibctransfertypes.DenomTrace

func GatherAllKeysFromStore

func GatherAllKeysFromStore(storeObj store.KVStore) []string

func GatherValuesFromStore

func GatherValuesFromStore[T any](storeObj store.KVStore, keyStart, keyEnd []byte, parseValue func([]byte) (T, error)) ([]T, error)

func GatherValuesFromStorePrefix

func GatherValuesFromStorePrefix[T any](storeObj store.KVStore, prefix []byte, parseValue func([]byte) (T, error)) ([]T, error)

func GetFirstValueAfterPrefixInclusive

func GetFirstValueAfterPrefixInclusive[T any](storeObj store.KVStore, keyStart []byte, parseValue func([]byte) (T, error)) (T, error)

func GetFirstValueInRange

func GetFirstValueInRange[T any](storeObj store.KVStore, keyStart, keyEnd []byte, reverseIterate bool, parseValue func([]byte) (T, error)) (T, error)

func GetIterValuesWithStop

func GetIterValuesWithStop[T any](
	storeObj store.KVStore,
	keyStart []byte,
	keyEnd []byte,
	reverse bool,
	stopFn func([]byte) bool,
	parseValue func([]byte) (T, error),
) ([]T, error)

func GetValuesUntilDerivedStop

func GetValuesUntilDerivedStop[T any](storeObj store.KVStore, keyStart []byte, stopFn func([]byte) bool, parseValue func([]byte) (T, error)) ([]T, error)

func Keys

func Keys[V interface{}](in map[string]V) []string

func LengthPrefixString

func LengthPrefixString(s string) []byte

LengthPrefixString returns length-prefixed bytes representation of a string.

func MockProofOps

func MockProofOps(_ sdk.Context, _ *ibckeeper.Keeper, _, _ string, _ int64, _ string, _, _ []byte, _ *crypto.ProofOps) error

func MockSelfProofOps

func MockSelfProofOps(_ sdk.Context, _ ClaimsManagerKeeper, _, _ string, _, _ []byte, _ *crypto.ProofOps) error

func MustGet

func MustGet(storeObj store.KVStore, key []byte, result proto.Message)

MustGet gets key from store by mutating result Panics on any error.

func MustGetDec

func MustGetDec(storeObj store.KVStore, key []byte) sdk.Dec

MustGetDec gets dec value from store at key. Panics on any error.

func MustSet

func MustSet(storeObj store.KVStore, key []byte, value proto.Message)

MustSet runs store.Set(key, proto.Marshal(value)) but panics on any error.

func MustSetDec

func MustSetDec(storeObj store.KVStore, key []byte, value sdk.Dec)

MustSetDec sets dec value to store at key. Panics on any error.

func SortSlice

func SortSlice[T constraints.Ordered](s []T)

SortSlice sorts a slice of type T elements that implement constraints.Ordered. Mutates input slice s.

func StringSliceToMap

func StringSliceToMap(in []string) map[string]bool

create a map from a slice of strings for efficient lookup

func Unique

func Unique[V interface{}](in []V) []V

func ValidateProofOps

func ValidateProofOps(
	ctx sdk.Context,
	ibcKeeper *ibckeeper.Keeper,
	connectionID,
	chainID string,
	height int64,
	module string,
	key,
	data []byte,
	proofOps *crypto.ProofOps,
) error

func ValidateSelfProofOps

func ValidateSelfProofOps(ctx sdk.Context, claimsKeeper ClaimsManagerKeeper, consensusStateKey, module string, key, data []byte, proofOps *crypto.ProofOps) error

func Verify

func Verify(
	trustedHeader *types.SignedHeader,
	trustedVals *types.ValidatorSet,
	untrustedHeader *types.SignedHeader,
	untrustedVals *types.ValidatorSet,
	trustingPeriod time.Duration,
	now time.Time,
	maxClockDrift time.Duration,
	trustLevel tmmath.Fraction,
) error

Verify combines both VerifyAdjacent and VerifyNonAdjacent functions.

func VerifyAdjacent

func VerifyAdjacent(
	trustedHeader *types.SignedHeader,
	untrustedHeader *types.SignedHeader,
	untrustedVals *types.ValidatorSet,
	trustingPeriod time.Duration,
	now time.Time,
	maxClockDrift time.Duration,
) error

func VerifyNonAdjacent

func VerifyNonAdjacent(
	trustedHeader *types.SignedHeader,
	trustedVals *types.ValidatorSet,
	untrustedHeader *types.SignedHeader,
	untrustedVals *types.ValidatorSet,
	trustingPeriod time.Duration,
	now time.Time,
	_ time.Duration,
	trustLevel tmmath.Fraction,
) error

VerifyNonAdjacent is identical to VerifyNonAdjacent in tendermint/tendermint/light/verifier.go, with the exception that it does not attempt to validate that the block is _newer_ than the current consensus state.

Types

type ClaimsManagerKeeper

type ClaimsManagerKeeper interface {
	IterateLastEpochUserClaims(ctx sdk.Context, chainID, address string, fn func(index int64, data claimsmanagertypes.Claim) (stop bool))
	GetSelfConsensusState(ctx sdk.Context, key string) (ibctmtypes.ConsensusState, bool)
}

type ContextKey

type ContextKey string

func (ContextKey) String

func (c ContextKey) String() string

type ProofOpsFn

type ProofOpsFn func(ctx sdk.Context, ibcKeeper *ibckeeper.Keeper, connectionID, chainID string, height int64, module string, key []byte, data []byte, proofOps *crypto.ProofOps) error

type SelfProofOpsFn

type SelfProofOpsFn func(ctx sdk.Context, claimsKeeper ClaimsManagerKeeper, consensusStateKey, module string, key []byte, data []byte, proofOps *crypto.ProofOps) error