vid-app-common/src/main/java/org/onap/vid/services/ExternalWorkflowsServiceImpl.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * VID
   4  * ================================================================================
   5  * Copyright (C) 2017 - 2019 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.vid.services;
  22
  23 import java.util.List;
  24 import org.onap.vid.model.SOWorkflow;
  25 import org.onap.vid.model.SOWorkflowParameterDefinitions;
  26 import org.onap.vid.model.SOWorkflows;
  27 import org.onap.vid.mso.MsoResponseWrapper2;
  28 import org.onap.vid.mso.rest.MockedWorkflowsRestClient;
  29 import org.springframework.beans.factory.annotation.Autowired;
  30 import org.springframework.stereotype.Service;
  31
  32 @Service
  33 public class ExternalWorkflowsServiceImpl implements ExternalWorkflowsService {
  34
  35     private MockedWorkflowsRestClient mockedWorkflowsRestClient;
  36
  37     @Autowired
  38     public ExternalWorkflowsServiceImpl(MockedWorkflowsRestClient mockedWorkflowsRestClient) {
  39         this.mockedWorkflowsRestClient = mockedWorkflowsRestClient;
  40     }
  41
  42     @Override
  43     public List<SOWorkflow> getWorkflows(String vnfModelId) {
  44         MsoResponseWrapper2<SOWorkflows> msoResponse = mockedWorkflowsRestClient.getWorkflows(vnfModelId);
  45         validateSOResponse(msoResponse, SOWorkflows.class);
  46         return convertMsoResponseToWorkflowList(msoResponse);
  47     }
  48
  49     @Override
  50     public SOWorkflowParameterDefinitions getWorkflowParameterDefinitions(Long workflowId) {
  51         MsoResponseWrapper2<SOWorkflowParameterDefinitions> msoResponse = mockedWorkflowsRestClient.getWorkflowParameterDefinitions(workflowId);
  52         validateSOResponse(msoResponse, SOWorkflowParameterDefinitions.class);
  53         return (SOWorkflowParameterDefinitions) msoResponse.getEntity();
  54     }
  55
  56     private List<SOWorkflow> convertMsoResponseToWorkflowList(MsoResponseWrapper2<SOWorkflows> msoResponse) {
  57         SOWorkflows soWorkflows = (SOWorkflows) msoResponse.getEntity();
  58         return soWorkflows.getWorkflows();
  59     }
  60
  61     private void validateSOResponse(MsoResponseWrapper2 response, Class<?> expectedResponseClass){
  62         if (response.getStatus() >= 400 || !expectedResponseClass.isInstance(response.getEntity())) {
  63             throw new BadResponseFromMso(response);
  64         }
  65     }
  66
  67     public static class BadResponseFromMso extends RuntimeException {
  68         private final MsoResponseWrapper2<?> msoResponse;
  69
  70         BadResponseFromMso(MsoResponseWrapper2<?> msoResponse) {
  71             this.msoResponse = msoResponse;
  72         }
  73
  74         public MsoResponseWrapper2<?> getMsoResponse() {
  75             return msoResponse;
  76         }
  77     }
  78
  79 }