+ // Check no services published
+ result = testutil.NewRequest().Get("/"+apfId+"/service-apis").Go(t, requestHandler)
+ assert.Equal(t, http.StatusOK, result.Code())
+
+ // Parse JSON from the response body
+ var responseArray []publishapi.ServiceAPIDescription
+ err = result.UnmarshalJsonToObject(&responseArray)
+ assert.NoError(t, err, "error unmarshaling response")
+
+ // Check if the parsed array is empty
+ assert.Zero(t, len(responseArray))
+}
+
+func TestPostUnpublishedServiceWithUnregisteredFunction(t *testing.T) {
+ apfId := "apfId"
+ aefId := "aefId"
+ serviceRegisterMock := serviceMocks.ServiceRegister{}
+ serviceRegisterMock.On("GetAefsForPublisher", apfId).Return([]string{"otherAefId"})
+ serviceRegisterMock.On("IsPublishingFunctionRegistered", apfId).Return(true)
+ _, _, requestHandler := getEcho(&serviceRegisterMock, nil)
+
+ newServiceDescription := getServiceAPIDescription(aefId, "apiName", "description")
+
+ // Publish a service
+ result := testutil.NewRequest().Post("/"+apfId+"/service-apis").WithJsonBody(newServiceDescription).Go(t, requestHandler)
+
+ assert.Equal(t, http.StatusNotFound, result.Code())
+ var resultError common29122.ProblemDetails
+ err := result.UnmarshalJsonToObject(&resultError)
+ assert.NoError(t, err, "error unmarshaling response")
+ assert.Contains(t, *resultError.Cause, aefId)
+ assert.Contains(t, *resultError.Cause, "not registered")
+ assert.Equal(t, http.StatusNotFound, *resultError.Status)
+}
+
+func TestGetServices(t *testing.T) {
+ apfId := "apfId"
+ aefId := "aefId"
+ serviceRegisterMock := serviceMocks.ServiceRegister{}
+ serviceRegisterMock.On("GetAefsForPublisher", apfId).Return([]string{aefId})
+ serviceRegisterMock.On("IsPublishingFunctionRegistered", apfId).Return(true)
+ _, _, requestHandler := getEcho(&serviceRegisterMock, nil)
+
+ // Check no services published
+ var resultServices []publishapi.ServiceAPIDescription
+
+ result := testutil.NewRequest().Get("/"+apfId+"/service-apis").Go(t, requestHandler)
+ assert.Equal(t, http.StatusOK, result.Code())
+
+ // Parse JSON from the response body
+ err := result.UnmarshalJsonToObject(&resultServices)
+ assert.NoError(t, err, "error unmarshaling response")
+
+ // Check if the parsed array is empty
+ assert.Zero(t, len(resultServices))
+
+ serviceDescription1 := getServiceAPIDescription(aefId, "api1", "Description")
+ serviceDescription2 := getServiceAPIDescription(aefId, "api2", "Description")
+
+ // Publish a service for provider
+ testutil.NewRequest().Post("/"+apfId+"/service-apis").WithJsonBody(serviceDescription1).Go(t, requestHandler)
+ testutil.NewRequest().Post("/"+apfId+"/service-apis").WithJsonBody(serviceDescription2).Go(t, requestHandler)
+
+ // Get all services for provider
+ result = testutil.NewRequest().Get("/"+apfId+"/service-apis").Go(t, requestHandler)
+ assert.Equal(t, http.StatusOK, result.Code())
+
+ err = result.UnmarshalJsonToObject(&resultServices)
+ assert.NoError(t, err, "error unmarshaling response")
+
+ assert.Len(t, resultServices, 2)
+ apiId1 := "api_id_api1"
+ serviceDescription1.ApiId = &apiId1
+ apiId2 := "api_id_api2"
+ serviceDescription2.ApiId = &apiId2
+
+ assert.Contains(t, resultServices, serviceDescription1)
+ assert.Contains(t, resultServices, serviceDescription2)
+}
+
+func TestGetPublishedServices(t *testing.T) {
+ serviceUnderTest := NewPublishService(nil, nil, nil)
+
+ profiles := make([]publishapi.AefProfile, 1)
+ serviceDescription := publishapi.ServiceAPIDescription{
+ AefProfiles: &profiles,
+ }
+ serviceUnderTest.publishedServices["publisher1"] = []publishapi.ServiceAPIDescription{
+ serviceDescription,
+ }
+ serviceUnderTest.publishedServices["publisher2"] = []publishapi.ServiceAPIDescription{
+ serviceDescription,
+ }
+ result := serviceUnderTest.GetAllPublishedServices()
+ assert.Len(t, result, 2)
+}
+
+func TestGetAllowedServices(t *testing.T) {
+ serviceUnderTest := NewPublishService(nil, nil, nil)
+
+ aefProfiles1 := []publishapi.AefProfile{}
+ apiName1 := "api Name 1"
+ aefProfiles2 := []publishapi.AefProfile{}
+ apiName2 := "api Name 2"
+ aefProfiles3 := []publishapi.AefProfile{}
+ apiName3 := "api Name 3"
+ aefProfiles4 := []publishapi.AefProfile{}
+ apiName4 := "api Name 4"
+
+ serviceUnderTest.publishedServices["publisher1"] = []publishapi.ServiceAPIDescription{
+ {
+ ApiName: apiName1,
+ AefProfiles: &aefProfiles1,
+ },
+ {
+ ApiName: apiName2,
+ AefProfiles: &aefProfiles2,
+ },
+ {
+ ApiName: apiName3,
+ AefProfiles: &aefProfiles3,
+ },
+ {
+ ApiName: apiName4,
+ AefProfiles: &aefProfiles4,
+ },
+ }
+
+ serviceDescription := publishapi.ServiceAPIDescription{
+ ApiName: apiName4,
+ AefProfiles: &aefProfiles4,
+ }
+ serviceUnderTest.publishedServices["publisher2"] = []publishapi.ServiceAPIDescription{
+ serviceDescription,
+ }
+
+ allowedApiList := []publishapi.ServiceAPIDescription{
+ {
+ ApiName: apiName2,
+ AefProfiles: &aefProfiles2,
+ },
+ {
+ ApiName: apiName3,
+ AefProfiles: &aefProfiles3,
+ },
+ }
+
+ result := serviceUnderTest.GetAllowedPublishedServices(allowedApiList)
+ assert.Len(t, result, 2)
+
+ result = serviceUnderTest.GetAllowedPublishedServices(nil)
+ assert.Len(t, result, 0)
+
+ result = serviceUnderTest.GetAllowedPublishedServices([]publishapi.ServiceAPIDescription{})
+ assert.Len(t, result, 0)
+
+ // Create a list with no ApiNames
+ badApiList := []publishapi.ServiceAPIDescription{
+ {
+ },
+ {
+ },
+ }
+ result = serviceUnderTest.GetAllowedPublishedServices(badApiList)
+ assert.Len(t, result, 0)
+}
+
+func TestUpdateDescription(t *testing.T) {
+ apfId := "apfId"
+ serviceApiId := "serviceApiId"
+ aefId := "aefId"
+ apiName := "apiName"
+ description := "description"
+
+ serviceRegisterMock := serviceMocks.ServiceRegister{}
+ serviceRegisterMock.On("GetAefsForPublisher", apfId).Return([]string{aefId, "otherAefId", "aefIdNew"})
+ serviceRegisterMock.On("IsPublishingFunctionRegistered", apfId).Return(true)
+ helmManagerMock := helmMocks.HelmManager{}
+ helmManagerMock.On("InstallHelmChart", mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(nil)
+ serviceUnderTest, eventChannel, requestHandler := getEcho(&serviceRegisterMock, &helmManagerMock)
+ serviceDescription := getServiceAPIDescription(aefId, apiName, description)
+ serviceDescription.ApiId = &serviceApiId
+ serviceUnderTest.publishedServices[apfId] = []publishapi.ServiceAPIDescription{serviceDescription}
+ (*serviceDescription.AefProfiles)[0].AefId = aefId
+
+ //Modify the service
+ updatedServiceDescription := getServiceAPIDescription(aefId, apiName, description)
+ updatedServiceDescription.ApiId = &serviceApiId
+ (*updatedServiceDescription.AefProfiles)[0].AefId = aefId
+ newDescription := "new description"
+ updatedServiceDescription.Description = &newDescription
+ newDomainName := "new domainName"
+ (*updatedServiceDescription.AefProfiles)[0].DomainName = &newDomainName
+
+ newProfileDomain := "new profile Domain name"