Copy latest code to master

[ric-plt/resource-status-manager.git] / RSM / controllers / controller_test.go

diff --git a/RSM/controllers/controller_test.go b/RSM/controllers/controller_test.go
index cc27b3c..db5462e 100644 (file)
--- a/RSM/controllers/controller_test.go
+++ b/RSM/controllers/controller_test.go
@@ -20,37 +20,129 @@
 
 package controllers
 
-/*
 import (
        "encoding/json"
        "fmt"
+       "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
        "github.com/stretchr/testify/assert"
+       "github.com/stretchr/testify/mock"
        "io"
        "io/ioutil"
        "net/http"
        "net/http/httptest"
        "rsm/configuration"
+       "rsm/enums"
+       "rsm/logger"
        "rsm/mocks"
        "rsm/models"
        "rsm/providers/httpmsghandlerprovider"
        "rsm/rsmerrors"
-       "rsm/tests/testhelper"
+       "rsm/services"
+       "rsm/tests"
+       "strings"
        "testing"
 )
 
-func setupControllerTest(t *testing.T) (*Controller, *mocks.RnibReaderMock, *mocks.RmrMessengerMock) {
-       config := configuration.ParseConfiguration()
+func setupControllerTest(t *testing.T) (*Controller, *mocks.RnibReaderMock, *mocks.RsmReaderMock, *mocks.RsmWriterMock, *mocks.ResourceStatusServiceMock) {
+       log, err := logger.InitLogger(logger.DebugLevel)
+       if err != nil {
+               t.Errorf("#... - failed to initialize logger, error: %s", err)
+       }
 
-       rmrMessengerMock := &mocks.RmrMessengerMock{}
-       readerMock := &mocks.RnibReaderMock{}
-       rnibDataService, rmrSender, log := testhelper.InitTestCase(t)
-       handlerProvider := httpmsghandlerprovider.NewRequestHandlerProvider(log, rmrSender, config, rnibDataService)
+       config, err := configuration.ParseConfiguration()
+       if err != nil {
+               t.Errorf("#... - failed to parse configuration error: %s", err)
+       }
+
+       resourceStatusServiceMock := &mocks.ResourceStatusServiceMock{}
+       rnibReaderMock := &mocks.RnibReaderMock{}
+       rsmReaderMock := &mocks.RsmReaderMock{}
+       rsmWriterMock := &mocks.RsmWriterMock{}
+
+       rnibDataService := services.NewRnibDataService(log, config, rnibReaderMock, rsmReaderMock, rsmWriterMock)
+       handlerProvider := httpmsghandlerprovider.NewRequestHandlerProvider(log, rnibDataService, resourceStatusServiceMock)
        controller := NewController(log, handlerProvider)
-       return controller, readerMock, rmrMessengerMock
+       return controller, rnibReaderMock, rsmReaderMock, rsmWriterMock, resourceStatusServiceMock
+}
+
+func TestResourceStatusInvalidBody(t *testing.T) {
+       controller, _, _, _ , _:= setupControllerTest(t)
+
+       header := http.Header{}
+       header.Set("Content-Type", "application/json")
+       httpRequest, _ := http.NewRequest("PUT", "http://localhost:4800/v1/general/resourcestatus", strings.NewReader("{}{}"))
+       httpRequest.Header = header
+
+       writer := httptest.NewRecorder()
+       controller.ResourceStatus(writer, httpRequest)
+
+       var errorResponse = parseJsonRequest(t, writer.Body)
+
+       assert.Equal(t, http.StatusBadRequest, writer.Result().StatusCode)
+       assert.Equal(t, rsmerrors.NewInvalidJsonError().Code, errorResponse.Code)
+}
+
+func TestResourceStatusSuccess(t *testing.T) {
+       controller, readerMock, rsmReaderMock, rsmWriterMock,  resourceStatusServiceMock := setupControllerTest(t)
+
+       cellId1 := "02f829:0007ab00"
+       cellId2 := "02f829:0007ab50"
+       nodebInfo := &entities.NodebInfo{
+               RanName:         tests.RanName,
+               ConnectionStatus: entities.ConnectionStatus_CONNECTED,
+               Configuration: &entities.NodebInfo_Enb{
+                       Enb: &entities.Enb{
+                               ServedCells: []*entities.ServedCellInfo{{CellId: cellId1}, {CellId: cellId2}},
+                       },
+               },
+       }
+       var nbIdentityList []*entities.NbIdentity
+       config := tests.GetRsmGeneralConfiguration(true)
+
+       rsmWriterMock.On("SaveRsmGeneralConfiguration", config).Return(nil)
+       rsmReaderMock.On("GetRsmGeneralConfiguration").Return(config, nil)
+       readerMock.On("GetListEnbIds").Return(nbIdentityList, nil)
+       readerMock.On("GetNodeb", tests.RanName).Return(nodebInfo)
+       resourceStatusServiceMock.On("BuildAndSendInitiateRequest", mock.AnythingOfType("*entities.NodebInfo"), mock.AnythingOfType("*models.RsmGeneralConfiguration"), enums.Enb1MeasurementId).Return(nil)
+
+       header := http.Header{}
+       header.Set("Content-Type", "application/json")
+       httpRequest, _ := http.NewRequest("PUT", "http://localhost:4800/v1/general/resourcestatus", strings.NewReader("{\"enableResourceStatus\":true}"))
+       httpRequest.Header = header
+
+       writer := httptest.NewRecorder()
+       controller.ResourceStatus(writer, httpRequest)
+
+       readerMock.AssertNumberOfCalls(t, "GetListEnbIds", 1)
+       resourceStatusServiceMock.AssertNumberOfCalls(t, "BuildAndSendInitiateRequest", 0)
+
+       assert.Equal(t, http.StatusNoContent, writer.Result().StatusCode)
+}
+
+func TestResourceStatusFail(t *testing.T) {
+
+       controller, readerMock, rsmReaderMock, _,  resourceStatusServiceMock := setupControllerTest(t)
+
+       rnibErr := &rsmerrors.RnibDbError{}
+
+       rsmReaderMock.On("GetRsmGeneralConfiguration").Return(tests.GetRsmGeneralConfiguration(true), rnibErr)
+
+       header := http.Header{}
+       header.Set("Content-Type", "application/json")
+       httpRequest, _ := http.NewRequest("PUT", "http://localhost:4800/v1/general/resourcestatus", strings.NewReader("{\"enableResourceStatus\":true}"))
+       httpRequest.Header = header
+
+       writer := httptest.NewRecorder()
+       controller.ResourceStatus(writer, httpRequest)
+
+       readerMock.AssertNumberOfCalls(t, "GetListEnbIds", 0)
+       resourceStatusServiceMock.AssertNumberOfCalls(t, "BuildAndSendInitiateRequest", 0)
+
+       assert.Equal(t, http.StatusInternalServerError, writer.Result().StatusCode)
 }
 
 func TestHeaderValidationFailed(t *testing.T) {
-       controller, _, _ := setupControllerTest(t)
+       controller, _, _ ,_ , _:= setupControllerTest(t)
 
        writer := httptest.NewRecorder()
        header := &http.Header{}
@@ -62,9 +154,9 @@ func TestHeaderValidationFailed(t *testing.T) {
        assert.Equal(t, errorResponse.Code, err.Code)
        assert.Equal(t, errorResponse.Message, err.Message)
 }
-*/
-/*func TestHandleInternalError(t *testing.T) {
-       controller, _, _ := setupControllerTest(t)
+
+func TestHandleInternalError(t *testing.T) {
+       controller, _, _,_ ,_ := setupControllerTest(t)
 
        writer := httptest.NewRecorder()
        err := rsmerrors.NewInternalError()
@@ -75,10 +167,10 @@ func TestHeaderValidationFailed(t *testing.T) {
        assert.Equal(t, http.StatusInternalServerError, writer.Result().StatusCode)
        assert.Equal(t, errorResponse.Code, err.Code)
        assert.Equal(t, errorResponse.Message, err.Message)
-}*/
+}
 
