ms/neng/src/main/java/org/onap/ccsdk/apps/ms/neng/core/service/rs/RestServiceImpl.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : CCSDK.apps
   4  * ================================================================================
   5  * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
   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
  21 package org.onap.ccsdk.apps.ms.neng.core.service.rs;
  22
  23 import java.util.HashMap;
  24 import java.util.Map;
  25 import java.util.logging.Logger;
  26 import javax.validation.Valid;
  27 import javax.ws.rs.core.Response;
  28 import org.onap.ccsdk.apps.ms.neng.core.exceptions.NengException;
  29 import org.onap.ccsdk.apps.ms.neng.core.resource.model.HelloWorld;
  30 import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenRequest;
  31 import org.onap.ccsdk.apps.ms.neng.core.resource.model.NameGenResponse;
  32 import org.onap.ccsdk.apps.ms.neng.core.service.SpringService;
  33 import org.onap.ccsdk.apps.ms.neng.persistence.entity.PolicyDetails;
  34 import org.springframework.beans.factory.annotation.Autowired;
  35 import org.springframework.stereotype.Component;
  36 import org.springframework.web.bind.annotation.RequestBody;
  37
  38 /**
  39  * Implementation of the REST-style interface/API to this micro-service.
  40  */
  41 @Component
  42 public class RestServiceImpl implements RestService {
  43     private static Logger log = Logger.getLogger(RestServiceImpl.class.getName());
  44     private static final String INTERNAL_ERROR_MSG = "Internal error occured while processing the request.";
  45
  46     @Autowired SpringService service;
  47
  48     /**
  49      * Heart-beat/ping API.
  50      */
  51     @Override
  52     public Response getQuickHello(String name) {
  53         log.info(name);
  54         HelloWorld hw = service.getQuickHello(name);
  55         return Response.ok().entity(hw).build();
  56     }
  57
  58     /**
  59      * Name generation API.
  60      */
  61     @Override
  62     public Response generateNetworkElementName(@RequestBody @Valid NameGenRequest request) {
  63         log.info("Received request: " + request.toString());
  64         Map<String, Object> response = new HashMap<>();
  65         try {
  66             NameGenResponse resp = service.generateOrUpdateName(request);
  67             return buildResponse(resp);
  68         } catch (NengException e) {
  69             log.warning(e.getMessage());
  70             response.put("error", buildErrorResponse("NELGEN-0003", e.getMessage()));
  71             return buildErrorResponse(response);
  72         } catch (Exception e) {
  73             log.warning(e.getMessage());
  74             response.put("error", buildErrorResponse("err-0500", INTERNAL_ERROR_MSG));
  75             return buildErrorResponse(response);
  76         }
  77     }
  78
  79     /**
  80      * Name removal API.
  81      */
  82     @Override
  83     public Response releaseNetworkElementName(NameGenRequest request) {
  84         NameGenResponse resp;
  85         Map<String, Object> response = new HashMap<>();
  86         try {
  87             resp = service.releaseNetworkElementName(request);
  88             return buildResponse(resp);
  89         } catch (NengException e) {
  90             log.warning(e.getMessage());
  91             response.put("error", buildErrorResponse("NELGEN-0002", e.getMessage()));
  92             return buildErrorResponse(response);
  93         } catch (Exception e) {
  94             log.warning(e.getMessage());
  95             response.put("error", buildErrorResponse("err-0500", INTERNAL_ERROR_MSG));
  96             return buildErrorResponse(response);
  97         }
  98     }
  99
 100     /**
 101      * API to return naming policy cached in this micro-service.
 102      */
 103     @Override
 104     public Response getPolicyResponse(String policyName) throws Exception {
 105         log.info("get-policy: " + policyName);
 106
 107         PolicyDetails policyDetails = service.getPolicyDetails(policyName);
 108         return Response.ok().entity(policyDetails.getPolicyResponse()).build();
 109     }
 110
 111     /**
 112      * API to add a naming policy to the database cache in this micro-service.
 113      */
 114     @Override
 115     public Response addPolicyToDb(Object request) throws Exception {
 116         Map<String, Object> response = new HashMap<>();
 117         try {
 118             service.addPolicy(request);
 119             response.put("status", "Policy added successfully");
 120             return buildResponse(response);
 121         } catch (Exception e) {
 122             log.warning(e.getMessage());
 123             response.put("error", buildErrorResponse("err-0500", e.getMessage()));
 124             return buildErrorResponse(response);
 125         }
 126     }
 127
 128     Response buildResponse(Object response) {
 129         return Response.ok().entity(response).build();
 130     }
 131
 132     Response buildErrorResponse(Map<String, Object> response) {
 133         return Response.status(500).entity(response).build();
 134     }
 135
 136     Map<String,Object> buildErrorResponse(String errorCode, String message) {
 137         Map<String,Object> error = new HashMap<>();
 138         error.put("errorId", errorCode);
 139         error.put("message", message);
 140         return error;
 141     }
 142 }