Skip to content

Commit 460ce6e

Browse files
committed
add upgrade handler
1 parent 2844f48 commit 460ce6e

File tree

2 files changed

+57
-3
lines changed

2 files changed

+57
-3
lines changed

app/upgrades.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,12 +7,11 @@ import (
77

88
"github.com/nymtech/nyxd/app/upgrades"
99
"github.com/nymtech/nyxd/app/upgrades/noop"
10-
v054 "github.com/nymtech/nyxd/app/upgrades/v054"
11-
v054testnet "github.com/nymtech/nyxd/app/upgrades/v054-testnet"
10+
v0541 "github.com/nymtech/nyxd/app/upgrades/v054-1"
1211
)
1312

1413
// Upgrades list of chain upgrades
15-
var Upgrades = []upgrades.Upgrade{v054testnet.Upgrade, v054.Upgrade}
14+
var Upgrades = []upgrades.Upgrade{v0541.Upgrade}
1615

1716
// RegisterUpgradeHandlers registers the chain upgrade handlers
1817
func (app *WasmApp) RegisterUpgradeHandlers() {

app/upgrades/v054-1/upgrades.go

Lines changed: 55 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,55 @@
1+
package v054
2+
3+
import (
4+
"context"
5+
"fmt"
6+
7+
storetypes "cosmossdk.io/store/types"
8+
upgradetypes "cosmossdk.io/x/upgrade/types"
9+
10+
sdk "github.com/cosmos/cosmos-sdk/types"
11+
"github.com/cosmos/cosmos-sdk/types/module"
12+
13+
"github.com/nymtech/nyxd/app/upgrades"
14+
)
15+
16+
// UpgradeName defines the on-chain upgrade name
17+
const UpgradeName = "v0.54.1"
18+
19+
var Upgrade = upgrades.Upgrade{
20+
UpgradeName: UpgradeName,
21+
CreateUpgradeHandler: CreateUpgradeHandler,
22+
StoreUpgrades: storetypes.StoreUpgrades{
23+
Added: []string{},
24+
Deleted: []string{},
25+
},
26+
}
27+
28+
func CreateUpgradeHandler(
29+
mm upgrades.ModuleManager,
30+
configurator module.Configurator,
31+
ak *upgrades.AppKeepers,
32+
) upgradetypes.UpgradeHandler {
33+
// sdk 47 to sdk 50
34+
return func(ctx context.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
35+
sdkCtx := sdk.UnwrapSDKContext(ctx)
36+
logger := sdkCtx.Logger().With("upgrade", UpgradeName)
37+
38+
logger.Info(fmt.Sprintf("Starting %s upgrade", UpgradeName))
39+
40+
// Run all configured migrations within the modules
41+
logger.Info("Running any configured module migrations")
42+
newVersionMap, err := mm.RunMigrations(ctx, configurator, fromVM)
43+
if err != nil {
44+
return nil, err
45+
}
46+
47+
// Check if we're good after the upgrade
48+
logger.Info(" === Asserting invariants post-upgrade === ")
49+
ak.CrisisKeeper.AssertInvariants(sdkCtx)
50+
51+
logger.Info("Upgrade complete! 🎉")
52+
53+
return newVersionMap, err
54+
}
55+
}

0 commit comments

Comments
 (0)