2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2021 Samsung Electronics Co. Ltd. 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.so.adapters.cnf.service.aai;
23 import org.apache.http.client.utils.URIBuilder;
24 import org.onap.so.adapters.cnf.model.instantiation.AaiRequest;
25 import org.onap.so.adapters.cnf.model.statuscheck.K8sRbInstanceGvk;
26 import org.onap.so.adapters.cnf.model.statuscheck.K8sRbInstanceResourceStatus;
27 import org.onap.so.adapters.cnf.model.statuscheck.K8sStatus;
28 import org.onap.so.adapters.cnf.model.statuscheck.K8sStatusMetadata;
29 import org.springframework.stereotype.Component;
31 import java.net.URISyntaxException;
32 import java.util.ArrayList;
33 import java.util.List;
37 public class AaiResponseParser {
39 private final static String INSTANCE_ID = "k8splugin.io/rb-instance-id";
41 private final AaiIdGeneratorService aaiIdGeneratorService;
43 public AaiResponseParser(AaiIdGeneratorService aaiIdGeneratorService) {
44 this.aaiIdGeneratorService = aaiIdGeneratorService;
47 KubernetesResource parse(K8sRbInstanceResourceStatus status, AaiRequest aaiRequest) {
48 KubernetesResource result = new KubernetesResource();
49 K8sRbInstanceGvk gvk = status.getGvk();
50 K8sStatus k8sStatus = status.getStatus();
51 K8sStatusMetadata metadata = k8sStatus.getK8sStatusMetadata();
52 String id = aaiIdGeneratorService.generateId(status, aaiRequest);
54 result.setName(status.getName());
55 result.setGroup(gvk.getGroup());
56 result.setVersion(gvk.getVersion());
57 result.setKind(gvk.getKind());
58 result.setNamespace(metadata.getNamespace());
59 List<String> labels = parseLabels(metadata.getLabels());
60 result.setLabels(labels);
61 URIBuilder uriBuilder = new URIBuilder();
66 .setHost("so-cnf-adapter")
68 .setPath("/api/cnf-adapter/v1/instance/" + aaiRequest.getInstanceId() + "/query")
69 .setParameter("ApiVersion", gvk.getVersion())
70 .setParameter("Kind", gvk.getKind())
71 .setParameter("Name", status.getName())
72 .setParameter("Namespace", metadata.getNamespace())
75 } catch (URISyntaxException e) {
76 throw new RuntimeException(e);
78 result.setK8sResourceSelfLink(selfLink);
82 private List<String> parseLabels(Map<String, String> labels) {
83 List<String> result = new ArrayList<>();
84 labels.entrySet().stream()
85 .filter(i -> i.getKey().equals(INSTANCE_ID))
87 .ifPresent(i -> addInstanceIdFist(i, result));
88 labels.entrySet().stream()
89 .filter(i -> !i.getKey().equals(INSTANCE_ID))
91 result.add(i.getKey());
92 result.add(i.getValue());
97 private void addInstanceIdFist(Map.Entry<String, String> instanceId, List<String> result) {
98 result.add(instanceId.getKey());
99 result.add(instanceId.getValue());