Skip to content

Commit

Permalink
Update
Browse files Browse the repository at this point in the history
  • Loading branch information
hwray committed Nov 22, 2024
1 parent 566e6d0 commit 41d53b5
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions protocol/x/perpetuals/keeper/perpetual_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ func TestModifyPerpetual_Success(t *testing.T) {
// Create liquidity tiers and perpetuals,
perps := keepertest.CreateLiquidityTiersAndNPerpetuals(t, pc.Ctx, pc.PerpetualsKeeper, pc.PricesKeeper, 100)
numMarkets := keepertest.GetNumMarkets(t, pc.Ctx, pc.PricesKeeper)
expectedIndexerEvents := make([]*indexerevents.UpdatePerpetualEventV1, len(perps))
expectedIndexerEvents := make([]*indexerevents.UpdatePerpetualEventV2, len(perps))
for i, item := range perps {
// Modify each field arbitrarily and
// verify the fields were modified in state.
Expand All @@ -60,12 +60,14 @@ func TestModifyPerpetual_Success(t *testing.T) {
require.NoError(t, err)

// Record the indexer event expected to emit from above `ModifyPerpetual`.
expectedIndexerEvents[i] = &indexerevents.UpdatePerpetualEventV1{
expectedIndexerEvents[i] = &indexerevents.UpdatePerpetualEventV2{
Id: item.Params.Id,
Ticker: ticker,
MarketId: marketId,
AtomicResolution: item.Params.AtomicResolution,
LiquidityTier: liquidityTier,
// TODO
MarketType: item.Params.MarketType,
}

// Verify updatedp perpetual in store.
Expand Down Expand Up @@ -112,15 +114,15 @@ func TestModifyPerpetual_Success(t *testing.T) {
func getUpdatePerpetualEventsFromIndexerBlock(
ctx sdk.Context,
perpetualsKeeper *keeper.Keeper,
) []*indexerevents.UpdatePerpetualEventV1 {
) []*indexerevents.UpdatePerpetualEventV2 {
block := perpetualsKeeper.GetIndexerEventManager().ProduceBlock(ctx)
var updatePerpetualEvents []*indexerevents.UpdatePerpetualEventV1
var updatePerpetualEvents []*indexerevents.UpdatePerpetualEventV2
for _, event := range block.Events {
if event.Subtype != indexerevents.SubtypeUpdatePerpetual {
continue
}
if _, ok := event.OrderingWithinBlock.(*indexer_manager.IndexerTendermintEvent_TransactionIndex); ok {
var updatePerpetualEvent indexerevents.UpdatePerpetualEventV1
var updatePerpetualEvent indexerevents.UpdatePerpetualEventV2
err := proto.Unmarshal(event.DataBytes, &updatePerpetualEvent)
if err != nil {
panic(err)
Expand Down

0 comments on commit 41d53b5

Please sign in to comment.