cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/operations/DmiOperations.java

   1 /*
   2  *  ============LICENSE_START=======================================================
   3  *  Copyright (C) 2021 Nordix Foundation
   4  *  ================================================================================
   5  *  Licensed under the Apache License, Version 2.0 (the "License");
   6  *  you may not use this file except in compliance with the License.
   7  *  You may obtain a copy of the License at
   8  *
   9  *        http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *  Unless required by applicable law or agreed to in writing, software
  12  *  distributed under the License is distributed on an "AS IS" BASIS,
  13  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *  See the License for the specific language governing permissions and
  15  *  limitations under the License.
  16  *
  17  *  SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.cps.ncmp.api.impl.operations;
  22
  23 import com.fasterxml.jackson.core.JsonProcessingException;
  24 import com.fasterxml.jackson.databind.ObjectMapper;
  25 import com.google.common.base.Strings;
  26 import lombok.Getter;
  27 import lombok.extern.slf4j.Slf4j;
  28 import org.onap.cps.ncmp.api.impl.client.DmiRestClient;
  29 import org.onap.cps.ncmp.api.impl.config.NcmpConfiguration;
  30 import org.onap.cps.ncmp.api.impl.exception.NcmpException;
  31 import org.springframework.http.HttpHeaders;
  32
  33 @Slf4j
  34 public class DmiOperations {
  35
  36     @Getter
  37     public enum DataStoreEnum {
  38         PASSTHROUGH_OPERATIONAL("ncmp-datastore:passthrough-operational"),
  39         PASSTHROUGH_RUNNING("ncmp-datastore:passthrough-running");
  40         private String value;
  41
  42         DataStoreEnum(final String value) {
  43             this.value = value;
  44         }
  45     }
  46
  47     protected ObjectMapper objectMapper;
  48     protected PersistenceCmHandleRetriever cmHandlePropertiesRetriever;
  49     protected DmiRestClient dmiRestClient;
  50     protected NcmpConfiguration.DmiProperties dmiProperties;
  51
  52     static final String URL_SEPARATOR = "/";
  53
  54     /**
  55      * Constructor for {@code DmiOperations}. This method also manipulates url properties.
  56      *
  57      * @param dmiRestClient {@code DmiRestClient}
  58      */
  59     public DmiOperations(final PersistenceCmHandleRetriever cmHandlePropertiesRetriever,
  60                          final ObjectMapper objectMapper,
  61                          final NcmpConfiguration.DmiProperties dmiProperties,
  62                          final DmiRestClient dmiRestClient) {
  63         this.cmHandlePropertiesRetriever = cmHandlePropertiesRetriever;
  64         this.objectMapper = objectMapper;
  65         this.dmiRestClient = dmiRestClient;
  66         this.dmiProperties = dmiProperties;
  67     }
  68
  69     String getCmHandleUrl(final String dmiServiceName, final String cmHandle) {
  70         return dmiServiceName
  71             + dmiProperties.getDmiBasePath()
  72             + URL_SEPARATOR
  73             + "v1"
  74             + URL_SEPARATOR
  75             + "ch"
  76             + URL_SEPARATOR
  77             + cmHandle
  78             + URL_SEPARATOR;
  79     }
  80
  81     String getDmiResourceUrl(final String dmiServiceName, final String cmHandle, final String resourceName) {
  82         return getCmHandleUrl(dmiServiceName, cmHandle) + resourceName;
  83     }
  84
  85     static String appendOptionsQuery(final String url, final String optionsParamInQuery) {
  86         if (Strings.isNullOrEmpty(optionsParamInQuery)) {
  87             return url;
  88         }
  89         return url + "&options=" + optionsParamInQuery;
  90     }
  91
  92     static HttpHeaders prepareHeader(final String acceptParam) {
  93         final var httpHeaders = new HttpHeaders();
  94         httpHeaders.set(HttpHeaders.ACCEPT, acceptParam);
  95         return httpHeaders;
  96     }
  97
  98     /**
  99      * Convert DmiRequestBody to JSON.
 100      *
 101      * @param dmiRequestBody the dmi request body
 102      * @return DmiRequestBody as JSON
 103      */
 104     String getDmiRequestBodyAsString(final DmiRequestBody dmiRequestBody) {
 105         try {
 106             return objectMapper.writeValueAsString(dmiRequestBody);
 107         } catch (final JsonProcessingException e) {
 108             log.error("Parsing error occurred while converting Object to JSON.");
 109             throw new NcmpException("Parsing error occurred while converting given object to JSON.",
 110                 e.getMessage());
 111         }
 112     }
 113
 114 }