aboutsummaryrefslogtreecommitdiffstats
path: root/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/api/impl/ParticipantIntermediaryApiImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/api/impl/ParticipantIntermediaryApiImpl.java')
-rwxr-xr-x[-rw-r--r--]participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/api/impl/ParticipantIntermediaryApiImpl.java41
1 files changed, 41 insertions, 0 deletions
diff --git a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/api/impl/ParticipantIntermediaryApiImpl.java b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/api/impl/ParticipantIntermediaryApiImpl.java
index ca5f08793..5cdbacab6 100644..100755
--- a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/api/impl/ParticipantIntermediaryApiImpl.java
+++ b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/api/impl/ParticipantIntermediaryApiImpl.java
@@ -30,10 +30,12 @@ import org.onap.policy.clamp.acm.participant.intermediary.handler.CacheProvider;
import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
import org.onap.policy.clamp.models.acm.concepts.AutomationComposition;
import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElement;
+import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElementDefinition;
import org.onap.policy.clamp.models.acm.concepts.DeployState;
import org.onap.policy.clamp.models.acm.concepts.LockState;
import org.onap.policy.clamp.models.acm.concepts.StateChangeResult;
import org.onap.policy.models.base.PfUtils;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
import org.springframework.stereotype.Component;
/**
@@ -81,4 +83,43 @@ public class ParticipantIntermediaryApiImpl implements ParticipantIntermediaryAp
var element = automationComposition.getElements().get(elementId);
return element != null ? new AutomationCompositionElement(element) : null;
}
+
+ @Override
+ public void sendAcDefinitionInfo(UUID compositionId, ToscaConceptIdentifier elementId,
+ Map<String, Object> outProperties) {
+ automationCompositionHandler.sendAcDefinitionInfo(compositionId, elementId, outProperties);
+ }
+
+ @Override
+ public AutomationComposition getAutomationComposition(UUID automationCompositionId) {
+ var automationComposition = cacheProvider.getAutomationCompositions().get(automationCompositionId);
+ return automationComposition != null ? new AutomationComposition(automationComposition) : null;
+ }
+
+ @Override
+ public Map<UUID, Map<ToscaConceptIdentifier, AutomationCompositionElementDefinition>> getAcElementsDefinitions() {
+ return PfUtils.mapMap(cacheProvider.getAcElementsDefinitions(),
+ map -> PfUtils.mapMap(map, AutomationCompositionElementDefinition::new));
+ }
+
+ @Override
+ public Map<ToscaConceptIdentifier, AutomationCompositionElementDefinition> getAcElementsDefinitions(
+ UUID compositionId) {
+ var acElementDefinitions = cacheProvider.getAcElementsDefinitions().get(compositionId);
+ if (acElementDefinitions == null) {
+ return null;
+ }
+ return PfUtils.mapMap(acElementDefinitions, AutomationCompositionElementDefinition::new);
+ }
+
+ @Override
+ public AutomationCompositionElementDefinition getAcElementDefinition(UUID compositionId,
+ ToscaConceptIdentifier elementId) {
+ var acElementDefinitions = cacheProvider.getAcElementsDefinitions().get(compositionId);
+ if (acElementDefinitions == null) {
+ return null;
+ }
+ var acElementDefinition = acElementDefinitions.get(elementId);
+ return acElementDefinition != null ? new AutomationCompositionElementDefinition(acElementDefinition) : null;
+ }
}