manifoldcf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kwri...@apache.org
Subject svn commit: r1599222 - /manifoldcf/branches/CONNECTORS-946/framework/crawler-ui/src/main/webapp/editjob.jsp
Date Mon, 02 Jun 2014 14:00:32 GMT
Author: kwright
Date: Mon Jun  2 14:00:31 2014
New Revision: 1599222

URL: http://svn.apache.org/r1599222
Log:
Support infrastructure for pipeline connections.

Modified:
    manifoldcf/branches/CONNECTORS-946/framework/crawler-ui/src/main/webapp/editjob.jsp

Modified: manifoldcf/branches/CONNECTORS-946/framework/crawler-ui/src/main/webapp/editjob.jsp
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-946/framework/crawler-ui/src/main/webapp/editjob.jsp?rev=1599222&r1=1599221&r2=1599222&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-946/framework/crawler-ui/src/main/webapp/editjob.jsp (original)
+++ manifoldcf/branches/CONNECTORS-946/framework/crawler-ui/src/main/webapp/editjob.jsp Mon
Jun  2 14:00:31 2014
@@ -35,9 +35,12 @@
 	IRepositoryConnection[] connList = connMgr.getAllConnections();
 	IOutputConnectionManager outputMgr = OutputConnectionManagerFactory.make(threadContext);
 	IOutputConnection[] outputList = outputMgr.getAllConnections();
+	ITransformationConnectionManager transformationMgr = TransformationConnectionManagerFactory.make(threadContext);
+	ITransformationConnection[] transformationList = transformationMgr.getAllConnections();
 
 	IOutputConnectorPool outputConnectorPool = OutputConnectorPoolFactory.make(threadContext);
 	IRepositoryConnectorPool repositoryConnectorPool = RepositoryConnectorPoolFactory.make(threadContext);
+	ITransformationConnectorPool transformationConnectorPool = TransformationConnectorPoolFactory.make(threadContext);
 
 	// Figure out tab name and sequence number
 	String tabName = variableContext.getParameter("tabname");
@@ -76,10 +79,13 @@
 	// Setup default fields
 	String connectionName = "";
 	String outputName = "";
+	String[] transformationNames = new String[0];
+	String[] transformationDescriptions = new String[0];
 	String description = "";
 	int type = IJobDescription.TYPE_SPECIFIED;
 	OutputSpecification outputSpecification = new OutputSpecification();
 	DocumentSpecification documentSpecification = new DocumentSpecification();
+	OutputSpecification[] transformationSpecifications = new OutputSpecification[0];
 	ArrayList scheduleRecords = new ArrayList();
 
 	EnumeratedValues dayOfWeek = null;
@@ -119,16 +125,24 @@
 		description = job.getDescription();
 		outputName = job.getOutputConnectionName();
 		connectionName = job.getConnectionName();
+		transformationNames = new String[job.countPipelineStages()];
+		transformationDescriptions = new String[job.countPipelineStages()];
+		transformationSpecifications = new OutputSpecification[job.countPipelineStages()];
+		for (int j = 0; j < job.countPipelineStages(); j++)
+		{
+			transformationNames[j] = job.getPipelineStageConnectionName(j);
+			transformationDescriptions[j] = job.getPipelineStageDescription(j);
+			transformationSpecifications[j] = job.getPipelineStageSpecification(j);
+		}
 		type = job.getType();
 		startMethod = job.getStartMethod();
 		hopcountMode = job.getHopcountMode();
 		outputSpecification = job.getOutputSpecification();
 		documentSpecification = job.getSpecification();
 		// Fill in schedule records from job
-		int j = 0;
-		while (j < job.getScheduleRecordCount())
+		for (int j = 0; j < job.getScheduleRecordCount(); j++)
 		{
-			scheduleRecords.add(job.getScheduleRecord(j++));
+			scheduleRecords.add(job.getScheduleRecord(j));
 		}
 
 		priority = job.getPriority();
@@ -170,6 +184,11 @@
 	{
 		outputConnection = outputMgr.load(outputName);
 	}
+	ITransformationConnection[] transformationConnections = new ITransformationConnection[transformationNames.length];
+	for (int j = 0; j < transformationConnections.length; j++)
+	{
+		transformationConnections[j] = transformationMgr.load(transformationNames[j]);
+	}
 
 	// Set up the predefined tabs
 	tabsArray.add(Messages.getString(pageContext.getRequest().getLocale(),"editjob.Name"));
@@ -481,7 +500,7 @@
 				outputConnectorPool.release(outputConnection,outputConnector);
 			}
 		}
-		Integer outputConnectionSequenceNumber = new Integer(1);
+		Integer outputConnectionSequenceNumber = new Integer(1+transformationConnections.length);
 		while (sequenceArray.size() < tabsArray.size())
 		{
 			sequenceArray.add(outputConnectionSequenceNumber);
@@ -512,6 +531,29 @@
 	}
 %>
 
+<%
+	for (int j = 0; j < transformationConnections.length; j++)
+	{
+		ITransformationConnector transformationConnector = transformationConnectorPool.grab(transformationConnections[j]);
+		if (transformationConnector != null)
+		{
+			try
+			{
+				transformationConnector.outputSpecificationHeader(new org.apache.manifoldcf.ui.jsp.JspWrapper(out,adminprofile),pageContext.getRequest().getLocale(),transformationSpecifications[j],1+j,tabsArray);
+			}
+			finally
+			{
+				transformationConnectorPool.release(transformationConnections[j],transformationConnector);
+			}
+		}
+		Integer transformationConnectionSequenceNumber = new Integer(1+j);
+		while (sequenceArray.size() < tabsArray.size())
+		{
+			sequenceArray.add(transformationConnectionSequenceNumber);
+		}
+	}
+%>
+
 </head>
 
 <body class="standardbody">



Mime
View raw message