-/*func TestValidateHeadersSuccess(t *testing.T) {
-       controller, _, _ := setupControllerTest(t)
+func TestValidateHeadersSuccess(t *testing.T) {
+       controller, _, _,_ ,_ := setupControllerTest(t)
 
        header := http.Header{}
        header.Set("Content-Type", "application/json")
@@ -86,8 +178,8 @@ func TestHeaderValidationFailed(t *testing.T) {
 
        assert.Nil(t, result)
 }
-*/
-/*func parseJsonRequest(t *testing.T, r io.Reader) models.ErrorResponse {
+
+func parseJsonRequest(t *testing.T, r io.Reader) models.ErrorResponse {
 
        var errorResponse models.ErrorResponse
        body, err := ioutil.ReadAll(r)
@@ -97,10 +189,10 @@ func TestHeaderValidationFailed(t *testing.T) {
        json.Unmarshal(body, &errorResponse)
 
        return errorResponse
-}*/
-/*
+}
+
 func TestHandleErrorResponse(t *testing.T) {
-       controller, _, _ := setupControllerTest(t)
+       controller, _, _ ,_ , _:= setupControllerTest(t)
 
        writer := httptest.NewRecorder()
        controller.handleErrorResponse(rsmerrors.NewRnibDbError(), writer)
@@ -133,5 +225,8 @@ func TestHandleErrorResponse(t *testing.T) {
        writer = httptest.NewRecorder()
        controller.handleErrorResponse(fmt.Errorf("ErrorError"), writer)
        assert.Equal(t, http.StatusInternalServerError, writer.Result().StatusCode)
-}
-*/
\ No newline at end of file
+
+       writer = httptest.NewRecorder()
+       controller.handleErrorResponse(rsmerrors.NewRsmError(2), writer)
+       assert.Equal(t, http.StatusInternalServerError, writer.Result().StatusCode)
+}
\ No newline at end of file