gerrit.onap Code Review - ccsdk/oran.git/blob

   1 /*-
   2  * ========================LICENSE_START=================================
   3  * ONAP : ccsdk oran
   4  * ======================================================================
   5  * Copyright (C) 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.lang.invoke.MethodHandles;
  24 import java.util.List;
  25
  26 import org.json.JSONObject;
  27 import org.onap.ccsdk.oran.a1policymanagementservice.configuration.RicConfig;
  28 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Policy;
  29 import org.slf4j.Logger;
  30 import org.slf4j.LoggerFactory;
  31 import org.springframework.web.util.DefaultUriBuilderFactory;
  32 import org.springframework.web.util.UriBuilderFactory;
  33
  34 import reactor.core.publisher.Flux;
  35 import reactor.core.publisher.Mono;
  36
  37 /**
  38  * Client for accessing ORAN A1-P Vesion 2.0 REST API
  39  */
  40 @SuppressWarnings("squid:S2629") // Invoke method(s) only conditionally
  41 public class StdA1ClientVersion2 implements A1Client {
  42     static final int CONCURRENCY_RIC = 1; // How many paralell requests that is sent to one NearRT RIC
  43
  44     public static class Factory implements A1Client.Factory {
  45         @Override
  46         public A1Client create(RicConfig ricConfig, AsyncRestClientFactory restClientFactory) {
  47             return new StdA1ClientVersion2(ricConfig, restClientFactory);
  48         }
  49     }
  50
  51     public static class OranV2UriBuilder implements A1UriBuilder {
  52         private final RicConfig ricConfig;
  53
  54         public OranV2UriBuilder(RicConfig ricConfig) {
  55             this.ricConfig = ricConfig;
  56         }
  57
  58         @Override
  59         public String createPutPolicyUri(String type, String policyId, String statusNotificationUri) {
  60             String policyUri = createPolicyUri(type, policyId);
  61             if (statusNotificationUri.isEmpty()) {
  62                 return policyUri;
  63             }
  64             UriBuilderFactory builderFactory = new DefaultUriBuilderFactory(policyUri);
  65             return builderFactory.builder() //
  66                     .queryParam("notificationDestination", statusNotificationUri) //
  67                     .build() //
  68                     .normalize() //
  69                     .toASCIIString();
  70         }
  71
  72         /**
  73          * /A1-P/v2/policytypes/{policy_type_id}/policies
  74          */
  75         @Override
  76         public String createGetPolicyIdsUri(String type) {
  77             return createPolicyTypeUri(type) + "/policies";
  78         }
  79
  80         @Override
  81         public String createDeleteUri(String type, String policyId) {
  82             return createPolicyUri(type, policyId);
  83         }
  84
  85         /**
  86          * /A1-P/v2/policytypes/{policy_type_id}/policies/{policy_instance_id}/status
  87          */
  88         @Override
  89         public String createGetPolicyStatusUri(String type, String policyId) {
  90             return createPolicyUri(type, policyId) + "/status";
  91         }
  92
  93         /**
  94          * /A1-P/v2/policytypes/{policy_type_id}
  95          */
  96         @Override
  97         public String createGetSchemaUri(String type) {
  98             return this.createPolicyTypeUri(type);
  99         }
 100
 101         /**
 102          * /A1-P/v2/policytypes/{policy_type_id}
 103          */
 104         @Override
 105         public String createPolicyTypesUri() {
 106             return baseUri() + "/policytypes";
 107         }
 108
 109         /**
 110          * /A1-P/v2/policytypes/{policy_type_id}/policies/{policy_instance_id}
 111          */
 112         private String createPolicyUri(String type, String id) {
 113             return createPolicyTypeUri(type) + "/policies/" + id;
 114         }
 115
 116         /**
 117          * /A1-P/v2/policytypes/{policy_type_id}
 118          */
 119         private String createPolicyTypeUri(String type) {
 120             return createPolicyTypesUri() + "/" + type;
 121         }
 122
 123         private String baseUri() {
 124             return ricConfig.baseUrl() + "/A1-P/v2";
 125         }
 126     }
 127
 128     private static final String TITLE = "title";
 129     private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
 130     private final AsyncRestClient restClient;
 131     private final OranV2UriBuilder uriBuiler;
 132
 133     public StdA1ClientVersion2(RicConfig ricConfig, AsyncRestClientFactory restClientFactory) {
 134         this(ricConfig, restClientFactory.createRestClientUseHttpProxy(""));
 135     }
 136
 137     public StdA1ClientVersion2(RicConfig ricConfig, AsyncRestClient restClient) {
 138         this.restClient = restClient;
 139         logger.debug("OscA1Client for ric: {}", ricConfig.ricId());
 140
 141         uriBuiler = new OranV2UriBuilder(ricConfig);
 142     }
 143
 144     public static Mono<String> extractPolicySchema(String policyTypeResponse, String policyTypeId) {
 145         try {
 146             JSONObject obj = new JSONObject(policyTypeResponse);
 147             JSONObject schemaObj = obj.getJSONObject("policySchema");
 148             schemaObj.put(TITLE, policyTypeId);
 149             return Mono.just(schemaObj.toString());
 150         } catch (Exception e) {
 151             String exceptionString = e.toString();
 152             logger.error("Unexpected response for policy type: {}, exception: {}", policyTypeResponse, exceptionString);
 153             return Mono.error(e);
 154         }
 155     }
 156
 157     @Override
 158     public Mono<List<String>> getPolicyTypeIdentities() {
 159         return getPolicyTypeIds() //
 160                 .collectList();
 161     }
 162
 163     @Override
 164     public Mono<List<String>> getPolicyIdentities() {
 165         return getPolicyTypeIds() //
 166                 .flatMap(this::getPolicyIdentitiesByType) //
 167                 .collectList();
 168     }
 169
 170     @Override
 171     public Mono<String> getPolicyTypeSchema(String policyTypeId) {
 172         String schemaUri = uriBuiler.createGetSchemaUri(policyTypeId);
 173         return restClient.get(schemaUri) //
 174                 .flatMap(response -> extractPolicySchema(response, policyTypeId));
 175     }
 176
 177     @Override
 178     public Mono<String> putPolicy(Policy policy) {
 179         String policyUri = this.uriBuiler.createPutPolicyUri(policy.getType().getId(), policy.getId(),
 180                 policy.getStatusNotificationUri());
 181         return restClient.put(policyUri, policy.getJson());
 182     }
 183
 184     @Override
 185     public Mono<String> deletePolicy(Policy policy) {
 186         return deletePolicyById(policy.getType().getId(), policy.getId());
 187     }
 188
 189     @Override
 190     public Mono<A1ProtocolType> getProtocolVersion() {
 191         return restClient.get(uriBuiler.createPolicyTypesUri()) //
 192                 .flatMap(notUsed -> Mono.just(A1ProtocolType.STD_V2_0_0));
 193     }
 194
 195     @Override
 196     public Flux<String> deleteAllPolicies() {
 197         return getPolicyTypeIds() //
 198                 .flatMap(this::deletePoliciesForType, CONCURRENCY_RIC);
 199     }
 200
 201     @Override
 202     public Mono<String> getPolicyStatus(Policy policy) {
 203         String statusUri = uriBuiler.createGetPolicyStatusUri(policy.getType().getId(), policy.getId());
 204         return restClient.get(statusUri);
 205
 206     }
 207
 208     private Flux<String> getPolicyTypeIds() {
 209         return restClient.get(uriBuiler.createPolicyTypesUri()) //
 210                 .flatMapMany(A1AdapterJsonHelper::parseJsonArrayOfString);
 211     }
 212
 213     private Flux<String> getPolicyIdentitiesByType(String typeId) {
 214         return restClient.get(uriBuiler.createGetPolicyIdsUri(typeId)) //
 215                 .flatMapMany(A1AdapterJsonHelper::parseJsonArrayOfString);
 216     }
 217
 218     private Mono<String> deletePolicyById(String typeId, String policyId) {
 219         String policyUri = uriBuiler.createDeleteUri(typeId, policyId);
 220         return restClient.delete(policyUri);
 221     }
 222
 223     private Flux<String> deletePoliciesForType(String typeId) {
 224         return getPolicyIdentitiesByType(typeId) //
 225                 .flatMap(policyId -> deletePolicyById(typeId, policyId), CONCURRENCY_RIC);
 226     }
 227 }