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     private static final String ERROR="error";
  46
  47
  48     @Autowired SpringService service;
  49
  50     /**
  51      * Heart-beat/ping API.
  52      */
  53     @Override
  54     public Response getQuickHello(String name) {
  55         log.info(name);
  56         HelloWorld hw = service.getQuickHello(name);
  57         return Response.ok().entity(hw).build();
  58     }
  59
  60     /**
  61      * Name generation API.
  62      */
  63     @Override
  64     public Response generateNetworkElementName(@RequestBody @Valid NameGenRequest request) {
  65         log.info("Received request: " + request.toString());
  66         Map<String, Object> response = new HashMap<>();
  67         try {
  68             NameGenResponse resp = service.generateOrUpdateName(request);
  69             return buildResponse(resp);
  70         } catch (NengException e) {
  71             log.warning(e.getMessage());
  72             response.put(ERROR, buildErrorResponse("NELGEN-0003", e.getMessage()));
  73             return buildErrorResponse(response);
  74         } catch (Exception e) {
  75             log.warning(e.getMessage());
  76             response.put(ERROR, buildErrorResponse("err-0500", INTERNAL_ERROR_MSG));
  77             return buildErrorResponse(response);
  78         }
  79     }
  80
  81     /**
  82      * Name removal API.
  83      */
  84     @Override
  85     public Response releaseNetworkElementName(NameGenRequest request) {
  86         NameGenResponse resp;
  87         Map<String, Object> response = new HashMap<>();
  88         try {
  89             resp = service.releaseNetworkElementName(request);
  90             return buildResponse(resp);
  91         } catch (NengException e) {
  92             log.warning(e.getMessage());
  93             response.put(ERROR, buildErrorResponse("NELGEN-0002", e.getMessage()));
  94             return buildErrorResponse(response);
  95         } catch (Exception e) {
  96             log.warning(e.getMessage());
  97             response.put(ERROR, buildErrorResponse("err-0500", INTERNAL_ERROR_MSG));
  98             return buildErrorResponse(response);
  99         }
 100     }
 101
 102     /**
 103      * API to return naming policy cached in this micro-service.
 104      */
 105     @Override
 106     public Response getPolicyResponse(String policyName) throws Exception {
 107         log.info("get-policy: " + policyName);
 108
 109         PolicyDetails policyDetails = service.getPolicyDetails(policyName);
 110         return Response.ok().entity(policyDetails.getPolicyResponse()).build();
 111     }
 112
 113     /**
 114      * API to add a naming policy to the database cache in this micro-service.
 115      */
 116     @Override
 117     public Response addPolicyToDb(Object request) throws Exception {
 118         Map<String, Object> response = new HashMap<>();
 119         try {
 120             service.addPolicy(request);
 121             response.put("status", "Policy added successfully");
 122             return buildResponse(response);
 123         } catch (Exception e) {
 124             log.warning(e.getMessage());
 125             response.put(ERROR, buildErrorResponse("err-0500", e.getMessage()));
 126             return buildErrorResponse(response);
 127         }
 128     }
 129
 130     Response buildResponse(Object response) {
 131         return Response.ok().entity(response).build();
 132     }
 133
 134     Response buildErrorResponse(Map<String, Object> response) {
 135         return Response.status(500).entity(response).build();
 136     }
 137
 138     Map<String,Object> buildErrorResponse(String errorCode, String message) {
 139         Map<String,Object> error = new HashMap<>();
 140         error.put("errorId", errorCode);
 141         error.put("message", message);
 142         return error;
 143     }
 144 }