keeper

package
v0.0.0-...-13dda56 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 18, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 75 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TestEpochInfoName           = "name"
	TestEpochDuration           = uint32(20)
	TestCreateEpochBlockTimeSec = 1656900000
)

Variables

This section is empty.

Functions

func AssertMarketCreateEventInIndexerBlock 

func AssertMarketCreateEventInIndexerBlock(
	t *testing.T,
	k *keeper.Keeper,
	ctx sdk.Context,
	createdMarketParam types.MarketParam,
)

AssertMarketCreateEventInIndexerBlock verifies that the market create has a corresponding market create event included in the Indexer block message.

func AssertMarketEventsNotInIndexerBlock 

func AssertMarketEventsNotInIndexerBlock(
	t *testing.T,
	k *keeper.Keeper,
	ctx sdk.Context,
)

AssertMarketEventsNotInIndexerBlock verifies that no market events were included in the Indexer block message.

func AssertMarketModifyEventInIndexerBlock 

func AssertMarketModifyEventInIndexerBlock(
	t *testing.T,
	k *keeper.Keeper,
	ctx sdk.Context,
	updatedMarketParam types.MarketParam,
)

AssertMarketModifyEventInIndexerBlock verifies that the market update has a corresponding market modify event included in the Indexer block message.

func AssertMarketPriceUpdateEventInIndexerBlock 

func AssertMarketPriceUpdateEventInIndexerBlock(
	t *testing.T,
	k *keeper.Keeper,
	ctx sdk.Context,
	updatedMarketPrice types.MarketPrice,
)

func AssertPriceUpdateEventsInIndexerBlock 

func AssertPriceUpdateEventsInIndexerBlock(
	t *testing.T,
	k *keeper.Keeper,
	ctx sdk.Context,
	updatedMarketPrices []types.MarketPrice,
)

AssertPriceUpdateEventsInIndexerBlock verifies that the market update has a corresponding price update event included in the Indexer block message.

func AssetsKeepers 

func AssetsKeepers(
	t testing.TB,
	msgSenderEnabled bool,
) (
	ctx sdk.Context,
	keeper *keeper.Keeper,
	pricesKeeper *priceskeeper.Keeper,
	accountKeeper *authkeeper.AccountKeeper,
	bankKeeper *bankkeeper.BaseKeeper,
	storeKey storetypes.StoreKey,
)

func CreateBTCAsset 

func CreateBTCAsset(ctx sdk.Context, assetsKeeper *keeper.Keeper) error

func CreateBTCAssetUpdate 

func CreateBTCAssetUpdate(
	deltaQuoteBalance *big.Int,
) []types.AssetUpdate

func CreateBTCMarket 

func CreateBTCMarket(t *testing.T, ctx sdk.Context, k *keeper.Keeper)

func CreateBtcAssetPosition 

func CreateBtcAssetPosition(
	quoteBalance *big.Int,
) []*types.AssetPosition

func CreateCollateralPoolsAndLiquidityTiersAndNPerpetuals 

func CreateCollateralPoolsAndLiquidityTiersAndNPerpetuals(
	t *testing.T,
	ctx sdk.Context,
	keeper *keeper.Keeper,
	pricesKeeper *priceskeeper.Keeper,
	n int,
) []types.Perpetual

func CreateNClobPair 

func CreateNClobPair(
	t *testing.T,
	keeper *keeper.Keeper,
	perpKeeper *perpkeeper.Keeper,
	pricesKeeper *priceskeeper.Keeper,
	assetsKeeper *asskeeper.Keeper,
	ctx sdk.Context,
	n int,
	mockIndexerEventManager *mocks.IndexerEventManager,
) []types.ClobPair

func CreateNMarkets 

func CreateNMarkets(t *testing.T, ctx sdk.Context, keeper *keeper.Keeper, n int) []types.MarketParamPrice

CreateNMarkets creates N MarketParam, MarketPrice pairs for testing.

func CreateNPerpetuals 

func CreateNPerpetuals(
	t *testing.T,
	ctx sdk.Context,
	keeper *keeper.Keeper,
	pricesKeeper *priceskeeper.Keeper,
	n int,
) ([]types.Perpetual, error)

func CreateNonDefaultTestMarkets 

func CreateNonDefaultTestMarkets(t *testing.T, ctx sdk.Context, k *keeper.Keeper)

func CreatePerpetualMarkets 

func CreatePerpetualMarkets(
	t *testing.T,
	ctx sdk.Context,
	perpKeeper *keeper.Keeper,
	perpetuals []types.Perpetual,
)

func CreateTDaiAsset 

func CreateTDaiAsset(ctx sdk.Context, assetsKeeper *keeper.Keeper) error

CreateTDaiAsset creates TDAI in the assets module for tests.

func CreateTDaiAssetPosition 

func CreateTDaiAssetPosition(
	quoteBalance *big.Int,
) []*types.AssetPosition

func CreateTDaiAssetUpdate 

func CreateTDaiAssetUpdate(
	deltaQuoteBalance *big.Int,
) []types.AssetUpdate

