X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=capifcore%2Finternal%2Finvokermanagement%2Finvokermanagement.go;h=c1ff264e72ddfd647f0832ccdbd5aa0599f98c7f;hb=c01d387b9ff3b5da35e6d9a635523e6747c5b72c;hp=1d8582dac1029ff44e62df84645807211828a6ce;hpb=c9e08b2a2f647f9f870040570c5e71305f0fb5d2;p=nonrtric%2Fplt%2Fsme.git

diff --git a/capifcore/internal/invokermanagement/invokermanagement.go b/capifcore/internal/invokermanagement/invokermanagement.go
index 1d8582d..c1ff264 100644
--- a/capifcore/internal/invokermanagement/invokermanagement.go
+++ b/capifcore/internal/invokermanagement/invokermanagement.go
@@ -39,21 +39,29 @@ import (
 
 //go:generate mockery --name InvokerRegister
 type InvokerRegister interface {
+	// Checks if the invoker is registered.
+	// Returns true of the provided invoker is registered, false otherwise.
 	IsInvokerRegistered(invokerId string) bool
+	// Verifies that the provided secret is the invoker's registered secret.
+	// Returns true if the provided secret is the registered invoker's secret, false otherwise.
 	VerifyInvokerSecret(invokerId, secret string) bool
+	// Gets the provided invoker's registered APIs.
+	// Returns a list of all the invoker's registered APIs.
+	GetInvokerApiList(invokerId string) *invokerapi.APIList
 }
 
 type InvokerManager struct {
 	onboardedInvokers map[string]invokerapi.APIInvokerEnrolmentDetails
-	apiRegister       publishservice.APIRegister
+	publishRegister   publishservice.PublishRegister
 	nextId            int64
 	lock              sync.Mutex
 }
 
-func NewInvokerManager(apiRegister publishservice.APIRegister) *InvokerManager {
+// Creates a manager that implements both the InvokerRegister and the invokermanagementapi.ServerInterface interfaces.
+func NewInvokerManager(publishRegister publishservice.PublishRegister) *InvokerManager {
 	return &InvokerManager{
 		onboardedInvokers: make(map[string]invokerapi.APIInvokerEnrolmentDetails),
-		apiRegister:       apiRegister,
+		publishRegister:   publishRegister,
 		nextId:            1000,
 	}
 }
@@ -77,6 +85,19 @@ func (im *InvokerManager) VerifyInvokerSecret(invokerId, secret string) bool {
 	return verified
 }
 
+func (im *InvokerManager) GetInvokerApiList(invokerId string) *invokerapi.APIList {
+	invoker, ok := im.onboardedInvokers[invokerId]
+	if ok {
+		var apiList invokerapi.APIList = im.publishRegister.GetAllPublishedServices()
+		im.lock.Lock()
+		defer im.lock.Unlock()
+		invoker.ApiList = &apiList
+		return &apiList
+	}
+	return nil
+}
+
+// Creates a new individual API Invoker profile.
 func (im *InvokerManager) PostOnboardedInvokers(ctx echo.Context) error {
 	var newInvoker invokerapi.APIInvokerEnrolmentDetails
 	err := ctx.Bind(&newInvoker)
@@ -101,6 +122,9 @@ func (im *InvokerManager) PostOnboardedInvokers(ctx echo.Context) error {
 	}
 	newInvoker.OnboardingInformation.OnboardingSecret = &onboardingSecret
 
+	var apiList invokerapi.APIList = im.publishRegister.GetAllPublishedServices()
+	newInvoker.ApiList = &apiList
+
 	im.onboardedInvokers[*newInvoker.ApiInvokerId] = newInvoker
 
 	uri := ctx.Request().Host + ctx.Request().URL.String()
@@ -114,6 +138,7 @@ func (im *InvokerManager) PostOnboardedInvokers(ctx echo.Context) error {
 	return nil
 }
 
+// Deletes an individual API Invoker.
 func (im *InvokerManager) DeleteOnboardedInvokersOnboardingId(ctx echo.Context, onboardingId string) error {
 	im.lock.Lock()
 	defer im.lock.Unlock()
@@ -123,6 +148,7 @@ func (im *InvokerManager) DeleteOnboardedInvokersOnboardingId(ctx echo.Context,
 	return ctx.NoContent(http.StatusNoContent)
 }
 
+// Updates an individual API invoker details.
 func (im *InvokerManager) PutOnboardedInvokersOnboardingId(ctx echo.Context, onboardingId string) error {
 	var invoker invokerapi.APIInvokerEnrolmentDetails
 	err := ctx.Bind(&invoker)
@@ -170,18 +196,18 @@ func (im *InvokerManager) validateInvoker(invoker invokerapi.APIInvokerEnrolment
 		return true, sendCoreError(ctx, http.StatusBadRequest, "Invoker missing required OnboardingInformation.ApiInvokerPublicKey")
 	}
 
-	if !im.areAPIsRegistered(invoker.ApiList) {
+	if !im.areAPIsPublished(invoker.ApiList) {
 		return true, sendCoreError(ctx, http.StatusBadRequest, "Some APIs needed by invoker are not registered")
 	}
 
 	return false, nil
 }
 
-func (im *InvokerManager) areAPIsRegistered(apis *invokerapi.APIList) bool {
+func (im *InvokerManager) areAPIsPublished(apis *invokerapi.APIList) bool {
 	if apis == nil {
 		return true
 	}
-	return im.apiRegister.AreAPIsRegistered((*[]publishapi.ServiceAPIDescription)(apis))
+	return im.publishRegister.AreAPIsPublished((*[]publishapi.ServiceAPIDescription)(apis))
 }
 
 func (im *InvokerManager) getId(invokerInfo *string) *string {