diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..a2ffea9 --- /dev/null +++ b/.gitignore @@ -0,0 +1,6 @@ +.gradle/ +.idea/ +build/ +gradlew.bat + +*.iml diff --git a/build.gradle b/build.gradle new file mode 100644 index 0000000..127e034 --- /dev/null +++ b/build.gradle @@ -0,0 +1,107 @@ +group 'io.advantageous.reakt' +version '2.1.0-SNAPSHOT' + +apply plugin: 'java' +apply plugin: 'maven' +apply plugin: 'signing' +apply plugin: 'idea' + + +ext { + vertxVersion = '3.2.1' +} + +sourceCompatibility = JavaVersion.VERSION_1_8 +targetCompatibility = JavaVersion.VERSION_1_8 + +task wrapper(type: Wrapper) { + gradleVersion = '2.11' +} + +test.onlyIf { !Boolean.getBoolean('skip.tests') } + + +repositories { + mavenLocal() + mavenCentral() +} + +dependencies { + + testCompile group: 'junit', name: 'junit', version: '4.11' + compile group: project.group, name: 'reakt', version: "2.1.0-SNAPSHOT" + compile group: 'io.vertx', name: 'vertx-core', version: vertxVersion + +} + +task javadocJar(type: Jar, dependsOn: javadoc) { + classifier = 'javadoc' + from 'build/docs/javadoc' +} + +task sourcesJar(type: Jar) { + from sourceSets.main.allSource + classifier = 'sources' +} + +artifacts { + archives jar + archives javadocJar + archives sourcesJar +} + +signing { + required false + sign configurations.archives +} + + + +uploadArchives { + repositories { + mavenDeployer { + beforeDeployment { MavenDeployment deployment -> signing.signPom(deployment) } + repository(url: "https://oss.sonatype.org/service/local/staging/deploy/maven2/") { + try { + authentication(userName: sonatypeUsername, password: sonatypePassword) + } catch (MissingPropertyException ignore) { + } + } + + pom.project { + packaging 'jar' + name project.name + description "Bridge from Reakt to Vertx to provide promises." + + url 'https://github.com/advantageous/${project.name}' + + scm { + url 'scm:git@github.com:advantageous/${project.name}.git' + connection 'scm:git@github.com:advantageous/${project.name}.git' + developerConnection 'scm:git@github.com:advantageous/${project.name}.git' + } + + licenses { + license { + name 'The Apache Software License, Version 2.0' + url 'http://www.apache.org/licenses/LICENSE-2.0.txt' + distribution 'repo' + } + } + + developers { + developer { + id 'richardHightower' + name 'Richard Hightower' + } + developer { + id 'sailorgeoffrey' + name 'Geoffrey Chandler' + } + } + } + } + } +} + + diff --git a/gradle/wrapper/gradle-wrapper.jar b/gradle/wrapper/gradle-wrapper.jar new file mode 100644 index 0000000..30d399d Binary files /dev/null and b/gradle/wrapper/gradle-wrapper.jar differ diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties new file mode 100644 index 0000000..99b8298 --- /dev/null +++ b/gradle/wrapper/gradle-wrapper.properties @@ -0,0 +1,6 @@ +#Wed Apr 13 23:49:57 PDT 2016 +distributionBase=GRADLE_USER_HOME +distributionPath=wrapper/dists +zipStoreBase=GRADLE_USER_HOME +zipStorePath=wrapper/dists +distributionUrl=https\://services.gradle.org/distributions/gradle-2.5-bin.zip diff --git a/gradlew b/gradlew new file mode 100755 index 0000000..91a7e26 --- /dev/null +++ b/gradlew @@ -0,0 +1,164 @@ +#!/usr/bin/env bash + +############################################################################## +## +## Gradle start up script for UN*X +## +############################################################################## + +# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. +DEFAULT_JVM_OPTS="" + +APP_NAME="Gradle" +APP_BASE_NAME=`basename "$0"` + +# Use the maximum available, or set MAX_FD != -1 to use that value. +MAX_FD="maximum" + +warn ( ) { + echo "$*" +} + +die ( ) { + echo + echo "$*" + echo + exit 1 +} + +# OS specific support (must be 'true' or 'false'). +cygwin=false +msys=false +darwin=false +case "`uname`" in + CYGWIN* ) + cygwin=true + ;; + Darwin* ) + darwin=true + ;; + MINGW* ) + msys=true + ;; +esac + +# For Cygwin, ensure paths are in UNIX format before anything is touched. +if $cygwin ; then + [ -n "$JAVA_HOME" ] && JAVA_HOME=`cygpath --unix "$JAVA_HOME"` +fi + +# Attempt to set APP_HOME +# Resolve links: $0 may be a link +PRG="$0" +# Need this for relative symlinks. +while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> \(.*\)$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG=`dirname "$PRG"`"/$link" + fi +done +SAVED="`pwd`" +cd "`dirname \"$PRG\"`/" >&- +APP_HOME="`pwd -P`" +cd "$SAVED" >&- + +CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar + +# Determine the Java command to use to start the JVM. +if [ -n "$JAVA_HOME" ] ; then + if [ -x "$JAVA_HOME/jre/sh/java" ] ; then + # IBM's JDK on AIX uses strange locations for the executables + JAVACMD="$JAVA_HOME/jre/sh/java" + else + JAVACMD="$JAVA_HOME/bin/java" + fi + if [ ! -x "$JAVACMD" ] ; then + die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME + +Please set the JAVA_HOME variable in your environment to match the +location of your Java installation." + fi +else + JAVACMD="java" + which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. + +Please set the JAVA_HOME variable in your environment to match the +location of your Java installation." +fi + +# Increase the maximum file descriptors if we can. +if [ "$cygwin" = "false" -a "$darwin" = "false" ] ; then + MAX_FD_LIMIT=`ulimit -H -n` + if [ $? -eq 0 ] ; then + if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then + MAX_FD="$MAX_FD_LIMIT" + fi + ulimit -n $MAX_FD + if [ $? -ne 0 ] ; then + warn "Could not set maximum file descriptor limit: $MAX_FD" + fi + else + warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT" + fi +fi + +# For Darwin, add options to specify how the application appears in the dock +if $darwin; then + GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\"" +fi + +# For Cygwin, switch paths to Windows format before running java +if $cygwin ; then + APP_HOME=`cygpath --path --mixed "$APP_HOME"` + CLASSPATH=`cygpath --path --mixed "$CLASSPATH"` + + # We build the pattern for arguments to be converted via cygpath + ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null` + SEP="" + for dir in $ROOTDIRSRAW ; do + ROOTDIRS="$ROOTDIRS$SEP$dir" + SEP="|" + done + OURCYGPATTERN="(^($ROOTDIRS))" + # Add a user-defined pattern to the cygpath arguments + if [ "$GRADLE_CYGPATTERN" != "" ] ; then + OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)" + fi + # Now convert the arguments - kludge to limit ourselves to /bin/sh + i=0 + for arg in "$@" ; do + CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -` + CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option + + if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition + eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"` + else + eval `echo args$i`="\"$arg\"" + fi + i=$((i+1)) + done + case $i in + (0) set -- ;; + (1) set -- "$args0" ;; + (2) set -- "$args0" "$args1" ;; + (3) set -- "$args0" "$args1" "$args2" ;; + (4) set -- "$args0" "$args1" "$args2" "$args3" ;; + (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;; + (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;; + (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;; + (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;; + (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;; + esac +fi + +# Split up the JVM_OPTS And GRADLE_OPTS values into an array, following the shell quoting and substitution rules +function splitJvmOpts() { + JVM_OPTS=("$@") +} +eval splitJvmOpts $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS +JVM_OPTS[${#JVM_OPTS[*]}]="-Dorg.gradle.appname=$APP_BASE_NAME" + +exec "$JAVACMD" "${JVM_OPTS[@]}" -classpath "$CLASSPATH" org.gradle.wrapper.GradleWrapperMain "$@" diff --git a/settings.gradle b/settings.gradle new file mode 100644 index 0000000..459c8e5 --- /dev/null +++ b/settings.gradle @@ -0,0 +1,2 @@ +rootProject.name = 'reakt-vertx' + diff --git a/src/main/java/io/advantageous/reakt/vertx/ReaktVertx.java b/src/main/java/io/advantageous/reakt/vertx/ReaktVertx.java new file mode 100644 index 0000000..9601fe5 --- /dev/null +++ b/src/main/java/io/advantageous/reakt/vertx/ReaktVertx.java @@ -0,0 +1,37 @@ +package io.advantageous.reakt.vertx; + +import io.advantageous.reakt.Callback; +import io.advantageous.reakt.promise.Promise; +import io.vertx.core.AsyncResult; +import io.vertx.core.Handler; + +public class ReaktVertx { + + + /** + * Works with both Reakt promises and Reakt callbacks + * @param promise promise + * @param type of result + * @return vertx handler + */ + public static Handler> convertPromise(final Promise promise) { + return convertCallback(promise); + } + + /** + * Works with both Reakt promises and Reakt callbacks + * @param callback callback + * @param type of result + * @return vertx handler + */ + public static Handler> convertCallback(final Callback callback) { + return event -> { + if (event.failed()) { + callback.reject(event.cause()); + } else { + callback.resolve(event.result()); + } + }; + } + +} diff --git a/src/test/java/io/advantageous/reakt/vertx/ReaktVertxTest.java b/src/test/java/io/advantageous/reakt/vertx/ReaktVertxTest.java new file mode 100644 index 0000000..ea53c7f --- /dev/null +++ b/src/test/java/io/advantageous/reakt/vertx/ReaktVertxTest.java @@ -0,0 +1,111 @@ +package io.advantageous.reakt.vertx; + +import io.advantageous.reakt.Expected; +import io.advantageous.reakt.promise.Promise; +import io.advantageous.reakt.promise.Promises; +import io.vertx.core.AsyncResult; +import io.vertx.core.Handler; +import org.junit.Test; + +import java.util.concurrent.atomic.AtomicReference; + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertTrue; + +public class ReaktVertxTest { + + public static class Employee { + private final String id; + + public Employee(String id) { + this.id = id; + } + } + + @Test + public void testConvertPromiseSuccess() throws Exception { + + AtomicReference> ref = new AtomicReference<>(); + Promise promise = Promises.promise(); + promise.thenExpect(ref::set); + final Handler> asyncResultHandler = ReaktVertx.convertPromise(promise); + + AsyncResult asyncResult = new AsyncResult() { + @Override + public Employee result() { + return new Employee("Bob"); + } + + @Override + public Throwable cause() { + return null; + } + + @Override + public boolean succeeded() { + return true; + } + + @Override + public boolean failed() { + return false; + } + }; + + + asyncResultHandler.handle(asyncResult); + + + assertTrue(promise.complete()); + assertTrue(promise.success()); + assertNotNull(promise.get()); + assertEquals("Bob", promise.get().id); + assertNotNull(ref.get()); + assertTrue(ref.get().isPresent()); + assertEquals("Bob", ref.get().get().id); + } + + + @Test + public void testConvertPromiseFailure() throws Exception { + + AtomicReference ref = new AtomicReference<>(); + Promise promise = Promises.promise(); + promise.catchError(ref::set); + final Handler> asyncResultHandler = ReaktVertx.convertPromise(promise); + + AsyncResult asyncResult = new AsyncResult() { + @Override + public Employee result() { + return null; + } + + @Override + public Throwable cause() { + return new Exception("bad stuff"); + } + + @Override + public boolean succeeded() { + return false; + } + + @Override + public boolean failed() { + return true; + } + }; + + + asyncResultHandler.handle(asyncResult); + + + assertTrue(promise.complete()); + assertTrue(promise.failure()); + assertNotNull(promise.cause()); + assertNotNull(ref.get()); + assertEquals("bad stuff", promise.cause().getMessage()); + assertEquals("bad stuff", ref.get().getMessage()); + } +} \ No newline at end of file