appc-inbound/appc-design-services/provider/src/main/java/org/onap/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.onap.appc.design.services.impl;
  26
  27 import java.util.concurrent.Future;
  28 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.DbserviceInput;
  29 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.DbserviceOutput;
  30 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.DbserviceOutputBuilder;
  31 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.DesignServicesService;
  32 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.ValidatorInput;
  33 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.ValidatorOutput;
  34 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.ValidatorOutputBuilder;
  35 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.XinterfaceserviceInput;
  36 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.XinterfaceserviceOutput;
  37 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.XinterfaceserviceOutputBuilder;
  38 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.data.DataBuilder;
  39 import org.opendaylight.yang.gen.v1.org.onap.appc.rev170627.status.StatusBuilder;
  40 import org.opendaylight.yangtools.yang.common.RpcResult;
  41 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  42 import org.onap.appc.design.dbervices.DbResponseProcessor;
  43 import org.onap.appc.design.dbervices.DesignDBService;
  44 import org.onap.appc.design.services.util.DesignServiceConstants;
  45 import org.onap.appc.design.validator.ValidatorResponseProcessor;
  46 import org.onap.appc.design.validator.ValidatorService;
  47 import org.onap.appc.design.xinterface.XInterfaceService;
  48 import org.onap.appc.design.xinterface.XResponseProcessor;
  49 import org.slf4j.Logger;
  50 import org.slf4j.LoggerFactory;
  51
  52 import com.google.common.util.concurrent.Futures;
  53
  54 public class DesignServicesImpl implements DesignServicesService {
  55
  56     private static final Logger log = LoggerFactory.getLogger(DesignServicesImpl.class);
  57
  58     @Override
  59     public Future<RpcResult<DbserviceOutput>> dbservice(DbserviceInput input) {
  60
  61         log.info("Received Request: " + input.getDesignRequest().getRequestId() + " Action : " +
  62                 input.getDesignRequest().getAction() + " with Payload :" + input.getDesignRequest().getPayload());
  63
  64
  65         DbserviceOutputBuilder outputBuilder = new DbserviceOutputBuilder();
  66         DataBuilder databuilder = new DataBuilder();
  67         StatusBuilder statusBuilder = new StatusBuilder();
  68
  69         try{
  70             DesignDBService dbservices = DesignDBService.initialise();
  71             DbResponseProcessor responseProcessor = new DbResponseProcessor();
  72             String response = responseProcessor.parseResponse(dbservices.execute(input.getDesignRequest().getAction(), input.getDesignRequest().getPayload(), input.getDesignRequest().getRequestId()), input.getDesignRequest().getAction());
  73             log.info("Response in for Design Service : " + response);
  74             databuilder.setBlock(response);
  75             databuilder.setRequestId(input.getDesignRequest().getRequestId());
  76             statusBuilder.setCode("400");
  77             statusBuilder.setMessage("success");
  78         }
  79         catch(Exception e){
  80             log.error("Error" + e.getMessage());
  81             e.printStackTrace();
  82             statusBuilder.setCode("401");
  83             statusBuilder.setMessage(e.getMessage());
  84         }
  85
  86         outputBuilder.setData(databuilder.build());
  87         outputBuilder.setStatus(statusBuilder.build());
  88
  89         RpcResult<DbserviceOutput> result  = RpcResultBuilder.<DbserviceOutput>status(true).withResult(outputBuilder.build()).build();
  90         return Futures.immediateFuture(result);
  91     }
  92
  93     @Override
  94     public Future<RpcResult<XinterfaceserviceOutput>> xinterfaceservice(XinterfaceserviceInput input) {
  95         log.info("Received Request: " + input.getDesignRequest().getRequestId() + " Action : " +
  96                 input.getDesignRequest().getAction() + " with Payload :" + input.getDesignRequest().getPayload());
  97         XinterfaceserviceOutputBuilder outputBuilder = new XinterfaceserviceOutputBuilder();
  98         DataBuilder databuilder = new DataBuilder();
  99         StatusBuilder statusBuilder = new StatusBuilder();
 100         try {
 101
 102             XInterfaceService xInterfaceService = new XInterfaceService();
 103             XResponseProcessor responseProcessor = new XResponseProcessor();
 104             String response = responseProcessor.parseResponse(xInterfaceService.execute(input.getDesignRequest().getAction(), input.getDesignRequest().getPayload()), input.getDesignRequest().getAction());
 105             databuilder.setBlock(response);
 106             databuilder.setRequestId(input.getDesignRequest().getRequestId());
 107             statusBuilder.setCode("400");
 108             statusBuilder.setMessage("success");
 109         } catch (Exception e) {
 110             e.printStackTrace();
 111             statusBuilder.setCode("401");
 112             statusBuilder.setMessage(e.getMessage());
 113         }
 114         outputBuilder.setData(databuilder.build());
 115         outputBuilder.setStatus(statusBuilder.build());
 116
 117         RpcResult<XinterfaceserviceOutput> result  = RpcResultBuilder.<XinterfaceserviceOutput>status(true).withResult(outputBuilder.build()).build();
 118         return Futures.immediateFuture(result);
 119     }
 120
 121     @Override
 122     public Future<RpcResult<ValidatorOutput>> validator(ValidatorInput input) {
 123         log.info("Received Request: " + input.getDesignRequest().getRequestId() + " Action : " +
 124                 input.getDesignRequest().getAction() + " with Payload :" + input.getDesignRequest().getPayload() +  " and Data Type = " + input.getDesignRequest().getDataType());
 125         ValidatorOutputBuilder outputBuilder = new ValidatorOutputBuilder();
 126         StatusBuilder statusBuilder = new StatusBuilder();
 127
 128
 129         try {
 130             if(input.getDesignRequest().getDataType() == null || input.getDesignRequest().getDataType().isEmpty())
 131                      throw new Exception ("Data Type required for validate Serivce");
 132             if(input.getDesignRequest().getAction()== null || input.getDesignRequest().getAction().isEmpty())
 133                  throw new Exception ("Action required for validate Serivce");
 134
 135
 136             if(! input.getDesignRequest().getDataType().equals(DesignServiceConstants.DATA_TYPE_JSON) &&
 137                     ! input.getDesignRequest().getDataType().equals(DesignServiceConstants.DATA_TYPE_YAML) &&
 138                     ! input.getDesignRequest().getDataType().equals(DesignServiceConstants.DATA_TYPE_XML) &&
 139                     ! input.getDesignRequest().getDataType().equals(DesignServiceConstants.DATA_TYPE_VELOCITY))
 140                 throw new Exception ("Request Data format " + input.getDesignRequest().getDataType()
 141                         + " is not supported by validate Service : Supported data types are : XML, YAML, VELOCITY, JSON ");
 142
 143             ValidatorService validatorService = new ValidatorService();
 144             ValidatorResponseProcessor responseProcessor = new ValidatorResponseProcessor();
 145             String response = validatorService.execute(input.getDesignRequest().getAction(), input.getDesignRequest().getPayload(), input.getDesignRequest().getDataType());
 146             statusBuilder.setCode("400");
 147             statusBuilder.setMessage(response);
 148         } catch (Exception e) {
 149             e.printStackTrace();
 150             statusBuilder.setCode("401");
 151             statusBuilder.setMessage(e.getMessage());
 152         }
 153
 154         outputBuilder.setStatus(statusBuilder.build());
 155
 156         RpcResult<ValidatorOutput> result  = RpcResultBuilder.<ValidatorOutput>status(true).withResult(outputBuilder.build()).build();
 157         return Futures.immediateFuture(result);
 158     }
 159 }