Work.

Author: khatchad

edu.cuny.hunter.streamrefactoring.core/src/edu/cuny/hunter/streamrefactoring/core/analysis/Stream.java

@@ -35,9 +35,11 @@
 import org.eclipse.jdt.core.dom.MethodInvocation;
 import org.eclipse.jdt.core.dom.SimpleName;
 import org.eclipse.jdt.core.dom.TypeDeclaration;
+import org.eclipse.jdt.core.dom.rewrite.ASTRewrite;
 import org.eclipse.jdt.internal.corext.dom.ASTNodes;
 import org.eclipse.jdt.internal.corext.dom.Bindings;
 import org.eclipse.jdt.internal.corext.refactoring.base.JavaStatusContext;
+import org.eclipse.jdt.internal.corext.refactoring.structure.CompilationUnitRewrite;
 import org.eclipse.jdt.internal.corext.util.JdtFlags;
 import org.eclipse.ltk.core.refactoring.RefactoringStatus;
 import org.eclipse.ltk.core.refactoring.RefactoringStatusContext;
@@ -769,4 +771,22 @@ public String toString() {
 		builder.append("]");
 		return builder.toString();
 	}
+
+	public void convertToParallel(CompilationUnitRewrite rewrite) {
+		LOGGER.info("Converting to parallel.");
+		MethodInvocation creation = this.getCreation();
+		ASTRewrite astRewrite = rewrite.getASTRewrite();
+		SimpleName newMethodName = creation.getAST().newSimpleName("parallelStream");
+		astRewrite.replace(creation.getName(), newMethodName, null);
+	}
+
+	public void convertToSequential(CompilationUnitRewrite rewrite) {
+		// TODO Auto-generated method stub
+		LOGGER.info("Converting to sequential.");
+	}
+
+	public void unorder(CompilationUnitRewrite rewrite) {
+		// TODO Auto-generated method stub
+		LOGGER.info("Unordering.");
+	}
 }

edu.cuny.hunter.streamrefactoring.core/src/edu/cuny/hunter/streamrefactoring/core/messages/Messages.java

@@ -22,6 +22,7 @@ public class Messages extends NLS {
 	public static String PreconditionFailed;
 	public static String RefactoringNotPossible;
 	public static String StreamsNotSpecified;
+	public static String NoStreamsToOptimize;
 
 	static {
 		// initialize resource bundle

edu.cuny.hunter.streamrefactoring.core/src/edu/cuny/hunter/streamrefactoring/core/messages/messages.properties

@@ -5,4 +5,5 @@ StreamsNotSpecified=No streams to refactor.
 CheckingPreconditions=Checking preconditions (may take a while)...
 CompilingSource=Compiling source ...
 CreatingChange=Creating change...
-NoStreamsHavePassedThePreconditions=No streams have passed preconditions.
+NoStreamsHavePassedThePreconditions=No streams have passed preconditions.
+NoStreamsToOptimize=No streams to optimize.

edu.cuny.hunter.streamrefactoring.core/src/edu/cuny/hunter/streamrefactoring/core/refactorings/OptimizeStreamsRefactoringProcessor.java

@@ -43,6 +43,7 @@
 import org.eclipse.ltk.core.refactoring.Change;
 import org.eclipse.ltk.core.refactoring.GroupCategory;
 import org.eclipse.ltk.core.refactoring.GroupCategorySet;
+import org.eclipse.ltk.core.refactoring.NullChange;
 import org.eclipse.ltk.core.refactoring.RefactoringDescriptor;
 import org.eclipse.ltk.core.refactoring.RefactoringStatus;
 import org.eclipse.ltk.core.refactoring.participants.CheckConditionsContext;
@@ -56,6 +57,7 @@
 import edu.cuny.hunter.streamrefactoring.core.analysis.PreconditionFailure;
 import edu.cuny.hunter.streamrefactoring.core.analysis.Stream;
 import edu.cuny.hunter.streamrefactoring.core.analysis.StreamAnalyzer;
+import edu.cuny.hunter.streamrefactoring.core.analysis.TransformationAction;
 import edu.cuny.hunter.streamrefactoring.core.descriptors.OptimizeStreamRefactoringDescriptor;
 import edu.cuny.hunter.streamrefactoring.core.messages.Messages;
 import edu.cuny.hunter.streamrefactoring.core.utils.TimeCollector;
@@ -337,9 +339,33 @@ public void clearCaches() {
 	@Override
 	public Change createChange(IProgressMonitor pm) throws CoreException, OperationCanceledException {
 		try {
-			pm.beginTask(Messages.CreatingChange, 1);
-
 			final TextEditBasedChangeManager manager = new TextEditBasedChangeManager();
+			Set<Stream> optimizableStreams = this.getOptimizableStreams();
+
+			if (optimizableStreams.isEmpty())
+				return new NullChange(Messages.NoStreamsToOptimize);
+			
+			pm.beginTask("Transforming streams ...", optimizableStreams.size());
+			for (Stream stream : optimizableStreams) {
+				CompilationUnitRewrite rewrite = getCompilationUnitRewrite(stream.getEnclosingEclipseMethod().getCompilationUnit(),
+						stream.getEnclosingCompilationUnit());
+				
+				// for each stream transformation.
+				for (TransformationAction action : stream.getActions()) {
+					switch (action) {
+					case CONVERT_TO_PARALLEL:
+						stream.convertToParallel(rewrite);
+						break;
+					case CONVERT_TO_SEQUENTIAL:
+						stream.convertToSequential();
+						break;
+					case UNORDER:
+						stream.unorder(rewrite);
+						break;
+					}
+				}
+				pm.worked(1);
+			}
 
 			// save the source changes.
 			ICompilationUnit[] units = this.getCompilationUnitToCompilationUnitRewriteMap().keySet().stream()