d83b8e052e900d63297395497f584cb31a14c5cd
[so/adapters/so-cnf-adapter.git] /
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP - SO
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
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.so.adapters.cnf.service.aai;
22
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;
30
31 import java.net.URISyntaxException;
32 import java.util.ArrayList;
33 import java.util.List;
34 import java.util.Map;
35
36 @Component
37 public class AaiResponseParser {
38
39     private final static String INSTANCE_ID = "k8splugin.io/rb-instance-id";
40
41     private final AaiIdGeneratorService aaiIdGeneratorService;
42
43     public AaiResponseParser(AaiIdGeneratorService aaiIdGeneratorService) {
44         this.aaiIdGeneratorService = aaiIdGeneratorService;
45     }
46
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);
53         result.setId(id);
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();
62         String selfLink;
63         try {
64             selfLink = uriBuilder
65                     .setScheme("http")
66                     .setHost("so-cnf-adapter")
67                     .setPort(8090)
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())
73                     .build()
74                     .toString();
75         } catch (URISyntaxException e) {
76             throw new RuntimeException(e);
77         }
78         result.setK8sResourceSelfLink(selfLink);
79         return result;
80     }
81
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))
86                 .findFirst()
87                 .ifPresent(i -> addInstanceIdFist(i, result));
88         labels.entrySet().stream()
89                 .filter(i -> !i.getKey().equals(INSTANCE_ID))
90                 .forEach(i -> {
91                     result.add(i.getKey());
92                     result.add(i.getValue());
93                 });
94         return result;
95     }
96
97     private void addInstanceIdFist(Map.Entry<String, String> instanceId, List<String> result) {
98         result.add(instanceId.getKey());
99         result.add(instanceId.getValue());
100     }
101 }