2 * ============LICENSE_START=======================================================
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.onap.vid.aai.model;
24 import com.google.common.collect.ImmutableList;
25 import org.onap.vid.aai.AaiResponse;
27 import java.util.LinkedList;
28 import java.util.List;
29 import java.util.Optional;
30 import java.util.function.Predicate;
31 import java.util.stream.Collectors;
33 public class PortDetailsTranslator {
35 public static class PortDetailsOk implements PortDetails {
37 private final String interfaceId;
38 private final String interfaceName;
39 private final boolean isPortMirrored;
41 public PortDetailsOk(String interfaceId, String interfaceName, boolean isPortMirrored) {
42 this.interfaceId = interfaceId;
43 this.interfaceName = interfaceName;
44 this.isPortMirrored = isPortMirrored;
47 public String getInterfaceId() {
51 public String getInterfaceName() {
55 public boolean getIsPortMirrored() {
56 return isPortMirrored;
60 public interface PortDetails {
63 public static class PortDetailsError implements PortDetails {
64 private final String errorDescription;
65 private final String rawAaiResponse;
67 public PortDetailsError(String errorDescription, String rawAaiResponse) {
68 this.errorDescription = errorDescription;
69 this.rawAaiResponse = rawAaiResponse;
72 public String getErrorDescription() {
73 return errorDescription;
76 public String getRawAaiResponse() {
77 return rawAaiResponse;
81 public static PortDetails extractPortDetailsFromProperties(Properties properties, String rawPayload) {
82 List<String> errorDescriptions = new LinkedList<>();
83 describeIfNullOrEmpty("interface-id", properties.getInterfaceId(), errorDescriptions);
84 describeIfNullOrEmpty("interface-name", properties.getInterfaceName(), errorDescriptions);
85 describeIfNullOrEmpty("is-port-mirrored", properties.getIsPortMirrored(), errorDescriptions);
87 if (errorDescriptions.isEmpty()) {
88 return new PortDetailsOk(properties.getInterfaceId(), properties.getInterfaceName(), properties.getIsPortMirrored());
90 return new PortDetailsError(String.join(" ", errorDescriptions), rawPayload);
94 private static void describeIfNullOrEmpty(String name, Object value, List<String> errorDescriptions) {
96 errorDescriptions.add("Value of '" + name + "' is missing.");
97 } else if (value.toString().isEmpty()) {
98 errorDescriptions.add("Value of '" + name + "' is empty.");
102 private static Optional<List<PortDetails>> extractErrorResponseIfHttpError(AaiResponse aaiResponse, String rawPayload) {
103 if (aaiResponse.getHttpCode() != org.springframework.http.HttpStatus.OK.value()) {
104 final String errorMessage = aaiResponse.getErrorMessage();
105 return Optional.of(ImmutableList.of(new PortDetailsError(
106 "Got " + aaiResponse.getHttpCode() + " from aai",
107 errorMessage != null ? errorMessage : rawPayload)
110 return Optional.empty();
114 public List<PortDetails> extractPortDetailsInternal(CustomQuerySimpleResult aaiGetPortsResponse, String rawPayload) {
115 List<SimpleResult> filteredResult = getFilteredPortList(aaiGetPortsResponse.getResults());
117 return filteredResult.stream()
118 .map(SimpleResult::getProperties)
119 .map(p -> extractPortDetailsFromProperties(p, rawPayload))
120 .collect(Collectors.toList());
123 public List<SimpleResult> getFilteredPortList(List<SimpleResult> results) {
124 final String LINTERFACE = "l-interface";
126 final Predicate<SimpleResult> ifIsPort = (SimpleResult r) -> LINTERFACE.equals(r.getNodeType());
127 Predicate<SimpleResult> ifIsSource = getIsSourcePredicate();
129 return results.stream()
132 .collect(Collectors.toList());
135 private Predicate<SimpleResult> getIsSourcePredicate() {
136 final String PORT_LABEL = "org.onap.relationships.inventory.Source";
137 return (SimpleResult r) -> r.getRelatedTo().stream()
138 .anyMatch(relatedTo -> PORT_LABEL.equalsIgnoreCase(relatedTo.getRelationshipLabel()));
141 public List<PortDetails> extractPortDetails(AaiResponse<CustomQuerySimpleResult> aaiGetPortsResponse, String rawPayload) {
142 return extractErrorResponseIfHttpError(aaiGetPortsResponse, rawPayload).orElseGet(() -> extractPortDetailsInternal(aaiGetPortsResponse.getT(), rawPayload));