pure netty dependencies test

Author: Alexander Furer

grpc-spring-boot-starter-demo/build.gradle

@@ -4,21 +4,39 @@ buildscript {
     }
     dependencies {
         classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
+        classpath "com.netflix.nebula:nebula-project-plugin:7.0.7"
     }
 }
 apply plugin: 'java'
 apply plugin: 'com.google.protobuf'
 apply plugin: 'org.springframework.boot'
 apply plugin: 'io.spring.dependency-management'
+apply plugin: "nebula.facet"
 
-
+facets {
+    pureNettyTest
+}
 
 dependencyManagement {
     imports {
         mavenBom "org.springframework.boot:spring-boot-starter-parent:${springBootVersion}"
         mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
     }
 }
+configurations.findAll{ cfg ->
+    if (cfg.name.startsWith("pureNetty")) {
+        cfg.exclude group: 'io.grpc', module: 'grpc-netty-shaded'
+        dependencies.add(cfg.name,"io.grpc:grpc-netty")
+    }
+    if(cfg.name.equals("pureNettyTestCompileClasspath")){
+        cfg.extendsFrom(configurations.getByName("testCompileClasspath"))
+    }
+    if(cfg.name.equals("pureNettyTestRuntimeClasspath")){
+        cfg.extendsFrom(configurations.getByName("testRuntimeClasspath"))
+    }
+
+}
+
 
 dependencies {
 
@@ -42,7 +60,6 @@ dependencies {
     testCompile 'org.awaitility:awaitility:4.0.3'
 
 
-
     testCompile "org.springframework.cloud:spring-cloud-config-server"
     testCompile "org.springframework.cloud:spring-cloud-config-client"
     testCompile "com.playtika.testcontainers:embedded-keycloak:2.0.6"
@@ -61,9 +78,9 @@ dependencies {
 
 configurations.all {
     resolutionStrategy.eachDependency { details ->
-            if ("io.grpc".equalsIgnoreCase(details.requested.group)) {
-                details.useVersion grpcVersion
-            }
+        if ("io.grpc".equalsIgnoreCase(details.requested.group)) {
+            details.useVersion grpcVersion
+        }
     }
 }
 sourceSets {

grpc-spring-boot-starter-demo/src/pureNettyTest/java/org/lognet/springboot/grpc/PureNettyTransportConfigTest.java

@@ -0,0 +1,93 @@
+package org.lognet.springboot.grpc;
+
+import io.grpc.ManagedChannel;
+import io.grpc.ManagedChannelBuilder;
+import io.grpc.Server;
+import io.grpc.ServerBuilder;
+import io.grpc.examples.GreeterGrpc;
+import io.grpc.examples.GreeterOuterClass;
+import org.hamcrest.Matchers;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.lognet.springboot.grpc.context.GRpcServerInitializedEvent;
+import org.lognet.springboot.grpc.context.LocalRunningGrpcPort;
+import org.lognet.springboot.grpc.demo.DemoApp;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Mockito;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+import org.springframework.context.event.EventListener;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.net.InetSocketAddress;
+import java.net.SocketAddress;
+import java.util.List;
+import java.util.concurrent.ExecutionException;
+
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.junit.Assert.assertNotNull;
+
+
+import static org.junit.Assert.assertThrows;
+import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.NONE;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = {DemoApp.class}, webEnvironment = NONE,
+        properties = {
+                "grpc.netty-server.additional-listen-addresses[0]=localhost:0",
+                "grpc.netty-server.primary-listen-address=localhost:0"
+
+}
+)
+@Import(PureNettyTransportConfigTest.TestConfig.class)
+public class PureNettyTransportConfigTest {
+
+    @LocalRunningGrpcPort
+    protected int runningPort;
+
+    @Configuration
+    static class TestConfig {
+
+        @EventListener
+        public void onServer(GRpcServerInitializedEvent e){
+            final List<? extends SocketAddress> listenSockets = e.getServer().getListenSockets();
+            assertThat(listenSockets.size(), Matchers.is(2));
+        }
+
+        @Bean
+        public GRpcServerBuilderConfigurer customGrpcServerBuilderConfigurer() {
+            return Mockito.mock(GRpcServerBuilderConfigurer.class);
+        }
+
+    }
+    @Autowired
+    private GRpcServerBuilderConfigurer configurer;
+
+
+    @Test
+    public void simpleGreeting() throws ExecutionException, InterruptedException {
+
+        assertThrows(ClassNotFoundException.class,()->Class.forName("io.grpc.netty.shaded.io.grpc.netty.NettyServerBuilder"));
+        final ArgumentCaptor<ServerBuilder> captor = ArgumentCaptor.forClass(ServerBuilder.class);
+        Mockito.verify(configurer,Mockito.times(1)).configure(captor.capture());
+        assertThat("Should be pure NettyServerBuilder, not repackaged",io.grpc.netty.NettyServerBuilder.class.isInstance(captor.getValue()));
+
+        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", runningPort)
+                .usePlaintext()
+                .build();
+
+
+        String name = "John";
+        final GreeterGrpc.GreeterFutureStub greeterFutureStub = GreeterGrpc.newFutureStub(channel);
+        final GreeterOuterClass.HelloRequest helloRequest = GreeterOuterClass.HelloRequest.newBuilder().setName(name).build();
+        final String reply = greeterFutureStub.sayHello(helloRequest).get().getMessage();
+        assertNotNull("Reply should not be null", reply);
+        assertThat(String.format("Reply should contain name '%s'", name), reply.contains(name));
+
+
+    }
+
+}

grpc-spring-boot-starter-demo/src/pureNettyTest/resources/application.yml

@@ -0,0 +1,15 @@
+management:
+  metrics:
+    export:
+      simple:
+        enabled: false
+  endpoints:
+    web:
+      base-path: "/"
+      exposure:
+        include: "*"
+
+
+logging:
+  level:
+    root: INFO

grpc-spring-boot-starter-demo/src/pureNettyTest/resources/bootstrap.yml

@@ -0,0 +1,19 @@
+spring:
+  application:
+    name: grpc-demo
+  cloud:
+    config:
+      enabled: false
+    consul:
+      discovery:
+        enabled: false
+      enabled: false
+    service-registry:
+      auto-registration:
+        enabled: false
+embedded:
+  keycloak:
+    enabled: false
+  containers:
+    enabled: false
+

grpc-spring-boot-starter-demo/src/pureNettyTest/resources/logback-test.xml

@@ -0,0 +1,6 @@
+<configuration>
+    <include resource="org/springframework/boot/logging/logback/base.xml"/>
+    <logger name="org.springframework" level="INFO"/>
+
+
+</configuration>

grpc-spring-boot-starter-demo/src/test/resources/application.yml

@@ -13,11 +13,6 @@ management:
 spring:
   profiles:
     active: disable-security
-  cloud:
-    consul:
-      discovery:
-        enabled: false
-      enabled: false
-    service-registry:
-      auto-registration:
-        enabled: false
+logging:
+  level:
+    root: INFO

grpc-spring-boot-starter-demo/src/test/resources/bootstrap.yml

@@ -2,6 +2,13 @@ spring:
   application:
     name: grpc-demo
   cloud:
+    consul:
+      discovery:
+        enabled: false
+      enabled: false
+    service-registry:
+      auto-registration:
+        enabled: false
     config:
       uri: http://localhost:${config.port:8888}
 embedded:

grpc-spring-boot-starter-demo/src/test/resources/logback-test.xml

@@ -0,0 +1,6 @@
+<configuration>
+    <include resource="org/springframework/boot/logging/logback/base.xml"/>
+    <logger name="org.springframework" level="INFO"/>
+
+
+</configuration>