Simple Spring Queries

src/main/kotlin/io/rsocket/cli/Main.kt

@@ -94,10 +94,10 @@ class Main : Runnable {
   var metadata: String? = null
 
   @Option(names = ["--metadataFormat"], description = ["Metadata Format"])
-  var metadataFormat = "json"
+  var metadataFormat: String? = null
 
   @Option(names = ["--dataFormat"], description = ["Data Format"])
-  var dataFormat = "binary"
+  var dataFormat: String? = null
 
   @Option(names = ["--setup"], description = ["String input or @path/to/file for setup metadata"])
   var setup: String? = null
@@ -141,7 +141,7 @@ class Main : Runnable {
     }
   }
 
-  private suspend fun exec(): Void? {
+  private suspend fun exec() {
     configureLogging(debug)
 
     if (!this::outputHandler.isInitialized) {
@@ -152,9 +152,27 @@ class Main : Runnable {
       inputPublisher = LineInputPublishers(outputHandler)
     }
 
+    if (route != null) {
+      if (metadataFormat == null) {
+        metadataFormat = "composite"
+      }
+
+      if (dataFormat == null) {
+        dataFormat = "json"
+      }
+    } else {
+      if (metadataFormat == null) {
+        metadataFormat = "json"
+      }
+
+      if (dataFormat == null) {
+        dataFormat = "binary"
+      }
+    }
+
     val uri = sanitizeUri(target ?: throw UsageException("no target specified"))
 
-    return if (serverMode) {
+    if (serverMode) {
       server = buildServer(uri)
 
       server.onClose().awaitFirstOrNull()

zsh/_rsocket-cli

@@ -29,6 +29,7 @@ _rsocket_cli() {
     --channel'[Channel]' \
     --fnf'[Fire And Forget]' \
     --metadataPush'[Metadata Push]' \
+    --route='[Spring Route]' \
     --server'[Server]' \
     {-i,--input}='[Input string input or @path/to/file]' \
     {-m,--metadata}='[Metadata input string input or @path/to/file]' \