Merge pull request #1027 from Talend/feature/DEVOPS-1729/patch/6.0.1s/TPS-1373_nexus

DEVOPS-1729 Nexus migration: Update URLs [patch/6.0.1s/TPS-1373]

main/plugins/org.talend.repository/plugin.xml

@@ -2579,6 +2579,15 @@
               name="ChangeBatchParameter4SomeDBComponents"
               version="6.0.1">
         </projecttask>
+        <projecttask
+              beforeLogon="false"
+              breaks="6.0.0"
+              class="org.talend.repository.model.migration.CheckUseHTTPChunkedTPS1373"
+              description="Change the UseHTTPChunked parameter default value of some tsalesforce components"
+              id="org.talend.repository.model.migration.CheckUseHTTPChunkedTPS1373"
+              name="CheckUseHTTPChunkedTPS1373"
+              version="6.0.1">
+        </projecttask>
    </extension>
 
    <extension

main/plugins/org.talend.repository/src/main/java/org/talend/repository/model/migration/CheckUseHTTPChunkedTPS1373.java

@@ -0,0 +1,72 @@
+package org.talend.repository.model.migration;
+
+import java.util.Arrays;
+import java.util.Date;
+import java.util.GregorianCalendar;
+import java.util.List;
+
+import org.talend.commons.exception.ExceptionHandler;
+import org.talend.commons.exception.PersistenceException;
+import org.talend.core.language.ECodeLanguage;
+import org.talend.core.model.components.ComponentUtilities;
+import org.talend.core.model.components.ModifyComponentsAction;
+import org.talend.core.model.components.conversions.IComponentConversion;
+import org.talend.core.model.components.filters.IComponentFilter;
+import org.talend.core.model.components.filters.NameComponentFilter;
+import org.talend.core.model.migration.AbstractJobMigrationTask;
+import org.talend.core.model.properties.Item;
+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;
+
+public class CheckUseHTTPChunkedTPS1373 extends AbstractJobMigrationTask {
+
+    @Override
+    public Date getOrder() {
+       return new GregorianCalendar(2016, 4, 12, 16, 0, 0).getTime();
+    }
+
+    @Override
+    public ExecutionResult execute(Item item) {
+        ProcessType processType = getProcessType(item);
+        
+        if (getProject().getLanguage() != ECodeLanguage.JAVA || processType == null) {
+            return ExecutionResult.NOTHING_TO_DO;
+        }
+        
+        List<String> filterList = Arrays.asList(
+        		"tSalesforceConnection","tSalesforceGetDeleted","tSalesforceGetServerTimestamp","tSalesforceGetUpdated","tSalesforceInput","tSalesforceOutput"
+        		);
+        
+        IComponentConversion correctBatchModeForDBComponents = new IComponentConversion() {
+			public void transform(NodeType node) {
+				ElementParameterType isUseHttpChunked = ComponentUtilities.getNodeProperty(node, "USE_HTTP_CHUNKED");
+				if(isUseHttpChunked == null){
+					ComponentUtilities.addNodeProperty(node, "USE_HTTP_CHUNKED", "CHECK");
+	                ComponentUtilities.getNodeProperty(node, "USE_HTTP_CHUNKED").setValue("true");
+				}else{
+					 
+	                 isUseHttpChunked.setValue("true");
+				}
+			}
+		};
+		
+		for(String componentName: filterList){
+			IComponentFilter filter = new NameComponentFilter(componentName);
+			try {
+				ModifyComponentsAction
+						.searchAndModify(
+								item,
+								processType,
+								filter,
+								Arrays.<IComponentConversion> asList(correctBatchModeForDBComponents));
+			} catch (PersistenceException e) {
+				ExceptionHandler.process(e);
+				return ExecutionResult.FAILURE;
+			}
+		}
+		
+        return ExecutionResult.SUCCESS_NO_ALERT;
+    }
+
+}

pom.xml

@@ -18,7 +18,7 @@
 			<snapshots>
 				<enabled>false</enabled>
 			</snapshots>
-			<url>http://newbuild.talend.com:8081/nexus/content/repositories/TalendOpenSourceRelease/</url>
+			<url>https://artifacts-oss.talend.com/nexus/content/repositories/TalendOpenSourceRelease/</url>
 		</repository>
 		<repository>
 			<id>talend_open_snapshots</id>
@@ -28,7 +28,7 @@
 			<snapshots>
 				<enabled>true</enabled>
 			</snapshots>
-			<url>http://newbuild.talend.com:8081/nexus/content/repositories/TalendOpenSourceSnapshot/</url>
+			<url>https://artifacts-oss.talend.com/nexus/content/repositories/TalendOpenSourceSnapshot/</url>
 		</repository>
 	</repositories>
 	<modules>