Merge CAPIF into MEC Federation branch for ETSI SNS4SNS demo (!1) · Merge requests · MEC - Multi-access Edge Computing / ETSI MEC Sandbox

charts/meep-app-enablement/values-template.yaml

+12 −0

Changes for charts/meep-app-enablement/values-template.yaml: 12 added lines, 0 removed lines.
Original line number	Diff line number	Diff line
		@@ -46,9 +46,15 @@ ingress:
		{{- if .IsMepService }}
		- /{{.SandboxName}}/{{.MepName}}/mec_app_support
		- /{{.SandboxName}}/{{.MepName}}/mec_service_mgmt
		- /{{.SandboxName}}/{{.MepName}}/service-apis
		- /{{.SandboxName}}/{{.MepName}}/published-apis
		- /{{.SandboxName}}/{{.MepName}}/capif-events
		{{- else }}
		- /{{.SandboxName}}/mec_app_support
		- /{{.SandboxName}}/mec_service_mgmt
		- /{{.SandboxName}}/service-apis
		- /{{.SandboxName}}/published-apis
		- /{{.SandboxName}}/capif-events
		{{- end }}
		annotations:
		kubernetes.io/ingress.class: nginx
		@@ -57,10 +63,16 @@ ingress:
		nginx.ingress.kubernetes.io/configuration-snippet: \|
		rewrite ^/{{ .SandboxName }}/{{.MepName}}/mec_app_support(/\|$)(.*)$ /mec_app_support/$2 break;
		rewrite ^/{{ .SandboxName }}/{{.MepName}}/mec_service_mgmt(/\|$)(.*)$ /mec_service_mgmt/$2 break;
		rewrite ^/{{ .SandboxName }}/{{.MepName}}/service-apis(/\|$)(.*)$ /service-apis/$2 break;
		rewrite ^/{{ .SandboxName }}/{{.MepName}}/published-apis(/\|$)(.*)$ /published-apis/$2 break;
		rewrite ^/{{ .SandboxName }}/{{.MepName}}/capif-events(/\|$)(.*)$ /capif-events/$2 break;
		{{- else }}
		nginx.ingress.kubernetes.io/configuration-snippet: \|
		rewrite ^/{{ .SandboxName }}/mec_app_support(/\|$)(.*)$ /mec_app_support/$2 break;
		rewrite ^/{{ .SandboxName }}/mec_service_mgmt(/\|$)(.*)$ /mec_service_mgmt/$2 break;
		rewrite ^/{{ .SandboxName }}/service-apis(/\|$)(.*)$ /service-apis/$2 break;
		rewrite ^/{{ .SandboxName }}/published-apis(/\|$)(.*)$ /published-apis/$2 break;
		rewrite ^/{{ .SandboxName }}/capif-events(/\|$)(.*)$ /capif-events/$2 break;
		{{- end }}
		{{- if .AuthEnabled }}
		nginx.ingress.kubernetes.io/auth-url: https://$http_host/auth/v1/authenticate?svc=meep-app-enablement&sbox={{.SandboxName}}&mep={{.MepName}}

go-apps/meep-app-enablement/api/capif-mgmt/swagger.yaml

0 → 100644

+1584 −0

File added.

Preview size limit exceeded, changes collapsed.

go-apps/meep-app-enablement/server/app-support/app-support.go

+130 −55

