-
- /**
- * Update port in consolidation data.
- *
- * @param translateTo the translate to
- * @param computeNodeType the compute node type
- * @param portNodeTemplateId the port node template id
- */
- public static void updatePortInConsolidationData(TranslateTo translateTo,
- String computeNodeType,
- String portNodeTemplateId) {
- TranslationContext translationContext = translateTo.getContext();
- ServiceTemplate serviceTemplate = translateTo.getServiceTemplate();
- ComputeTemplateConsolidationData computeTemplateConsolidationData =
- getComputeTemplateConsolidationData(translationContext, serviceTemplate, computeNodeType,
- translateTo.getTranslatedId());
- computeTemplateConsolidationData.addPort(getPortType(portNodeTemplateId), portNodeTemplateId);
- // create port in consolidation data
- getPortTemplateConsolidationData(translationContext, serviceTemplate, portNodeTemplateId);
- }
-
- /**
- * Update nodes connected in and out for Depends on and connectivity in consolidation data.
- *
- * @param translateTo the translate to
- * @param targetResourceId the target resource id
- * @param nodeTemplateId the source node template id
- * @param requirementAssignment the requirement assignment
- */
- public static void updateNodesConnectedData(TranslateTo translateTo, String targetResourceId,
- Resource targetResource, Resource sourceResource,
- String nodeTemplateId, String requirementId,
- RequirementAssignment requirementAssignment) {
- ConsolidationEntityType consolidationEntityType = ConsolidationEntityType.OTHER;
- HeatOrchestrationTemplate heatOrchestrationTemplate = translateTo
- .getHeatOrchestrationTemplate();
- TranslationContext translationContext = translateTo.getContext();
-
- consolidationEntityType.setEntityType(heatOrchestrationTemplate, sourceResource,
- targetResource, translateTo.getContext());
- // Add resource dependency information in nodesConnectedIn if the target node
- // is a consolidation entity
- if (isConsolidationEntity(consolidationEntityType.getTargetEntityType())) {
- ConsolidationDataUtil.updateNodesConnectedIn(translateTo,
- nodeTemplateId, consolidationEntityType.getTargetEntityType(), targetResourceId,
- requirementId, requirementAssignment);
+ /**
+ * Update nodes connected from this node in consolidation data.
+ *
+ * @param translateTo the translate to
+ * @param sourceNodeTemplateId the node template id of the source node
+ * @param consolidationEntityType Entity type (compute or port)
+ * @param targetResourceId Target Resource Id
+ * @param requirementId Requirement Id
+ * @param requirementAssignment the requirement assignment
+ */
+ public static void updateNodesConnectedIn(TranslateTo translateTo, String sourceNodeTemplateId, ConsolidationEntityType consolidationEntityType,
+ String targetResourceId, String requirementId, RequirementAssignment requirementAssignment) {
+ TranslationContext translationContext = translateTo.getContext();
+ Optional<ConsolidationDataHandler> consolidationDataHandler = translationContext.getConsolidationDataHandler(consolidationEntityType);
+ String dependentNodeTemplateId = requirementAssignment.getNode();
+ consolidationDataHandler.ifPresent(handler -> handler
+ .addNodesConnectedIn(translateTo, sourceNodeTemplateId, dependentNodeTemplateId, targetResourceId, requirementId, requirementAssignment));