X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?p=ric-plt%2Fresource-status-manager.git;a=blobdiff_plain;f=RSM%2Fservices%2Frnib_data_service_test.go;fp=RSM%2Fservices%2Frnib_data_service_test.go;h=ab0e47499e5e4ae35d961ba58436aef8b8358d1b;hp=2582c4f0e23b51f7b1c455f269f58be15d856886;hb=60652d98d51ee23c1eaca2e8bc2bf19c74c57658;hpb=b8d3ff3abf409da49ecab244cd6d2c2124dbce7c diff --git a/RSM/services/rnib_data_service_test.go b/RSM/services/rnib_data_service_test.go index 2582c4f..ab0e474 100644 --- a/RSM/services/rnib_data_service_test.go +++ b/RSM/services/rnib_data_service_test.go @@ -24,7 +24,6 @@ import ( "fmt" "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common" "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities" - "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/reader" "github.com/stretchr/testify/assert" "net" "rsm/configuration" @@ -50,15 +49,14 @@ func setupRnibDataServiceTestWithMaxAttempts(t *testing.T, maxAttempts int) (*rN } config.Rnib.MaxRnibConnectionAttempts = maxAttempts - readerMock := &mocks.RnibReaderMock{} - rnibReaderProvider := func() reader.RNibReader { - return readerMock - } + rnibReaderMock := &mocks.RnibReaderMock{} + rsmReaderMock := &mocks.RsmReaderMock{} + rsmWriterMock := &mocks.RsmWriterMock{} - rnibDataService := NewRnibDataService(logger, config, rnibReaderProvider) + rnibDataService := NewRnibDataService(logger, config, rnibReaderMock, rsmReaderMock, rsmWriterMock) assert.NotNil(t, rnibDataService) - return rnibDataService, readerMock + return rnibDataService, rnibReaderMock } func TestSuccessfulGetNodeb(t *testing.T) { @@ -84,7 +82,7 @@ func TestConnFailureGetNodeb(t *testing.T) { res, err := rnibDataService.GetNodeb(invName) readerMock.AssertNumberOfCalls(t, "GetNodeb", 3) - assert.True(t, strings.Contains(err.Error(), "connection error", )) + assert.True(t, strings.Contains(err.Error(), "connection error")) assert.Equal(t, nodeb, res) } @@ -109,7 +107,7 @@ func TestConnFailureGetNodebIdList(t *testing.T) { res, err := rnibDataService.GetListNodebIds() readerMock.AssertNumberOfCalls(t, "GetListNodebIds", 3) - assert.True(t, strings.Contains(err.Error(), "connection error", )) + assert.True(t, strings.Contains(err.Error(), "connection error")) assert.Equal(t, nodeIds, res) } @@ -125,12 +123,12 @@ func TestConnFailureTwiceGetNodebIdList(t *testing.T) { res, err := rnibDataService.GetListNodebIds() readerMock.AssertNumberOfCalls(t, "GetListNodebIds", 3) - assert.True(t, strings.Contains(err.Error(), "connection error", )) + assert.True(t, strings.Contains(err.Error(), "connection error")) assert.Equal(t, nodeIds, res) res2, err := rnibDataService.GetNodeb(invName) readerMock.AssertNumberOfCalls(t, "GetNodeb", 3) - assert.True(t, strings.Contains(err.Error(), "connection error", )) + assert.True(t, strings.Contains(err.Error(), "connection error")) assert.Equal(t, nodeb, res2) } @@ -143,7 +141,7 @@ func TestConnFailureWithAnotherConfig(t *testing.T) { res, err := rnibDataService.GetListNodebIds() readerMock.AssertNumberOfCalls(t, "GetListNodebIds", 5) - assert.True(t, strings.Contains(err.Error(), "connection error", )) + assert.True(t, strings.Contains(err.Error(), "connection error")) assert.Equal(t, nodeIds, res) } @@ -180,4 +178,4 @@ func TestPingRnibOkOtherError(t *testing.T) { res := rnibDataService.PingRnib() readerMock.AssertNumberOfCalls(t, "GetListNodebIds", 1) assert.True(t, res) -} +} \ No newline at end of file