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

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