Merge pull request #5971 from multiversx/more_chainSimulator_tests

More chain simulator tests

node/chainSimulator/components/bootstrapComponents.go

@@ -39,7 +39,7 @@ type bootstrapComponentsHolder struct {
 }
 
 // CreateBootstrapComponents will create a new instance of bootstrap components holder
-func CreateBootstrapComponents(args ArgsBootstrapComponentsHolder) (factory.BootstrapComponentsHandler, error) {
+func CreateBootstrapComponents(args ArgsBootstrapComponentsHolder) (*bootstrapComponentsHolder, error) {
 	instance := &bootstrapComponentsHolder{
 		closeHandler: NewCloseHandler(),
 	}

node/chainSimulator/components/bootstrapComponents_test.go

@@ -0,0 +1,193 @@
+package components
+
+import (
+	"testing"
+
+	"github.com/multiversx/mx-chain-core-go/core"
+	"github.com/multiversx/mx-chain-core-go/data/typeConverters"
+	"github.com/multiversx/mx-chain-core-go/hashing"
+	"github.com/multiversx/mx-chain-core-go/marshal"
+	"github.com/multiversx/mx-chain-go/config"
+	"github.com/multiversx/mx-chain-go/consensus"
+	"github.com/multiversx/mx-chain-go/integrationTests/mock"
+	"github.com/multiversx/mx-chain-go/process"
+	"github.com/multiversx/mx-chain-go/sharding"
+	"github.com/multiversx/mx-chain-go/sharding/nodesCoordinator"
+	"github.com/multiversx/mx-chain-go/storage"
+	"github.com/multiversx/mx-chain-go/testscommon"
+	"github.com/multiversx/mx-chain-go/testscommon/cryptoMocks"
+	"github.com/multiversx/mx-chain-go/testscommon/economicsmocks"
+	"github.com/multiversx/mx-chain-go/testscommon/epochNotifier"
+	"github.com/multiversx/mx-chain-go/testscommon/factory"
+	"github.com/multiversx/mx-chain-go/testscommon/p2pmocks"
+	"github.com/multiversx/mx-chain-go/testscommon/shardingMocks"
+	"github.com/multiversx/mx-chain-go/testscommon/statusHandler"
+	"github.com/stretchr/testify/require"
+)
+
+func createArgsBootstrapComponentsHolder() ArgsBootstrapComponentsHolder {
+	return ArgsBootstrapComponentsHolder{
+		CoreComponents: &factory.CoreComponentsHolderStub{
+			ChainIDCalled: func() string {
+				return "T"
+			},
+			GenesisNodesSetupCalled: func() sharding.GenesisNodesSetupHandler {
+				return &testscommon.NodesSetupStub{}
+			},
+			InternalMarshalizerCalled: func() marshal.Marshalizer {
+				return &testscommon.MarshallerStub{}
+			},
+			EpochNotifierCalled: func() process.EpochNotifier {
+				return &epochNotifier.EpochNotifierStub{}
+			},
+			EconomicsDataCalled: func() process.EconomicsDataHandler {
+				return &economicsmocks.EconomicsHandlerMock{}
+			},
+			RaterCalled: func() sharding.PeerAccountListAndRatingHandler {
+				return &testscommon.RaterMock{}
+			},
+			NodesShufflerCalled: func() nodesCoordinator.NodesShuffler {
+				return &shardingMocks.NodeShufflerMock{}
+			},
+			RoundHandlerCalled: func() consensus.RoundHandler {
+				return &testscommon.RoundHandlerMock{}
+			},
+			HasherCalled: func() hashing.Hasher {
+				return &testscommon.HasherStub{}
+			},
+			PathHandlerCalled: func() storage.PathManagerHandler {
+				return &testscommon.PathManagerStub{}
+			},
+			TxMarshalizerCalled: func() marshal.Marshalizer {
+				return &testscommon.MarshallerStub{}
+			},
+			AddressPubKeyConverterCalled: func() core.PubkeyConverter {
+				return &testscommon.PubkeyConverterStub{}
+			},
+			Uint64ByteSliceConverterCalled: func() typeConverters.Uint64ByteSliceConverter {
+				return &mock.Uint64ByteSliceConverterMock{}
+			},
+			TxSignHasherCalled: func() hashing.Hasher {
+				return &testscommon.HasherStub{}
+			},
+		},
+		CryptoComponents: &mock.CryptoComponentsStub{
+			PubKey:                  &mock.PublicKeyMock{},
+			BlockSig:                &cryptoMocks.SingleSignerStub{},
+			BlKeyGen:                &cryptoMocks.KeyGenStub{},
+			TxSig:                   &cryptoMocks.SingleSignerStub{},
+			TxKeyGen:                &cryptoMocks.KeyGenStub{},
+			ManagedPeersHolderField: &testscommon.ManagedPeersHolderStub{},
+		},
+		NetworkComponents: &mock.NetworkComponentsStub{
+			Messenger:                        &p2pmocks.MessengerStub{},
+			FullArchiveNetworkMessengerField: &p2pmocks.MessengerStub{},
+		},
+		StatusCoreComponents: &factory.StatusCoreComponentsStub{
+			TrieSyncStatisticsField: &testscommon.SizeSyncStatisticsHandlerStub{},
+			AppStatusHandlerField:   &statusHandler.AppStatusHandlerStub{},
+			StateStatsHandlerField:  &testscommon.StateStatisticsHandlerStub{},
+		},
+		WorkingDir:     ".",
+		FlagsConfig:    config.ContextFlagsConfig{},
+		ImportDBConfig: config.ImportDbConfig{},
+		PrefsConfig:    config.Preferences{},
+		Config: config.Config{
+			EpochStartConfig: config.EpochStartConfig{
+				MinNumConnectedPeersToStart:       1,
+				MinNumOfPeersToConsiderBlockValid: 1,
+			},
+			TrieSync: config.TrieSyncConfig{
+				MaxHardCapForMissingNodes: 1,
+				NumConcurrentTrieSyncers:  1,
+			},
+			GeneralSettings: config.GeneralSettingsConfig{
+				SetGuardianEpochsDelay: 1,
+			},
+			Versions: config.VersionsConfig{
+				Cache: config.CacheConfig{
+					Type:     "LRU",
+					Capacity: 123,
+				},
+				DefaultVersion: "1",
+				VersionsByEpochs: []config.VersionByEpochs{
+					{
+						StartEpoch: 0,
+						Version:    "1",
+					},
+				},
+			},
+			WhiteListPool: config.CacheConfig{
+				Type:     "LRU",
+				Capacity: 123,
+			},
+		},
+		ShardIDStr: "0",
+	}
+}
+
+func TestCreateBootstrapComponents(t *testing.T) {
+	t.Parallel()
+
+	t.Run("should work", func(t *testing.T) {
+		t.Parallel()
+
+		comp, err := CreateBootstrapComponents(createArgsBootstrapComponentsHolder())
+		require.NoError(t, err)
+		require.NotNil(t, comp)
+
+		require.Nil(t, comp.Create())
+		require.Nil(t, comp.Close())
+	})
+	t.Run("NewBootstrapComponentsFactory failure should error", func(t *testing.T) {
+		t.Parallel()
+
+		args := createArgsBootstrapComponentsHolder()
+		args.StatusCoreComponents = &factory.StatusCoreComponentsStub{}
+		comp, err := CreateBootstrapComponents(args)
+		require.Error(t, err)
+		require.Nil(t, comp)
+	})
+	t.Run("managedBootstrapCreate failure should error", func(t *testing.T) {
+		t.Parallel()
+
+		args := createArgsBootstrapComponentsHolder()
+		args.StatusCoreComponents = &factory.StatusCoreComponentsStub{
+			TrieSyncStatisticsField: &testscommon.SizeSyncStatisticsHandlerStub{},
+			AppStatusHandlerField:   &statusHandler.AppStatusHandlerStub{},
+		}
+		comp, err := CreateBootstrapComponents(args)
+		require.Error(t, err)
+		require.Nil(t, comp)
+	})
+}
+
+func TestBootstrapComponentsHolder_IsInterfaceNil(t *testing.T) {
+	t.Parallel()
+
+	var comp *bootstrapComponentsHolder
+	require.True(t, comp.IsInterfaceNil())
+
+	comp, _ = CreateBootstrapComponents(createArgsBootstrapComponentsHolder())
+	require.False(t, comp.IsInterfaceNil())
+	require.Nil(t, comp.Close())
+}
+
+func TestBootstrapComponentsHolder_Getters(t *testing.T) {
+	t.Parallel()
+
+	comp, err := CreateBootstrapComponents(createArgsBootstrapComponentsHolder())
+	require.NoError(t, err)
+
+	require.NotNil(t, comp.EpochStartBootstrapper())
+	require.NotNil(t, comp.EpochBootstrapParams())
+	require.NotEmpty(t, comp.NodeType())
+	require.NotNil(t, comp.ShardCoordinator())
+	require.NotNil(t, comp.VersionedHeaderFactory())
+	require.NotNil(t, comp.HeaderVersionHandler())
+	require.NotNil(t, comp.HeaderIntegrityVerifier())
+	require.NotNil(t, comp.GuardedAccountHandler())
+	require.Nil(t, comp.CheckSubcomponents())
+	require.Empty(t, comp.String())
+	require.Nil(t, comp.Close())
+}

node/chainSimulator/components/coreComponents.go

@@ -93,7 +93,7 @@ type ArgsCoreComponentsHolder struct {
 }
 
 // CreateCoreComponents will create a new instance of factory.CoreComponentsHolder
-func CreateCoreComponents(args ArgsCoreComponentsHolder) (factory.CoreComponentsHandler, error) {
+func CreateCoreComponents(args ArgsCoreComponentsHolder) (*coreComponentsHolder, error) {
 	var err error
 	instance := &coreComponentsHolder{
 		closeHandler: NewCloseHandler(),