gerrit.onap Code Review - policy/clamp.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2021-2025 OpenInfra Foundation Europe. All rights reserved.
   4  *  Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
   5  * ================================================================================
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  * SPDX-License-Identifier: Apache-2.0
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.onap.policy.clamp.acm.participant.intermediary.api.impl;
  23
  24 import java.util.Map;
  25 import java.util.UUID;
  26 import lombok.RequiredArgsConstructor;
  27 import org.onap.policy.clamp.acm.participant.intermediary.api.CompositionElementDto;
  28 import org.onap.policy.clamp.acm.participant.intermediary.api.ElementState;
  29 import org.onap.policy.clamp.acm.participant.intermediary.api.InstanceElementDto;
  30 import org.onap.policy.clamp.acm.participant.intermediary.api.ParticipantIntermediaryApi;
  31 import org.onap.policy.clamp.acm.participant.intermediary.handler.AutomationCompositionOutHandler;
  32 import org.onap.policy.clamp.acm.participant.intermediary.handler.cache.CacheProvider;
  33 import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
  34 import org.onap.policy.clamp.models.acm.concepts.AutomationComposition;
  35 import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElement;
  36 import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElementDefinition;
  37 import org.onap.policy.clamp.models.acm.concepts.DeployState;
  38 import org.onap.policy.clamp.models.acm.concepts.LockState;
  39 import org.onap.policy.clamp.models.acm.concepts.StateChangeResult;
  40 import org.onap.policy.clamp.models.acm.utils.AcmUtils;
  41 import org.onap.policy.models.base.PfUtils;
  42 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  43 import org.springframework.stereotype.Component;
  44
  45 /**
  46  * This class is api implementation used by participant intermediary.
  47  */
  48 @Component
  49 @RequiredArgsConstructor
  50 public class ParticipantIntermediaryApiImpl implements ParticipantIntermediaryApi {
  51
  52     // The handler for the automationComposition intermediary
  53     private final AutomationCompositionOutHandler automationCompositionHandler;
  54     private final CacheProvider cacheProvider;
  55
  56     @Override
  57     public void updateAutomationCompositionElementState(UUID instance, UUID elementId, DeployState deployState,
  58             LockState lockState, StateChangeResult stateChangeResult, String message) {
  59         automationCompositionHandler.updateAutomationCompositionElementState(instance, elementId, deployState,
  60             lockState, stateChangeResult, message);
  61     }
  62
  63     @Override
  64     public void updateAutomationCompositionElementStage(UUID instance, UUID elementId,
  65             StateChangeResult stateChangeResult, int stage, String message) {
  66         automationCompositionHandler.updateAutomationCompositionElementStage(instance, elementId, stateChangeResult,
  67             stage, message);
  68     }
  69
  70     @Override
  71     public void sendAcElementInfo(UUID instance, UUID elementId, String useState,
  72             String operationalState, Map<String, Object> outProperties) {
  73         automationCompositionHandler.sendAcElementInfo(instance, elementId, useState, operationalState,
  74                 outProperties);
  75     }
  76
  77     @Override
  78     public Map<UUID, AutomationComposition> getAutomationCompositions() {
  79         return PfUtils.mapMap(cacheProvider.getAutomationCompositions(), AutomationComposition::new);
  80     }
  81
  82     @Override
  83     public void updateCompositionState(UUID compositionId, AcTypeState state, StateChangeResult stateChangeResult,
  84             String message) {
  85         automationCompositionHandler.updateCompositionState(compositionId, state, stateChangeResult, message);
  86     }
  87
  88     @Override
  89     public AutomationCompositionElement getAutomationCompositionElement(UUID instanceId, UUID elementId) {
  90         var automationComposition = cacheProvider.getAutomationCompositions().get(instanceId);
  91         if (automationComposition == null) {
  92             return null;
  93         }
  94         var element = automationComposition.getElements().get(elementId);
  95         return element != null ? new AutomationCompositionElement(element) : null;
  96     }
  97
  98     @Override
  99     public InstanceElementDto getInstanceElementDto(UUID instanceId, UUID elementId) {
 100         var element = getAutomationCompositionElement(instanceId, elementId);
 101         return element == null
 102             ? new InstanceElementDto(instanceId, elementId, Map.of(), Map.of(), ElementState.NOT_PRESENT)
 103             : new InstanceElementDto(instanceId, elementId, element.getProperties(), element.getOutProperties());
 104     }
 105
 106     @Override
 107     public void sendAcDefinitionInfo(UUID compositionId, ToscaConceptIdentifier elementId,
 108             Map<String, Object> outProperties) {
 109         automationCompositionHandler.sendAcDefinitionInfo(compositionId, elementId, outProperties);
 110     }
 111
 112     @Override
 113     public AutomationComposition getAutomationComposition(UUID instanceId) {
 114         var automationComposition = cacheProvider.getAutomationCompositions().get(instanceId);
 115         return automationComposition != null ? new AutomationComposition(automationComposition) : null;
 116     }
 117
 118     @Override
 119     public Map<UUID, Map<ToscaConceptIdentifier, AutomationCompositionElementDefinition>> getAcElementsDefinitions() {
 120         return PfUtils.mapMap(cacheProvider.getAcElementsDefinitions(),
 121             acDefinition -> PfUtils.mapMap(acDefinition.getElements(), AutomationCompositionElementDefinition::new));
 122     }
 123
 124     @Override
 125     public Map<ToscaConceptIdentifier, AutomationCompositionElementDefinition> getAcElementsDefinitions(
 126             UUID compositionId) {
 127         var acElementDefinitions = cacheProvider.getAcElementsDefinitions().get(compositionId);
 128         if (acElementDefinitions == null) {
 129             return Map.of();
 130         }
 131         return PfUtils.mapMap(acElementDefinitions.getElements(), AutomationCompositionElementDefinition::new);
 132     }
 133
 134     @Override
 135     public AutomationCompositionElementDefinition getAcElementDefinition(UUID compositionId,
 136             ToscaConceptIdentifier elementId) {
 137         var acDefinition = cacheProvider.getAcElementsDefinitions().get(compositionId);
 138         if (acDefinition == null) {
 139             return null;
 140         }
 141         var acElementDefinition = acDefinition.getElements().get(elementId);
 142         return acElementDefinition != null ? new AutomationCompositionElementDefinition(acElementDefinition) : null;
 143     }
 144
 145     @Override
 146     public CompositionElementDto getCompositionElementDto(UUID compositionId, ToscaConceptIdentifier elementId) {
 147         var element = getAcElementDefinition(compositionId, elementId);
 148         return element == null
 149                 ? new CompositionElementDto(compositionId, elementId, Map.of(), Map.of(), ElementState.NOT_PRESENT)
 150                 : new CompositionElementDto(compositionId, elementId,
 151                 element.getAutomationCompositionElementToscaNodeTemplate().getProperties(), element.getOutProperties());
 152     }
 153 }