diff options
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.java | 41 |
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; + } } |