Added support for running the TCK in Arquillian

streams/pom.xml

@@ -37,6 +37,7 @@
     <modules>
         <module>api</module>
         <module>tck</module>
+        <module>tck-arquillian</module>
         <module>spec</module>
     </modules>
 
@@ -67,6 +68,23 @@
                 <artifactId>org.osgi.annotation.versioning</artifactId>
                 <version>1.0.0</version>
             </dependency>
+            <dependency>
+                <groupId>org.jboss.arquillian</groupId>
+                <artifactId>arquillian-bom</artifactId>
+                <version>1.1.15.Final</version>
+                <scope>import</scope>
+                <type>pom</type>
+            </dependency>
+            <dependency>
+                <groupId>org.testng</groupId>
+                <artifactId>testng</artifactId>
+                <version>6.11</version>
+            </dependency>
+            <dependency>
+                <groupId>javax.enterprise</groupId>
+                <artifactId>cdi-api</artifactId>
+                <version>2.0</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
 </project>

streams/tck-arquillian/pom.xml

@@ -0,0 +1,131 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+  ~ Copyright (c) 2018 Contributors to the Eclipse Foundation
+  ~
+  ~ See the NOTICE file(s) distributed with this work for additional
+  ~ information regarding copyright ownership.
+  ~
+  ~ Licensed under the Apache License, Version 2.0 (the "License");
+  ~ You may not use this file except in compliance with the License.
+  ~ You may obtain a copy of the License at
+  ~
+  ~     http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~ Unless required by applicable law or agreed to in writing, software
+  ~ distributed under the License is distributed on an "AS IS" BASIS,
+  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~ See the License for the specific language governing permissions and
+  ~ limitations under the License.
+  ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~-->
+
+<!--
+    Licensed under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+-->
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.eclipse.microprofile.reactive.streams</groupId>
+        <artifactId>microprofile-reactive-streams-parent</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>microprofile-reactive-streams-operators-tck-arquillian</artifactId>
+    <name>MicroProfile Reactive Streams Operators TCK Arquillian</name>
+    <description>MicroProfile Reactive Streams Operators :: TCK Arquillian runner</description>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.eclipse.microprofile.reactive.streams</groupId>
+            <artifactId>microprofile-reactive-streams-operators</artifactId>
+            <version>${project.version}</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.microprofile.reactive.streams</groupId>
+            <artifactId>microprofile-reactive-streams-operators-tck</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.jboss.arquillian.test</groupId>
+            <artifactId>arquillian-test-spi</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.jboss.arquillian.testng</groupId>
+            <artifactId>arquillian-testng-container</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>javax.enterprise</groupId>
+            <artifactId>cdi-api</artifactId>
+            <scope>provided</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-javadoc-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <id>attach-javadocs</id>
+                        <goals>
+                            <goal>jar</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-source-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <id>attach-sources</id>
+                        <goals>
+                            <goal>jar</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.eclipse.microprofile.maven</groupId>
+                <artifactId>microprofile-maven-build-extension</artifactId>
+                <extensions>true</extensions>
+            </plugin>
+        </plugins>
+    </build>
+
+    <profiles>
+        <profile>
+            <id>eclipse-jarsigner</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.eclipse.cbi.maven.plugins</groupId>
+                        <artifactId>eclipse-jarsigner-plugin</artifactId>
+                        <executions>
+                            <execution>
+                                <goals>
+                                    <goal>sign</goal>
+                                </goals>
+                            </execution>
+                        </executions>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
+
+</project>

streams/tck-arquillian/src/main/java/org/eclipse/microprofile/reactive/streams/tck/arquillian/ReactiveStreamsArquillianTck.java

