Doing work

Author: gregwhitaker

README.md

@@ -12,6 +12,30 @@ Follow the steps below to run the example application:
 1. Run the following command to start the `hello-service`:
 
         ./gradlew :hello-service:bootRun
+        
+2. In a new terminal, run the following command to send a request to the unsecured `hello` endpoint:
+
+        ./gradlew :hello-client:bootRun --args="hello Bob"
+        
+    If successful, you will see the following response:
+    
+        2019-12-18 11:02:55.038  INFO 3540 --- [           main] e.client.hello.HelloClientApplication    : Sending message without Basic Auth metadata...
+        2019-12-18 11:02:55.065  INFO 3540 --- [           main] e.client.hello.HelloClientApplication    : Response: Hello, Bob, from unsecured method
+        
+3. Next, run the following command to send a request to the secure `hello.secure` endpoint:
+
+        ./gradlew :hello-client:bootRun --args="hello.secure Bob"
+        
+    You will receive an `io.rsocket.exceptions.ApplicationErrorException: Access Denied` because you have not supplied valid credentials.
+   
+4. Next, run the following command to send a request to the secure `hello.secure` endpoint, but this time supplying valid credentials:
+
+        ./gradlew :hello-client:bootRun --args="--username=admin --password=password hello.secure Bob"
+        
+    If successful, you will see the following response:
+
+        2019-12-18 11:07:12.171  INFO 3575 --- [           main] e.client.hello.HelloClientApplication    : Sending message with Basic Auth metadata...
+        2019-12-18 11:07:12.284  INFO 3575 --- [           main] e.client.hello.HelloClientApplication    : Response: Hello, Bob, from secured method
 
 ## License
 MIT License

hello-client/src/main/java/example/client/hello/HelloClientApplication.java

@@ -3,6 +3,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -29,8 +30,13 @@ public static void main(String... args) {
     @Component
     public class Runner implements CommandLineRunner {
 
+        @Qualifier("insecureRSocketRequester")
         @Autowired
-        private RSocketRequester helloServiceRequester;
+        private RSocketRequester insecureRSocketRequester;
+
+        @Qualifier("secureRSocketRequester")
+        @Autowired
+        private RSocketRequester secureRSocketRequester;
 
         @Override
         public void run(String... args) throws Exception {
@@ -45,7 +51,7 @@ public void run(String... args) throws Exception {
                 LOG.info("Sending message with Basic Auth metadata...");
 
                 // Sending request to the hello-service
-                String message = helloServiceRequester.route(params.method)
+                String message = secureRSocketRequester.route(params.method)
                         .metadata(new UsernamePasswordMetadata(params.username, params.password), UsernamePasswordMetadata.BASIC_AUTHENTICATION_MIME_TYPE)
                         .data(params.name)
                         .retrieveMono(String.class)
@@ -59,7 +65,7 @@ public void run(String... args) throws Exception {
                 LOG.info("Sending message without Basic Auth metadata...");
 
                 // Sending request to the hello-service
-                String message = helloServiceRequester.route(params.method)
+                String message = insecureRSocketRequester.route(params.method)
                         .data(params.name)
                         .retrieveMono(String.class)
                         .doOnError(throwable -> {
@@ -86,7 +92,7 @@ public static class ClientArguments {
         /**
          * Basic auth password
          */
-        @Option(names = "--password", defaultValue = "basic auth password")
+        @Option(names = "--password", description = "basic auth password")
         public String password;
 
         /**

hello-client/src/main/java/example/client/hello/config/RSocketConfiguration.java

@@ -1,5 +1,6 @@
 package example.client.hello.config;
 
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -17,17 +18,20 @@ public class RSocketConfiguration {
     @Value("${example.service.hello.port}")
     private int helloServicePort;
 
-    @Bean
-    public RSocketStrategies rSocketStrategies() {
-        return RSocketStrategies.builder()
-                .encoder(new BasicAuthenticationEncoder())
-                .build();
+    @Bean("insecureRSocketRequester")
+    public RSocketRequester insecureRSocketRequester() {
+        return RSocketRequester.builder()
+                .dataMimeType(MimeTypeUtils.TEXT_PLAIN)
+                .connectTcp(helloServiceHostname, helloServicePort)
+                .block();
     }
 
-    @Bean
-    public RSocketRequester helloServiceRequester(RSocketStrategies rSocketStrategies) {
+    @Bean(name = "secureRSocketRequester")
+    public RSocketRequester helloServiceRequester() {
         return RSocketRequester.builder()
-                .rsocketStrategies(rSocketStrategies)
+                .rsocketStrategies(builder -> {
+                    builder.encoder(new BasicAuthenticationEncoder());
+                })
                 .dataMimeType(MimeTypeUtils.TEXT_PLAIN)
                 .connectTcp(helloServiceHostname, helloServicePort)
                 .block();