Experimental/jsonrpc: _WIP_Implement JSONRPC as wire protocol

.github/maven-cd-settings.xml

@@ -0,0 +1,63 @@
+<!--
+  ~ Copyright (c) 2021 Red Hat, Inc.
+  ~
+  ~ 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.
+  -->
+
+<settings>
+
+  <interactiveMode>false</interactiveMode>
+
+  <servers>
+    <server>
+      <id>vertx-snapshots-repository</id>
+      <username>${env.VERTX_NEXUS_USERNAME}</username>
+      <password>${env.VERTX_NEXUS_PASSWORD}</password>
+    </server>
+  </servers>
+
+  <profiles>
+    <profile>
+      <id>google-mirror</id>
+      <activation>
+        <activeByDefault>true</activeByDefault>
+      </activation>
+      <repositories>
+        <repository>
+          <id>google-maven-central</id>
+          <name>GCS Maven Central mirror EU</name>
+          <url>https://maven-central.storage-download.googleapis.com/maven2/</url>
+          <releases>
+            <enabled>true</enabled>
+          </releases>
+          <snapshots>
+            <enabled>false</enabled>
+          </snapshots>
+        </repository>
+      </repositories>
+      <pluginRepositories>
+        <pluginRepository>
+          <id>google-maven-central</id>
+          <name>GCS Maven Central mirror</name>
+          <url>https://maven-central.storage-download.googleapis.com/maven2/</url>
+          <releases>
+            <enabled>true</enabled>
+          </releases>
+          <snapshots>
+            <enabled>false</enabled>
+          </snapshots>
+        </pluginRepository>
+      </pluginRepositories>
+    </profile>
+  </profiles>
+</settings>

.github/maven-ci-settings.xml

@@ -0,0 +1,55 @@
+<!--
+  ~ Copyright (c) 2021 Red Hat, Inc.
+  ~
+  ~ 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.
+  -->
+
+<settings>
+
+  <interactiveMode>false</interactiveMode>
+
+  <profiles>
+    <profile>
+      <id>google-mirror</id>
+      <activation>
+        <activeByDefault>true</activeByDefault>
+      </activation>
+      <repositories>
+        <repository>
+          <id>google-maven-central</id>
+          <name>GCS Maven Central mirror EU</name>
+          <url>https://maven-central.storage-download.googleapis.com/maven2/</url>
+          <releases>
+            <enabled>true</enabled>
+          </releases>
+          <snapshots>
+            <enabled>false</enabled>
+          </snapshots>
+        </repository>
+      </repositories>
+      <pluginRepositories>
+        <pluginRepository>
+          <id>google-maven-central</id>
+          <name>GCS Maven Central mirror</name>
+          <url>https://maven-central.storage-download.googleapis.com/maven2/</url>
+          <releases>
+            <enabled>true</enabled>
+          </releases>
+          <snapshots>
+            <enabled>false</enabled>
+          </snapshots>
+        </pluginRepository>
+      </pluginRepositories>
+    </profile>
+  </profiles>
+</settings>

.github/workflows/ci.yml

@@ -0,0 +1,51 @@
+name: CI
+on:
+  push:
+    branches:
+      - master
+      - '[0-9]+.[0-9]+'
+  pull_request:
+    branches:
+      - master
+      - '[0-9]+.[0-9]+'
+  schedule:
+    - cron:  '0 4 * * *'
+jobs:
+  Test:
+    name: Run tests
+    strategy:
+      matrix:
+        os: [ubuntu-latest]
+        jdk: [8, 17]
+    runs-on: ${{ matrix.os }}
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v2
+      - name: Install JDK
+        uses: actions/setup-java@v2
+        with:
+          java-version: ${{ matrix.jdk }}
+          distribution: temurin
+      - name: Run tests
+        run: mvn -s .github/maven-ci-settings.xml -q clean verify -B
+  Deploy:
+    name: Deploy to OSSRH
+    if: ${{ github.repository_owner == 'vert-x3' && (github.event_name == 'push' || github.event_name == 'schedule') }}
+    needs: Test
+    runs-on: ubuntu-latest
+    env:
+      VERTX_NEXUS_USERNAME: ${{ secrets.VERTX_NEXUS_USERNAME }}
+      VERTX_NEXUS_PASSWORD: ${{ secrets.VERTX_NEXUS_PASSWORD }}
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v2
+      - name: Install JDK
+        uses: actions/setup-java@v2
+        with:
+          java-version: 8
+          distribution: temurin
+      - name: Get project version
+        run: echo "PROJECT_VERSION=$(mvn org.apache.maven.plugins:maven-help-plugin:evaluate -Dexpression=project.version -B | grep -v '\[')" >> $GITHUB_ENV
+      - name: Maven deploy
+        if: ${{ endsWith(env.PROJECT_VERSION, '-SNAPSHOT') }}
+        run: mvn deploy -s .github/maven-cd-settings.xml -DskipTests -B

README.md

@@ -1,6 +1,6 @@
 # vertx-tcp-eventbus-bridge
 
