X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=capifcore%2Finternal%2Fprovidermanagement%2Fprovidermanagement_test.go;fp=capifcore%2Finternal%2Fprovidermanagement%2Fprovidermanagement_test.go;h=06919e5e2db2483ef40695b21c04b0090a522ec7;hb=c9e08b2a2f647f9f870040570c5e71305f0fb5d2;hp=0000000000000000000000000000000000000000;hpb=8fcfa4ecde6d95ead33c34b0e7efc4933ad44444;p=nonrtric%2Fplt%2Fsme.git

diff --git a/capifcore/internal/providermanagement/providermanagement_test.go b/capifcore/internal/providermanagement/providermanagement_test.go
new file mode 100644
index 0000000..06919e5
--- /dev/null
+++ b/capifcore/internal/providermanagement/providermanagement_test.go
@@ -0,0 +1,147 @@
+// -
+//   ========================LICENSE_START=================================
+//   O-RAN-SC
+//   %%
+//   Copyright (C) 2022: Nordix Foundation
+//   %%
+//   Licensed under the Apache License, Version 2.0 (the "License");
+//   you may not use this file except in compliance with the License.
+//   You may obtain a copy of the License at
+//
+//        http://www.apache.org/licenses/LICENSE-2.0
+//
+//   Unless required by applicable law or agreed to in writing, software
+//   distributed under the License is distributed on an "AS IS" BASIS,
+//   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//   See the License for the specific language governing permissions and
+//   limitations under the License.
+//   ========================LICENSE_END===================================
+//
+
+package providermanagement
+
+import (
+	"fmt"
+	"net/http"
+	"os"
+	"testing"
+
+	"github.com/labstack/echo/v4"
+
+	"oransc.org/nonrtric/capifcore/internal/common29122"
+	provapi "oransc.org/nonrtric/capifcore/internal/providermanagementapi"
+
+	"github.com/deepmap/oapi-codegen/pkg/middleware"
+	"github.com/deepmap/oapi-codegen/pkg/testutil"
+	echomiddleware "github.com/labstack/echo/v4/middleware"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestProviderHandlingSuccessfully(t *testing.T) {
+	managerUnderTest, requestHandler := getEcho()
+
+	domainInfo := "rApp domain"
+	funcInfoAPF := "rApp as APF"
+	funcInfoAMF := "rApp as AMF"
+	funcInfoAEF := "rApp as AEF"
+	testFuncs := []provapi.APIProviderFunctionDetails{
+		{
+			ApiProvFuncInfo: &funcInfoAPF,
+			ApiProvFuncRole: provapi.ApiProviderFuncRoleAPF,
+		},
+		{
+			ApiProvFuncInfo: &funcInfoAMF,
+			ApiProvFuncRole: provapi.ApiProviderFuncRoleAMF,
+		},
+		{
+			ApiProvFuncInfo: &funcInfoAEF,
+			ApiProvFuncRole: provapi.ApiProviderFuncRoleAEF,
+		},
+	}
+	newProvider := provapi.APIProviderEnrolmentDetails{
+		ApiProvDomInfo: &domainInfo,
+		ApiProvFuncs:   &testFuncs,
+	}
+
+	// Register a valid provider
+	result := testutil.NewRequest().Post("/registrations").WithJsonBody(newProvider).Go(t, requestHandler)
+
+	domainID := "domain_id_rApp_domain"
+	funcIdAPF := "APF_id_rApp_as_APF"
+	funcIdAMF := "AMF_id_rApp_as_AMF"
+	funcIdAEF := "AEF_id_rApp_as_AEF"
+	assert.Equal(t, http.StatusCreated, result.Code())
+	var resultProvider provapi.APIProviderEnrolmentDetails
+	err := result.UnmarshalBodyToObject(&resultProvider)
+	assert.NoError(t, err, "error unmarshaling response")
+	assert.Equal(t, *resultProvider.ApiProvDomId, domainID)
+	assert.Equal(t, *(*resultProvider.ApiProvFuncs)[0].ApiProvFuncId, funcIdAPF)
+	assert.Equal(t, *(*resultProvider.ApiProvFuncs)[1].ApiProvFuncId, funcIdAMF)
+	assert.Equal(t, *(*resultProvider.ApiProvFuncs)[2].ApiProvFuncId, funcIdAEF)
+	assert.Empty(t, resultProvider.FailReason)
+	assert.Equal(t, "http://example.com/registrations/"+*resultProvider.ApiProvDomId, result.Recorder.Header().Get(echo.HeaderLocation))
+	assert.True(t, managerUnderTest.IsFunctionRegistered("APF_id_rApp_as_APF"))
+
+	// Update the provider
+	newProvider.ApiProvDomId = &domainID
+	(*newProvider.ApiProvFuncs)[0].ApiProvFuncId = &funcIdAPF
+	(*newProvider.ApiProvFuncs)[1].ApiProvFuncId = &funcIdAMF
+	(*newProvider.ApiProvFuncs)[2].ApiProvFuncId = &funcIdAEF
+	newFuncInfoAEF := "new func as AEF"
+	testFuncs = append(testFuncs, provapi.APIProviderFunctionDetails{
+		ApiProvFuncInfo: &newFuncInfoAEF,
+		ApiProvFuncRole: "AEF",
+	})
+
+	result = testutil.NewRequest().Put("/registrations/"+domainID).WithJsonBody(newProvider).Go(t, requestHandler)
+
+	assert.Equal(t, http.StatusOK, result.Code())
+	err = result.UnmarshalBodyToObject(&resultProvider)
+	assert.NoError(t, err, "error unmarshaling response")
+	assert.Equal(t, *(*resultProvider.ApiProvFuncs)[3].ApiProvFuncId, "AEF_id_new_func_as_AEF")
+	assert.Empty(t, resultProvider.FailReason)
+	assert.True(t, managerUnderTest.IsFunctionRegistered("AEF_id_new_func_as_AEF"))
+
+	// Delete the provider
+	result = testutil.NewRequest().Delete("/registrations/"+*resultProvider.ApiProvDomId).Go(t, requestHandler)
+
+	assert.Equal(t, http.StatusNoContent, result.Code())
+	assert.False(t, managerUnderTest.IsFunctionRegistered("APF_id_rApp_as_APF"))
+}
+
+func TestProviderHandlingValidation(t *testing.T) {
+	_, requestHandler := getEcho()
+
+	newProvider := provapi.APIProviderEnrolmentDetails{}
+
+	// Register a valid provider
+	result := testutil.NewRequest().Post("/registrations").WithJsonBody(newProvider).Go(t, requestHandler)
+
+	assert.Equal(t, http.StatusBadRequest, result.Code())
+	var problemDetails common29122.ProblemDetails
+	err := result.UnmarshalBodyToObject(&problemDetails)
+	assert.NoError(t, err, "error unmarshaling response")
+	badRequest := 400
+	assert.Equal(t, &badRequest, problemDetails.Status)
+	errMsg := "Provider missing required ApiProvDomInfo"
+	assert.Equal(t, &errMsg, problemDetails.Cause)
+}
+
+func getEcho() (*ProviderManager, *echo.Echo) {
+	swagger, err := provapi.GetSwagger()
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Error loading swagger spec\n: %s", err)
+		os.Exit(1)
+	}
+
+	swagger.Servers = nil
+
+	pm := NewProviderManager()
+
+	e := echo.New()
+	e.Use(echomiddleware.Logger())
+	e.Use(middleware.OapiRequestValidator(swagger))
+
+	provapi.RegisterHandlers(e, pm)
+	return pm, e
+}