130f5500176f93ceecfbf1f7e89cfcb3a2d6f7a6
[ccsdk/oran.git] /
1 /*-
2  * ========================LICENSE_START=================================
3  * ONAP : ccsdk oran
4  * ======================================================================
5  * Copyright (C) 2019-2020 Nordix Foundation. 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.ccsdk.oran.a1policymanagementservice.clients;
22
23 import java.util.Arrays;
24 import java.util.List;
25
26 import org.onap.ccsdk.oran.a1policymanagementservice.configuration.RicConfig;
27 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Policy;
28
29 import reactor.core.publisher.Flux;
30 import reactor.core.publisher.Mono;
31
32 /**
33  * Client for accessing standard A1 REST API version 1.1
34  */
35 public class StdA1ClientVersion1 implements A1Client {
36
37     public static class UriBuilder implements A1UriBuilder {
38
39         private final RicConfig ricConfig;
40
41         public UriBuilder(RicConfig ricConfig) {
42             this.ricConfig = ricConfig;
43         }
44
45         /**
46          * /A1-P/v1/policies/{policyId}
47          */
48         @Override
49         public String createPutPolicyUri(String type, String policyId, String statusNotificationUri) {
50             return policiesBaseUri() + policyId;
51         }
52
53         /**
54          * /A1-P/v1/policies
55          */
56         @Override
57         public String createGetPolicyIdsUri(String type) {
58             return baseUri() + "/policies";
59         }
60
61         /**
62          * /A1-P/v1/policies/{policyId}
63          */
64         @Override
65         public String createDeleteUri(String type, String policyId) {
66             return policiesBaseUri() + policyId;
67         }
68
69         /**
70          * /A1-P/v1/policies/{policyId}/status
71          */
72         @Override
73         public String createGetPolicyStatusUri(String type, String policyId) {
74             return policiesBaseUri() + policyId + "/status";
75         }
76
77         private String baseUri() {
78             return ricConfig.baseUrl() + "/A1-P/v1";
79         }
80
81         private String policiesBaseUri() {
82             return createGetPolicyIdsUri("") + "/";
83         }
84
85         @Override
86         public String createPolicyTypesUri() {
87             throw new NullPointerException("Not supported URI");
88         }
89
90         @Override
91         public String createGetSchemaUri(String type) {
92             throw new NullPointerException("Not supported URI");
93         }
94     }
95
96     private final AsyncRestClient restClient;
97     private final UriBuilder uri;
98
99     public StdA1ClientVersion1(RicConfig ricConfig, AsyncRestClientFactory restClientFactory) {
100         this(restClientFactory.createRestClient(""), ricConfig);
101     }
102
103     public StdA1ClientVersion1(AsyncRestClient restClient, RicConfig ricConfig) {
104         this.restClient = restClient;
105         this.uri = new UriBuilder(ricConfig);
106     }
107
108     @Override
109     public Mono<List<String>> getPolicyIdentities() {
110         return getPolicyIds() //
111                 .collectList();
112     }
113
114     @Override
115     public Mono<String> putPolicy(Policy policy) {
116         return restClient.put(
117                 uri.createPutPolicyUri(policy.getType().getId(), policy.getId(), policy.getStatusNotificationUri()),
118                 policy.getJson());
119     }
120
121     @Override
122     public Mono<List<String>> getPolicyTypeIdentities() {
123         return Mono.just(Arrays.asList(""));
124     }
125
126     @Override
127     public Mono<String> getPolicyTypeSchema(String policyTypeId) {
128         return Mono.just("{}");
129     }
130
131     @Override
132     public Mono<String> deletePolicy(Policy policy) {
133         return deletePolicyById(policy.getId());
134     }
135
136     @Override
137     public Flux<String> deleteAllPolicies() {
138         return getPolicyIds() //
139                 .flatMap(this::deletePolicyById); //
140     }
141
142     @Override
143     public Mono<A1ProtocolType> getProtocolVersion() {
144         return getPolicyIdentities() //
145                 .flatMap(x -> Mono.just(A1ProtocolType.STD_V1_1));
146     }
147
148     @Override
149     public Mono<String> getPolicyStatus(Policy policy) {
150         return restClient.get(uri.createGetPolicyStatusUri(policy.getType().getId(), policy.getId()));
151     }
152
153     private Flux<String> getPolicyIds() {
154         return restClient.get(uri.createGetPolicyIdsUri("")) //
155                 .flatMapMany(A1AdapterJsonHelper::parseJsonArrayOfString);
156     }
157
158     private Mono<String> deletePolicyById(String policyId) {
159         return restClient.delete(uri.createDeleteUri("", policyId));
160     }
161 }