-[![Build Status](https://travis-ci.org/vert-x3/vertx-tcp-eventbus-bridge.svg?branch=master)](https://travis-ci.org/vert-x3/vertx-tcp-eventbus-bridge)
+[![Build Status](https://github.com/vert-x3/vertx-tcp-eventbus-bridge/workflows/CI/badge.svg?branch=master)](https://github.com/vert-x3/vertx-tcp-eventbus-bridge/actions?query=workflow%3ACI)
 
 This is a TCP eventbus bridge implementation.
 
@@ -34,7 +34,7 @@ It is the response to the `ping` request from client to bridge.
 For a regular message, the object will also contain:
 
 * `address`: (string, required) Destination address.
-* `body`: (object, required) Message content as a JSON object.
+* `body`: (any, required) Message content as a JSON valid type.
 * `headers`: (object, optional) Headers as a JSON object with String values.
 * `replyAddress`: (string, optional) Address for replying to.
 * `send`: (boolean, required) Will be `true` if the message is a send, `false` if a publish.
@@ -54,7 +54,7 @@ type is shown below, along with the companion keys for that type:
 #### `type: "send"`, `type: "publish"`
 
 * `address`: (string, required) Destination address
-* `body`: (object, required) Message content as a JSON object.
+* `body`: (any, required) Message content as a JSON valid type.
 * `headers`: (object, optional) Headers as a JSON object with String values.
 * `replyAddress`: (string, optional) Address for replying to.
 

pom.xml

@@ -20,16 +20,16 @@
   <parent>
     <groupId>io.vertx</groupId>
     <artifactId>vertx-ext-parent</artifactId>
-    <version>34</version>
+    <version>38</version>
   </parent>
 
   <artifactId>vertx-tcp-eventbus-bridge</artifactId>
-  <version>4.0.0-SNAPSHOT</version>
+  <version>4.2.1-SNAPSHOT</version>
 
   <name>Vert.x TCP EventBus Bridge</name>
 
   <properties>
-    <stack.version>4.0.0-SNAPSHOT</stack.version>
+    <stack.version>4.2.1-SNAPSHOT</stack.version>
   </properties>
 
   <dependencyManagement>
@@ -77,12 +77,18 @@
       <groupId>junit</groupId>
       <artifactId>junit</artifactId>
       <scope>test</scope>
-      <version>4.12</version>
+      <version>4.13.1</version>
     </dependency>
     <dependency>
       <groupId>io.vertx</groupId>
       <artifactId>vertx-unit</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.bouncycastle</groupId>
+      <artifactId>bcpkix-jdk15on</artifactId>
+      <version>1.65</version>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 </project>

src/client/nodejs/lib/tcp-vertx-eventbus.js

@@ -47,7 +47,7 @@ function send(transport, message) {
   message = Buffer.from(message, "utf-8");
   var msgLen = message.length;
 
-  var buffer = new Buffer(4);
+  var buffer =  Buffer.alloc(4);
   buffer.writeInt32BE(msgLen, 0);
 
   transport.write(Buffer.concat([buffer, message], 4 + msgLen));
@@ -101,7 +101,7 @@ var EventBus = function (host, port, options) {
   this.onerror = console.error;
 
   // message buffer
-  var buffer = new Buffer(0);
+  var buffer =  Buffer.alloc(0);
   var len    = 0;
 
   this.transport.on('close', function () {

src/client/nodejs/package.json

@@ -2,7 +2,7 @@
   "name": "vertx3-eventbus-client",
   "description": "Vert.x3 TCP event bus client",
   "dependencies": {
-    "node-uuid": "1.4.3"
+    "node-uuid": "1.4.8"
   },
   "devDependencies": {
     "mocha": "2.3.3"

src/main/java/io/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge.java

@@ -18,6 +18,7 @@
 import io.vertx.codegen.annotations.Fluent;
 import io.vertx.codegen.annotations.VertxGen;
 import io.vertx.core.AsyncResult;
+import io.vertx.core.Future;
 import io.vertx.core.Handler;
 import io.vertx.core.Vertx;
 import io.vertx.core.net.NetServerOptions;
@@ -49,10 +50,9 @@ static TcpEventBusBridge create(Vertx vertx, BridgeOptions options, NetServerOpt
   /**
    * Listen on default port 7000
    *
-   * @return self
+   * @return a future of the result
    */
-  @Fluent
-  TcpEventBusBridge listen();
+  Future<TcpEventBusBridge> listen();
 
   /**
    * Listen on default port 7000 with a handler to report the state of the socket listen operation.
@@ -69,10 +69,9 @@ static TcpEventBusBridge create(Vertx vertx, BridgeOptions options, NetServerOpt
    * @param port tcp port
    * @param address tcp address to the bind
    *
-   * @return self
+   * @return a future of the result
    */
-  @Fluent
-  TcpEventBusBridge listen(int port, String address);
+  Future<TcpEventBusBridge> listen(int port, String address);
 
   /**
    * Listen on specific port and bind to specific address
@@ -91,10 +90,9 @@ static TcpEventBusBridge create(Vertx vertx, BridgeOptions options, NetServerOpt
    *
    * @param port tcp port
    *
-   * @return self
+   * @return a future of the result
    */
-  @Fluent
-  TcpEventBusBridge listen(int port);
+  Future<TcpEventBusBridge> listen(int port);
 
   /**
    * Listen on specific port
@@ -116,6 +114,8 @@ static TcpEventBusBridge create(Vertx vertx, BridgeOptions options, NetServerOpt
 
   /**
    * Close the current socket.
+   *
+   * @return a future of the result
    */
-  void close();
+  Future<Void> close();
 }