X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=E2Manager%2Fclients%2Frouting_manager_client_test.go;h=31a4c7f65aef0b7c5fbe4e18266a53d51708e8c3;hb=e5480be0d39eb6a49a6f021a27665ef447523145;hp=bf5f82c41c6e21e2520c48fbc4141d2a3abaa6c1;hpb=a75da9a56d61ca4754650d44a54bbf0b04f610d1;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/clients/routing_manager_client_test.go b/E2Manager/clients/routing_manager_client_test.go index bf5f82c..31a4c7f 100644 --- a/E2Manager/clients/routing_manager_client_test.go +++ b/E2Manager/clients/routing_manager_client_test.go @@ -63,7 +63,7 @@ func TestDeleteE2TInstanceSuccess(t *testing.T) { func TestDeleteE2TInstanceFailure(t *testing.T) { rmClient, httpClientMock, config := initRoutingManagerClientTest(t) - data := models.NewRoutingManagerDeleteRequestModel(E2TAddress, []string{"test1"},nil) + data := models.NewRoutingManagerDeleteRequestModel(E2TAddress, []string{"test1"}, nil) marshaled, _ := json.Marshal(data) body := bytes.NewBuffer(marshaled) url := config.RoutingManager.BaseUrl + "e2t" @@ -76,7 +76,7 @@ func TestDeleteE2TInstanceFailure(t *testing.T) { func TestDeleteE2TInstanceDeleteFailure(t *testing.T) { rmClient, httpClientMock, config := initRoutingManagerClientTest(t) - data := models.NewRoutingManagerDeleteRequestModel(E2TAddress, []string{"test1"},nil) + data := models.NewRoutingManagerDeleteRequestModel(E2TAddress, []string{"test1"}, nil) marshaled, _ := json.Marshal(data) body := bytes.NewBuffer(marshaled) url := config.RoutingManager.BaseUrl + "e2t" @@ -199,9 +199,57 @@ func TestDissociateRanE2TInstance_RoutingManager_400(t *testing.T) { assert.IsType(t, &e2managererrors.RoutingManagerError{}, err) } +func TestDissociateAllRans_Success(t *testing.T) { + rmClient, httpClientMock, config := initRoutingManagerClientTest(t) + + data := models.RoutingManagerE2TDataList{ + models.NewRoutingManagerE2TData(E2TAddress), + models.NewRoutingManagerE2TData(E2TAddress2), + } + marshaled, _ := json.Marshal(data) + body := bytes.NewBuffer(marshaled) + url := config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix + respBody := ioutil.NopCloser(bytes.NewBufferString("")) + httpClientMock.On("Post", url, "application/json", body).Return(&http.Response{StatusCode: http.StatusCreated, Body: respBody}, nil) + err := rmClient.DissociateAllRans([]string{E2TAddress, E2TAddress2}) + assert.Nil(t, err) +} + +func TestDissociateAllRans_RoutingManagerError(t *testing.T) { + rmClient, httpClientMock, config := initRoutingManagerClientTest(t) + + data := models.RoutingManagerE2TDataList{ + models.NewRoutingManagerE2TData(E2TAddress), + models.NewRoutingManagerE2TData(E2TAddress2), + } + marshaled, _ := json.Marshal(data) + body := bytes.NewBuffer(marshaled) + url := config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix + httpClientMock.On("Post", url, "application/json", body).Return(&http.Response{}, errors.New("error")) + err := rmClient.DissociateAllRans([]string{E2TAddress, E2TAddress2}) + assert.IsType(t, &e2managererrors.RoutingManagerError{}, err) +} + +func TestDissociateAllRans_RoutingManager_400(t *testing.T) { + rmClient, httpClientMock, config := initRoutingManagerClientTest(t) + + data := models.RoutingManagerE2TDataList{ + models.NewRoutingManagerE2TData(E2TAddress), + models.NewRoutingManagerE2TData(E2TAddress2), + } + marshaled, _ := json.Marshal(data) + body := bytes.NewBuffer(marshaled) + url := config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix + respBody := ioutil.NopCloser(bytes.NewBufferString("")) + httpClientMock.On("Post", url, "application/json", body).Return(&http.Response{StatusCode: http.StatusBadRequest, Body: respBody}, nil) + err := rmClient.DissociateAllRans([]string{E2TAddress, E2TAddress2}) + assert.IsType(t, &e2managererrors.RoutingManagerError{}, err) +} + // TODO: extract to test_utils func initLog(t *testing.T) *logger.Logger { - log, err := logger.InitLogger(logger.InfoLevel) + level := int8(1) + log, err := logger.InitLogger(level) if err != nil { t.Errorf("#delete_all_request_handler_test.TestHandleSuccessFlow - failed to initialize logger, error: %s", err) }