gerrit.onap Code Review - cps.git/blob

   1 /*
   2  *  ============LICENSE_START=======================================================
   3  *  Copyright (C) 2025 OpenInfra Foundation Europe
   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.impl.data.policyexecutor;
  22
  23 import com.fasterxml.jackson.core.JsonProcessingException;
  24 import com.fasterxml.jackson.core.type.TypeReference;
  25 import com.fasterxml.jackson.databind.ObjectMapper;
  26 import com.google.common.base.Strings;
  27 import java.util.ArrayList;
  28 import java.util.HashMap;
  29 import java.util.List;
  30 import java.util.Map;
  31 import lombok.RequiredArgsConstructor;
  32 import lombok.extern.slf4j.Slf4j;
  33 import org.onap.cps.ncmp.api.data.models.OperationType;
  34 import org.onap.cps.ncmp.api.exceptions.ProvMnSException;
  35 import org.onap.cps.ncmp.impl.provmns.RequestPathParameters;
  36 import org.onap.cps.ncmp.impl.provmns.model.PatchItem;
  37 import org.onap.cps.utils.JsonObjectMapper;
  38 import org.springframework.stereotype.Service;
  39
  40 @Slf4j
  41 @Service
  42 @RequiredArgsConstructor
  43 public class OperationDetailsFactory {
  44
  45     private static final String ATTRIBUTE_NAME_SEPARATOR = "/";
  46     private static final String REGEX_FOR_LEADING_AND_TRAILING_SEPARATORS = "(^/)|(/$)";
  47
  48     private final JsonObjectMapper jsonObjectMapper;
  49     private final ObjectMapper objectMapper;
  50
  51     /**
  52      * Build a PatchOperationDetails object from ProvMnS request details.
  53      *
  54      * @param requestPathParameters    request parameters including uri-ldn-first-part, className and id
  55      * @param patchItems               provided request list of patch Items
  56      * @return CreateOperationDetails object
  57      */
  58     public PatchOperationsDetails buildPatchOperationDetails(final RequestPathParameters requestPathParameters,
  59                                                              final List<PatchItem> patchItems) {
  60         final List<Object> operations = new ArrayList<>(patchItems.size());
  61         for (final PatchItem patchItem : patchItems) {
  62             switch (patchItem.getOp()) {
  63                 case ADD -> operations.add(buildCreateOperationDetails(OperationType.CREATE, requestPathParameters,
  64                                         patchItem.getValue()));
  65                 case REPLACE -> operations.add(buildCreateOperationDetailsForUpdate(OperationType.UPDATE,
  66                                         requestPathParameters,
  67                                         patchItem));
  68                 case REMOVE -> operations.add(buildDeleteOperationDetails(requestPathParameters.toAlternateId()));
  69                 default -> log.warn("Unsupported Patch Operation Type:{}", patchItem.getOp().getValue());
  70             }
  71         }
  72         return new PatchOperationsDetails("Some Permission Id", "cm-legacy", operations);
  73     }
  74
  75     /**
  76      * Build a CreateOperationDetails object from ProvMnS request details.
  77      *
  78      * @param operationType            Type of operation create, update.
  79      * @param requestPathParameters    request parameters including uri-ldn-first-part, className and id
  80      * @param resourceAsObject         provided request payload
  81      * @return CreateOperationDetails object
  82      */
  83     public CreateOperationDetails buildCreateOperationDetails(final OperationType operationType,
  84                                                               final RequestPathParameters requestPathParameters,
  85                                                               final Object resourceAsObject) {
  86
  87         final ResourceObjectDetails resourceObjectDetails = createResourceObjectDetails(resourceAsObject,
  88                                                                                         requestPathParameters);
  89
  90         final OperationEntry operationEntry = new OperationEntry(resourceObjectDetails.id(),
  91                 resourceObjectDetails.attributes());
  92
  93         final Map<String, List<OperationEntry>> operationEntriesPerObjectClass =
  94                 Map.of(resourceObjectDetails.objectClass(), List.of(operationEntry));
  95
  96         return new CreateOperationDetails(
  97                 operationType.name(),
  98                 requestPathParameters.getUriLdnFirstPart(),
  99                 operationEntriesPerObjectClass
 100         );
 101     }
 102
 103     /**
 104      * Build a CreateOperationDetails object from ProvMnS request details.
 105      *
 106      * @param operationType            Type of operation create, update.
 107      * @param requestPathParameters    request parameters including uri-ldn-first-part, className and id
 108      * @param patchItem                 provided request
 109      * @return CreateOperationDetails object
 110      */
 111     public CreateOperationDetails buildCreateOperationDetailsForUpdate(final OperationType operationType,
 112                                                                      final RequestPathParameters requestPathParameters,
 113                                                                      final PatchItem patchItem) {
 114         if (patchItem.getPath().contains("#/attributes")) {
 115             return buildCreateOperationDetailsForUpdateWithHash(operationType, requestPathParameters, patchItem);
 116         } else {
 117             return buildCreateOperationDetails(operationType, requestPathParameters, patchItem.getValue());
 118         }
 119     }
 120
 121     /**
 122      * Builds a DeleteOperationDetails object from provided alternate id.
 123      *
 124      * @param alternateId        alternate id for request
 125      * @return DeleteOperationDetails object
 126      */
 127     public DeleteOperationDetails buildDeleteOperationDetails(final String alternateId) {
 128         return new DeleteOperationDetails(OperationType.DELETE.name(), alternateId);
 129     }
 130
 131     private ResourceObjectDetails createResourceObjectDetails(final Object resourceAsObject,
 132                                                               final RequestPathParameters requestPathParameters) {
 133         try {
 134             final String resourceAsJson = jsonObjectMapper.asJsonString(resourceAsObject);
 135             final TypeReference<Map<String, Object>> typeReference = new TypeReference<>() {};
 136             final Map<String, Object> resourceAsMap = objectMapper.readValue(resourceAsJson, typeReference);
 137
 138             return new ResourceObjectDetails(requestPathParameters.getId(),
 139                                              extractObjectClass(resourceAsMap, requestPathParameters),
 140                                              resourceAsMap.get("attributes"));
 141         } catch (final JsonProcessingException e) {
 142             log.debug("JSON processing error: {}", e.getMessage());
 143             throw new ProvMnSException("Cannot convert Resource Object", e.getMessage());
 144         }
 145     }
 146
 147     private static String extractObjectClass(final Map<String, Object> resourceAsMap,
 148                                              final RequestPathParameters requestPathParameters) {
 149         final String objectClass = (String) resourceAsMap.get("objectClass");
 150         if (Strings.isNullOrEmpty(objectClass)) {
 151             return requestPathParameters.getClassName();
 152         }
 153         return objectClass;
 154     }
 155
 156
 157     private CreateOperationDetails buildCreateOperationDetailsForUpdateWithHash(final OperationType operationType,
 158                                                                      final RequestPathParameters requestPathParameters,
 159                                                                      final PatchItem patchItem) {
 160         final Map<String, List<OperationEntry>> operationEntriesPerObjectClass = new HashMap<>();
 161         final String className = requestPathParameters.getClassName();
 162
 163         final Map<String, Object> attributeHierarchyAsMap = createNestedMap(patchItem);
 164
 165         final OperationEntry operationEntry = new OperationEntry(requestPathParameters.getId(),
 166                                                                  attributeHierarchyAsMap);
 167         operationEntriesPerObjectClass.put(className, List.of(operationEntry));
 168
 169         return new CreateOperationDetails(operationType.getOperationName(),
 170                 requestPathParameters.getUriLdnFirstPart(),
 171                 operationEntriesPerObjectClass);
 172     }
 173
 174     private Map<String, Object> createNestedMap(final PatchItem patchItem) {
 175         final Map<String, Object> attributeHierarchyMap = new HashMap<>();
 176         Map<String, Object> currentLevel = attributeHierarchyMap;
 177
 178         final String[] attributeHierarchyNames = patchItem.getPath().split("#/attributes")[1]
 179                 .replaceAll(REGEX_FOR_LEADING_AND_TRAILING_SEPARATORS, "")
 180                 .split(ATTRIBUTE_NAME_SEPARATOR);
 181
 182         for (int level = 0; level < attributeHierarchyNames.length; level++) {
 183             final String attributeName = attributeHierarchyNames[level];
 184
 185             if (isLastLevel(attributeHierarchyNames, level)) {
 186                 currentLevel.put(attributeName, patchItem.getValue());
 187             } else {
 188                 final Map<String, Object> nextLevel = new HashMap<>();
 189                 currentLevel.put(attributeName, nextLevel);
 190                 currentLevel = nextLevel;
 191             }
 192         }
 193         return attributeHierarchyMap;
 194     }
 195
 196     private boolean isLastLevel(final String[] attributeNamesArray, final int level) {
 197         return level == attributeNamesArray.length - 1;
 198     }
 199 }
 200