clean up keepertest.PricesKeepers()

protocol/app/prepare/prepare_proposal_test.go

@@ -361,7 +361,7 @@ func TestPrepareProposalHandler(t *testing.T) {
 			mockClobKeeper.On("GetOperations", mock.Anything, mock.Anything).
 				Return(tc.clobResp)
 
-			ctx, _, _, _, _, _, _ := keepertest.PricesKeepers(t)
+			ctx, _, _, _, _, _ := keepertest.PricesKeepers(t)
 
 			handler := prepare.PrepareProposalHandler(
 				mockTxConfig,
@@ -440,7 +440,7 @@ func TestPrepareProposalHandler_OtherTxs(t *testing.T) {
 			mockBridgeKeeper.On("GetAcknowledgeBridges", mock.Anything, mock.Anything).
 				Return(constants.MsgAcknowledgeBridges_Ids0_1_Height0)
 
-			ctx, _, _, _, _, _, _ := keepertest.PricesKeepers(t)
+			ctx, _, _, _, _, _ := keepertest.PricesKeepers(t)
 
 			handler := prepare.PrepareProposalHandler(
 				encodingCfg.TxConfig,

protocol/app/process/full_node_process_proposal_test.go

@@ -73,7 +73,7 @@ func TestFullNodeProcessProposalHandler(t *testing.T) {
 			// Setup.
 			_, bridgeKeeper, _, _, _, _, _ := keepertest.BridgeKeepers(t)
 
-			ctx, pricesKeeper, _, indexPriceCache, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+			ctx, pricesKeeper, _, indexPriceCache, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 			mockTimeProvider.On("Now").Return(constants.TimeT)
 			keepertest.CreateTestMarkets(t, ctx, pricesKeeper)
 			indexPriceCache.UpdatePrices(constants.AtTimeTSingleExchangePriceUpdate)

protocol/app/process/market_prices_test.go

@@ -65,7 +65,7 @@ func TestDecodeUpdateMarketPricesTx(t *testing.T) {
 
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
-			ctx, k, _, _, _, _, _ := keepertest.PricesKeepers(t)
+			ctx, k, _, _, _, _ := keepertest.PricesKeepers(t)
 			pricesTxDecoder := process.NewDefaultUpdateMarketPriceTxDecoder(k, encodingCfg.TxConfig.TxDecoder())
 			umpt, err := pricesTxDecoder.DecodeUpdateMarketPricesTx(ctx, [][]byte{tc.txBytes})
 			if tc.expectedErr != nil {
@@ -120,7 +120,7 @@ func TestUpdateMarketPricesTx_Validate(t *testing.T) {
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
 			// Setup.
-			ctx, k, _, indexPriceCache, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+			ctx, k, _, indexPriceCache, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 			mockTimeProvider.On("Now").Return(constants.TimeT)
 			keepertest.CreateTestMarkets(t, ctx, k)
 			indexPriceCache.UpdatePrices(tc.indexPrices)
@@ -162,7 +162,7 @@ func TestUpdateMarketPricesTx_GetMsg(t *testing.T) {
 		t.Run(name, func(t *testing.T) {
 			var msg sdk.Msg
 			if tc.txBytes != nil {
-				ctx, k, _, _, _, _, _ := keepertest.PricesKeepers(t)
+				ctx, k, _, _, _, _ := keepertest.PricesKeepers(t)
 
 				// Decode.
 				pricesTxDecoder := process.NewDefaultUpdateMarketPriceTxDecoder(k, constants.TestEncodingCfg.TxConfig.TxDecoder())

protocol/app/process/process_proposal_test.go

@@ -258,7 +258,7 @@ func TestProcessProposalHandler_Error(t *testing.T) {
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
 			// Setup.
-			ctx, pricesKeeper, _, indexPriceCache, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+			ctx, pricesKeeper, _, indexPriceCache, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 			mockTimeProvider.On("Now").Return(constants.TimeT)
 			keepertest.CreateTestMarkets(t, ctx, pricesKeeper)
 			indexPriceCache.UpdatePrices(constants.AtTimeTSingleExchangePriceUpdate)

protocol/app/process/transactions_test.go

@@ -108,7 +108,7 @@ func TestDecodeProcessProposalTxs_Error(t *testing.T) {
 		t.Run(name, func(t *testing.T) {
 			// Setup.
 			_, bridgeKeeper, _, _, _, _, _ := keepertest.BridgeKeepers(t)
-			ctx, pricesKeeper, _, _, _, _, _ := keepertest.PricesKeepers(t)
+			ctx, pricesKeeper, _, _, _, _ := keepertest.PricesKeepers(t)
 
 			// Run.
 			_, err := process.DecodeProcessProposalTxs(
@@ -188,7 +188,7 @@ func TestDecodeProcessProposalTxs_Valid(t *testing.T) {
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
 			// Setup.
-			ctx, pricesKeeper, _, _, _, _, _ := keepertest.PricesKeepers(t)
+			ctx, pricesKeeper, _, _, _, _ := keepertest.PricesKeepers(t)
 			_, bridgeKeeper, _, _, _, _, _ := keepertest.BridgeKeepers(t)
 
 			// Run.
@@ -318,7 +318,7 @@ func TestProcessProposalTxs_Validate_Error(t *testing.T) {
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
 			// Setup.
-			ctx, pricesKeeper, _, indexPriceCache, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+			ctx, pricesKeeper, _, indexPriceCache, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 			mockTimeProvider.On("Now").Return(constants.TimeT)
 			keepertest.CreateTestMarkets(t, ctx, pricesKeeper)
 			indexPriceCache.UpdatePrices(constants.AtTimeTSingleExchangePriceUpdate)
@@ -425,7 +425,7 @@ func TestProcessProposalTxs_Validate_Valid(t *testing.T) {
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
 			// Setup.
-			ctx, pricesKeeper, _, indexPriceCache, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+			ctx, pricesKeeper, _, indexPriceCache, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 			mockTimeProvider.On("Now").Return(constants.TimeT)
 			keepertest.CreateTestMarkets(t, ctx, pricesKeeper)
 			indexPriceCache.UpdatePrices(constants.AtTimeTSingleExchangePriceUpdate)

protocol/testutil/keeper/prices.go

@@ -40,7 +40,6 @@ func PricesKeepers(t testing.TB) (
 	indexPriceCache *pricefeedserver_types.MarketToExchangePrices,
 	mockTimeProvider *mocks.TimeProvider,
 	revShareKeeper *revsharekeeper.Keeper,
-	marketMapKeeper *marketmapkeeper.Keeper,
 ) {
 	ctx = initKeepers(t, func(
 		db *dbm.MemDB,
@@ -51,7 +50,7 @@ func PricesKeepers(t testing.TB) (
 	) []GenesisInitializer {
 		// Necessary keeper for testing
 		revShareKeeper, _, _ = createRevShareKeeper(stateStore, db, cdc)
-		marketMapKeeper, _ = createMarketMapKeeper(stateStore, db, cdc)
+		marketMapKeeper, _ := createMarketMapKeeper(stateStore, db, cdc)
 
 		// Define necessary keepers here for unit tests
 		keeper, storeKey, indexPriceCache, mockTimeProvider =
@@ -60,7 +59,7 @@ func PricesKeepers(t testing.TB) (
 		return []GenesisInitializer{keeper}
 	})
 
-	return ctx, keeper, storeKey, indexPriceCache, mockTimeProvider, revShareKeeper, marketMapKeeper
+	return ctx, keeper, storeKey, indexPriceCache, mockTimeProvider, revShareKeeper
 }
 
 func createPricesKeeper(

protocol/x/prices/genesis_test.go

@@ -34,7 +34,7 @@ func TestExportGenesis(t *testing.T) {
 	}
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
-			ctx, k, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+			ctx, k, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 			mockTimeProvider.On("Now").Return(constants.TimeT)
 
 			prices.InitGenesis(ctx, *k, *tc.genesisState)
@@ -51,7 +51,7 @@ func TestExportGenesis(t *testing.T) {
 }
 
 func TestExportGenesis_WithMutation(t *testing.T) {
-	ctx, k, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, k, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	prices.InitGenesis(ctx, *k, *types.DefaultGenesis())
 
@@ -95,7 +95,7 @@ func invalidGenesis() types.GenesisState {
 }
 
 func TestInitGenesis_Panics(t *testing.T) {
-	ctx, k, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, k, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 
 	// Verify InitGenesis panics when given an invalid genesis state.
@@ -105,7 +105,7 @@ func TestInitGenesis_Panics(t *testing.T) {
 }
 
 func TestInitGenesisEmitsMarketUpdates(t *testing.T) {
-	ctx, k, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, k, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 
 	prices.InitGenesis(ctx, *k, constants.Prices_DefaultGenesisState)

protocol/x/prices/keeper/grpc_query_market_test.go

@@ -16,7 +16,7 @@ import (
 )
 
 func TestMarketPriceQuerySingle(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	msgs := keepertest.CreateNMarkets(t, ctx, keeper, 2)
 	for _, tc := range []struct {
@@ -67,7 +67,7 @@ func TestMarketPriceQuerySingle(t *testing.T) {
 }
 
 func TestMarketPriceQueryPaginated(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	msgs := keepertest.CreateNMarkets(t, ctx, keeper, 5)
 	prices := make([]types.MarketPrice, len(msgs))
@@ -127,7 +127,7 @@ func TestMarketPriceQueryPaginated(t *testing.T) {
 }
 
 func TestMarketParamQuerySingle(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	msgs := keepertest.CreateNMarkets(t, ctx, keeper, 2)
 	for _, tc := range []struct {
@@ -178,7 +178,7 @@ func TestMarketParamQuerySingle(t *testing.T) {
 }
 
 func TestMarketParamQueryPaginated(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	msgs := keepertest.CreateNMarkets(t, ctx, keeper, 5)
 	params := make([]types.MarketParam, len(msgs))

protocol/x/prices/keeper/keeper_test.go

@@ -8,7 +8,7 @@ import (
 )
 
 func TestLogger(t *testing.T) {
-	ctx, keeper, _, _, _, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, _, _ := keepertest.PricesKeepers(t)
 	logger := keeper.Logger(ctx)
 	require.NotNil(t, logger)
 }

protocol/x/prices/keeper/market_param_test.go

@@ -16,7 +16,7 @@ import (
 )
 
 func TestModifyMarketParam(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	ctx = ctx.WithTxBytes(constants.TestTxBytes)
 	items := keepertest.CreateNMarkets(t, ctx, keeper, 10)
@@ -47,7 +47,7 @@ func TestModifyMarketParam(t *testing.T) {
 }
 
 func TestModifyMarketParamUpdatesCache(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	ctx = ctx.WithTxBytes(constants.TestTxBytes)
 
@@ -180,7 +180,7 @@ func TestModifyMarketParam_Errors(t *testing.T) {
 	}
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
-			ctx, keeper, _, _, mockTimeKeeper, _, _ := keepertest.PricesKeepers(t)
+			ctx, keeper, _, _, mockTimeKeeper, _ := keepertest.PricesKeepers(t)
 			mockTimeKeeper.On("Now").Return(constants.TimeT)
 			ctx = ctx.WithTxBytes(constants.TestTxBytes)
 			keepertest.CreateNMarkets(t, ctx, keeper, 2)
@@ -201,7 +201,7 @@ func TestModifyMarketParam_Errors(t *testing.T) {
 }
 
 func TestGetMarketParam(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	items := keepertest.CreateNMarkets(t, ctx, keeper, 10)
 	for _, item := range items {
@@ -216,13 +216,13 @@ func TestGetMarketParam(t *testing.T) {
 }
 
 func TestGetMarketParam_NotFound(t *testing.T) {
-	ctx, keeper, _, _, _, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, _, _ := keepertest.PricesKeepers(t)
 	_, exists := keeper.GetMarketParam(ctx, uint32(0))
 	require.False(t, exists)
 }
 
 func TestGetAllMarketParams(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	items := keepertest.CreateNMarkets(t, ctx, keeper, 10)
 	params := make([]types.MarketParam, len(items))

protocol/x/prices/keeper/market_price_test.go

@@ -25,7 +25,7 @@ func createNMarketPriceUpdates(
 }
 
 func TestUpdateMarketPrices(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	ctx = ctx.WithTxBytes(constants.TestTxBytes)
 	items := keepertest.CreateNMarkets(t, ctx, keeper, 10)
@@ -60,7 +60,7 @@ func TestUpdateMarketPrices(t *testing.T) {
 }
 
 func TestUpdateMarketPrices_NotFound(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	ctx = ctx.WithTxBytes(constants.TestTxBytes)
 	priceUpdates := createNMarketPriceUpdates(10)
@@ -89,7 +89,7 @@ func TestUpdateMarketPrices_NotFound(t *testing.T) {
 }
 
 func TestGetMarketPrice(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	items := keepertest.CreateNMarkets(t, ctx, keeper, 10)
 	for _, item := range items {
@@ -104,13 +104,13 @@ func TestGetMarketPrice(t *testing.T) {
 }
 
 func TestGetMarketPrice_NotFound(t *testing.T) {
-	ctx, keeper, _, _, _, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, _, _ := keepertest.PricesKeepers(t)
 	_, err := keeper.GetMarketPrice(ctx, uint32(0))
 	require.EqualError(t, err, "0: Market price does not exist")
 }
 
 func TestGetAllMarketPrices(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	items := keepertest.CreateNMarkets(t, ctx, keeper, 10)
 	prices := make([]types.MarketPrice, len(items))
@@ -126,7 +126,7 @@ func TestGetAllMarketPrices(t *testing.T) {
 }
 
 func TestGetMarketIdToValidIndexPrice(t *testing.T) {
-	ctx, keeper, _, indexPriceCache, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, indexPriceCache, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	// Now() is used by `GetMarketIdToValidIndexPrice` internally compare with the cutoff time
 	// of each price.
 	mockTimeProvider.On("Now").Return(constants.TimeT)

protocol/x/prices/keeper/market_test.go

@@ -15,7 +15,7 @@ import (
 )
 
 func TestCreateMarket(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, revShareKeeper, marketMapKeeper := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, revShareKeeper := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	ctx = ctx.WithTxBytes(constants.TestTxBytes)
 
@@ -28,15 +28,15 @@ func TestCreateMarket(t *testing.T) {
 		MinPriceChangePpm:  uint32(9_999),
 	}
 
-	// Validate that market in Market Map is not enabled before we create a new Oracle Market
+	// Create market in market map and validate that it's not enabled before we create a new Oracle Market
 	keepertest.CreateMarketInMarketMapFromParams(
 		t,
 		ctx,
 		keeper.MarketMapKeeper.(*marketmapkeeper.Keeper),
 		[]types.MarketParam{testMarketParams},
 	)
 	currencyPair, _ := slinky.MarketPairToCurrencyPair(constants.BtcUsdPair)
-	mmMarket, _ := marketMapKeeper.GetMarket(ctx, currencyPair.String())
+	mmMarket, _ := keeper.MarketMapKeeper.GetMarket(ctx, currencyPair.String())
 	require.False(t, mmMarket.Ticker.Enabled)
 
 	marketParam, err := keeper.CreateMarket(
@@ -78,7 +78,7 @@ func TestCreateMarket(t *testing.T) {
 	require.NoError(t, err)
 
 	// Verify market is enabled in market map
-	mmMarket, _ = marketMapKeeper.GetMarket(ctx, currencyPair.String())
+	mmMarket, _ = keeper.MarketMapKeeper.GetMarket(ctx, currencyPair.String())
 	require.True(t, mmMarket.Ticker.Enabled)
 
 	expirationTs := uint64(ctx.BlockTime().Unix() + int64(revShareParams.ValidDays*24*3600))
@@ -168,7 +168,7 @@ func TestCreateMarket_Errors(t *testing.T) {
 	}
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
-			ctx, keeper, _, _, mockTimeKeeper, _, _ := keepertest.PricesKeepers(t)
+			ctx, keeper, _, _, mockTimeKeeper, _ := keepertest.PricesKeepers(t)
 			ctx = ctx.WithTxBytes(constants.TestTxBytes)
 
 			mockTimeKeeper.On("Now").Return(constants.TimeT)
@@ -217,7 +217,7 @@ func TestCreateMarket_Errors(t *testing.T) {
 }
 
 func TestGetAllMarketParamPrices(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	items := keepertest.CreateNMarkets(t, ctx, keeper, 10)
 
@@ -231,7 +231,7 @@ func TestGetAllMarketParamPrices(t *testing.T) {
 }
 
 func TestAcquireNextMarketID(t *testing.T) {
-	ctx, keeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+	ctx, keeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 	mockTimeProvider.On("Now").Return(constants.TimeT)
 	ctx = ctx.WithTxBytes(constants.TestTxBytes)
 

protocol/x/prices/keeper/msg_server_create_oracle_market_test.go

@@ -101,7 +101,7 @@ func TestCreateOracleMarket(t *testing.T) {
 
 	for name, tc := range testCases {
 		t.Run(name, func(t *testing.T) {
-			ctx, pricesKeeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+			ctx, pricesKeeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 			mockTimeProvider.On("Now").Return(constants.TimeT)
 			msgServer := keeper.NewMsgServerImpl(pricesKeeper)
 			tc.setup(t, ctx, pricesKeeper)

protocol/x/prices/keeper/msg_server_update_market_param_test.go

@@ -144,7 +144,7 @@ func TestUpdateMarketParam(t *testing.T) {
 
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
-			ctx, pricesKeeper, _, _, mockTimeProvider, _, _ := keepertest.PricesKeepers(t)
+			ctx, pricesKeeper, _, _, mockTimeProvider, _ := keepertest.PricesKeepers(t)
 			mockTimeProvider.On("Now").Return(constants.TimeT)
 			msgServer := keeper.NewMsgServerImpl(pricesKeeper)
 			initialMarketParam, err := keepertest.CreateTestMarket(t, ctx, pricesKeeper, testMarketParam, testMarketPrice)