add native test and support

.github/workflows/build.yml

@@ -45,9 +45,13 @@ jobs:
       uses: actions/cache@v2
       with:
         path: ~/.m2/repository
-        # refresh cache every month to avoid unlimited growth
-        key: maven-repo-${{ runner.os }}-${{ steps.get-date.outputs.date }}
+        key: ${{ runner.os }}-maven-${{ hashFiles('**/pom.xml') }}
+        restore-keys: |
+          ${{ runner.os }}-maven-
 
-    - name: Build with Maven
-      run: mvn -B formatter:validate verify --file pom.xml
+    - name: Build - JVM
+      run: mvn -B formatter:validate install --file pom.xml
+
+    - name: Build - Native
+      run: mvn -B verify -Pnative --file integration-tests/pom.xml
 

deployment/pom.xml

@@ -15,6 +15,7 @@
         <dependency>
             <groupId>io.quarkiverse.rsocket</groupId>
             <artifactId>quarkus-rsocket</artifactId>
+            <version>${project.version}</version>
         </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>

deployment/src/main/java/io/quarkiverse/rsocket/deployment/RsocketProcessor.java

@@ -17,6 +17,7 @@
 import io.quarkus.deployment.annotations.Record;
 import io.quarkus.deployment.builditem.CombinedIndexBuildItem;
 import io.quarkus.deployment.builditem.FeatureBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
 import io.quarkus.runtime.RuntimeValue;
 import io.rsocket.frame.FrameType;
 
@@ -40,6 +41,11 @@ FeatureBuildItem feature() {
         return new FeatureBuildItem(FEATURE);
     }
 
+    @BuildStep
+    void nativeSupport(BuildProducer<ReflectiveClassBuildItem> reflectives) {
+        reflectives.produce(new ReflectiveClassBuildItem(true, true, "sun.misc.Unsafe"));
+    }
+
     @BuildStep
     void configure(CombinedIndexBuildItem combinedIndexBuildItem,
             BuildProducer<RSocketBuildItem> rsockets,

integration-tests/src/test/java/io/quarkiverse/rsocket/test/RSocketTestCaseIT.java

@@ -0,0 +1,79 @@
+package io.quarkiverse.rsocket.test;
+
+import java.nio.ByteBuffer;
+import java.nio.CharBuffer;
+import java.nio.charset.StandardCharsets;
+import java.util.Collections;
+
+import org.jboss.logging.Logger;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import com.google.common.base.Charsets;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+import io.netty.buffer.CompositeByteBuf;
+import io.quarkiverse.rsocket.runtime.JsonEncoder;
+import io.quarkus.test.junit.NativeImageTest;
+import io.rsocket.Payload;
+import io.rsocket.core.RSocketConnector;
+import io.rsocket.metadata.CompositeMetadataCodec;
+import io.rsocket.metadata.RoutingMetadata;
+import io.rsocket.metadata.TaggingMetadataCodec;
+import io.rsocket.metadata.WellKnownMimeType;
+import io.rsocket.transport.netty.client.TcpClientTransport;
+import io.rsocket.util.DefaultPayload;
+
+@NativeImageTest
+public class RSocketTestCaseIT {
+    private static final Logger LOGGER = Logger.getLogger(RSocketTestCase.class);
+
+    @Test
+    public void testRSocketRoute() {
+        String hello = "Hello RSocket";
+        CompositeByteBuf metadata = ByteBufAllocator.DEFAULT.compositeBuffer();
+        RoutingMetadata routingMetadata = TaggingMetadataCodec.createRoutingMetadata(ByteBufAllocator.DEFAULT,
+                Collections.singletonList("/foo"));
+        CompositeMetadataCodec.encodeAndAddMetadata(metadata,
+                ByteBufAllocator.DEFAULT,
+                WellKnownMimeType.MESSAGE_RSOCKET_ROUTING,
+                routingMetadata.getContent());
+        ByteBuf data = ByteBufAllocator.DEFAULT.buffer().writeBytes(hello.getBytes(Charsets.UTF_8));
+        ByteBuffer byteBuffer = StandardCharsets.UTF_8.encode(CharBuffer.wrap(hello));
+        Payload rspPayload = RSocketConnector.create()
+                .metadataMimeType(WellKnownMimeType.MESSAGE_RSOCKET_COMPOSITE_METADATA.getString())
+                //.payloadDecoder(PayloadDecoder.ZERO_COPY)
+                .connect(TcpClientTransport.create("127.0.0.1", 7000))
+                .block()
+                .requestResponse(DefaultPayload.create(byteBuffer, metadata.nioBuffer()))
+                .block();
+        metadata.release();
+        Assertions.assertEquals(hello, rspPayload.getDataUtf8(), "failed to get response");
+    }
+
+    @Test
+    public void testRSocketEncoder() {
+
+        CompositeByteBuf metadata = ByteBufAllocator.DEFAULT.compositeBuffer();
+        RoutingMetadata routingMetadata = TaggingMetadataCodec.createRoutingMetadata(ByteBufAllocator.DEFAULT,
+                Collections.singletonList("/foo"));
+        CompositeMetadataCodec.encodeAndAddMetadata(metadata,
+                ByteBufAllocator.DEFAULT,
+                WellKnownMimeType.MESSAGE_RSOCKET_ROUTING,
+                routingMetadata.getContent());
+        Car c = new Car();
+        c.setName("batmobile");
+        JsonEncoder encoder = new JsonEncoder();
+        Payload payload = encoder.encode(c);
+        Payload rspPayload = RSocketConnector.create()
+                .metadataMimeType(WellKnownMimeType.MESSAGE_RSOCKET_COMPOSITE_METADATA.getString())
+                //.payloadDecoder(PayloadDecoder.ZERO_COPY)
+                .connect(TcpClientTransport.create("127.0.0.1", 7000))
+                .block()
+                .requestResponse(DefaultPayload.create(payload.getData(), metadata.nioBuffer()))
+                .block();
+        metadata.release();
+        Assertions.assertEquals("{\"name\":\"batmobile\"}", rspPayload.getDataUtf8(), "failed to get response");
+    }
+}

pom.xml

@@ -37,16 +37,6 @@
                 <type>pom</type>
                 <scope>import</scope>
             </dependency>
-            <dependency>
-                <groupId>io.quarkiverse.rsocket</groupId>
-                <artifactId>quarkus-rsocket</artifactId>
-                <version>${project.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>io.quarkiverse.rsocket</groupId>
-                <artifactId>quarkus-rsocket-deployment</artifactId>
-                <version>${project.version}</version>
-            </dependency>
             <dependency>
                 <groupId>io.rsocket</groupId>
                 <artifactId>rsocket-core</artifactId>