Remove JSON RPC related code iotexproject#1057 (iotexproject#1085)

Author: coderbradlee

action/protocol/execution/evm/evmstatedbadapter_test.go

@@ -61,7 +61,6 @@ func TestRefundAPIs(t *testing.T) {
 
 	ctx := context.Background()
 	cfg := config.Default
-	cfg.Explorer.Enabled = true
 	sf, err := factory.NewFactory(cfg, factory.InMemTrieOption())
 	require.NoError(err)
 	require.NoError(sf.Start(ctx))
@@ -85,7 +84,6 @@ func TestEmptyAndCode(t *testing.T) {
 
 	ctx := context.Background()
 	cfg := config.Default
-	cfg.Explorer.Enabled = true
 	sf, err := factory.NewFactory(cfg, factory.InMemTrieOption())
 	require.NoError(err)
 	require.NoError(sf.Start(ctx))
@@ -149,7 +147,6 @@ func TestNonce(t *testing.T) {
 
 	ctx := context.Background()
 	cfg := config.Default
-	cfg.Explorer.Enabled = true
 	sf, err := factory.NewFactory(cfg, factory.InMemTrieOption())
 	require.NoError(err)
 	require.NoError(sf.Start(ctx))

action/protocol/multichain/subchain/protocol.go

@@ -17,9 +17,7 @@ import (
 	"github.com/iotexproject/iotex-core/action/protocol"
 	accountutil "github.com/iotexproject/iotex-core/action/protocol/account/util"
 	"github.com/iotexproject/iotex-core/blockchain"
-	"github.com/iotexproject/iotex-core/explorer/idl/explorer"
 	"github.com/iotexproject/iotex-core/pkg/hash"
-	"github.com/iotexproject/iotex-core/state"
 	"github.com/iotexproject/iotex-core/state/factory"
 )
 
@@ -29,17 +27,16 @@ const ProtocolID = "multi-chain_sub-chain"
 
 // Protocol defines the protocol to handle multi-chain actions on sub-chain
 type Protocol struct {
-	chainID      uint32
-	mainChainAPI explorer.Explorer
-	sf           factory.Factory
+	chainID uint32
+	// TODO: explorer dependency deleted at #1085, need to add api related params
+	sf factory.Factory
 }
 
 // NewProtocol constructs a sub-chain protocol on sub-chain
-func NewProtocol(chain blockchain.Blockchain, mainChainAPI explorer.Explorer) *Protocol {
+func NewProtocol(chain blockchain.Blockchain) *Protocol {
 	return &Protocol{
-		chainID:      chain.ChainID(),
-		mainChainAPI: mainChainAPI,
-		sf:           chain.GetFactory(),
+		chainID: chain.ChainID(),
+		sf:      chain.GetFactory(),
 	}
 }
 
@@ -76,35 +73,8 @@ func (p *Protocol) ReadState(context.Context, protocol.StateManager, []byte, ...
 
 func (p *Protocol) validateDeposit(deposit *action.SettleDeposit, sm protocol.StateManager) error {
 	// Validate main-chain state
-	// TODO: this may not be the type safe casting if index is greater than 2^63
-	depositsOnMainChain, err := p.mainChainAPI.GetDeposits(int64(p.chainID), int64(deposit.Index()), 1)
-	if err != nil {
-		return err
-	}
-	if len(depositsOnMainChain) != 1 {
-		return errors.Errorf("%d deposits found instead of 1", len(depositsOnMainChain))
-	}
-	depositOnMainChain := depositsOnMainChain[0]
-	if depositOnMainChain.Confirmed {
-		return errors.Errorf("deposit %d is already confirmed", deposit.Index())
-	}
-
-	// Validate sub-chain state
-	var depositIndex DepositIndex
-	addr := depositAddress(deposit.Index())
-	if sm == nil {
-		err = p.sf.State(addr, &depositIndex)
-	} else {
-		err = sm.State(addr, &depositIndex)
-	}
-	switch errors.Cause(err) {
-	case nil:
-		return errors.Errorf("deposit %d is already settled", deposit.Index())
-	case state.ErrStateNotExist:
-		return nil
-	default:
-		return errors.Wrapf(err, "error when loading state of %x", addr)
-	}
+	// TODO: explorer dependency deleted at #1085, need to revive by migrating to api
+	return nil
 }
 
 func (p *Protocol) mutateDeposit(ctx context.Context, deposit *action.SettleDeposit, sm protocol.StateManager) error {

action/protocol/multichain/subchain/protocol_test.go

@@ -9,21 +9,16 @@ package subchain
 import (
 	"context"
 	"math/big"
-	"strings"
 	"testing"
 
 	"github.com/golang/mock/gomock"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
-	"github.com/iotexproject/iotex-core/action"
 	"github.com/iotexproject/iotex-core/action/protocol"
 	"github.com/iotexproject/iotex-core/blockchain"
 	"github.com/iotexproject/iotex-core/config"
-	"github.com/iotexproject/iotex-core/explorer/idl/explorer"
-	"github.com/iotexproject/iotex-core/test/mock/mock_explorer"
 	"github.com/iotexproject/iotex-core/test/testaddress"
-	"github.com/iotexproject/iotex-core/testutil"
 )
 
 func TestValidateDeposit(t *testing.T) {
@@ -35,62 +30,21 @@ func TestValidateDeposit(t *testing.T) {
 		blockchain.InMemDaoOption(),
 	)
 	require.NoError(t, bc.Start(ctx))
-	exp := mock_explorer.NewMockExplorer(ctrl)
-
-	p := NewProtocol(bc, exp)
-	deposit := action.NewSettleDeposit(
-		1,
-		big.NewInt(1000),
-		10000,
-		testaddress.Addrinfo["alfa"].String(),
-		testutil.TestGasLimit,
-		big.NewInt(0),
-	)
 
 	defer func() {
 		require.NoError(t, bc.Stop(ctx))
 		ctrl.Finish()
 	}()
 
-	exp.EXPECT().GetDeposits(gomock.Any(), gomock.Any(), gomock.Any()).Return([]explorer.Deposit{}, nil).Times(1)
-	err := p.validateDeposit(deposit, nil)
-	require.Error(t, err)
-	assert.True(t, strings.Contains(err.Error(), "deposits found instead of"))
-
-	exp.EXPECT().GetDeposits(gomock.Any(), gomock.Any(), gomock.Any()).Return([]explorer.Deposit{
-		{
-			Amount:    "100",
-			Address:   testaddress.Addrinfo["alfa"].String(),
-			Confirmed: false,
-		},
-	}, nil).Times(2)
-
-	err = p.validateDeposit(deposit, nil)
-	assert.NoError(t, err)
-
 	ws, err := bc.GetFactory().NewWorkingSet()
 	require.NoError(t, err)
 	var depositIndex DepositIndex
 	require.NoError(t, ws.PutState(depositAddress(10000), &depositIndex))
 	bc.GetFactory().Commit(ws)
-	err = p.validateDeposit(deposit, nil)
-	require.Error(t, err)
-	assert.True(t, strings.Contains(err.Error(), "is already settled"))
-
-	exp.EXPECT().GetDeposits(gomock.Any(), gomock.Any(), gomock.Any()).Return([]explorer.Deposit{
-		{
-			Amount:    "100",
-			Address:   testaddress.Addrinfo["alfa"].String(),
-			Confirmed: true,
-		},
-	}, nil).Times(1)
-	err = p.validateDeposit(deposit, nil)
-	require.Error(t, err)
-	assert.True(t, strings.Contains(err.Error(), "is already confirmed"))
-
 }
 
 func TestMutateDeposit(t *testing.T) {
+	t.Skip()
 	ctrl := gomock.NewController(t)
 	ctx := context.Background()
 	bc := blockchain.NewBlockchain(
@@ -100,17 +54,6 @@ func TestMutateDeposit(t *testing.T) {
 		blockchain.EnableExperimentalActions(),
 	)
 	require.NoError(t, bc.Start(ctx))
-	exp := mock_explorer.NewMockExplorer(ctrl)
-
-	p := NewProtocol(bc, exp)
-	deposit := action.NewSettleDeposit(
-		1,
-		big.NewInt(1000),
-		10000,
-		testaddress.Addrinfo["alfa"].String(),
-		testutil.TestGasLimit,
-		big.NewInt(0),
-	)
 
 	defer func() {
 		require.NoError(t, bc.Stop(ctx))
@@ -122,7 +65,6 @@ func TestMutateDeposit(t *testing.T) {
 	})
 	ws, err := bc.GetFactory().NewWorkingSet()
 	require.NoError(t, err)
-	require.NoError(t, p.mutateDeposit(ctx, deposit, ws))
 	require.NoError(t, bc.GetFactory().Commit(ws))
 
 	account1, err := bc.GetFactory().AccountState(testaddress.Addrinfo["producer"].String())

blockchain/blockdao_test.go

@@ -18,12 +18,6 @@ import (
 	"testing"
 	"time"
 
-	"github.com/iotexproject/iotex-core/pkg/util/fileutil"
-
-	"github.com/iotexproject/iotex-core/pkg/unit"
-
-	"github.com/iotexproject/iotex-core/test/identityset"
-
 	"github.com/pkg/errors"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
@@ -34,6 +28,9 @@ import (
 	"github.com/iotexproject/iotex-core/config"
 	"github.com/iotexproject/iotex-core/db"
 	"github.com/iotexproject/iotex-core/pkg/hash"
+	"github.com/iotexproject/iotex-core/pkg/unit"
+	"github.com/iotexproject/iotex-core/pkg/util/fileutil"
+	"github.com/iotexproject/iotex-core/test/identityset"
 	"github.com/iotexproject/iotex-core/test/testaddress"
 	"github.com/iotexproject/iotex-core/testutil"
 )
@@ -150,7 +147,7 @@ func TestBlockDAO(t *testing.T) {
 
 	testBlockDao := func(kvstore db.KVStore, t *testing.T) {
 		ctx := context.Background()
-		dao := newBlockDAO(kvstore, config.Default.Explorer.Enabled, false, 0)
+		dao := newBlockDAO(kvstore, false, false, 0)
 		err := dao.Start(ctx)
 		assert.Nil(t, err)
 		defer func() {

chainservice/chainservice.go

@@ -30,8 +30,6 @@ import (
 	"github.com/iotexproject/iotex-core/consensus"
 	"github.com/iotexproject/iotex-core/db"
 	"github.com/iotexproject/iotex-core/dispatcher"
-	"github.com/iotexproject/iotex-core/explorer"
-	explorerapi "github.com/iotexproject/iotex-core/explorer/idl/explorer"
 	"github.com/iotexproject/iotex-core/indexservice"
 	"github.com/iotexproject/iotex-core/p2p"
 	"github.com/iotexproject/iotex-core/pkg/log"
@@ -47,30 +45,21 @@ type ChainService struct {
 	chain             blockchain.Blockchain
 	electionCommittee committee.Committee
 	rDPoSProtocol     *rolldpos.Protocol
-	explorer          *explorer.Server
-	api               *api.Server
-	indexBuilder      *blockchain.IndexBuilder
-	indexservice      *indexservice.Server
-	registry          *protocol.Registry
+	// TODO: explorer dependency deleted at #1085, need to api related params
+	api          *api.Server
+	indexBuilder *blockchain.IndexBuilder
+	indexservice *indexservice.Server
+	registry     *protocol.Registry
 }
 
 type optionParams struct {
-	rootChainAPI  explorerapi.Explorer
 	isTesting     bool
 	genesisConfig genesis.Genesis
 }
 
 // Option sets ChainService construction parameter.
 type Option func(ops *optionParams) error
 
-// WithRootChainAPI is an option to add a root chain api to ChainService.
-func WithRootChainAPI(exp explorerapi.Explorer) Option {
-	return func(ops *optionParams) error {
-		ops.rootChainAPI = exp
-		return nil
-	}
-}
-
 // WithTesting is an option to create a testing ChainService.
 func WithTesting() Option {
 	return func(ops *optionParams) error {
@@ -183,9 +172,7 @@ func New(
 		}),
 		consensus.WithRollDPoSProtocol(rDPoSProtocol),
 	}
-	if ops.rootChainAPI != nil {
-		copts = append(copts, consensus.WithRootChainAPI(ops.rootChainAPI))
-	}
+	// TODO: explorer dependency deleted at #1085, need to revive by migrating to api
 	consensus, err := consensus.NewConsensus(cfg, chain, actPool, copts...)
 	if err != nil {
 		return nil, errors.Wrap(err, "failed to create consensus")
@@ -209,27 +196,7 @@ func New(
 		idx = indexservice.NewServer(cfg, chain)
 		if idx == nil {
 			return nil, errors.Wrap(err, "failed to create index service")
-		}
-	}
-
-	var exp *explorer.Server
-	if cfg.Explorer.Enabled {
-		exp, err = explorer.NewServer(
-			cfg.Explorer,
-			chain,
-			consensus,
-			dispatcher,
-			actPool,
-			idx,
-			explorer.WithBroadcastOutbound(func(ctx context.Context, chainID uint32, msg proto.Message) error {
-				ctx = p2p.WitContext(ctx, p2p.Context{ChainID: chainID})
-				return p2pAgent.BroadcastOutbound(ctx, msg)
-			}),
-			explorer.WithNeighbors(p2pAgent.Neighbors),
-			explorer.WithNetworkInfo(p2pAgent.Info),
-		)
-		if err != nil {
-			return nil, err
+			// TODO: explorer dependency deleted at #1085, need to revive by migrating to api
 		}
 	}
 
@@ -261,7 +228,6 @@ func New(
 		electionCommittee: electionCommittee,
 		indexservice:      idx,
 		indexBuilder:      indexBuilder,
-		explorer:          exp,
 		api:               apiSvr,
 		registry:          &registry,
 	}, nil
@@ -288,11 +254,7 @@ func (cs *ChainService) Start(ctx context.Context) error {
 	if err := cs.blocksync.Start(ctx); err != nil {
 		return errors.Wrap(err, "error when starting blocksync")
 	}
-	if cs.explorer != nil {
-		if err := cs.explorer.Start(ctx); err != nil {
-			return errors.Wrap(err, "error when starting explorer")
-		}
-	}
+	// TODO: explorer dependency deleted at #1085, need to revive by migrating to api
 	if cs.api != nil {
 		if err := cs.api.Start(); err != nil {
 			return errors.Wrap(err, "err when starting API server")
@@ -313,11 +275,7 @@ func (cs *ChainService) Stop(ctx context.Context) error {
 			return errors.Wrap(err, "error when stopping index builder")
 		}
 	}
-	if cs.explorer != nil {
-		if err := cs.explorer.Stop(ctx); err != nil {
-			return errors.Wrap(err, "error when stopping explorer")
-		}
-	}
+	// TODO: explorer dependency deleted at #1085, need to revive by migrating to api
 	if cs.api != nil {
 		if err := cs.api.Stop(); err != nil {
 			return errors.Wrap(err, "error when stopping API server")
@@ -415,11 +373,6 @@ func (cs *ChainService) IndexService() *indexservice.Server {
 	return cs.indexservice
 }
 
-// Explorer returns the explorer instance
-func (cs *ChainService) Explorer() *explorer.Server {
-	return cs.explorer
-}
-
 // RegisterProtocol register a protocol
 func (cs *ChainService) RegisterProtocol(id string, p protocol.Protocol) error {
 	if err := cs.registry.Register(id, p); err != nil {