webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/controller/AcXappController.java

   1 /*-
   2  * ========================LICENSE_START=================================
   3  * O-RAN-SC
   4  * %%
   5  * Copyright (C) 2019 AT&T Intellectual Property and Nokia
   6  * %%
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ========================LICENSE_END===================================
  19  */
  20 package org.oransc.ric.portal.dashboard.controller;
  21
  22 import java.lang.invoke.MethodHandles;
  23
  24 import javax.servlet.http.HttpServletResponse;
  25
  26 import org.oransc.ric.a1med.client.api.A1MediatorApi;
  27 import org.oransc.ric.portal.dashboard.DashboardApplication;
  28 import org.oransc.ric.portal.dashboard.DashboardConstants;
  29 import org.oransc.ric.portal.dashboard.model.SuccessTransport;
  30 import org.slf4j.Logger;
  31 import org.slf4j.LoggerFactory;
  32 import org.springframework.beans.factory.annotation.Autowired;
  33 import org.springframework.http.MediaType;
  34 import org.springframework.util.Assert;
  35 import org.springframework.web.bind.annotation.PathVariable;
  36 import org.springframework.web.bind.annotation.RequestBody;
  37 import org.springframework.web.bind.annotation.RequestMapping;
  38 import org.springframework.web.bind.annotation.RequestMethod;
  39 import org.springframework.web.bind.annotation.RestController;
  40
  41 import com.fasterxml.jackson.databind.JsonNode;
  42
  43 import io.swagger.annotations.ApiOperation;
  44 import io.swagger.annotations.ApiParam;
  45
  46 /**
  47  * Provides methods to manage policies of the Admission Control xApp. All
  48  * messages go via the A1 Mediatior.
  49  */
  50 @RestController
  51 @RequestMapping(value = DashboardConstants.ENDPOINT_PREFIX + "/xapp/ac", produces = MediaType.APPLICATION_JSON_VALUE)
  52 public class AcXappController {
  53
  54         private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
  55
  56         private static final String POLICY_NAME = "policyname";
  57
  58         // Populated by the autowired constructor
  59         private final A1MediatorApi a1MediatorApi;
  60
  61         @Autowired
  62         public AcXappController(final A1MediatorApi a1MediatorApi) {
  63                 Assert.notNull(a1MediatorApi, "API must not be null");
  64                 this.a1MediatorApi = a1MediatorApi;
  65         }
  66
  67         @ApiOperation(value = "Gets the A1 client library MANIFEST.MF property Implementation-Version.", response = SuccessTransport.class)
  68         @RequestMapping(value = DashboardConstants.VERSION_PATH, method = RequestMethod.GET)
  69         public SuccessTransport getVersion() {
  70                 logger.debug("getVersion enter");
  71                 return new SuccessTransport(200, DashboardApplication.getImplementationVersion(A1MediatorApi.class));
  72         }
  73
  74         @ApiOperation(value = "Gets the named policy for AC xApp via the A1 Mediator")
  75         @RequestMapping(value = "policy/{" + POLICY_NAME + "}", method = RequestMethod.GET)
  76         public Object getPolicy(@PathVariable(POLICY_NAME) String policyName) {
  77                 logger.debug("getPolicy: policy {}", policyName);
  78                 a1MediatorApi.a1ControllerGetHandler(policyName);
  79                 return null;
  80         }
  81
  82         @ApiOperation(value = "Sets the named policy for AC xApp via the A1 Mediator")
  83         @RequestMapping(value = "policy/{" + POLICY_NAME + "}", method = RequestMethod.PUT)
  84         public void putPolicy(@PathVariable(POLICY_NAME) String policyName, //
  85                         @ApiParam(value = "JSON formatted policy") @RequestBody JsonNode policy, //
  86                         HttpServletResponse response) {
  87                 logger.debug("putPolicy: policy {}", policyName);
  88                 a1MediatorApi.a1ControllerPutHandler(policyName, policy);
  89                 response.setStatus(a1MediatorApi.getApiClient().getStatusCode().value());
  90         }
  91
  92 }