ci: use common-deps 1.6.1-SNAPSHOT; add the lib-snapshot-local repo (#68)

* ci: use common-deps 1.6.1-SNAPSHOT; add the lib-snapshot-local repo

* ci: write-locks

* fix compile errors

Author: flyinprogrammer

build.gradle

@@ -65,6 +65,13 @@ subprojects {
                 password = project.findProperty('netifiArtifactoryPassword') ?: System.getenv('NETIFI_ARTIFACTORY_PASSWORD')
             }
         }
+        maven {
+            url = 'https://artifactory.netifiinc.com/artifactory/libs-snapshot-local'
+            credentials {
+                username = project.findProperty('netifiArtifactoryUsername') ?: System.getenv('NETIFI_ARTIFACTORY_USERNAME')
+                password = project.findProperty('netifiArtifactoryPassword') ?: System.getenv('NETIFI_ARTIFACTORY_PASSWORD')
+            }
+        }
         maven {
             url  "https://dl.bintray.com/netifi/netifi-oss"
         }

dependency-management.gradle

@@ -1,7 +1,7 @@
 apply plugin: 'io.spring.dependency-management'
 
 ext['slf4j.version'] = '1.7.25'
-ext['proteus-common-dependencies.version'] = '1.6.0'
+ext['proteus-common-dependencies.version'] = '1.6.1-SNAPSHOT'
 
 dependencyManagement {
   imports {

proteus-auth/gradle/dependency-locks/testCompileClasspath.lockfile

@@ -17,9 +17,9 @@ io.netty:netty-transport:4.1.33.Final
 io.projectreactor.netty:reactor-netty:0.8.5.RELEASE
 io.projectreactor:reactor-core:3.2.6.RELEASE
 io.projectreactor:reactor-test:3.2.6.RELEASE
-io.rsocket:rsocket-core:0.11.17.2
-io.rsocket:rsocket-transport-local:0.11.17.2
-io.rsocket:rsocket-transport-netty:0.11.17.2
+io.rsocket:rsocket-core:0.12.2-RC1
+io.rsocket:rsocket-transport-local:0.12.2-RC1
+io.rsocket:rsocket-transport-netty:0.12.2-RC1
 javax.inject:javax.inject:1
 junit:junit:4.12
 net.bytebuddy:byte-buddy-agent:1.9.7

proteus-auth/gradle/dependency-locks/testRuntimeClasspath.lockfile

@@ -17,9 +17,9 @@ io.netty:netty-transport:4.1.33.Final
 io.projectreactor.netty:reactor-netty:0.8.5.RELEASE
 io.projectreactor:reactor-core:3.2.6.RELEASE
 io.projectreactor:reactor-test:3.2.6.RELEASE
-io.rsocket:rsocket-core:0.11.17.2
-io.rsocket:rsocket-transport-local:0.11.17.2
-io.rsocket:rsocket-transport-netty:0.11.17.2
+io.rsocket:rsocket-core:0.12.2-RC1
+io.rsocket:rsocket-transport-local:0.12.2-RC1
+io.rsocket:rsocket-transport-netty:0.12.2-RC1
 javax.inject:javax.inject:1
 junit:junit:4.12
 net.bytebuddy:byte-buddy-agent:1.9.7

proteus-client/gradle/dependency-locks/compile.lockfile

@@ -20,9 +20,9 @@ io.netty:netty-transport:4.1.33.Final
 io.opentracing:opentracing-api:0.31.0
 io.projectreactor.netty:reactor-netty:0.8.5.RELEASE
 io.projectreactor:reactor-core:3.2.6.RELEASE
-io.rsocket.rpc:rsocket-rpc-core:0.2.13.3
-io.rsocket:rsocket-core:0.11.17.2
-io.rsocket:rsocket-transport-netty:0.11.17.2
+io.rsocket.rpc:rsocket-rpc-core:0.2.17
+io.rsocket:rsocket-core:0.12.2-RC1
+io.rsocket:rsocket-transport-netty:0.12.2-RC1
 javax.annotation:javax.annotation-api:1.3.2
 javax.inject:javax.inject:1
 org.hdrhistogram:HdrHistogram:2.1.10

proteus-client/gradle/dependency-locks/compileClasspath.lockfile

@@ -20,9 +20,9 @@ io.netty:netty-transport:4.1.33.Final
 io.opentracing:opentracing-api:0.31.0
 io.projectreactor.netty:reactor-netty:0.8.5.RELEASE
 io.projectreactor:reactor-core:3.2.6.RELEASE
-io.rsocket.rpc:rsocket-rpc-core:0.2.13.3
-io.rsocket:rsocket-core:0.11.17.2
-io.rsocket:rsocket-transport-netty:0.11.17.2
+io.rsocket.rpc:rsocket-rpc-core:0.2.17
+io.rsocket:rsocket-core:0.12.2-RC1
+io.rsocket:rsocket-transport-netty:0.12.2-RC1
 javax.annotation:javax.annotation-api:1.3.2
 javax.inject:javax.inject:1
 org.hdrhistogram:HdrHistogram:2.1.10

proteus-client/gradle/dependency-locks/protobufToolsLocator_rsocketRpc.lockfile

@@ -1,4 +1,4 @@
 # This is a Gradle generated file for dependency locking.
 # Manual edits can break the build and are not advised.
 # This file is expected to be part of source control.
-io.rsocket.rpc:rsocket-rpc-protobuf:0.2.13.3
+io.rsocket.rpc:rsocket-rpc-protobuf:0.2.17

proteus-client/src/main/java/io/netifi/proteus/rsocket/NamedRSocketServiceWrapper.java

@@ -64,6 +64,11 @@ public String getService() {
     return name;
   }
 
+  @Override
+  public Flux<Payload> requestChannel(Payload payload, Flux<Payload> publisher) {
+    return requestChannel(payload, (Publisher<Payload>) publisher);
+  }
+
   @Override
   public final Flux<Payload> requestChannel(Payload payload, Publisher<Payload> publisher) {
     if (source instanceof ResponderRSocket) {

proteus-client/src/main/java/io/netifi/proteus/rsocket/WeightedReconnectingRSocket.java

@@ -23,6 +23,7 @@
 import io.netty.buffer.ByteBufUtil;
 import io.rsocket.*;
 import io.rsocket.RSocketFactory.ClientRSocketFactory;
+import io.rsocket.frame.decoder.PayloadDecoder;
 import io.rsocket.rpc.exception.TimeoutException;
 import io.rsocket.util.Clock;
 import java.nio.channels.ClosedChannelException;
@@ -193,7 +194,7 @@ synchronized void resetStatistics() {
   }
 
   private ClientRSocketFactory getClientFactory() {
-    ClientRSocketFactory connect = RSocketFactory.connect().frameDecoder(Frame::retain);
+    ClientRSocketFactory connect = RSocketFactory.connect().frameDecoder(PayloadDecoder.ZERO_COPY);
 
     if (keepalive) {
       connect =

proteus-client/src/main/java/io/netifi/proteus/rsocket/transport/WeightedClientTransportSupplier.java

@@ -66,10 +66,10 @@ public ClientTransport get() {
 
     int i = selectCount.get();
 
-    return () ->
+    return (int mtu) ->
         clientTransportFunction
             .apply(socketAddress)
-            .connect()
+            .connect(mtu)
             .doOnNext(
                 duplexConnection -> {
                   logger.debug("opened connection to {} - active connections {}", socketAddress, i);