Websocketsupport (#40)

Author: yschimke

rsocket-cli

@@ -2,5 +2,5 @@
 
 ./gradlew -q installDist
 
-./build/install/reactivesocket-cli/bin/reactivesocket-cli "$@"
+./build/install/rsocket-cli/bin/rsocket-cli "$@"
 

settings.gradle

@@ -1 +1 @@
-rootProject.name='reactivesocket-cli'
+rootProject.name='rsocket-cli'

src/dist/bash/completion.bash

@@ -30,7 +30,7 @@ _reactivesocket_complete()
   fi
 
   # TODO remember recent hosts
-  _reactivesocket_hosts="tcp://localhost:9898"
+  _reactivesocket_hosts="tcp://localhost:9898 ws://localhost:9897"
   COMPREPLY=( $( compgen -W "$_reactivesocket_hosts" -- "$cur" ) )
 
   __ltrim_colon_completions "$cur"

src/main/java/io/rsocket/cli/ConnectionHelper.java

@@ -16,7 +16,9 @@
 import io.rsocket.transport.ClientTransport;
 import io.rsocket.transport.ServerTransport;
 import io.rsocket.transport.netty.client.TcpClientTransport;
+import io.rsocket.transport.netty.client.WebsocketClientTransport;
 import io.rsocket.transport.netty.server.TcpServerTransport;
+import io.rsocket.transport.netty.server.WebsocketServerTransport;
 import reactor.ipc.netty.tcp.TcpClient;
 import reactor.ipc.netty.tcp.TcpServer;
 
@@ -26,6 +28,8 @@ public class ConnectionHelper {
     public static ClientTransport buildClientConnection(URI uri) {
         if ("tcp".equals(uri.getScheme())) {
             return TcpClientTransport.create(TcpClient.create(uri.getHost(), uri.getPort()));
+        } else if ("ws".equals(uri.getScheme())) {
+            return WebsocketClientTransport.create(uri.getHost(), uri.getPort());
         } else {
             throw new UnsupportedOperationException("uri unsupported: " + uri);
         }
@@ -34,6 +38,8 @@ public static ClientTransport buildClientConnection(URI uri) {
     public static ServerTransport buildServerConnection(URI uri) {
         if ("tcp".equals(uri.getScheme())) {
             return TcpServerTransport.create(TcpServer.create(uri.getHost(), uri.getPort()));
+        } else if ("ws".equals(uri.getScheme())) {
+            return WebsocketServerTransport.create(uri.getHost(), uri.getPort());
         } else {
             throw new UnsupportedOperationException("uri unsupported: " + uri);
         }