Implement registrations/{appInstanceId} GET method (bfdb5194) · Commits · MEC - Multi-access Edge Computing / ETSI MEC Sandbox

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

+4 −0

Original line number	Diff line number	Diff line
		@@ -62,3 +62,7 @@ func TimingCurrentTimeGET(w http.ResponseWriter, r *http.Request) {
		func RegisterMecAppPOST(w http.ResponseWriter, r *http.Request) {
		registerAppPost(w, r)
		}

		func AppRegistrationGET(w http.ResponseWriter, r *http.Request) {
		appRegistrationGET(w, r)
		}

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

+34 −0

Original line number	Diff line number	Diff line
		@@ -682,6 +682,40 @@ func registerAppPost(w http.ResponseWriter, r *http.Request) {
		fmt.Fprint(w, string(jsonResponse))
		}

		func appRegistrationGET(w http.ResponseWriter, r *http.Request) {
		w.Header().Set("Content-Type", "application/json; charset=UTF-8")
		vars := mux.Vars(r)
		appInstanceId := vars["appInstanceId"]

		mutex.Lock()
		defer mutex.Unlock()

		keyName := baseKey + "Ins_Id:" + appInstanceId
		jsonAppInfo, err := rc.JSONGetEntry(keyName, ".")

		if err != nil {
		err = errors.New("appInfo not found against the provided appInstanceId")
		log.Error(err.Error())
		errHandlerProblemDetails(w, err.Error(), http.StatusNotFound)
		return
		}

		var appInfo AppInfo
		err = json.Unmarshal([]byte(jsonAppInfo), &appInfo)
		if err != nil {
		log.Error(err.Error())
		errHandlerProblemDetails(w, err.Error(), http.StatusInternalServerError)
		return
		}

		// Marshal the AppInfo struct to JSON format
		jsonResponse := convertAppInfoToJson(&appInfo)

		// write the JSON response
		w.WriteHeader(http.StatusOK)
		fmt.Fprint(w, jsonResponse)
		}

		func deleteAppInstance(appId string) {
		log.Info("Deleting App instance: ", appId)

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

+7 −0

Original line number	Diff line number	Diff line
		@@ -195,6 +195,13 @@ var routes = Routes{
		appSupport.RegisterMecAppPOST,
		},

		Route{
		"AppRegistrationGET",
		strings.ToUpper("GET"),
		"/mec_app_support/v2/registrations/{appInstanceId}",
		appSupport.AppRegistrationGET,
		},

		Route{
		"Index",
		"GET",

go-packages/meep-app-support-client/api_mec_app_support.go

+117 −0

Original line number	Diff line number	Diff line
		@@ -418,6 +418,123 @@ func (a *MecAppSupportApiService) ApplicationsRegistrationsPOST(ctx context.Cont
		return localVarHttpResponse, nil
		}

		/*
		MecAppSupportApiService
		This method retrieves the information about the existing MEC application instance registration to the MEC platform.
		- @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
		- @param appInstanceId Represents a MEC application instance. Note that the appInstanceId is allocated by the MEC platform manager.

		@return AppInfo
		*/
		func (a MecAppSupportApiService) ApplicationsRegistrationGET(ctx context.Context, appInstanceId string) (AppInfo, http.Response, error) {
		var (
		localVarHttpMethod = strings.ToUpper("Get")
		localVarPostBody interface{}
		localVarFileName string
		localVarFileBytes []byte
		localVarReturnValue AppInfo
		)

		// create path and map variables
		localVarPath := a.client.cfg.BasePath + "/registrations/{appInstanceId}"
		localVarPath = strings.Replace(localVarPath, "{"+"appInstanceId"+"}", fmt.Sprintf("%v", appInstanceId), -1)

		localVarHeaderParams := make(map[string]string)
		localVarQueryParams := url.Values{}
		localVarFormParams := url.Values{}

		// to determine the Content-Type header
		localVarHttpContentTypes := []string{}

		// set Content-Type header
		localVarHttpContentType := selectHeaderContentType(localVarHttpContentTypes)
		if localVarHttpContentType != "" {
		localVarHeaderParams["Content-Type"] = localVarHttpContentType
		}

		// to determine the Accept header
		localVarHttpHeaderAccepts := []string{"application/json", "application/problem+json", "text/plain"}

		// set Accept header
		localVarHttpHeaderAccept := selectHeaderAccept(localVarHttpHeaderAccepts)
		if localVarHttpHeaderAccept != "" {
		localVarHeaderParams["Accept"] = localVarHttpHeaderAccept
		}
		r, err := a.client.prepareRequest(ctx, localVarPath, localVarHttpMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFileName, localVarFileBytes)
		if err != nil {
		return localVarReturnValue, nil, err
		}

		localVarHttpResponse, err := a.client.callAPI(r)
		if err != nil \|\| localVarHttpResponse == nil {
		return localVarReturnValue, localVarHttpResponse, err
		}

		localVarBody, err := ioutil.ReadAll(localVarHttpResponse.Body)
		localVarHttpResponse.Body.Close()
		if err != nil {
		return localVarReturnValue, localVarHttpResponse, err
		}

		if localVarHttpResponse.StatusCode < 300 {
		// If we succeed, return the data, otherwise pass on to decode error.
		err = a.client.decode(&localVarReturnValue, localVarBody, localVarHttpResponse.Header.Get("Content-Type"))
		if err == nil {
		return localVarReturnValue, localVarHttpResponse, err
		}
		}

		if localVarHttpResponse.StatusCode >= 300 {
		newErr := GenericSwaggerError{
		body: localVarBody,
		error: localVarHttpResponse.Status,
		}
		if localVarHttpResponse.StatusCode == 200 {
		var v AppInfo
		err = a.client.decode(&v, localVarBody, localVarHttpResponse.Header.Get("Content-Type"))
		if err != nil {
		newErr.error = err.Error()
		return localVarReturnValue, localVarHttpResponse, newErr
		}
		newErr.model = v
		return localVarReturnValue, localVarHttpResponse, newErr
		}
		if localVarHttpResponse.StatusCode == 400 {
		var v ProblemDetails
		err = a.client.decode(&v, localVarBody, localVarHttpResponse.Header.Get("Content-Type"))
		if err != nil {
		newErr.error = err.Error()
		return localVarReturnValue, localVarHttpResponse, newErr
		}
		newErr.model = v
		return localVarReturnValue, localVarHttpResponse, newErr
		}
		if localVarHttpResponse.StatusCode == 403 {
		var v ProblemDetails
		err = a.client.decode(&v, localVarBody, localVarHttpResponse.Header.Get("Content-Type"))
		if err != nil {
		newErr.error = err.Error()
		return localVarReturnValue, localVarHttpResponse, newErr
		}
		newErr.model = v
		return localVarReturnValue, localVarHttpResponse, newErr
		}
		if localVarHttpResponse.StatusCode == 404 {
		var v ProblemDetails
		err = a.client.decode(&v, localVarBody, localVarHttpResponse.Header.Get("Content-Type"))
		if err != nil {
		newErr.error = err.Error()
		return localVarReturnValue, localVarHttpResponse, newErr
		}
		newErr.model = v
		return localVarReturnValue, localVarHttpResponse, newErr
		}
		return localVarReturnValue, localVarHttpResponse, newErr
		}

		return localVarReturnValue, localVarHttpResponse, nil
		}

		/*
		MecAppSupportApiService
		This method deletes a mecAppSuptApiSubscription. This method is typically used in \"Unsubscribing from service availability event notifications\" procedure.