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

   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 }