func CreateTestClobPairs 

func CreateTestClobPairs(
	t *testing.T,
	ctx sdk.Context,
	clobKeeper *keeper.Keeper,
	clobPairs []types.ClobPair,
)

func CreateTestCollateralPools 

func CreateTestCollateralPools(t *testing.T, ctx sdk.Context, k *keeper.Keeper)

func CreateTestLiquidityTiers 

func CreateTestLiquidityTiers(t *testing.T, ctx sdk.Context, k *keeper.Keeper)

func CreateTestMarkets 

func CreateTestMarkets(t *testing.T, ctx sdk.Context, k *keeper.Keeper)

CreateTestMarkets creates a standard set of test markets for testing. This function assumes no markets exist and will create markets as id `0`, `1`, and `2`, ... using markets defined in constants.TestMarkets.

func CreateTestPerpetuals 

func CreateTestPerpetuals(t *testing.T, ctx sdk.Context, k *keeper.Keeper)

func CreateTestPriceMarkets 

func CreateTestPriceMarkets(
	t *testing.T,
	ctx sdk.Context,
	pricesKeeper *keeper.Keeper,
	markets []types.MarketParamPrice,
)

CreateTestPriceMarkets is a test utility function that creates list of given price markets in state.

func DelayMsgKeepers 

func DelayMsgKeepers(
	t testing.TB,
) (
	ctx sdk.Context,
	delayMsgKeeper *keeper.Keeper,
	storeKey storetypes.StoreKey,
	bridgeKeeper *bridgekeeper.Keeper,
	bankKeeper bankkeeper.Keeper,
	perpsKeeper *perpetualskeeper.Keeper,
	pricesKeeper *priceskeeper.Keeper,
	yieldsKeeper *yieldskeeper.Keeper,
	authorities []string,
)

func EpochsKeeper 

func EpochsKeeper(
	t testing.TB,
) (
	ctx sdk.Context,
	epochsKeeper *keeper.Keeper,
	storeKey storetypes.StoreKey,
)

func GetAssetCreateEventsFromIndexerBlock 

func GetAssetCreateEventsFromIndexerBlock(
	ctx sdk.Context,
	keeper *keeper.Keeper,
) []*indexerevents.AssetCreateEventV1

GetAssetCreateEventsFromIndexerBlock returns the asset create events in the Indexer Block event Kafka message.

func GetLiquidityTierUpsertEventsFromIndexerBlock 

func GetLiquidityTierUpsertEventsFromIndexerBlock(
	ctx sdk.Context,
	keeper *keeper.Keeper,
) []*indexerevents.LiquidityTierUpsertEventV1

GetLiquidityTierUpsertEventsFromIndexerBlock returns the liquidityTier upsert events in the Indexer Block event Kafka message. TODO(IND-365): Consider using generics here to reduce duplicated code.

func GetNumMarkets 

func GetNumMarkets(t *testing.T, ctx sdk.Context, keeper *keeper.Keeper) uint32

func GetSubaccountUpdateEventsFromIndexerBlock 

func GetSubaccountUpdateEventsFromIndexerBlock(
	ctx sdk.Context,
	keeper *keeper.Keeper,
) []*indexerevents.SubaccountUpdateEventV1

GetSubaccountUpdateEventsFromIndexerBlock returns the subaccount update events in the Indexer Block event Kafka message.

func GetUpdatePerpetualEventsFromIndexerBlock 

func GetUpdatePerpetualEventsFromIndexerBlock(
	ctx sdk.Context,
	keeper *keeper.Keeper,
) []*indexerevents.UpdatePerpetualEventV1

func GetUpdateYieldsParamsFromIndexerBlock 

func GetUpdateYieldsParamsFromIndexerBlock(
	ctx sdk.Context,
	keeper *yieldskeeper.Keeper,
) []*indexerevents.UpdateYieldsParamsEventV1

func PopulateTestPremiumStore 

func PopulateTestPremiumStore(
	t *testing.T,
	ctx sdk.Context,
	k *keeper.Keeper,
	perpetuals []types.Perpetual,
	testFundingPremiums []int32,
	isVote bool,
)

PopulateTestPremiumStore populates either `PremiumVotes` (`isVote` is true) or `PremiumSamples` (`isVote` is false) for test. For each perpetual in the given perpetuals, insert the same list of testFundingSamples into state.

func PricesKeepers 

func PricesKeepers(
	t testing.TB,
) (
	ctx sdk.Context,
	keeper *keeper.Keeper,
	storeKey storetypes.StoreKey,
	daemonPriceCache *pricefeedserver_types.MarketToExchangePrices,
	marketToSmoothedPrices types.MarketToSmoothedPrices,
	mockTimeProvider *mocks.TimeProvider,
)

func SubaccountsKeepers 