@@ -0,0 +1,177 @@
+/*******************************************************************************
+ * Copyright (c) 2018 Contributors to the Eclipse Foundation
+ *
+ * See the NOTICE file(s) distributed with this work for additional
+ * information regarding copyright ownership.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * You may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ ******************************************************************************/
+
+package org.eclipse.microprofile.reactive.streams.tck.arquillian;
+
+import org.eclipse.microprofile.reactive.streams.tck.ReactiveStreamsTck;
+import org.jboss.arquillian.container.test.api.Deployment;
+import org.jboss.arquillian.testng.Arquillian;
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.asset.EmptyAsset;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.reactivestreams.tck.TestEnvironment;
+import org.testng.IClassListener;
+import org.testng.IMethodInstance;
+import org.testng.IMethodInterceptor;
+import org.testng.IObjectFactory;
+import org.testng.ITestClass;
+import org.testng.ITestContext;
+import org.testng.ITestListener;
+import org.testng.ITestNGListener;
+import org.testng.ITestResult;
+import org.testng.TestNG;
+import org.testng.annotations.Test;
+import org.testng.internal.ObjectFactoryImpl;
+
+import javax.inject.Inject;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.List;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicReference;
+
+/**
+ * Test runner for running the TCK in Arquillian.
+ * <p>
+ * It would be nice if this was able to run the tests properly, and I did get something working, but it was so complex
+ * and fragile because Arquillian really isn't that flexible that I decided it simply wasn't worth it, this is much
+ * simpler.
+ */
+public class ReactiveStreamsArquillianTck extends Arquillian {
+    @Deployment
+    public static JavaArchive tckDeployment() {
+        return ShrinkWrap.create(JavaArchive.class)
+            // Add everything from the TCK
+            .addPackages(true, ReactiveStreamsTck.class.getPackage())
+            // And add the reactive streams TCK
+            .addPackages(true, TestEnvironment.class.getPackage())
+            // And we need a CDI descriptor
+            .addAsManifestResource(EmptyAsset.INSTANCE, "beans.xml");
+
+    }
+
+    @Inject
+    private ReactiveStreamsCdiTck tck;
+
+    @Test
+    public void runAllTckTests() throws Throwable {
+        TestNG testng = new TestNG();
+
+        ObjectFactoryImpl delegate = new ObjectFactoryImpl();
+        testng.setObjectFactory((IObjectFactory) (constructor, params) -> {
+            if (constructor.getDeclaringClass().equals(ReactiveStreamsCdiTck.class)) {
+                return tck;
+            }
+            else {
+                return delegate.newInstance(constructor, params);
+            }
+        });
+
+        testng.setUseDefaultListeners(false);
+        ResultListener resultListener = new ResultListener();
+        testng.addListener((ITestNGListener) resultListener);
+        testng.setTestClasses(new Class[]{ ReactiveStreamsCdiTck.class });
+        testng.setMethodInterceptor(new IMethodInterceptor() {
+            @Override
+            public List<IMethodInstance> intercept(List<IMethodInstance> methods, ITestContext context) {
+                methods.sort(Comparator.comparing(m -> m.getInstance().getClass().getName()));
+                return methods;
+            }
+        });
+        testng.run();
+        int total = resultListener.success.get() + resultListener.failed.get() + resultListener.skipped.get();
+        System.out.println(String.format("Ran %d tests, %d passed, %d failed, %d skipped.", total, resultListener.success.get(),
+            resultListener.failed.get(), resultListener.skipped.get()));
+        System.out.println("Failed tests:");
+        resultListener.failures.forEach(result -> {
+            System.out.println(result.getInstance().getClass().getName() + "." + result.getMethod().getMethodName());
+        });
+        if (resultListener.failed.get() > 0) {
+            if (resultListener.lastFailure.get() != null) {
+                throw resultListener.lastFailure.get();
+            }
+            else {
+                throw new Exception("Tests failed with no exception");
+            }
+        }
+    }
+
+    private static class ResultListener implements IClassListener, ITestListener {
+        private final AtomicInteger success = new AtomicInteger();
+        private final AtomicInteger failed = new AtomicInteger();
+        private final AtomicInteger skipped = new AtomicInteger();
+        private final AtomicReference<Throwable> lastFailure = new AtomicReference<>();
+        private final List<ITestResult> failures = Collections.synchronizedList(new ArrayList<>());
+
+        @Override
+        public void onBeforeClass(ITestClass testClass) {
+            System.out.println(testClass.getName() + ":");
+        }
+
+        @Override
+        public void onAfterClass(ITestClass testClass) {
+        }
+
+        @Override
+        public void onTestStart(ITestResult result) {
+        }
+
+        @Override
+        public void onTestSuccess(ITestResult result) {
+            printResult(result, "SUCCESS");
+            success.incrementAndGet();
+        }
+
+        @Override
+        public void onTestFailure(ITestResult result) {
+            printResult(result, "FAILED");
+            if (result.getThrowable() != null) {
+                result.getThrowable().printStackTrace(System.out);
+                lastFailure.set(result.getThrowable());
+            }
+            failures.add(result);
+            failed.incrementAndGet();
+        }
+
+        @Override
+        public void onTestSkipped(ITestResult result) {
+            printResult(result, "SKIPPED");
+            skipped.incrementAndGet();
+        }
+
+        @Override
+        public void onTestFailedButWithinSuccessPercentage(ITestResult result) {
+        }
+
+        @Override
+        public void onStart(ITestContext context) {
+        }
+
+        @Override
+        public void onFinish(ITestContext context) {
+
+        }
+
+        private static void printResult(ITestResult result, String status) {
+            String methodName = String.format("%-100s", result.getMethod().getMethodName()).replace(' ', '.');
+            System.out.println(" - " + methodName + "." + status);
+        }
+    }
+}

streams/tck-arquillian/src/main/java/org/eclipse/microprofile/reactive/streams/tck/arquillian/ReactiveStreamsCdiTck.java

@@ -0,0 +1,43 @@
+/*******************************************************************************
+ * Copyright (c) 2018 Contributors to the Eclipse Foundation
+ *
+ * See the NOTICE file(s) distributed with this work for additional
+ * information regarding copyright ownership.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * You may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ ******************************************************************************/
+
+package org.eclipse.microprofile.reactive.streams.tck.arquillian;
+
+import org.eclipse.microprofile.reactive.streams.spi.ReactiveStreamsEngine;
+import org.eclipse.microprofile.reactive.streams.tck.ReactiveStreamsTck;
+import org.reactivestreams.tck.TestEnvironment;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Inject;
+
+@ApplicationScoped
+public class ReactiveStreamsCdiTck extends ReactiveStreamsTck<ReactiveStreamsEngine> {
+
+    public ReactiveStreamsCdiTck() {
+        super(new TestEnvironment());
+    }
+
+    @Inject
+    private ReactiveStreamsEngine engine;
+
+    @Override
+    protected ReactiveStreamsEngine createEngine() {
+        return engine;
+    }
+}