Merge branch 'master' into arashankar/master/APPINT-33784

main/plugins/org.talend.designer.core/plugin.xml

@@ -972,5 +972,11 @@
                 id="org.talend.designer.core.model.analysistask.DuplicatedRouteIdUsageAnalysisTask"
                 name="DuplicatedRouteIdUsageAnalysisTask">
           </analysisTask>
+		  <analysisTask
+                class="org.talend.designer.core.model.analysistask.CustomComponentsDepRiskAnalysisTask"
+                description="Check if custom components are used"
+                id="org.talend.designer.core.model.analysistask.CustomComponentsDepRiskAnalysisTask"
+                name="CustomComponentsDepRiskAnalysisTask">
+		  </analysisTask
        </extension>
 </plugin>

main/plugins/org.talend.designer.core/src/main/java/messages.properties

@@ -1029,4 +1029,5 @@ ChildJobMissingAnalysisTask.childJobMissing=Node {0}:Child job is missing.
 ChildJobMissingAnalysisTask.emptyChildJob=Node {0}:Child job not setup yet.
 UnresolvedRoutineDependencyAnalysisTask.missingDependency={0} is missing {1}
 UnresolvedComponentsDependenciesAnalysisTask.missingDependency={0} {1} is missing {2}
-DuplicatedRouteIdUsageAnalysisTask.duplicateUsage={0} "{1}" is using "routeId()" instruction which will cause the route execution to fail (routeId can only be used once per route and is already set in generated code). New to Camel 3.
+DuplicatedRouteIdUsageAnalysisTask.duplicateUsage={0} "{1}" is using "routeId()" instruction which will cause the route execution to fail (routeId can only be used once per route and is already set in generated code). New to Camel 3.
+CustomComponent.updateComponentAndDependencies=Custom component {0} of type {1} found in item. Ensure this custom component and its dependencies are up-to-date.

main/plugins/org.talend.designer.core/src/main/java/org/talend/designer/core/model/analysistask/CustomComponentsDepRiskAnalysisTask.java

@@ -0,0 +1,78 @@
+package org.talend.designer.core.model.analysistask;
+
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+import org.talend.analysistask.AbstractItemAnalysisTask;
+import org.talend.analysistask.AnalysisReportRecorder;
+import org.talend.analysistask.AnalysisReportRecorder.SeverityOption;
+import org.talend.core.i18n.Messages;
+import org.talend.core.model.components.IComponent;
+import org.talend.core.model.properties.Item;
+import org.talend.core.model.repository.ERepositoryObjectType;
+import org.talend.core.ui.component.ComponentsFactoryProvider;
+import org.talend.designer.core.model.utils.emf.talendfile.ElementParameterType;
+import org.talend.designer.core.model.utils.emf.talendfile.NodeType;
+import org.talend.designer.core.model.utils.emf.talendfile.ProcessType;
+
+/**
+ * Find if custom components are used in models and show warning message
+ *
+ */
+public class CustomComponentsDepRiskAnalysisTask  extends AbstractItemAnalysisTask {
+
+    @Override
+    public List<AnalysisReportRecorder> execute(Item item) {
+
+        ProcessType processType = getProcessType(item);
+        if (processType == null) {
+            return null;
+        }
+        List<AnalysisReportRecorder> recordList = new ArrayList<AnalysisReportRecorder>();
+        List<String> loadedCustomComponentsTypes = new ArrayList<String>();
+        List<String> loadedAllComponentsTypes = new ArrayList<String>();
+
+        Set<IComponent> components = ComponentsFactoryProvider.getInstance().getComponents();
+        components.forEach(component ->  loadedAllComponentsTypes.add(component.getName()));
+
+        List<IComponent> loadedCustomComponents = ComponentsFactoryProvider.getInstance().getCustomComponents();
+        loadedCustomComponents.forEach(component ->  loadedCustomComponentsTypes.add(component.getName()));
+
+        for(Object nodeObject : processType.getNode()) {
+            NodeType nodeType = (NodeType) nodeObject;
+            if(loadedCustomComponentsTypes.contains(nodeType.getComponentName())) {
+                recordList.add(prepareMessage(item, nodeType));
+            }else if(!loadedAllComponentsTypes.contains(nodeType.getComponentName())){
+                recordList.add(prepareMessage(item, nodeType));
+            }
+        }
+        return recordList;
+    }
+
+    private AnalysisReportRecorder prepareMessage(Item item, NodeType nodeType) {
+        for (Object o : nodeType.getElementParameter()) {
+            ElementParameterType t = (ElementParameterType) o;
+            if ("UNIQUE_NAME".equals(t.getName())) {
+                String compnentNameVal = t.getValue();
+                if (compnentNameVal != null) {
+                    return new AnalysisReportRecorder(this, item, SeverityOption.WARNING,
+                            Messages.getString("CustomComponent.updateComponentAndDependencies",
+                                    compnentNameVal, nodeType.getComponentName()));
+                }
+            }
+        }
+        return null;
+    }
+
+    @Override
+    public Set<ERepositoryObjectType> getRepositoryObjectTypeScope() {
+        Set<ERepositoryObjectType> types = new HashSet<ERepositoryObjectType>();
+        types.addAll(ERepositoryObjectType.getAllTypesOfProcess());
+        types.addAll(ERepositoryObjectType.getAllTypesOfBigDataProcess());
+        types.addAll(ERepositoryObjectType.getAllTypesOfProcess2());
+        types.addAll(ERepositoryObjectType.getAllTypesOfTestContainer());
+        return types;
+    }
+}