[action] New MigrateStake Action

action/builder.go

@@ -257,6 +257,9 @@ func newStakingActionFromABIBinary(data []byte) (actionPayload, error) {
 	if act, err := NewCandidateTransferOwnershipFromABIBinary(data); err == nil {
 		return act, nil
 	}
+	if act, err := NewMigrateStakeFromABIBinary(data); err == nil {
+		return act, nil
+	}
 	return nil, ErrInvalidABI
 }
 

action/envelope.go

@@ -107,6 +107,8 @@ func (elp *envelope) Proto() *iotextypes.ActionCore {
 		actCore.Action = &iotextypes.ActionCore_CandidateTransferOwnership{CandidateTransferOwnership: act.Proto()}
 	case *txContainer:
 		actCore.Action = &iotextypes.ActionCore_TxContainer{TxContainer: act.proto()}
+	case *MigrateStake:
+		actCore.Action = &iotextypes.ActionCore_StakeMigrate{StakeMigrate: act.Proto()}
 	default:
 		log.S().Panicf("Cannot convert type of action %T.\r\n", act)
 	}
@@ -241,6 +243,12 @@ func (elp *envelope) LoadProto(pbAct *iotextypes.ActionCore) error {
 			return err
 		}
 		elp.payload = act
+	case pbAct.GetStakeMigrate() != nil:
+		act := &MigrateStake{}
+		if err := act.LoadProto(pbAct.GetStakeMigrate()); err != nil {
+			return err
+		}
+		elp.payload = act
 	default:
 		return errors.Errorf("no applicable action to handle proto type %T", pbAct.Action)
 	}

action/protocol/context.go

@@ -124,6 +124,7 @@ type (
 		CandidateIdentifiedByOwner              bool
 		UseTxContainer                          bool
 		LimitedStakingContract                  bool
+		MigrateNativeStake                      bool
 	}
 
 	// FeatureWithHeightCtx provides feature check functions.
@@ -273,6 +274,7 @@ func WithFeatureCtx(ctx context.Context) context.Context {
 			CandidateIdentifiedByOwner:              !g.IsToBeEnabled(height),
 			UseTxContainer:                          g.IsToBeEnabled(height),
 			LimitedStakingContract:                  !g.IsToBeEnabled(height),
+			MigrateNativeStake:                      g.IsToBeEnabled(height),
 		},
 	)
 }

action/protocol/execution/protocol_test.go

@@ -3,7 +3,7 @@
 // or fitness for purpose and, to the extent permitted by law, all liability for your use of the code is disclaimed.
 // This source code is governed by Apache License 2.0 that can be found in the LICENSE file.
 
-package execution
+package execution_test
 
 import (
 	"bytes"
@@ -33,6 +33,7 @@ import (
 	"github.com/iotexproject/iotex-core/action/protocol"
 	"github.com/iotexproject/iotex-core/action/protocol/account"
 	accountutil "github.com/iotexproject/iotex-core/action/protocol/account/util"
+	"github.com/iotexproject/iotex-core/action/protocol/execution"
 	"github.com/iotexproject/iotex-core/action/protocol/execution/evm"
 	"github.com/iotexproject/iotex-core/action/protocol/rewarding"
 	"github.com/iotexproject/iotex-core/action/protocol/rolldpos"
@@ -490,7 +491,7 @@ func (sct *SmartContractTest) prepareBlockchain(
 	r.NoError(reward.Register(registry))
 
 	r.NotNil(bc)
-	execution := NewProtocol(dao.GetBlockHash, rewarding.DepositGasWithSGD, nil, getBlockTimeForTest)
+	execution := execution.NewProtocol(dao.GetBlockHash, rewarding.DepositGasWithSGD, nil, getBlockTimeForTest)
 	r.NoError(execution.Register(registry))
 	r.NoError(bc.Start(ctx))
 
@@ -638,7 +639,7 @@ func (sct *SmartContractTest) run(r *require.Assertions) {
 
 func TestProtocol_Validate(t *testing.T) {
 	require := require.New(t)
-	p := NewProtocol(func(uint64) (hash.Hash256, error) {
+	p := execution.NewProtocol(func(uint64) (hash.Hash256, error) {
 		return hash.ZeroHash256, nil
 	}, rewarding.DepositGasWithSGD, nil, getBlockTimeForTest)
 
@@ -650,8 +651,8 @@ func TestProtocol_Validate(t *testing.T) {
 	}{
 		{"limit 32KB", 0, 32683, nil},
 		{"exceed 32KB", 0, 32684, action.ErrOversizedData},
-		{"limit 48KB", genesis.Default.SumatraBlockHeight, uint64(_executionSizeLimit48KB), nil},
-		{"exceed 48KB", genesis.Default.SumatraBlockHeight, uint64(_executionSizeLimit48KB) + 1, action.ErrOversizedData},
+		{"limit 48KB", genesis.Default.SumatraBlockHeight, uint64(48 * 1024), nil},
+		{"exceed 48KB", genesis.Default.SumatraBlockHeight, uint64(48*1024) + 1, action.ErrOversizedData},
 	}
 
 	for i := range cases {
@@ -733,7 +734,7 @@ func TestProtocol_Handle(t *testing.T) {
 				protocol.NewGenericValidator(sf, accountutil.AccountState),
 			)),
 		)
-		exeProtocol := NewProtocol(dao.GetBlockHash, rewarding.DepositGasWithSGD, nil, getBlockTimeForTest)
+		exeProtocol := execution.NewProtocol(dao.GetBlockHash, rewarding.DepositGasWithSGD, nil, getBlockTimeForTest)
 		require.NoError(exeProtocol.Register(registry))
 		require.NoError(bc.Start(ctx))
 		require.NotNil(bc)

action/protocol/managers.go

@@ -92,4 +92,51 @@ type (
 		Unload(string, string, interface{}) error
 		Reset()
 	}
+
+	// StateManagerWrapper wraps a StateReader to implement StateManager, this is a temporary solution
+	// until the candidate state manager and candidate state reader are refactored
+	StateManagerWrapper struct {
+		StateReader
+	}
 )
+
+// NewStateManagerWrapper creates a new StateManagerWrapper
+func NewStateManagerWrapper(sr StateReader) *StateManagerWrapper {
+	return &StateManagerWrapper{StateReader: sr}
+}
+
+func (wrapper *StateManagerWrapper) Snapshot() int {
+	panic("unimplemented")
+}
+
+func (wrapper *StateManagerWrapper) Revert(int) error {
+	panic("unimplemented")
+}
+
+func (wrapper *StateManagerWrapper) PutState(interface{}, ...StateOption) (uint64, error) {
+	panic("unimplemented")
+}
+
+func (wrapper *StateManagerWrapper) DelState(...StateOption) (uint64, error) {
+	panic("unimplemented")
+}
+
+func (wrapper *StateManagerWrapper) WriteView(string, interface{}) error {
+	panic("unimplemented")
+}
+
+func (wrapper *StateManagerWrapper) ProtocolDirty(string) bool {
+	panic("unimplemented")
+}
+
+func (wrapper *StateManagerWrapper) Load(string, string, interface{}) error {
+	panic("unimplemented")
+}
+
+func (wrapper *StateManagerWrapper) Unload(string, string, interface{}) error {
+	panic("unimplemented")
+}
+
+func (wrapper *StateManagerWrapper) Reset() {
+	panic("unimplemented")
+}