Skip to content

Commit

Permalink
migrations
Browse files Browse the repository at this point in the history
  • Loading branch information
keruch committed Nov 7, 2024
1 parent e498879 commit ded06b0
Show file tree
Hide file tree
Showing 9 changed files with 125 additions and 68 deletions.
18 changes: 18 additions & 0 deletions app/upgrades/v4/delayedack_params.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
package v4

import (
sdk "github.com/cosmos/cosmos-sdk/types"

delayedackkeeper "github.com/dymensionxyz/dymension/v3/x/delayedack/keeper"
delayedacktypes "github.com/dymensionxyz/dymension/v3/x/delayedack/types"
)

func migrateDelayedAckParams(ctx sdk.Context, delayedAckKeeper delayedackkeeper.Keeper) {
// overwrite params for rollapp module due to proto change
params := delayedacktypes.DefaultParams()

// EpochIdentifier is the only one that hasn't changed
params.EpochIdentifier = delayedAckKeeper.GetParams(ctx).EpochIdentifier

delayedAckKeeper.SetParams(ctx, params)
}
1 change: 0 additions & 1 deletion app/upgrades/v4/dymns.go

This file was deleted.

13 changes: 13 additions & 0 deletions app/upgrades/v4/dymns_params.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,13 @@
package v4

import (
sdk "github.com/cosmos/cosmos-sdk/types"

dymnskeeper "github.com/dymensionxyz/dymension/v3/x/dymns/keeper"
dymnstypes "github.com/dymensionxyz/dymension/v3/x/dymns/types"
)

func migrateDymnsParams(ctx sdk.Context, dk dymnskeeper.Keeper) error {
params := dymnstypes.DefaultParams()
return dk.SetParams(ctx, params)
}
17 changes: 0 additions & 17 deletions app/upgrades/v4/old_rollapps.go
Original file line number Diff line number Diff line change
@@ -1,12 +1,8 @@
package v4

import (
"fmt"

"cosmossdk.io/math"
sdk "github.com/cosmos/cosmos-sdk/types"

rollappkeeper "github.com/dymensionxyz/dymension/v3/x/rollapp/keeper"
rollapptypes "github.com/dymensionxyz/dymension/v3/x/rollapp/types"
)

Expand Down Expand Up @@ -84,16 +80,3 @@ var (
"ibc/04E01477A69DF1E5EE99F85C15B66D68D23292275357CAA44B2E0527310A405E", // EVMOS
}
)

func validateOldRollappsAreInStore(ctx sdk.Context, rk *rollappkeeper.Keeper) error {
// validate old rollapps are in the store
_, found := rk.GetRollapp(ctx, nimRollappID)
if !found {
return fmt.Errorf("rollapp not found: %s", nimRollappID)
}
_, found = rk.GetRollapp(ctx, mandeRollappID)
if !found {
return fmt.Errorf("rollapp not found: %s", mandeRollappID)
}
return nil
}
15 changes: 4 additions & 11 deletions app/upgrades/v4/upgrade.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,11 +49,6 @@ func CreateUpgradeHandler(
return func(ctx sdk.Context, _ upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
logger := ctx.Logger().With("upgrade", UpgradeName)

// sanity check to re-ensure old rollapps are in the store
if err := validateOldRollappsAreInStore(ctx, keepers.RollappKeeper); err != nil {
return nil, err
}

LoadDeprecatedParamsSubspaces(keepers)

migrateModuleParams(ctx, keepers)
Expand Down Expand Up @@ -87,6 +82,10 @@ func CreateUpgradeHandler(
return nil, err
}

if err := migrateDymnsParams(ctx, keepers.DymNSKeeper); err != nil {
return nil, err
}

// Start running the module migrations
logger.Debug("running module migrations ...")
return mm.RunMigrations(ctx, configurator, fromVM)
Expand Down Expand Up @@ -145,12 +144,6 @@ func LoadDeprecatedParamsSubspaces(keepers *keepers.AppKeepers) {
}
}

func migrateDelayedAckParams(ctx sdk.Context, delayedAckKeeper delayedackkeeper.Keeper) {
// overwrite params for delayedack module due to added parameters
params := delayedacktypes.DefaultParams()
delayedAckKeeper.SetParams(ctx, params)
}

// migrateRollappGauges creates a gauge for each rollapp in the store
func migrateRollappGauges(ctx sdk.Context, rollappkeeper *rollappkeeper.Keeper, incentivizeKeeper *incentiveskeeper.Keeper) error {
rollapps := rollappkeeper.GetAllRollapps(ctx)
Expand Down
2 changes: 2 additions & 0 deletions app/upgrades/v4/upgrade_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -204,6 +204,8 @@ func (s *UpgradeTestSuite) validateRollappsMigration(numRoll int) error {
s.Require().Equal(expectLivenessSlashInterval, s.App.RollappKeeper.GetParams(s.Ctx).LivenessSlashInterval)

if !reflect.DeepEqual(rollapps, expectRollapps) {
s.T().Log("Expect rollapps", expectRollapps)
s.T().Log("Actual rollapps", rollapps)
return fmt.Errorf("rollapps do not match")
}
return nil
Expand Down
6 changes: 5 additions & 1 deletion proto/dymensionxyz/dymension/eibc/demand_order.proto
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,11 @@ message DemandOrder {
(gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins"
];
string recipient = 5;
reserved 6;

// Deprecated: use DemandOrder.IsFulfilled method instead.
// Only used for backwards compatibility.
bool deprecated_is_fulfilled = 6 [deprecated = true];

dymensionxyz.dymension.common.Status tracking_packet_status = 8;
string rollapp_id = 9;
common.RollappPacket.Type type = 10;
Expand Down
2 changes: 1 addition & 1 deletion x/eibc/types/demand_order.go
Original file line number Diff line number Diff line change
Expand Up @@ -161,7 +161,7 @@ func (m *DemandOrder) ValidateOrderIsOutstanding() error {
}

func (m *DemandOrder) IsFulfilled() bool {
return m.FulfillerAddress != ""
return m.FulfillerAddress != "" || m.DeprecatedIsFulfilled
}

// BuildDemandIDFromPacketKey returns a unique demand order id from the packet key.
Expand Down
119 changes: 82 additions & 37 deletions x/eibc/types/demand_order.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

0 comments on commit ded06b0

Please sign in to comment.