feat: bc fusion hardfork implementation

docs/sdk/core/examples/app2.go

@@ -128,6 +128,9 @@ func (msg MsgIssue) GetInvolvedAddresses() []sdk.AccAddress {
 // Handle MsgIssue.
 func handleMsgIssue(keyIssue *sdk.KVStoreKey, keyAcc *sdk.KVStoreKey) sdk.Handler {
 	return func(ctx sdk.Context, msg sdk.Msg) sdk.Result {
+		if sdk.IsUpgrade(sdk.BEPXXX) {
+			return sdk.ErrMsgNotSupported("").Result()
+		}
 		issueMsg, ok := msg.(MsgIssue)
 		if !ok {
 			return sdk.NewError(2, 1, "MsgIssue is malformed").Result()

types/upgrade.go

@@ -25,6 +25,9 @@ const (
 	FixDoubleSignChainId        = "FixDoubleSignChainId"
 	BEP126                      = "BEP126" //https://github.com/binance-chain/BEPs/pull/126
 	BEP255                      = "BEP255" // https://github.com/bnb-chain/BEPs/pull/255
+
+	// TODO: to be determined
+	BEPXXX = "BEPXXX-DECO"
 )
 
 var MainNetConfig = UpgradeConfig{

x/stake/cross_stake/cross_stake.go

@@ -140,6 +140,9 @@ func (app *CrossStakeApp) ExecuteFailAckPackage(ctx sdk.Context, payload []byte)
 }
 
 func (app *CrossStakeApp) handleDelegate(ctx sdk.Context, pack *types.CrossStakeDelegateSynPackage, relayFee int64) (sdk.ExecuteResult, uint8, error) {
+	if sdk.IsUpgrade(sdk.BEPXXX) {
+		return sdk.ExecuteResult{}, uint8(sdk.ErrMsgNotSupported("").Code()), nil
+	}
 	var errCode uint8
 	sideChainId := app.stakeKeeper.DestChainName
 	if scCtx, err := app.stakeKeeper.ScKeeper.PrepareCtxForSideChain(ctx, sideChainId); err != nil {
@@ -264,6 +267,9 @@ func (app *CrossStakeApp) handleUndelegate(ctx sdk.Context, pack *types.CrossSta
 }
 
 func (app *CrossStakeApp) handleRedelegate(ctx sdk.Context, pack *types.CrossStakeRedelegateSynPackage, relayFee int64) (sdk.ExecuteResult, uint8, error) {
+	if sdk.IsUpgrade(sdk.BEPXXX) {
+		return sdk.ExecuteResult{}, uint8(sdk.ErrMsgNotSupported("").Code()), nil
+	}
 	var errCode uint8
 	sideChainId := app.stakeKeeper.DestChainName
 	if scCtx, err := app.stakeKeeper.ScKeeper.PrepareCtxForSideChain(ctx, sideChainId); err != nil {

x/stake/handler.go

@@ -127,6 +127,9 @@ func handleMsgRemoveValidatorAfterProposal(ctx sdk.Context, msg MsgRemoveValidat
 }
 
 func handleMsgCreateValidatorOpen(ctx sdk.Context, msg MsgCreateValidatorOpen, k keeper.Keeper) sdk.Result {
+	if sdk.IsUpgrade(sdk.BEPXXX) {
+		return sdk.ErrMsgNotSupported("").Result()
+	}
 	pubkey, err := sdk.GetConsPubKeyBech32(msg.PubKey)
 	if err != nil {
 		return ErrInvalidPubKey(k.Codespace()).Result()
@@ -143,6 +146,9 @@ func handleMsgCreateValidatorOpen(ctx sdk.Context, msg MsgCreateValidatorOpen, k
 }
 
 func handleMsgCreateValidator(ctx sdk.Context, msg MsgCreateValidator, k keeper.Keeper) sdk.Result {
+	if sdk.IsUpgrade(sdk.BEPXXX) {
+		return sdk.ErrMsgNotSupported("").Result()
+	}
 	// consensus pubkey only support ed25519
 	if _, ok := msg.PubKey.(ed25519.PubKeyEd25519); !ok {
 		return ErrInvalidPubKey(k.Codespace()).Result()
@@ -206,6 +212,9 @@ func handleMsgCreateValidator(ctx sdk.Context, msg MsgCreateValidator, k keeper.
 }
 
 func checkCreateProposal(ctx sdk.Context, keeper keeper.Keeper, govKeeper gov.Keeper, msg MsgCreateValidatorProposal) error {
+	if sdk.IsUpgrade(sdk.BEPXXX) {
+		return sdk.ErrMsgNotSupported("")
+	}
 	proposal := govKeeper.GetProposal(ctx, msg.ProposalId)
 	if proposal == nil {
 		return fmt.Errorf("proposal %d does not exist", msg.ProposalId)
@@ -354,6 +363,9 @@ func handleMsgDelegateV1(ctx sdk.Context, msg types.MsgDelegate, k keeper.Keeper
 }
 
 func handleMsgDelegate(ctx sdk.Context, msg types.MsgDelegate, k keeper.Keeper) sdk.Result {
+	if sdk.IsUpgrade(sdk.BEPXXX) {
+		return sdk.ErrMsgNotSupported("").Result()
+	}
 	validator, found := k.GetValidator(ctx, msg.ValidatorAddr)
 	if !found {
 		return ErrNoValidatorFound(k.Codespace()).Result()
@@ -446,6 +458,9 @@ func handleMsgUndelegate(ctx sdk.Context, msg types.MsgUndelegate, k keeper.Keep
 }
 
 func handleMsgBeginUnbonding(ctx sdk.Context, msg types.MsgBeginUnbonding, k keeper.Keeper) sdk.Result {
+	if sdk.IsUpgrade(sdk.BEPXXX) {
+		return sdk.ErrMsgNotSupported("").Result()
+	}
 	ubd, err := k.BeginUnbonding(ctx, msg.DelegatorAddr, msg.ValidatorAddr, msg.SharesAmount)
 	if err != nil {
 		return err.Result()
@@ -462,6 +477,9 @@ func handleMsgBeginUnbonding(ctx sdk.Context, msg types.MsgBeginUnbonding, k kee
 }
 
 func handleMsgRedelegate(ctx sdk.Context, msg types.MsgRedelegate, k keeper.Keeper) sdk.Result {
+	if sdk.IsUpgrade(sdk.BEPXXX) {
+		return sdk.ErrMsgNotSupported("").Result()
+	}
 	if msg.Amount.Denom != k.BondDenom(ctx) {
 		return ErrBadDenom(k.Codespace()).Result()
 	}