func SubaccountsKeepers(
	t testing.TB,
	msgSenderEnabled bool,
) (
	ctx sdk.Context,
	keeper *keeper.Keeper,
	pricesKeeper *priceskeeper.Keeper,
	perpetualsKeeper *perpskeeper.Keeper,
	accountKeeper *authkeeper.AccountKeeper,
	bankKeeper *bankkeeper.BaseKeeper,
	assetsKeeper *asskeeper.Keeper,
	yieldsKeeper *yieldskeeper.Keeper,
	blocktimeKeeper *blocktimekeeper.Keeper,
	storeKey storetypes.StoreKey,
)

Types

type BridgeKeepersTestContext 

type BridgeKeepersTestContext struct {
	Ctx                sdk.Context
	AccountKeeper      *authkeeper.AccountKeeper
	BankKeeper         *bankkeeper.BaseKeeper
	BridgeKeeper       *keeper.Keeper
	PricesKeeper       *priceskeeper.Keeper
	PerpetualsKeeper   *perpkeeper.Keeper
	AssetsKeeper       *assetskeeper.Keeper
	YieldsKeeper       *yieldskeeper.Keeper
	BridgeEventManager *bridgeserver_types.BridgeEventManager
	MockDelayMsgKeeper *mocks.DelayMsgKeeper
	MockTimeProvider   *mocks.TimeProvider
	StoreKey           storetypes.StoreKey
}

func BridgeKeepers 

func BridgeKeepers(
	t testing.TB,
) (ks BridgeKeepersTestContext,
)

type ClobKeepersTestContext 

type ClobKeepersTestContext struct {
	Ctx               sdk.Context
	ClobKeeper        keeper.Keeper
	PricesKeeper      *priceskeeper.Keeper
	AssetsKeeper      *asskeeper.Keeper
	BlockTimeKeeper   *blocktimekeeper.Keeper
	FeeTiersKeeper    *feetierskeeper.Keeper
	YieldsKeeper      *yieldskeeper.Keeper
	PerpetualsKeeper  *perpkeeper.Keeper
	StatsKeeper       *statskeeper.Keeper
	SubaccountsKeeper *subkeeper.Keeper
	EpochsKeeper      *epochskeeper.Keeper
	StoreKey          storetypes.StoreKey
	MemKey            storetypes.StoreKey
	Cdc               *codec.ProtoCodec
}

func NewClobKeepersTestContext 

func NewClobKeepersTestContext(
	t testing.TB,
	memClob types.MemClob,
	bankKeeper bankkeeper.Keeper,
	indexerEventManager indexer_manager.IndexerEventManager,
	voteAggregator veaggregator.VoteAggregator,
) (ks ClobKeepersTestContext)

func NewClobKeepersTestContextWithUninitializedMemStore 

func NewClobKeepersTestContextWithUninitializedMemStore(
	t testing.TB,
	memClob types.MemClob,
	bankKeeper bankkeeper.Keeper,
	indexerEventManager indexer_manager.IndexerEventManager,
	voteAggregator veaggregator.VoteAggregator,
) (ks ClobKeepersTestContext)

type GenesisInitializer 

type GenesisInitializer interface {
	InitializeForGenesis(ctx sdk.Context)
}

type PerpKeepersTestContext 

type PerpKeepersTestContext struct {
	Ctx               sdk.Context
	PricesKeeper      *priceskeeper.Keeper
	DaemonPriceCache  *pricefeedserver_types.MarketToExchangePrices
	AssetsKeeper      *assetskeeper.Keeper
	EpochsKeeper      *epochskeeper.Keeper
	PerpetualsKeeper  *keeper.Keeper
	StoreKey          storetypes.StoreKey
	MemKey            storetypes.StoreKey
	Cdc               *codec.ProtoCodec
	MockTimeProvider  *mocks.TimeProvider
	TransientStoreKey storetypes.StoreKey
}

func PerpetualsKeepers 

func PerpetualsKeepers(
	t testing.TB,
) (pc PerpKeepersTestContext)

func PerpetualsKeepersWithClobHelpers 

func PerpetualsKeepersWithClobHelpers(
	t testing.TB,
	clobKeeper types.PerpetualsClobKeeper,
) (pc PerpKeepersTestContext)

type SendingKeepersTestContext 

type SendingKeepersTestContext struct {
	Ctx               sdk.Context
	SendingKeeper     *keeper.Keeper
	AccountKeeper     *authkeeper.AccountKeeper
	BankKeeper        *bankkeeper.BaseKeeper
	PricesKeeper      *priceskeeper.Keeper
	PerpetualsKeeper  *perpkeeper.Keeper
	AssetsKeeper      *assetskeeper.Keeper
	SubaccountsKeeper types.SubaccountsKeeper
	YieldsKeeper      *yieldskeeper.Keeper
	StoreKey          storetypes.StoreKey
}

func SendingKeepers 

func SendingKeepers(t testing.TB) (
	ks SendingKeepersTestContext,
)

func SendingKeepersWithSubaccountsKeeper 

func SendingKeepersWithSubaccountsKeeper(t testing.TB, saKeeper types.SubaccountsKeeper) (
	ks SendingKeepersTestContext,
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.