Doing work

Author: gregwhitaker

hello-client/build.gradle

@@ -14,6 +14,7 @@ dependencies {
  implementation 'org.springframework.boot:spring-boot-starter-security'
  implementation 'org.springframework.security:spring-security-messaging'
  implementation 'org.springframework.security:spring-security-rsocket'
+ implementation 'info.picocli:picocli:4.1.2'
 }
 
 task buildImage(type: DockerBuildImage, dependsOn: build) {

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

@@ -1,12 +1,19 @@
 package example.client.hello;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.stereotype.Component;
 
+import static picocli.CommandLine.Option;
+import static picocli.CommandLine.Parameters;
+import static picocli.CommandLine.populateCommand;
+
 @SpringBootApplication
 public class HelloClientApplication {
+ private static final Logger LOG = LoggerFactory.getLogger(HelloClientApplication.class);
 
  public static void main(String... args) {
  SpringApplication.run(HelloClientApplication.class, args);
@@ -17,7 +24,35 @@ public class Runner implements CommandLineRunner {
 
  @Override
  public void run(String... args) throws Exception {
+ ClientArguments params = populateCommand(new ClientArguments(), args);
 
+ LOG.debug("token: {}", params.token);
+ LOG.debug("method: {}", params.method);
+ LOG.debug("name: {}", params.name);
  }
  }
+
+ /**
+ * Hello client command line arguments.
+ */
+ public static class ClientArguments {
+
+ /**
+ * Basic auth username
+ */
+ @Option(names = "--token", description = "jwt token")
+ public String token;
+
+ /**
+ * RSocket method name
+ */
+ @Parameters(index = "0", arity = "1", description = "the method to call")
+ public String method;
+
+ /**
+ * "name" argument to send to the method
+ */
+ @Parameters(index = "1", arity = "1", defaultValue = "name argument for method")
+ public String name;
+ }
 }

hello-service/src/main/java/example/service/hello/config/RSocketSecurityConfiguration.java

@@ -17,6 +17,23 @@
 @EnableRSocketSecurity
 public class RSocketSecurityConfiguration {
 
+ @Bean
+ public ReactiveUserDetailsService userDetailsService() {
+ UserDetails admin = User.withDefaultPasswordEncoder()
+ .username("admin")
+ .password("password")
+ .roles("ADMIN")
+ .build();
+
+ UserDetails user = User.withDefaultPasswordEncoder()
+ .username("user")
+ .password("password")
+ .roles("USER")
+ .build();
+
+ return new MapReactiveUserDetailsService(admin, user);
+ }
+
  @Bean
  public PayloadSocketAcceptorInterceptor rsocketInterceptor(RSocketSecurity rsocket) {
  rsocket.authorizePayload(authorize ->