[chain_simulator] Enable http server option

node/chainSimulator/chainSimulator.go

@@ -31,6 +31,7 @@ func NewChainSimulator(
 	genesisTimestamp int64,
 	roundDurationInMillis uint64,
 	roundsPerEpoch core.OptionalUint64,
+	enableHttpServer bool,
 ) (*simulator, error) {
 	syncedBroadcastNetwork := components.NewSyncedBroadcastNetwork()
 
@@ -42,7 +43,7 @@ func NewChainSimulator(
 		chanStopNodeProcess:    make(chan endProcess.ArgEndProcess),
 	}
 
-	err := instance.createChainHandlers(tempDir, numOfShards, pathToInitialConfig, genesisTimestamp, roundDurationInMillis, roundsPerEpoch)
+	err := instance.createChainHandlers(tempDir, numOfShards, pathToInitialConfig, genesisTimestamp, roundDurationInMillis, roundsPerEpoch, enableHttpServer)
 	if err != nil {
 		return nil, err
 	}
@@ -57,6 +58,7 @@ func (s *simulator) createChainHandlers(
 	genesisTimestamp int64,
 	roundDurationInMillis uint64,
 	roundsPerEpoch core.OptionalUint64,
+	enableHttpServer bool,
 ) error {
 	outputConfigs, err := configs.CreateChainSimulatorConfigs(configs.ArgsChainSimulatorConfigs{
 		NumOfShards:               numOfShards,
@@ -76,7 +78,7 @@ func (s *simulator) createChainHandlers(
 	}
 
 	for idx := range outputConfigs.ValidatorsPrivateKeys {
-		node, errCreate := s.createTestNode(outputConfigs.Configs, idx, outputConfigs.GasScheduleFilename)
+		node, errCreate := s.createTestNode(outputConfigs.Configs, idx, outputConfigs.GasScheduleFilename, enableHttpServer)
 		if errCreate != nil {
 			return errCreate
 		}
@@ -106,8 +108,10 @@ func (s *simulator) createTestNode(
 	configs *config.Configs,
 	skIndex int,
 	gasScheduleFilename string,
+	enableHttpServer bool,
 ) (process.NodeHandler, error) {
 	args := components.ArgsTestOnlyProcessingNode{
+		Configs:                  *configs,
 		Config:                   *configs.GeneralConfig,
 		EpochConfig:              *configs.EpochConfig,
 		EconomicsConfig:          *configs.EconomicsConfig,
@@ -122,6 +126,7 @@ func (s *simulator) createTestNode(
 		NumShards:                s.numOfShards,
 		GasScheduleFilename:      gasScheduleFilename,
 		SkIndex:                  skIndex,
+		EnableHTTPServer:         enableHttpServer,
 	}
 
 	return components.NewTestOnlyProcessingNode(args)
@@ -161,6 +166,16 @@ func (s *simulator) GetNodeHandler(shardID uint32) process.NodeHandler {
 	return s.nodes[shardID]
 }
 
+// GetRestAPIInterfaces will return a map with the rest api interfaces for every node
+func (s *simulator) GetRestAPIInterfaces() map[uint32]string {
+	resMap := make(map[uint32]string)
+	for shardID, node := range s.nodes {
+		resMap[shardID] = node.GetFacadeHandler().RestApiInterface()
+	}
+
+	return resMap
+}
+
 // Close will stop and close the simulator
 func (s *simulator) Close() error {
 	var errorStrings []string

node/chainSimulator/chainSimulator_test.go

@@ -18,7 +18,7 @@ const (
 func TestNewChainSimulator(t *testing.T) {
 	startTime := time.Now().Unix()
 	roundDurationInMillis := uint64(6000)
-	chainSimulator, err := NewChainSimulator(t.TempDir(), 3, defaultPathToInitialConfig, startTime, roundDurationInMillis, core.OptionalUint64{})
+	chainSimulator, err := NewChainSimulator(t.TempDir(), 3, defaultPathToInitialConfig, startTime, roundDurationInMillis, core.OptionalUint64{}, false)
 	require.Nil(t, err)
 	require.NotNil(t, chainSimulator)
 
@@ -31,7 +31,7 @@ func TestNewChainSimulator(t *testing.T) {
 func TestChainSimulator_GenerateBlocksShouldWork(t *testing.T) {
 	startTime := time.Now().Unix()
 	roundDurationInMillis := uint64(6000)
-	chainSimulator, err := NewChainSimulator(t.TempDir(), 3, defaultPathToInitialConfig, startTime, roundDurationInMillis, core.OptionalUint64{})
+	chainSimulator, err := NewChainSimulator(t.TempDir(), 3, defaultPathToInitialConfig, startTime, roundDurationInMillis, core.OptionalUint64{}, false)
 	require.Nil(t, err)
 	require.NotNil(t, chainSimulator)
 
@@ -51,7 +51,7 @@ func TestChainSimulator_GenerateBlocksAndEpochChangeShouldWork(t *testing.T) {
 		HasValue: true,
 		Value:    20,
 	}
-	chainSimulator, err := NewChainSimulator(t.TempDir(), 3, defaultPathToInitialConfig, startTime, roundDurationInMillis, roundsPerEpoch)
+	chainSimulator, err := NewChainSimulator(t.TempDir(), 3, defaultPathToInitialConfig, startTime, roundDurationInMillis, roundsPerEpoch, false)
 	require.Nil(t, err)
 	require.NotNil(t, chainSimulator)
 
@@ -72,6 +72,8 @@ func TestChainSimulator_GenerateBlocksAndEpochChangeShouldWork(t *testing.T) {
 	assert.True(t, accountAfterRewards.GetBalance().Cmp(initialAccount.GetBalance()) > 0,
 		fmt.Sprintf("initial balance %s, balance after rewards %s", initialAccount.GetBalance().String(), accountAfterRewards.GetBalance().String()))
 
+	fmt.Println(chainSimulator.GetRestAPIInterfaces())
+
 	err = chainSimulator.Close()
 	assert.Nil(t, err)
 }

node/chainSimulator/components/bootstrapComponents.go

@@ -38,7 +38,7 @@ type bootstrapComponentsHolder struct {
 }
 
 // CreateBootstrapComponentHolder will create a new instance of bootstrap components holder
-func CreateBootstrapComponentHolder(args ArgsBootstrapComponentsHolder) (factory.BootstrapComponentsHolder, error) {
+func CreateBootstrapComponentHolder(args ArgsBootstrapComponentsHolder) (factory.BootstrapComponentsHandler, error) {
 	instance := &bootstrapComponentsHolder{
 		closeHandler: NewCloseHandler(),
 	}
@@ -137,3 +137,18 @@ func (b *bootstrapComponentsHolder) Close() error {
 func (b *bootstrapComponentsHolder) IsInterfaceNil() bool {
 	return b == nil
 }
+
+// Create will do nothing
+func (b *bootstrapComponentsHolder) Create() error {
+	return nil
+}
+
+// CheckSubcomponents will do nothing
+func (b *bootstrapComponentsHolder) CheckSubcomponents() error {
+	return nil
+}
+
+// String will do nothing
+func (b *bootstrapComponentsHolder) String() string {
+	return ""
+}

node/chainSimulator/components/coreComponents.go

@@ -90,7 +90,7 @@ type ArgsCoreComponentsHolder struct {
 }
 
 // CreateCoreComponentsHolder will create a new instance of factory.CoreComponentsHolder
-func CreateCoreComponentsHolder(args ArgsCoreComponentsHolder) (factory.CoreComponentsHolder, error) {
+func CreateCoreComponentsHolder(args ArgsCoreComponentsHolder) (factory.CoreComponentsHandler, error) {
 	var err error
 	instance := &coreComponentsHolder{
 		closeHandler: NewCloseHandler(),
@@ -433,3 +433,18 @@ func (c *coreComponentsHolder) Close() error {
 func (c *coreComponentsHolder) IsInterfaceNil() bool {
 	return c == nil
 }
+
+// Create will do nothing
+func (c *coreComponentsHolder) Create() error {
+	return nil
+}
+
+// CheckSubcomponents will do nothing
+func (c *coreComponentsHolder) CheckSubcomponents() error {
+	return nil
+}
+
+// String will do nothing
+func (c *coreComponentsHolder) String() string {
+	return ""
+}

node/chainSimulator/components/cryptoComponents.go

@@ -46,7 +46,7 @@ type cryptoComponentsHolder struct {
 }
 
 // CreateCryptoComponentsHolder will create a new instance of cryptoComponentsHolder
-func CreateCryptoComponentsHolder(args ArgsCryptoComponentsHolder) (factory.CryptoComponentsHolder, error) {
+func CreateCryptoComponentsHolder(args ArgsCryptoComponentsHolder) (factory.CryptoComponentsHandler, error) {
 	instance := &cryptoComponentsHolder{}
 
 	cryptoComponentsHandlerArgs := cryptoComp.CryptoComponentsFactoryArgs{
@@ -237,3 +237,23 @@ func (c *cryptoComponentsHolder) Clone() interface{} {
 func (c *cryptoComponentsHolder) IsInterfaceNil() bool {
 	return c == nil
 }
+
+// Create will do nothing
+func (c *cryptoComponentsHolder) Create() error {
+	return nil
+}
+
+// CheckSubcomponents will do nothing
+func (c *cryptoComponentsHolder) CheckSubcomponents() error {
+	return nil
+}
+
+// String will do nothing
+func (c *cryptoComponentsHolder) String() string {
+	return ""
+}
+
+// Close will do nothing
+func (c *cryptoComponentsHolder) Close() error {
+	return nil
+}

node/chainSimulator/components/dataComponents.go

@@ -25,7 +25,7 @@ type dataComponentsHolder struct {
 }
 
 // CreateDataComponentsHolder will create the data components holder
-func CreateDataComponentsHolder(args ArgsDataComponentsHolder) (factory.DataComponentsHolder, error) {
+func CreateDataComponentsHolder(args ArgsDataComponentsHolder) (factory.DataComponentsHandler, error) {
 	miniBlockStorer, err := args.StorageService.GetStorer(dataRetriever.MiniBlockUnit)
 	if err != nil {
 		return nil, err
@@ -106,3 +106,18 @@ func (d *dataComponentsHolder) Close() error {
 func (d *dataComponentsHolder) IsInterfaceNil() bool {
 	return d == nil
 }
+
+// Create will do nothing
+func (d *dataComponentsHolder) Create() error {
+	return nil
+}
+
+// CheckSubcomponents will do nothing
+func (d *dataComponentsHolder) CheckSubcomponents() error {
+	return nil
+}
+
+// String will do nothing
+func (d *dataComponentsHolder) String() string {
+	return ""
+}

node/chainSimulator/components/networkComponents.go

@@ -27,7 +27,7 @@ type networkComponentsHolder struct {
 }
 
 // CreateNetworkComponentsHolder creates a new networkComponentsHolder instance
-func CreateNetworkComponentsHolder(network SyncedBroadcastNetworkHandler) (*networkComponentsHolder, error) {
+func CreateNetworkComponentsHolder(network SyncedBroadcastNetworkHandler) (factory.NetworkComponentsHandler, error) {
 	messenger, err := NewSyncedMessenger(network)
 	if err != nil {
 		return nil, err
@@ -125,3 +125,18 @@ func (holder *networkComponentsHolder) Close() error {
 func (holder *networkComponentsHolder) IsInterfaceNil() bool {
 	return holder == nil
 }
+
+// Create will do nothing
+func (holder *networkComponentsHolder) Create() error {
+	return nil
+}
+
+// CheckSubcomponents will do nothing
+func (holder *networkComponentsHolder) CheckSubcomponents() error {
+	return nil
+}
+
+// String will do nothing
+func (holder *networkComponentsHolder) String() string {
+	return ""
+}