1 files changed, 207 insertions, 0 deletions
diff --git a/bundles/org.eclipse.equinox.p2.tests/src/org/eclipse/equinox/prov/tests/artifact/repository/processing/ProcessingStepHandlerTest.java b/bundles/org.eclipse.equinox.p2.tests/src/org/eclipse/equinox/prov/tests/artifact/repository/processing/ProcessingStepHandlerTest.java
new file mode 100644
index 000000000..d7006c219
--- /dev/null
+++ b/bundles/org.eclipse.equinox.p2.tests/src/org/eclipse/equinox/prov/tests/artifact/repository/processing/ProcessingStepHandlerTest.java
@@ -0,0 +1,207 @@
+/*******************************************************************************
+* Copyright (c) 2007 compeople AG and others.
+* All rights reserved. This program and the accompanying materials
+* are made available under the terms of the Eclipse Public License v1.0
+* which accompanies this distribution, and is available at
+* http://www.eclipse.org/legal/epl-v10.html
+*
+* Contributors:
+* 	compeople AG (Stefan Liebig) - initial API and implementation
+*  IBM - continuing development
+*******************************************************************************/
+package org.eclipse.equinox.prov.tests.artifact.repository.processing;
+
+import java.io.*;
+import java.util.Arrays;
+import junit.framework.TestCase;
+import org.eclipse.core.runtime.*;
+import org.eclipse.equinox.prov.artifact.repository.processing.*;
+import org.eclipse.equinox.prov.core.helpers.FileUtils;
+import org.eclipse.equinox.prov.tests.TestActivator;
+
+public class ProcessingStepHandlerTest extends TestCase {
+
+	//	private static final int BUFFER_SIZE = 8 * 1024;
+
+	ProcessingStepHandler handler = new ProcessingStepHandler();
+	IProgressMonitor monitor = new NullProgressMonitor();
+
+	public void testExecuteNoPSs() throws IOException {
+		ProcessingStepDescriptor[] descriptors = new ProcessingStepDescriptor[0];
+		OutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.createAndLink(descriptors, null, result, monitor);
+		testStream.write("Test".getBytes());
+		testStream.close();
+		assertEquals("Test", result.toString());
+	}
+
+	public void testExecuteOneByteShifterPS() throws IOException {
+		ProcessingStep[] steps = new ProcessingStep[] {new ByteShifter(1)};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write(new byte[] {1});
+		testStream.close();
+		assertTrue(Arrays.equals(new byte[] {2}, result.toByteArray()));
+	}
+
+	public void testExecuteTwoByteShifterPSs() throws IOException {
+		ProcessingStep[] steps = new ProcessingStep[] {new ByteShifter(1), new ByteShifter(2)};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write(new byte[] {1});
+		testStream.close();
+		assertTrue(Arrays.equals(new byte[] {8}, result.toByteArray()));
+	}
+
+	public void testExecuteOneMD5VerifierPSOk() throws IOException {
+		ProcessingStep[] steps = new ProcessingStep[] {new MD5Verifier("0cbc6611f5540bd0809a388dc95a615b")};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write("Test".getBytes());
+		testStream.close();
+		assertEquals("Test", result.toString());
+	}
+
+	public void testExecuteOneMD5VerifierPSFails() throws IOException {
+		ProcessingStep[] steps = new ProcessingStep[] {new MD5Verifier("9cbc6611f5540bd0809a388dc95a615b")};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write("Test".getBytes());
+		try {
+			testStream.close();
+			assertEquals("Test", result.toString());
+			assertTrue((handler.validateSteps(testStream).getSeverity() == IStatus.ERROR));
+		} catch (IOException e) {
+			assertTrue(true);
+		}
+	}
+
+	public void testExecuteOneByteShifterAndOneMD5VerifierPSOk() throws IOException {
+		// Order of PSs is important!!
+		ProcessingStep[] steps = new ProcessingStep[] {new ByteShifter(1), new MD5Verifier("ceeee507e8db83294600218b4e198897")};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write(new byte[] {1, 2, 3, 4, 5});
+		testStream.close();
+		assertTrue(Arrays.equals(new byte[] {2, 4, 6, 8, 10}, result.toByteArray()));
+	}
+
+	public void testExecuteOneByteShifterAndOneMD5VerifierPSFailWrongOrder() throws IOException {
+		// Order of PSs is important - here it wrong!!
+		ProcessingStep[] steps = new ProcessingStep[] {new MD5Verifier("af476bbaf152a4c39ca4e5c498a88aa0"), new ByteShifter(1)};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write(new byte[] {1, 2, 3, 4, 5});
+		try {
+			testStream.close();
+			assertTrue(Arrays.equals(new byte[] {2, 4, 6, 8, 10}, result.toByteArray()));
+			assertTrue((handler.validateSteps(testStream).getSeverity() == IStatus.ERROR));
+		} catch (IOException e) {
+			assertTrue(true);
+		}
+	}
+
+	public void testAssureOrderingOfPSs1() throws IOException {
+		ProcessingStep[] steps = new ProcessingStep[] {new Adder(1), new Multiplier(2)};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write(new byte[] {1, 2, 3, 4, 5});
+		testStream.close();
+		assertTrue(Arrays.equals(new byte[] {4, 6, 8, 10, 12}, result.toByteArray()));
+	}
+
+	public void testAssureOrderingOfPSs2() throws IOException {
+		ProcessingStep[] steps = new ProcessingStep[] {new Multiplier(2), new Adder(1)};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write(new byte[] {1, 2, 3, 4, 5});
+		testStream.close();
+		assertTrue(Arrays.equals(new byte[] {3, 5, 7, 9, 11}, result.toByteArray()));
+	}
+
+	public void testExecuteOnePack200UnpackerPS() throws IOException {
+		ProcessingStep[] steps = new ProcessingStep[] {new Pack200Unpacker()};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(100000);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		InputStream inputStream = TestActivator.getContext().getBundle().getEntry("testData/jarprocessor.jar.pack.gz").openStream();
+		FileUtils.copyStream(inputStream, true, testStream, true);
+		assertEquals(35062, result.size());
+	}
+
+	public void testCreateByteShifterPS() {
+		ProcessingStepDescriptor descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.ByteShifter", "1", true);
+		ProcessingStep step = handler.create(descriptor, null);
+		assertNotNull(step);
+		assertEquals(ByteShifter.class, step.getClass());
+	}
+
+	public void testCreateMD5VerifierPS() {
+		ProcessingStepDescriptor descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.MD5Verifier", "1", true);
+		ProcessingStep step = handler.create(descriptor, null);
+		assertNotNull(step);
+		assertEquals(MD5Verifier.class, step.getClass());
+	}
+
+	public void testCreateAdderPS() {
+		ProcessingStepDescriptor descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Adder", "1", true);
+		ProcessingStep step = handler.create(descriptor, null);
+		assertNotNull(step);
+		assertEquals(Adder.class, step.getClass());
+	}
+
+	public void testCreateMultiplierPS() {
+		ProcessingStepDescriptor descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Multiplier", "2", true);
+		ProcessingStep step = handler.create(descriptor, null);
+		assertNotNull(step);
+		assertEquals(Multiplier.class, step.getClass());
+	}
+
+	public void testCreatePack200UnpackerPS() {
+		ProcessingStepDescriptor descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Pack200Unpacker", null, true);
+		ProcessingStep step = handler.create(descriptor, null);
+		assertNotNull(step);
+		assertEquals(Pack200Unpacker.class, step.getClass());
+	}
+
+	public void testCreatePSsAndAssureOrderingOfPSs1() throws IOException {
+		ProcessingStepDescriptor descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Adder", "1", true);
+		ProcessingStep adder = handler.create(descriptor, null);
+
+		descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Multiplier", "2", true);
+		ProcessingStep multiplier = handler.create(descriptor, null);
+
+		ProcessingStep[] steps = new ProcessingStep[] {adder, multiplier};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write(new byte[] {1, 2, 3, 4, 5});
+		testStream.close();
+		assertTrue(Arrays.equals(new byte[] {4, 6, 8, 10, 12}, result.toByteArray()));
+	}
+
+	public void testCreatePSsAndAssureOrderingOfPSs2() throws IOException {
+		ProcessingStepDescriptor descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Adder", "1", true);
+		ProcessingStep adder = handler.create(descriptor, null);
+
+		descriptor = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Multiplier", "2", true);
+		ProcessingStep multiplier = handler.create(descriptor, null);
+
+		ProcessingStep[] steps = new ProcessingStep[] {multiplier, adder};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.link(steps, result, monitor);
+		testStream.write(new byte[] {1, 2, 3, 4, 5});
+		testStream.close();
+		assertTrue(Arrays.equals(new byte[] {3, 5, 7, 9, 11}, result.toByteArray()));
+	}
+
+	public void testLinkPSs() throws IOException {
+		ProcessingStepDescriptor descriptor1 = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Adder", "1", true);
+		ProcessingStepDescriptor descriptor2 = new ProcessingStepDescriptor("org.eclipse.equinox.prov.processing.Multiplier", "2", true);
+		ProcessingStepDescriptor[] descriptors = new ProcessingStepDescriptor[] {descriptor1, descriptor2};
+		ByteArrayOutputStream result = new ByteArrayOutputStream(10);
+		OutputStream testStream = handler.createAndLink(descriptors, null, result, monitor);
+		testStream.write(new byte[] {1, 2, 3, 4, 5});
+		testStream.close();
+		assertTrue(Arrays.equals(new byte[] {4, 6, 8, 10, 12}, result.toByteArray()));
+	}
+
+}