Skip to content

Commit

Permalink
fix: Switch to baseapp default store loader fallback
Browse files Browse the repository at this point in the history
  • Loading branch information
Eengineer1 committed Mar 27, 2024
1 parent 1c4195e commit 0585ec3
Showing 1 changed file with 27 additions and 1 deletion.
28 changes: 27 additions & 1 deletion app/app.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package app

import (
"fmt"
"io"
"net/http"
"os"
Expand Down Expand Up @@ -803,9 +804,13 @@ func New(
// v1UpgradeHandler := app.upgradeHandlerV1(icaModule, keys[didtypes.StoreKey], keys[resourcetypes.StoreKey])
// app.UpgradeKeeper.SetUpgradeHandler(upgradeV1.UpgradeName, v1UpgradeHandler)

app.setupUpgradeStoreLoaders()

if loadLatest {
if err := app.LoadLatestVersion(); err != nil {
panic(err)
fmt.Printf("Error loading latest version: %v\n", err)
// CONTRACT: baseapp default store loader will be used to load latest version
// panic(err)
}
}

Expand Down Expand Up @@ -1064,6 +1069,27 @@ func (app *App) RegisterUpgradeHandlers() {
)
}

// configure store loader that checks if version == upgradeHeight and applies store upgrades
func (app *App) setupUpgradeStoreLoaders() {
upgradeInfo, err := app.UpgradeKeeper.ReadUpgradeInfoFromDisk()
if err != nil {
panic(fmt.Sprintf("failed to read upgrade info from disk %s", err))
}

if upgradeInfo.Name == upgradeV2.UpgradeName && !app.UpgradeKeeper.IsSkipHeight(upgradeInfo.Height) {
storeUpgrades := storetypes.StoreUpgrades{
Added: []string{
consensusparamtypes.StoreKey,
crisistypes.StoreKey,
ibcfeetypes.StoreKey,
},
}

// configure store loader that checks if version == upgradeHeight and applies store upgrades
app.SetStoreLoader(upgradetypes.UpgradeStoreLoader(upgradeInfo.Height, &storeUpgrades))
}
}

func (app *App) Configurator() module.Configurator {
return app.configurator
}

0 comments on commit 0585ec3

Please sign in to comment.