Skip to content

Commit

Permalink
passing all keepers to upgrade handler instead of just account keeper
Browse files Browse the repository at this point in the history
  • Loading branch information
spoo-bar committed Sep 19, 2023
1 parent 727afe1 commit 90c376d
Show file tree
Hide file tree
Showing 14 changed files with 33 additions and 31 deletions.
15 changes: 8 additions & 7 deletions app/app.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ import (
"path/filepath"
"strings"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/x/genmsg"

wasmdKeeper "github.com/CosmWasm/wasmd/x/wasm/keeper"
Expand Down Expand Up @@ -265,7 +266,7 @@ type ArchwayApp struct {
memKeys map[string]*sdk.MemoryStoreKey

// Keepers
Keepers ArchwayKeepers
Keepers keepers.ArchwayKeepers

ScopedIBCKeeper capabilitykeeper.ScopedKeeper
ScopedICAHostKeeper capabilitykeeper.ScopedKeeper
Expand Down Expand Up @@ -326,7 +327,7 @@ func NewArchwayApp(
keys: keys,
tkeys: tkeys,
memKeys: memKeys,
Keepers: ArchwayKeepers{},
Keepers: keepers.ArchwayKeepers{},
}

app.Keepers.ParamsKeeper = initParamsKeeper(
Expand Down Expand Up @@ -393,7 +394,7 @@ func NewArchwayApp(
authtypes.FeeCollectorName,
app.ModuleAccountAddrs(),
)
app.Keepers.slashingKeeper = slashingkeeper.NewKeeper(
app.Keepers.SlashingKeeper = slashingkeeper.NewKeeper(
appCodec,
keys[slashingtypes.StoreKey],
&stakingKeeper,
Expand All @@ -416,7 +417,7 @@ func NewArchwayApp(
// register the staking hooks
// NOTE: stakingKeeper above is passed by reference, so that it will contain these hooks
app.Keepers.StakingKeeper = *stakingKeeper.SetHooks(
stakingtypes.NewMultiStakingHooks(app.Keepers.DistrKeeper.Hooks(), app.Keepers.slashingKeeper.Hooks()),
stakingtypes.NewMultiStakingHooks(app.Keepers.DistrKeeper.Hooks(), app.Keepers.SlashingKeeper.Hooks()),
)

app.Keepers.IBCKeeper = ibckeeper.NewKeeper(
Expand Down Expand Up @@ -475,7 +476,7 @@ func NewArchwayApp(
appCodec,
keys[evidencetypes.StoreKey],
&app.Keepers.StakingKeeper,
app.Keepers.slashingKeeper,
app.Keepers.SlashingKeeper,
)
app.Keepers.EvidenceKeeper = *evidenceKeeper

Expand Down Expand Up @@ -610,7 +611,7 @@ func NewArchwayApp(
capability.NewAppModule(appCodec, *app.Keepers.CapabilityKeeper),
gov.NewAppModule(appCodec, app.Keepers.GovKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper),
mint.NewAppModule(appCodec, app.Keepers.MintKeeper, app.Keepers.AccountKeeper),
slashing.NewAppModule(appCodec, app.Keepers.slashingKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper, app.Keepers.StakingKeeper),
slashing.NewAppModule(appCodec, app.Keepers.SlashingKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper, app.Keepers.StakingKeeper),
distr.NewAppModule(appCodec, app.Keepers.DistrKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper, app.Keepers.StakingKeeper),
staking.NewAppModule(appCodec, app.Keepers.StakingKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper),
upgrade.NewAppModule(app.Keepers.UpgradeKeeper),
Expand Down Expand Up @@ -756,7 +757,7 @@ func NewArchwayApp(
mint.NewAppModule(appCodec, app.Keepers.MintKeeper, app.Keepers.AccountKeeper),
staking.NewAppModule(appCodec, app.Keepers.StakingKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper),
distr.NewAppModule(appCodec, app.Keepers.DistrKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper, app.Keepers.StakingKeeper),
slashing.NewAppModule(appCodec, app.Keepers.slashingKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper, app.Keepers.StakingKeeper),
slashing.NewAppModule(appCodec, app.Keepers.SlashingKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper, app.Keepers.StakingKeeper),
params.NewAppModule(app.Keepers.ParamsKeeper),
evidence.NewAppModule(app.Keepers.EvidenceKeeper),
wasm.NewAppModule(appCodec, &app.Keepers.WASMKeeper, app.Keepers.StakingKeeper, app.Keepers.AccountKeeper, app.Keepers.BankKeeper),
Expand Down
2 changes: 1 addition & 1 deletion app/app_upgrades.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ func (app *ArchwayApp) setUpgradeHandlers() {
for _, u := range Upgrades {
app.Keepers.UpgradeKeeper.SetUpgradeHandler(
u.UpgradeName,
u.CreateUpgradeHandler(app.mm, app.configurator, app.Keepers.AccountKeeper),
u.CreateUpgradeHandler(app.mm, app.configurator, app.Keepers),
)
}
}
4 changes: 2 additions & 2 deletions app/app_upgrades_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@ import (
storeTypes "github.com/cosmos/cosmos-sdk/store/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"
"github.com/cosmos/cosmos-sdk/x/auth/keeper"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"
"github.com/stretchr/testify/require"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/app/upgrades"
e2eTesting "github.com/archway-network/archway/e2e/testing"
rewardsTypes "github.com/archway-network/archway/x/rewards/types"
Expand Down Expand Up @@ -45,7 +45,7 @@ func TestUpgrades(t *testing.T) {
proposalExecuted := false
fauxUpgrade := upgrades.Upgrade{
UpgradeName: "test-upgrade",
CreateUpgradeHandler: func(manager *module.Manager, configurator module.Configurator, _ keeper.AccountKeeper) upgradetypes.UpgradeHandler {
CreateUpgradeHandler: func(manager *module.Manager, configurator module.Configurator, _ keepers.ArchwayKeepers) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
proposalExecuted = true
return manager.RunMigrations(ctx, configurator, fromVM)
Expand Down
2 changes: 1 addition & 1 deletion app/app_upgrades_util_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,6 @@ import "github.com/archway-network/archway/app/upgrades"
func (app *ArchwayApp) AddUpgradeHandler(upgrade upgrades.Upgrade) {
app.Keepers.UpgradeKeeper.SetUpgradeHandler(
upgrade.UpgradeName,
upgrade.CreateUpgradeHandler(app.mm, app.configurator, app.Keepers.AccountKeeper),
upgrade.CreateUpgradeHandler(app.mm, app.configurator, app.Keepers),
)
}
4 changes: 2 additions & 2 deletions app/export.go
Original file line number Diff line number Diff line change
Expand Up @@ -183,11 +183,11 @@ func (app *ArchwayApp) prepForZeroHeightGenesis(ctx sdk.Context, jailAllowedAddr
/* Handle slashing state. */

// reset start height on signing infos
app.Keepers.slashingKeeper.IterateValidatorSigningInfos(
app.Keepers.SlashingKeeper.IterateValidatorSigningInfos(
ctx,
func(addr sdk.ConsAddress, info slashingtypes.ValidatorSigningInfo) (stop bool) {
info.StartHeight = 0
app.Keepers.slashingKeeper.SetValidatorSigningInfo(ctx, addr, info)
app.Keepers.SlashingKeeper.SetValidatorSigningInfo(ctx, addr, info)
return false
},
)
Expand Down
4 changes: 2 additions & 2 deletions app/keepers.go → app/keepers/keepers.go
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package app
package keepers

import (
"github.com/CosmWasm/wasmd/x/wasm"
Expand Down Expand Up @@ -29,7 +29,7 @@ type ArchwayKeepers struct {
BankKeeper bankkeeper.Keeper
CapabilityKeeper *capabilitykeeper.Keeper
StakingKeeper stakingkeeper.Keeper
slashingKeeper slashingkeeper.Keeper
SlashingKeeper slashingkeeper.Keeper
MintKeeper mintkeeper.Keeper
DistrKeeper distrkeeper.Keeper
GovKeeper govkeeper.Keeper
Expand Down
4 changes: 2 additions & 2 deletions app/upgrades/06/upgrades.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,18 +4,18 @@ import (
storetypes "github.com/cosmos/cosmos-sdk/store/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"
"github.com/cosmos/cosmos-sdk/x/auth/keeper"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"
ibcfeetypes "github.com/cosmos/ibc-go/v4/modules/apps/29-fee/types"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/app/upgrades"
)

const Name = "v0.6.0"

var Upgrade = upgrades.Upgrade{
UpgradeName: Name,
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keeper.AccountKeeper) upgradetypes.UpgradeHandler {
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keepers.ArchwayKeepers) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
return mm.RunMigrations(ctx, cfg, fromVM)
}
Expand Down
4 changes: 2 additions & 2 deletions app/upgrades/1_0_0_rc_4/upgrades.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,17 +4,17 @@ import (
storetypes "github.com/cosmos/cosmos-sdk/store/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"
"github.com/cosmos/cosmos-sdk/x/auth/keeper"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/app/upgrades"
)

const Name = "v1.0.0-rc.4"

var Upgrade = upgrades.Upgrade{
UpgradeName: Name,
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keeper.AccountKeeper) upgradetypes.UpgradeHandler {
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keepers.ArchwayKeepers) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
return mm.RunMigrations(ctx, cfg, fromVM)
}
Expand Down
4 changes: 2 additions & 2 deletions app/upgrades/2_0_0/upgrades.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import (
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"

"github.com/cosmos/cosmos-sdk/x/auth/keeper"
banktypes "github.com/cosmos/cosmos-sdk/x/bank/types"
distrtypes "github.com/cosmos/cosmos-sdk/x/distribution/types"
govtypes "github.com/cosmos/cosmos-sdk/x/gov/types"
Expand All @@ -17,14 +16,15 @@ import (
icahosttypes "github.com/cosmos/ibc-go/v4/modules/apps/27-interchain-accounts/host/types"
icatypes "github.com/cosmos/ibc-go/v4/modules/apps/27-interchain-accounts/types"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/app/upgrades"
)

const Name = "v2.0.0"

var Upgrade = upgrades.Upgrade{
UpgradeName: Name,
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keeper.AccountKeeper) upgradetypes.UpgradeHandler {
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keepers.ArchwayKeepers) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {

// Set Initial Consensus Version
Expand Down
4 changes: 2 additions & 2 deletions app/upgrades/3_0_0/upgrades.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,17 +4,17 @@ import (
storetypes "github.com/cosmos/cosmos-sdk/store/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"
"github.com/cosmos/cosmos-sdk/x/auth/keeper"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/app/upgrades"
)

const Name = "v3.0.0"

var Upgrade = upgrades.Upgrade{
UpgradeName: Name,
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keeper.AccountKeeper) upgradetypes.UpgradeHandler {
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keepers.ArchwayKeepers) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
return mm.RunMigrations(ctx, cfg, fromVM)
}
Expand Down
4 changes: 2 additions & 2 deletions app/upgrades/4_0_0/upgrades.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,17 +4,17 @@ import (
storetypes "github.com/cosmos/cosmos-sdk/store/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"
"github.com/cosmos/cosmos-sdk/x/auth/keeper"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/app/upgrades"
)

const Name = "v4.0.0"

var Upgrade = upgrades.Upgrade{
UpgradeName: Name,
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keeper.AccountKeeper) upgradetypes.UpgradeHandler {
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, _ keepers.ArchwayKeepers) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
return mm.RunMigrations(ctx, cfg, fromVM)
}
Expand Down
5 changes: 3 additions & 2 deletions app/upgrades/4_0_2/upgrades.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,19 +6,20 @@ import (
storetypes "github.com/cosmos/cosmos-sdk/store/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"
"github.com/cosmos/cosmos-sdk/x/auth/keeper"
authtypes "github.com/cosmos/cosmos-sdk/x/auth/types"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/app/upgrades"
)

const Name = "v4.0.2"

var Upgrade = upgrades.Upgrade{
UpgradeName: Name,
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, accountKeeper keeper.AccountKeeper) upgradetypes.UpgradeHandler {
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, keepers keepers.ArchwayKeepers) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
accountKeeper := keepers.AccountKeeper
fcAccount := accountKeeper.GetModuleAccount(ctx, authtypes.FeeCollectorName)
account, ok := fcAccount.(*authtypes.ModuleAccount)
if !ok {
Expand Down
4 changes: 2 additions & 2 deletions app/upgrades/latest/upgrades.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,9 @@ import (
storetypes "github.com/cosmos/cosmos-sdk/store/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"
"github.com/cosmos/cosmos-sdk/x/auth/keeper"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"

"github.com/archway-network/archway/app/keepers"
"github.com/archway-network/archway/app/upgrades"
)

Expand All @@ -25,7 +25,7 @@ const NameAsciiArt = `

var Upgrade = upgrades.Upgrade{
UpgradeName: Name,
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, accountKeeper keeper.AccountKeeper) upgradetypes.UpgradeHandler {
CreateUpgradeHandler: func(mm *module.Manager, cfg module.Configurator, keepers keepers.ArchwayKeepers) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
migrations, err := mm.RunMigrations(ctx, cfg, fromVM)
if err != nil {
Expand Down
4 changes: 2 additions & 2 deletions app/upgrades/upgrades.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package upgrades

import (
"github.com/archway-network/archway/app/keepers"
"github.com/cosmos/cosmos-sdk/store/types"
"github.com/cosmos/cosmos-sdk/types/module"
"github.com/cosmos/cosmos-sdk/x/auth/keeper"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"
)

Expand All @@ -16,7 +16,7 @@ type Upgrade struct {
UpgradeName string

// CreateUpgradeHandler defines the function that creates an upgrade handler
CreateUpgradeHandler func(*module.Manager, module.Configurator, keeper.AccountKeeper) upgradetypes.UpgradeHandler
CreateUpgradeHandler func(*module.Manager, module.Configurator, keepers.ArchwayKeepers) upgradetypes.UpgradeHandler

// Store upgrades, should be used for any new modules introduced, new modules deleted, or store names renamed.
StoreUpgrades types.StoreUpgrades
Expand Down

0 comments on commit 90c376d

Please sign in to comment.