Skip to content

Commit

Permalink
upgrade handler for TESTNET ONLY
Browse files Browse the repository at this point in the history
  • Loading branch information
faneaatiku committed Jul 1, 2024
1 parent 0379472 commit e5900b0
Showing 1 changed file with 3 additions and 41 deletions.
44 changes: 3 additions & 41 deletions app/app.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package app

import (
"github.com/bze-alphateam/bze/app/openapi"
"github.com/bze-alphateam/bze/app/upgrades"
v700 "github.com/bze-alphateam/bze/app/upgrades/v700"
"github.com/bze-alphateam/bze/x/epochs"
epochskeeper "github.com/bze-alphateam/bze/x/epochs/keeper"
Expand Down Expand Up @@ -712,47 +713,8 @@ func (app *App) setupUpgradeHandlers(cfg module.Configurator) {
)

app.UpgradeKeeper.SetUpgradeHandler(
"v7.0.0-rc4",
func(ctx sdk.Context, _plan upgradetypes.Plan, vm module.VersionMap) (module.VersionMap, error) {
app.Logger().Info("[TESTNET]running migration")
allAggOrders := app.TradebinKeeper.GetAllAggregatedOrder(ctx)
for _, order := range allAggOrders {
app.Logger().With("agg_order", order).Info("[TESTNET] deleting agg order")
app.TradebinKeeper.RemoveAggregatedOrder(ctx, order)
}

allOrders := app.TradebinKeeper.GetAllOrder(ctx)
for _, order := range allOrders {
app.Logger().With("order", order).Info("[TESTNET] processing order")
agg, ok := app.TradebinKeeper.GetAggregatedOrder(ctx, order.MarketId, order.OrderType, order.Price)
if !ok {
app.Logger().With("order", order).Info("[TESTNET] aggregated order not found. creating new one")
agg = tradebintypes.AggregatedOrder{
MarketId: order.MarketId,
OrderType: order.OrderType,
Amount: "0",
Price: order.Price,
}
}

aggAmount, ok := sdk.NewIntFromString(agg.Amount)
if !ok {
continue
}

orderAmount, ok := sdk.NewIntFromString(order.Amount)
if !ok {
continue
}

agg.Amount = aggAmount.Add(orderAmount).String()
app.TradebinKeeper.SetAggregatedOrder(ctx, agg)

app.Logger().With("order", order, "agg", agg).Info("[TESTNET] aggregated order calculated and saved")
}

return vm, nil
},
"v7.0.0-rc5",
upgrades.EmptyUpgradeHandler(),
)

upgradeInfo, err := app.UpgradeKeeper.ReadUpgradeInfoFromDisk()
Expand Down

0 comments on commit e5900b0

Please sign in to comment.