test fixes #355

Author: jvmlet

grpc-spring-boot-starter-demo/src/main/java/org/lognet/springboot/grpc/demo/ReactiveGreeterGrpcService.java

@@ -10,10 +10,12 @@
 import org.lognet.springboot.grpc.recovery.GRpcExceptionScope;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
 import org.springframework.security.access.annotation.Secured;
+import org.springframework.security.core.context.SecurityContextHolder;
 import org.springframework.transaction.annotation.Transactional;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
+import java.util.Optional;
 import java.util.stream.IntStream;
 
 
@@ -31,6 +33,8 @@ public ReactiveGreeterGrpcService(ReactiveGreeterService reactiveGreeterService)
     @Override
     @Secured({})
     public Mono<ReactiveHelloResponse> greet(Mono<ReactiveHelloRequest> request) {
+        Optional.ofNullable(SecurityContextHolder.getContext().getAuthentication())
+                .orElseThrow();
         return reactiveGreeterService.greet(request);
 
     }

grpc-spring-boot-starter-demo/src/reactiveTest/java/org/lognet/springboot/grpc/reactive/ReactiveDemoTest.java

@@ -12,11 +12,13 @@
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.lognet.springboot.grpc.auth.JwtAuthBaseTest;
+import org.lognet.springboot.grpc.auth.JwtRoleTest;
 import org.lognet.springboot.grpc.demo.DemoApp;
 import org.lognet.springboot.grpc.security.GrpcSecurity;
 import org.lognet.springboot.grpc.security.GrpcSecurityConfigurerAdapter;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.boot.test.context.TestConfiguration;
+import org.springframework.context.annotation.Import;
 import org.springframework.test.annotation.DirtiesContext;
 import org.springframework.test.context.ActiveProfiles;
 import org.springframework.test.context.junit4.SpringRunner;
@@ -34,27 +36,15 @@
 
 @Slf4j
 @RunWith(SpringRunner.class)
-@SpringBootTest(classes = DemoApp.class, webEnvironment = NONE)
+@SpringBootTest(classes = DemoApp.class)
 @ActiveProfiles({"keycloack-test", "r2dbc-test"})
 @DirtiesContext
 public class ReactiveDemoTest extends JwtAuthBaseTest {
 
-    @TestConfiguration
-    static class TestCfg {
-        private static class DemoGrpcSecurityAdapter extends GrpcSecurityConfigurerAdapter {
-            @Override
-            public void configure(GrpcSecurity builder) throws Exception {
-                builder.authorizeRequests()
-                        .withSecuredAnnotation();
-
-            }
-        }
-    }
-
     @Test
     public void grpcGreetTest() {
         String shrek = "Shrek";
-        String message = ReactiveGreeterGrpc.newBlockingStub(channel)
+        String message = ReactiveGreeterGrpc.newBlockingStub(getChannel())
                 .greet(ReactiveHelloRequest.newBuilder().setName(shrek).build())
                 .getMessage();
         assertThat(message, containsString(shrek));
@@ -64,7 +54,7 @@ public void grpcGreetTest() {
     @Test
     public void reactorGreetTest() {
         String shrek = "Shrek";
-        ReactiveHelloResponse helloResponse = ReactorReactiveGreeterGrpc.newReactorStub(channel)
+        ReactiveHelloResponse helloResponse = ReactorReactiveGreeterGrpc.newReactorStub(getChannel())
                 .greet(simpleRequest(shrek))
                 .block(Duration.ofSeconds(10));
         assertThat(helloResponse, notNullValue());
@@ -78,7 +68,7 @@ public void reactorGreetFailureTest() {
         String shrek = "Wolf";
         StatusRuntimeException e = assertThrows(StatusRuntimeException.class, () -> {
 
-            ReactorReactiveGreeterGrpc.newReactorStub(channel)
+            ReactorReactiveGreeterGrpc.newReactorStub(getChannel())
                     .greet(simpleRequest(shrek))
                     .block(Duration.ofSeconds(10));
         });
@@ -91,7 +81,7 @@ public void reactorGreetFailureTest() {
     @Test
     public void reactorMultiGreerTest() {
         String shrek = "Shrek";
-        List<ReactiveHelloResponse> greets = ReactorReactiveGreeterGrpc.newReactorStub(channel)
+        List<ReactiveHelloResponse> greets = ReactorReactiveGreeterGrpc.newReactorStub(getChannel())
                 .multiGreet(simpleRequest(shrek))
                 .collectList()
                 .block(Duration.ofSeconds(10));
@@ -111,7 +101,7 @@ public void reactorBidiGreerTest() {
                 "Robin",
                 "Christopher"
         };
-        List<ReactiveHelloResponse> greets = ReactorReactiveGreeterGrpc.newReactorStub(channel)
+        List<ReactiveHelloResponse> greets = ReactorReactiveGreeterGrpc.newReactorStub(getChannel())
                 .streamGreet(
                         Flux.fromStream(Arrays.stream(names).map(this::simpleRequest))
                 )