appc-inbound/appc-design-services/provider/src/main/java/org/openecomp/appc/design/services/impl/DesignServicesImpl.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : APPC
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Copyright (C) 2017 Amdocs
   8  * =============================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  *
  21  * ECOMP is a trademark and service mark of AT&T Intellectual Property.
  22  * ============LICENSE_END=========================================================
  23  */
  24
  25 package org.openecomp.appc.design.services.impl;
  26
  27 import java.util.concurrent.Future;
  28 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.DbserviceInput;
  29 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.DbserviceOutput;
  30 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.DbserviceOutputBuilder;
  31 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.DesignServicesService;
  32 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.ValidatorInput;
  33 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.ValidatorOutput;
  34 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.ValidatorOutputBuilder;
  35 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.XinterfaceserviceInput;
  36 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.XinterfaceserviceOutput;
  37 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.XinterfaceserviceOutputBuilder;
  38 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.data.DataBuilder;
  39 import org.opendaylight.yang.gen.v1.org.openecomp.appc.rev170627.status.StatusBuilder;
  40 import org.opendaylight.yangtools.yang.common.RpcResult;
  41 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  42 import org.openecomp.appc.design.dbervices.DbResponseProcessor;
  43 import org.openecomp.appc.design.dbervices.DesignDBService;
  44 import org.openecomp.appc.design.services.util.DesignServiceConstants;
  45 import org.openecomp.appc.design.validator.ValidatorResponseProcessor;
  46 import org.openecomp.appc.design.validator.ValidatorService;
  47 import org.openecomp.appc.design.xinterface.XInterfaceService;
  48 import org.openecomp.appc.design.xinterface.XResponseProcessor;
  49 import org.slf4j.Logger;
  50 import org.slf4j.LoggerFactory;
  51
  52 import com.google.common.collect.Lists;
  53 import com.google.common.util.concurrent.Futures;
  54
  55 public class DesignServicesImpl implements DesignServicesService {
  56
  57     private static final Logger log = LoggerFactory.getLogger(DesignServicesImpl.class);
  58
  59     @Override
  60     public Future<RpcResult<DbserviceOutput>> dbservice(DbserviceInput input) {
  61
  62         log.info("Received Request: " + input.getDesignRequest().getRequestId() + " Action : " +
  63                 input.getDesignRequest().getAction() + " with Payload :" + input.getDesignRequest().getPayload());
  64
  65
  66         DbserviceOutputBuilder outputBuilder = new DbserviceOutputBuilder();
  67         DataBuilder databuilder = new DataBuilder();
  68         StatusBuilder statusBuilder = new StatusBuilder();
  69
  70         try{
  71             DesignDBService dbservices = DesignDBService.initialise();
  72             DbResponseProcessor responseProcessor = new DbResponseProcessor();
  73             String response = responseProcessor.parseResponse(dbservices.execute(input.getDesignRequest().getAction(), input.getDesignRequest().getPayload(), input.getDesignRequest().getRequestId()), input.getDesignRequest().getAction());
  74             log.info("Response in for Design Service : " + response);
  75             databuilder.setBlock(response);
  76             databuilder.setRequestId(input.getDesignRequest().getRequestId());
  77             statusBuilder.setCode("400");
  78             statusBuilder.setMessage("success");
  79         }
  80         catch(Exception e){
  81             log.error("Error" + e.getMessage());
  82             e.printStackTrace();
  83             statusBuilder.setCode("401");
  84             statusBuilder.setMessage(e.getMessage());
  85         }
  86
  87         outputBuilder.setData(databuilder.build());
  88         outputBuilder.setStatus(statusBuilder.build());
  89
  90         RpcResult<DbserviceOutput> result  = RpcResultBuilder.<DbserviceOutput>status(true).withResult(outputBuilder.build()).build();
  91         return Futures.immediateFuture(result);
  92     }
  93
  94     @Override
  95     public Future<RpcResult<XinterfaceserviceOutput>> xinterfaceservice(XinterfaceserviceInput input) {
  96         log.info("Received Request: " + input.getDesignRequest().getRequestId() + " Action : " +
  97                 input.getDesignRequest().getAction() + " with Payload :" + input.getDesignRequest().getPayload());
  98         XinterfaceserviceOutputBuilder outputBuilder = new XinterfaceserviceOutputBuilder();
  99         DataBuilder databuilder = new DataBuilder();
 100         StatusBuilder statusBuilder = new StatusBuilder();
 101         try {
 102
 103             XInterfaceService xInterfaceService = new XInterfaceService();
 104             XResponseProcessor responseProcessor = new XResponseProcessor();
 105             String response = responseProcessor.parseResponse(xInterfaceService.execute(input.getDesignRequest().getAction(), input.getDesignRequest().getPayload()), input.getDesignRequest().getAction());
 106             databuilder.setBlock(response);
 107             databuilder.setRequestId(input.getDesignRequest().getRequestId());
 108             statusBuilder.setCode("400");
 109             statusBuilder.setMessage("success");
 110         } catch (Exception e) {
 111             e.printStackTrace();
 112             statusBuilder.setCode("401");
 113             statusBuilder.setMessage(e.getMessage());
 114         }
 115         outputBuilder.setData(databuilder.build());
 116         outputBuilder.setStatus(statusBuilder.build());
 117
 118         RpcResult<XinterfaceserviceOutput> result  = RpcResultBuilder.<XinterfaceserviceOutput>status(true).withResult(outputBuilder.build()).build();
 119         return Futures.immediateFuture(result);
 120     }
 121
 122     @Override
 123     public Future<RpcResult<ValidatorOutput>> validator(ValidatorInput input) {
 124         log.info("Received Request: " + input.getDesignRequest().getRequestId() + " Action : " +
 125                 input.getDesignRequest().getAction() + " with Payload :" + input.getDesignRequest().getPayload() +  " and Data Type = " + input.getDesignRequest().getDataType());
 126         ValidatorOutputBuilder outputBuilder = new ValidatorOutputBuilder();
 127         StatusBuilder statusBuilder = new StatusBuilder();
 128
 129
 130         try {
 131             if(input.getDesignRequest().getDataType() == null || input.getDesignRequest().getDataType().isEmpty())
 132                      throw new Exception ("Data Type required for validate Serivce");
 133             if(input.getDesignRequest().getAction()== null || input.getDesignRequest().getAction().isEmpty())
 134                  throw new Exception ("Action required for validate Serivce");
 135
 136
 137             if(! input.getDesignRequest().getDataType().equals(DesignServiceConstants.DATA_TYPE_JSON) &&
 138                     ! input.getDesignRequest().getDataType().equals(DesignServiceConstants.DATA_TYPE_YAML) &&
 139                     ! input.getDesignRequest().getDataType().equals(DesignServiceConstants.DATA_TYPE_XML) &&
 140                     ! input.getDesignRequest().getDataType().equals(DesignServiceConstants.DATA_TYPE_VELOCITY))
 141                 throw new Exception ("Request Data format " + input.getDesignRequest().getDataType()
 142                         + " is not supported by validate Service : Supported data types are : XML, YAML, VELOCITY, JSON ");
 143
 144             ValidatorService validatorService = new ValidatorService();
 145             ValidatorResponseProcessor responseProcessor = new ValidatorResponseProcessor();
 146             String response = validatorService.execute(input.getDesignRequest().getAction(), input.getDesignRequest().getPayload(), input.getDesignRequest().getDataType());
 147             statusBuilder.setCode("400");
 148             statusBuilder.setMessage(response);
 149         } catch (Exception e) {
 150             e.printStackTrace();
 151             statusBuilder.setCode("401");
 152             statusBuilder.setMessage(e.getMessage());
 153         }
 154
 155         outputBuilder.setStatus(statusBuilder.build());
 156
 157         RpcResult<ValidatorOutput> result  = RpcResultBuilder.<ValidatorOutput>status(true).withResult(outputBuilder.build()).build();
 158         return Futures.immediateFuture(result);
 159     }
 160 }