src/main/java/org/onap/nbi/apis/serviceinventory/ServiceInventoryService.java

   1 /**
   2  *
   3  *     Copyright (c) 2017 Orange.  All rights reserved.
   4  *
   5  *     Licensed under the Apache License, Version 2.0 (the "License");
   6  *     you may not use this file except in compliance with the License.
   7  *     You may obtain a copy of the License at
   8  *
   9  *         http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *     Unless required by applicable law or agreed to in writing, software
  12  *     distributed under the License is distributed on an "AS IS" BASIS,
  13  *     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *     See the License for the specific language governing permissions and
  15  *     limitations under the License.
  16  */
  17 package org.onap.nbi.apis.serviceinventory;
  18
  19 import java.util.ArrayList;
  20 import java.util.LinkedHashMap;
  21 import java.util.List;
  22 import org.onap.nbi.apis.serviceinventory.jolt.FindServiceInventoryJsonTransformer;
  23 import org.onap.nbi.apis.serviceinventory.jolt.GetServiceInventoryJsonTransformer;
  24 import org.onap.nbi.exceptions.BackendFunctionalException;
  25 import org.springframework.beans.factory.annotation.Autowired;
  26 import org.springframework.http.HttpStatus;
  27 import org.springframework.stereotype.Service;
  28 import org.springframework.util.MultiValueMap;
  29 import org.springframework.util.StringUtils;
  30
  31 @Service
  32 public class ServiceInventoryService {
  33
  34     @Autowired
  35     NbiClient nbiClient;
  36
  37     @Autowired
  38     AaiClient aaiClient;
  39
  40     @Autowired
  41     GetServiceInventoryJsonTransformer getServiceInventoryJsonTransformer;
  42
  43     @Autowired
  44     FindServiceInventoryJsonTransformer findServiceInventoryJsonTransformer;
  45
  46     public LinkedHashMap get(String serviceId, MultiValueMap<String, String> params) {
  47
  48         String clientId = params.getFirst("relatedParty.id");
  49         String serviceSpecId = params.getFirst("serviceSpecification.id");
  50         String serviceSpecName = params.getFirst("serviceSpecification.name");
  51
  52         if (StringUtils.isEmpty(serviceSpecId) && StringUtils.isEmpty(serviceSpecName)) {
  53             throw new BackendFunctionalException(HttpStatus.NOT_FOUND,
  54                     "serviceSpecName or serviceSpecId must be provided");
  55         }
  56
  57         String customerId = getCustomerId(clientId);
  58         String serviceName = getServiceName(serviceSpecName, serviceSpecId);
  59         LinkedHashMap serviceResponse = aaiClient.getCatalogService(customerId, serviceName, serviceId);
  60
  61         if (serviceResponse != null) {
  62             addVnfsToResponse(serviceResponse);
  63             LinkedHashMap serviceInventoryResponse =
  64                     (LinkedHashMap) getServiceInventoryJsonTransformer.transform(serviceResponse);
  65             addRelatedPartyId(customerId, serviceInventoryResponse);
  66             return serviceInventoryResponse;
  67         } else {
  68             throw new BackendFunctionalException(HttpStatus.NOT_FOUND, "no catalog service found");
  69         }
  70
  71     }
  72
  73
  74     private String getCustomerId(String clientId) {
  75
  76         if (StringUtils.isEmpty(clientId)) {
  77             return "generic";
  78         } else {
  79             return clientId;
  80         }
  81
  82     }
  83
  84     private String getServiceName(String serviceSpecificationName, String serviceSpecificationId) {
  85
  86         if (StringUtils.isEmpty(serviceSpecificationName)) {
  87             LinkedHashMap serviceSpecification = nbiClient.getServiceSpecification(serviceSpecificationId);
  88             return (String) serviceSpecification.get("name");
  89         } else {
  90             return serviceSpecificationName;
  91         }
  92
  93     }
  94
  95     private void addRelatedPartyId(String customerId, LinkedHashMap serviceInventoryResponse) {
  96
  97         LinkedHashMap relatedParty = (LinkedHashMap) serviceInventoryResponse.get("relatedParty");
  98         relatedParty.put("id", customerId);
  99
 100     }
 101
 102     private void addVnfsToResponse(LinkedHashMap serviceResponse) {
 103
 104         List<LinkedHashMap> vnfs = new ArrayList<>();
 105         LinkedHashMap relationShip = (LinkedHashMap) serviceResponse.get("relationship-list");
 106         List<LinkedHashMap> relationsList = (List<LinkedHashMap>) relationShip.get("relationship");
 107         for (LinkedHashMap relation : relationsList) {
 108             String relatedLink = (String) relation.get("related-link");
 109             LinkedHashMap vnf = aaiClient.getVNF(relatedLink);
 110             if (vnf != null) {
 111                 vnfs.add(vnf);
 112             }
 113         }
 114         serviceResponse.put("vnfs", vnfs);
 115
 116     }
 117
 118
 119     public List<LinkedHashMap> find(MultiValueMap<String, String> params) {
 120
 121         String clientId = params.getFirst("relatedParty.id");
 122         String serviceSpecId = params.getFirst("serviceSpecification.id");
 123         String serviceSpecName = params.getFirst("serviceSpecification.name");
 124         String customerId = getCustomerId(clientId);
 125         String serviceName;
 126         List<LinkedHashMap> serviceInstances = new ArrayList<>();
 127         if (StringUtils.isEmpty(serviceSpecId) && StringUtils.isEmpty(serviceSpecName)) {
 128             LinkedHashMap servicesInAaiForCustomer = aaiClient.getServicesInAaiForCustomer(customerId);
 129             List<LinkedHashMap> servicesInAAI =
 130                     (List<LinkedHashMap>) servicesInAaiForCustomer.get("service-subscription");
 131             for (LinkedHashMap service : servicesInAAI) {
 132                 String serviceType = (String) service.get("service-type");
 133                 buildServiceInstances(serviceInstances, customerId, serviceType);
 134             }
 135         } else {
 136             serviceName = getServiceName(serviceSpecName, serviceSpecId);
 137             buildServiceInstances(serviceInstances, customerId, serviceName);
 138         }
 139
 140         List<LinkedHashMap> serviceInventoryResponse =
 141                 (List<LinkedHashMap>) findServiceInventoryJsonTransformer.transform(serviceInstances);
 142         for (LinkedHashMap serviceInventory : serviceInventoryResponse) {
 143             LinkedHashMap party = (LinkedHashMap) serviceInventory.get("relatedParty");
 144             party.put("id", customerId);
 145         }
 146         return serviceInventoryResponse;
 147
 148     }
 149
 150     private void buildServiceInstances(List<LinkedHashMap> serviceInstances, String customerId, String serviceType) {
 151
 152         LinkedHashMap serviceInstancesInAaiForCustomer =
 153                 aaiClient.getServiceInstancesInAaiForCustomer(customerId, serviceType);
 154         List<LinkedHashMap> serviceInstancesForServiceType =
 155                 (List<LinkedHashMap>) serviceInstancesInAaiForCustomer.get("service-instance");
 156
 157         // add service type for jolt
 158         for (LinkedHashMap serviceInstanceForServiceType : serviceInstancesForServiceType) {
 159             serviceInstanceForServiceType.put("service-type", serviceType);
 160         }
 161         serviceInstances.addAll(serviceInstancesForServiceType);
 162
 163     }
 164
 165 }