Skip to content

Commit

Permalink
fixes after review
Browse files Browse the repository at this point in the history
  • Loading branch information
axenteoctavian committed Apr 15, 2024
1 parent 01443e4 commit 74a3d3f
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 6 deletions.
4 changes: 1 addition & 3 deletions cmd/sovereignnode/sovereignNodeRunner.go
Original file line number Diff line number Diff line change
Expand Up @@ -1681,8 +1681,6 @@ func (snr *sovereignNodeRunner) CreateArgsRunTypeComponents(coreComp mainFactory
return nil, err
}

topicsCheckerHandler := incomingHeader.NewTopicsChecker()

runTypeComponentsFactory, err := runType.NewRunTypeComponentsFactory(coreComp)
if err != nil {
return nil, fmt.Errorf("NewRunTypeComponentsFactory failed: %w", err)
Expand All @@ -1692,7 +1690,7 @@ func (snr *sovereignNodeRunner) CreateArgsRunTypeComponents(coreComp mainFactory
RunTypeComponentsFactory: runTypeComponentsFactory,
Config: *sovereignCfg,
DataCodec: dataDecoderHandler,
TopicsChecker: topicsCheckerHandler,
TopicsChecker: incomingHeader.NewTopicsChecker(),
}, nil
}

Expand Down
2 changes: 1 addition & 1 deletion factory/processing/processComponents.go
Original file line number Diff line number Diff line change
Expand Up @@ -2136,7 +2136,7 @@ func checkProcessComponentsArgs(args ProcessComponentsFactoryArgs) error {
if check.IfNil(args.RunTypeComponents.SCProcessorCreator()) {
return fmt.Errorf("%s: %w", baseErrMessage, errorsMx.ErrNilSCProcessorCreator)
}
// TODO make sure consensus model is correct on higher level
// TODO make sure consensus model is correct on higher level - task MX-15366
if args.RunTypeComponents.ConsensusModel() == consensus.ConsensusModelInvalid {
return fmt.Errorf("%s: %w", baseErrMessage, errorsMx.ErrInvalidConsensusModel)
}
Expand Down
2 changes: 1 addition & 1 deletion factory/runType/runTypeComponentsHandler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ func TestManagedRunTypeComponents_Create(t *testing.T) {
require.NotNil(t, managedRunTypeComponents.AdditionalStorageServiceCreator())
require.NotNil(t, managedRunTypeComponents.SCProcessorCreator())
require.NotNil(t, managedRunTypeComponents.SCResultsPreProcessorCreator())
require.NotEqual(t, consensus.ConsensusModelInvalid, managedRunTypeComponents.ConsensusModel())
require.Equal(t, consensus.ConsensusModelV1, managedRunTypeComponents.ConsensusModel())
require.NotNil(t, managedRunTypeComponents.VmContainerMetaFactoryCreator())
require.NotNil(t, managedRunTypeComponents.VmContainerShardFactoryCreator())
require.NotNil(t, managedRunTypeComponents.AccountsCreator())
Expand Down
2 changes: 1 addition & 1 deletion process/block/baseProcess_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -846,7 +846,7 @@ func TestCheckProcessorNilParameters(t *testing.T) {
}

func getRunTypeComponentsMock() *mock.RunTypeComponentsStub {
rt := components.GetRunTypeComponents()
rt := mock.NewRunTypeComponentsStub()
return &mock.RunTypeComponentsStub{
AccountCreator: rt.AccountsCreator(),
DataCodec: rt.DataDecoderHandler(),
Expand Down

0 comments on commit 74a3d3f

Please sign in to comment.