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(uri.createPutPolicyUri(policy.type().id(), policy.id(), policy.statusNotificationUri()),
 117                 policy.json());
 118     }
 119
 120     @Override
 121     public Mono<List<String>> getPolicyTypeIdentities() {
 122         return Mono.just(Arrays.asList(""));
 123     }
 124
 125     @Override
 126     public Mono<String> getPolicyTypeSchema(String policyTypeId) {
 127         return Mono.just("{}");
 128     }
 129
 130     @Override
 131     public Mono<String> deletePolicy(Policy policy) {
 132         return deletePolicyById(policy.id());
 133     }
 134
 135     @Override
 136     public Flux<String> deleteAllPolicies() {
 137         return getPolicyIds() //
 138                 .flatMap(this::deletePolicyById); //
 139     }
 140
 141     @Override
 142     public Mono<A1ProtocolType> getProtocolVersion() {
 143         return getPolicyIdentities() //
 144                 .flatMap(x -> Mono.just(A1ProtocolType.STD_V1_1));
 145     }
 146
 147     @Override
 148     public Mono<String> getPolicyStatus(Policy policy) {
 149         return restClient.get(uri.createGetPolicyStatusUri(policy.type().id(), policy.id()));
 150     }
 151
 152     private Flux<String> getPolicyIds() {
 153         return restClient.get(uri.createGetPolicyIdsUri("")) //
 154                 .flatMapMany(A1AdapterJsonHelper::parseJsonArrayOfString);
 155     }
 156
 157     private Mono<String> deletePolicyById(String policyId) {
 158         return restClient.delete(uri.createDeleteUri("", policyId));
 159     }
 160 }