Changes for go-apps/meep-app-enablement/server/app-support/app-support.go: 130 added lines, 55 removed lines.
Original line number	Diff line number	Diff line
		@@ -22,6 +22,7 @@ import (
		"fmt"
		"net/http"
		"net/url"
		"reflect"
		"strconv"
		"sync"
		"time"
		@@ -658,79 +659,124 @@ func appRegistrationPOST(w http.ResponseWriter, r *http.Request) {

		w.Header().Set("Content-Type", "application/json; charset=UTF-8")

		// Decode the request body into AppInfo struct
		// Parse request body into AppInfo struct
		var appInfo AppInfo
		err := json.NewDecoder(r.Body).Decode(&appInfo)
		if err != nil {
		log.Error(err.Error())
		errHandlerProblemDetails(w, err.Error(), http.StatusBadRequest)
		if err := json.NewDecoder(r.Body).Decode(&appInfo); err != nil {
		log.Error("Error decoding request body:", err)
		errHandlerProblemDetails(w, "Invalid request body.", http.StatusBadRequest)
		return
		}
		log.Info("appRegistrationPOST: appInfo: ", appInfo)
		log.Info("appRegistrationPOST: Received appInfo:", appInfo)

		// Validation of mandatory parameters
		// Validate required fields
		if appInfo.AppName == "" {
		log.Error("Mandatory AppName parameter not present")
		errHandlerProblemDetails(w, "Mandatory AppName parameter not present", http.StatusBadRequest)
		log.Error("Missing mandatory parameter: AppName")
		errHandlerProblemDetails(w, "Mandatory attribute AppName is missing.", http.StatusBadRequest)
		return
		}

		if appInfo.AppInstanceId == "" {
		log.Error("Mandatory appInstanceId parameter should be present")
		errHandlerProblemDetails(w, "Mandatory attribute appInstanceId is missing in the request body.", http.StatusBadRequest)
		log.Error("Missing mandatory parameter: AppInstanceId")
		errHandlerProblemDetails(w, "Mandatory attribute AppInstanceId is missing.", http.StatusBadRequest)
		return
		}

		if !appInfo.IsInsByMec && appInfo.Endpoint == nil {
		log.Error("Shall be present when IsInsByMec is FALSE")
		errHandlerProblemDetails(w, "Endpoint shall be present when IsInsByMec is FALSE.", http.StatusBadRequest)
		log.Error("Endpoint is required when IsInsByMec is FALSE")
		errHandlerProblemDetails(w, "Endpoint is required when IsInsByMec is FALSE.", http.StatusBadRequest)
		return
		}

		// Get App instance
		log.Info("appRegistrationPOST: appInfo.AppInstanceId: ", appInfo.AppInstanceId)
		// Process appProfile if provided
		if appInfo.AppProfile != nil {
		// Validate appProvider and other fields mapped to EASProfile
		if appInfo.AppProvider != appInfo.AppProfile.ProvId {
		log.Error("Mismatch between appProvider in AppInfo and provId in appProfile")
		errHandlerProblemDetails(w, "appProvider and provId must match.", http.StatusBadRequest)
		return
		}

		if !reflect.DeepEqual(getEndpointUris(appInfo.Endpoint), getProfileEndpointUris(appInfo.AppProfile.EndPt)) {
		log.Error("Mismatch between endpoint in AppInfo and endPt in appProfile")
		errHandlerProblemDetails(w, "Endpoint and endPt must match.", http.StatusBadRequest)
		return
		}

		if appInfo.AppProfile.EasId == "" {
		log.Error("Missing mandatory parameter: easId")
		errHandlerProblemDetails(w, "Mandatory attribute easId is missing.", http.StatusBadRequest)
		return
		}

		if appInfo.AppName != appInfo.AppProfile.EasId {
		log.Error("Mismatch between AppName in AppInfo and EasId in appProfile")
		errHandlerProblemDetails(w, "AppName and EasId must match.", http.StatusBadRequest)
		return
		}
		// Additional checks for attributes such as scheds, svcArea, etc., as required.
		}

		// Retrieve App instance information
		log.Info("appRegistrationPOST: Processing AppInstanceId:", appInfo.AppInstanceId)
		appId, err := getAppInfo(appInfo.AppInstanceId)
		if err != nil {
		log.Error(err.Error())
		errHandlerProblemDetails(w, err.Error(), http.StatusNotFound)
		log.Error("Error retrieving app instance:", err)
		errHandlerProblemDetails(w, "App instance not found.", http.StatusNotFound)
		return
		}
		log.Info("appRegistrationPOST: appId: ", appId)
		log.Info("appRegistrationPOST: Retrieved appId:", appId)

		// Validate App info
		// Validate the retrieved AppInfo
		code, problemDetails, err := validateAppInfo(appId)
		if err != nil {
		log.Error(err.Error())
		log.Error("Error validating app info:", err)
		if problemDetails != "" {
		w.WriteHeader(code)
		fmt.Fprint(w, problemDetails)
		} else {
		errHandlerProblemDetails(w, err.Error(), code)
		errHandlerProblemDetails(w, "Validation error.", code)
		}
		return
		}

		// Set the application info in Redis
		// Store AppInfo in Redis
		keyName := baseKey + "appInfo:" + appInfo.AppInstanceId
		log.Info("appRegistrationPOST: keyName: ", keyName)
		log.Info("appRegistrationPOST: Storing data with key:", keyName)
		if err := rc.JSONSetEntry(keyName, ".", convertAppInfoToJson(&appInfo)); err != nil {
		log.Error("Unable to store new Registration in redis")
		errHandlerProblemDetails(w, "Unable to store new Registration in redis", http.StatusInternalServerError)
		log.Error("Failed to store registration in Redis:", err)
		errHandlerProblemDetails(w, "Server error. Could not store registration.", http.StatusInternalServerError)
		return
		}

		// Create a unique link for every subscription and concatenate subscription to it
		// Generate resource URI for the created app registration
		resourceURI := hostUrl.String() + basePath + "registrations/" + appInfo.AppInstanceId
		log.Info("appRegistrationPOST: resourceUDI: ", resourceURI)
		log.Info("appRegistrationPOST: Generated resource URI:", resourceURI)
		w.Header().Set("Location", resourceURI)

		// Prepare & send response
		// Send JSON response with status 201 Created
		jsonResponse := convertAppInfoToJson(&appInfo)
		// On successful registration, return 201 Created with the response body
		w.WriteHeader(http.StatusCreated)
		fmt.Fprint(w, jsonResponse)
		}

		func getEndpointUris(endpoint *OneOfAppInfoEndpoint) []string {
		if endpoint == nil {
		return nil
		}

		// Access the `Uris` field directly from `EndPointInfoUris`
		return endpoint.EndPointInfoUris.Uris
		}

		func getProfileEndpointUris(endPt *OneOfAppProfileEndPt) []string {
		if endPt == nil {
		return nil
		}

		// Access the `Uris` field directly from `EndPointInfoUris`
		return endPt.EndPointInfoUris.Uris
		}

		/*
		* appRegistrationGET handles retrieving the registration information of an application.
		* It fetches the appInstanceId from the URL variables, retrieves the associated application info from Redis, and sends it back in the response. If the appInstanceId is not found or an error occurs, it responds with the appropriate status and error message.
		@@ -790,57 +836,86 @@ func appRegistrationPUT(w http.ResponseWriter, r *http.Request) {
		w.Header().Set("Content-Type", "application/json; charset=UTF-8")
		vars := mux.Vars(r)
		appInstanceId := vars["appInstanceId"]
		log.Info("appRegistrationPUT: appInstanceId: ", appInstanceId)
		log.Info("appRegistrationPUT: Received appInstanceId:", appInstanceId)

		// Read JSON input stream provided in the Request, and stores it in the buffer of a Decoder object
		decoder := json.NewDecoder(r.Body)
		// Decode function return strings containing the text provided in the request body
		// Decode JSON input from request body into AppInfo structure
		var appInfoPut AppInfo
		err := decoder.Decode(&appInfoPut)
		if err != nil {
		log.Error(err.Error())
		errHandlerProblemDetails(w, err.Error(), http.StatusBadRequest)
		if err := json.NewDecoder(r.Body).Decode(&appInfoPut); err != nil {
		log.Error("Error decoding request body:", err)
		errHandlerProblemDetails(w, "Invalid request body.", http.StatusBadRequest)
		return
		}
		log.Info("appRegistrationPUT: appInfoPut: ", appInfoPut)
		log.Info("appRegistrationPUT: Parsed appInfoPut:", appInfoPut)

		// Check if the appInfo exists in Redis for the given appInstanceId
		keyName := baseKey + "appInfo:" + appInstanceId
		log.Info("appRegistrationPUT: keyName: ", keyName)
		log.Info("appRegistrationPUT: Checking existence of key:", keyName)
		jsonAppInfo, _ := rc.JSONGetEntry(keyName, ".")
		if jsonAppInfo == "" {
		log.Error("appInfo not found against the provided appInstanceId")
		errHandlerProblemDetails(w, "appInfo not found against the provided appInstanceId", http.StatusNotFound)
		log.Error("No appInfo found for provided appInstanceId")
		errHandlerProblemDetails(w, "appInfo not found for the provided appInstanceId", http.StatusNotFound)
		return
		}

		if appInfoPut.AppInstanceId != "" {
		if appInstanceId != appInfoPut.AppInstanceId {
		log.Error("appInstnaceId provided in endpoint and in request body not matching")
		errHandlerProblemDetails(w, "appInstanceId provided in endpoint and in request body not matching", http.StatusNotFound)
		// Validate appInstanceId consistency between URL and request body
		if appInfoPut.AppInstanceId != "" && appInstanceId != appInfoPut.AppInstanceId {
		log.Error("appInstanceId mismatch between endpoint and request body")
		errHandlerProblemDetails(w, "appInstanceId in endpoint and request body do not match", http.StatusBadRequest)
		return
		}
		}

		// Validate required parameters
		if appInfoPut.AppName == "" {
		log.Error("Mandatory AppName parameter not present")
		errHandlerProblemDetails(w, "Mandatory AppName parameter not present", http.StatusBadRequest)
		log.Error("Missing mandatory parameter: AppName")
		errHandlerProblemDetails(w, "Mandatory attribute AppName is missing.", http.StatusBadRequest)
		return
		}

		if !appInfoPut.IsInsByMec && appInfoPut.Endpoint == nil {
		log.Error("Shall be present when IsInsByMec is FALSE")
		errHandlerProblemDetails(w, "Shall be present when IsInsByMec is FALSE.", http.StatusBadRequest)
		log.Error("Endpoint is required when IsInsByMec is FALSE")
		errHandlerProblemDetails(w, "Endpoint is required when IsInsByMec is FALSE.", http.StatusBadRequest)
		return
		}

		appInfoPut.AppInstanceId = appInstanceId
		// Process appProfile if provided
		if appInfoPut.AppProfile != nil {
		// Validate appProvider and associated fields as per EASProfile mapping
		if appInfoPut.AppProvider != appInfoPut.AppProfile.ProvId {
		log.Error("Mismatch between appProvider in AppInfo and provId in appProfile")
		errHandlerProblemDetails(w, "appProvider and provId must match.", http.StatusBadRequest)
		return
		}

		// Store appInfo key in redis
		err = rc.JSONSetEntry(baseKey+"appInfo:"+appInstanceId, ".", convertAppInfoToJson(&appInfoPut))
		if err != nil {
		log.Error("Failed to store AppInfo in the redis DB: ", err)
		if !reflect.DeepEqual(getEndpointUris(appInfoPut.Endpoint), getProfileEndpointUris(appInfoPut.AppProfile.EndPt)) {
		log.Error("Mismatch between endpoint in AppInfo and endPt in appProfile")
		errHandlerProblemDetails(w, "Endpoint and endPt must match.", http.StatusBadRequest)
		return
		}

		if appInfoPut.AppProfile.EasId == "" {
		log.Error("Missing mandatory parameter: easId")
		errHandlerProblemDetails(w, "Mandatory attribute easId is missing.", http.StatusBadRequest)
		return
		}

		if appInfoPut.AppName != appInfoPut.AppProfile.EasId {
		log.Error("Mismatch between AppName in AppInfo and EasId in appProfile")
		errHandlerProblemDetails(w, "AppName and EasId must match.", http.StatusBadRequest)
		return
		}
		// Additional consistency checks for fields such as scheds, svcArea, etc., as required.
		}

		// Set appInstanceId in appInfoPut and store in Redis
		appInfoPut.AppInstanceId = appInstanceId
		log.Info("appRegistrationPUT: Storing updated appInfo for appInstanceId:", appInstanceId)
		if err := rc.JSONSetEntry(keyName, ".", convertAppInfoToJson(&appInfoPut)); err != nil {
		log.Error("Failed to store updated AppInfo in Redis:", err)
		errHandlerProblemDetails(w, "Server error. Could not store updated appInfo.", http.StatusInternalServerError)
		return
		}

		// Respond with status 204 No Content to indicate successful update
		w.WriteHeader(http.StatusNoContent)
		}

go-apps/meep-app-enablement/server/capif-mgmt/README.md

0 → 100644

+25 −0

Changes for go-apps/meep-app-enablement/server/capif-mgmt/README.md: 25 added lines, 0 removed lines.
Original line number	Diff line number	Diff line
		# Go API Server for server

		MEC Service Management Service is AdvantEDGE's implementation of [ETSI MEC ISG MEC011 Application Enablement API](https://www.etsi.org/deliver/etsi_gs/MEC/001_099/011/02.02.01_60/gs_MEC011v020201p.pdf) <p>[Copyright (c) ETSI 2024](https://forge.etsi.org/etsi-forge-copyright-notice.txt) <p>Micro-service<br>[meep-app-enablement](https://github.com/InterDigitalInc/AdvantEDGE/tree/master/go-apps/meep-app-enablement/server/service-mgmt) <p>Type & Usage<br>Edge Service used by edge applications that want to get information about services in the network <p>Note<br>AdvantEDGE supports all of Service Management API endpoints (see below).

		## Overview
		This server was generated by the [swagger-codegen]
		(https://github.com/swagger-api/swagger-codegen) project.
		By using the [OpenAPI-Spec](https://github.com/OAI/OpenAPI-Specification) from a remote server, you can easily generate a server stub.
		-

		To see how to make this your own, look here:

		[README](https://github.com/swagger-api/swagger-codegen/blob/master/README.md)

		- API version: 3.1.1
		- Build date: 2024-03-25T08:32:22.065107-05:00


		### Running the server
		To run the server, follow these simple steps:

		```
		go run main.go
		```

go-apps/meep-app-enablement/server/capif-mgmt/api_mec_service_mgmt.go

0 → 100644

+95 −0

Changes for go-apps/meep-app-enablement/server/capif-mgmt/api_mec_service_mgmt.go: 95 added lines, 0 removed lines.
Original line number	Diff line number	Diff line
		/*
		* Copyright (c) 2024 The AdvantEDGE Authors
		*
		* 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.
		*
		* AdvantEDGE Service Management API
		*
		* MEC Service Management Service is AdvantEDGE's implementation of [ETSI MEC ISG MEC011 Application Enablement API](https://www.etsi.org/deliver/etsi_gs/MEC/001_099/011/03.01.01_60/gs_MEC011v030101p.pdf) <p>[Copyright (c) ETSI 2024](https://forge.etsi.org/etsi-forge-copyright-notice.txt) <p>Micro-service<br>[meep-app-enablement](https://github.com/InterDigitalInc/AdvantEDGE/tree/master/go-apps/meep-app-enablement/server/service-mgmt) <p>Type & Usage<br>Edge Service used by edge applications that want to get information about services in the network <p>Note<br>AdvantEDGE supports all of Service Management API endpoints (see below).
		*
		* API version: 3.1.1
		* Contact: AdvantEDGE@InterDigital.com
		* Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)
		*/
		package server

		import (
		"net/http"
		)

		func AppServicesGET(w http.ResponseWriter, r *http.Request) {
		appServicesGET(w, r)
		}

		func AppServicesPOST(w http.ResponseWriter, r *http.Request) {
		appServicesPOST(w, r)
		}

		func AppServicesServiceIdDELETE(w http.ResponseWriter, r *http.Request) {
		appServicesByIdDELETE(w, r)
		}

		func AppServicesServiceIdGET(w http.ResponseWriter, r *http.Request) {
		appServicesByIdGET(w, r)
		}

		func AppServicesServiceIdPUT(w http.ResponseWriter, r *http.Request) {
		appServicesByIdPUT(w, r)
		}

		func AppServicesServiceIdPATCH(w http.ResponseWriter, r *http.Request) {
		appServicesByIdPATCH(w, r)
		}

		func ApplicationsSubscriptionDELETE(w http.ResponseWriter, r *http.Request) {
		applicationsSubscriptionDELETE(w, r)
		}

		func ApplicationsSubscriptionGET(w http.ResponseWriter, r *http.Request) {
		applicationsSubscriptionGET(w, r)
		}

		func ApplicationsSubscriptionsGET(w http.ResponseWriter, r *http.Request) {
		applicationsSubscriptionsGET(w, r)
		}

		func ApplicationsSubscriptionsPOST(w http.ResponseWriter, r *http.Request) {
		applicationsSubscriptionsPOST(w, r)
		}
		func ApplicationsSubscriptionsPUT(w http.ResponseWriter, r *http.Request) {
		applicationsSubscriptionsPUT(w, r)
		}

		func ApplicationsSubscriptionsPATCH(w http.ResponseWriter, r *http.Request) {
		applicationsSubscriptionsPATCH(w, r)
		}

		func ServicesGET(w http.ResponseWriter, r *http.Request) {
		servicesGET(w, r)
		}

		func ServicesServiceIdGET(w http.ResponseWriter, r *http.Request) {
		servicesByIdGET(w, r)
		}

		func GetIndividualMECService(w http.ResponseWriter, r *http.Request) {
		getIndividualMECService(w, r)
		}

		func PatchIndividualMECService(w http.ResponseWriter, r *http.Request) {
		patchIndividualMECService(w, r)
		}

		func TransportsGET(w http.ResponseWriter, r *http.Request) {
		transportsGET(w, r)
		}

Merge CAPIF into MEC Federation branch for ETSI SNS4SNS demo

Merge request reports