Access to encryption keys export capability (#10)

* exposes exportKeys oas capability

* help message

* graal json field added

Co-authored-by: Bart van Deenen <bartvandeenen@streammachine.io>

Author: bvdeenen

src/main/kotlin/io/streammachine/api/cli/commands/Exporters.kt

@@ -3,6 +3,7 @@ package io.streammachine.api.cli.commands
 import com.github.ajalt.clikt.core.CliktCommand
 import com.github.ajalt.clikt.core.subcommands
 import com.github.ajalt.clikt.parameters.arguments.argument
+import com.github.ajalt.clikt.parameters.options.flag
 import com.github.ajalt.clikt.parameters.options.option
 import com.github.ajalt.clikt.parameters.options.required
 import com.github.ajalt.clikt.parameters.types.choice
@@ -55,9 +56,14 @@ open class ExportersGet : CliktCommand(
         "--exporter-name",
         help = "Name of the exporter that is linked to this stream."
     ).required()
+    internal val exportKeys by option(
+        "-k",
+        "--export-keys",
+        help = "Export the encryption keys"
+    ).flag()
 
     override fun run() {
-        "/v1/exporters/$streamName/$exporterName"
+        "/v1/exporters/$streamName/$exporterName?exportKeys=$exportKeys"
             .httpGet()
             .printResponse()
     }
@@ -73,9 +79,14 @@ open class ExportersDelete : CliktCommand(
         "--exporter-name",
         help = "Name of the exporter that is linked to this stream."
     ).required()
+    internal val exportKeys by option(
+        "-k",
+        "--export-keys",
+        help = "Export the encryption keys"
+    ).flag()
 
     override fun run() {
-        "/v1/exporters/$streamName/$exporterName"
+        "/v1/exporters/$streamName/$exporterName?exportKeys=$exportKeys"
             .httpDelete()
             .printResponse()
     }
@@ -122,6 +133,13 @@ open class ExportersCreate : CliktCommand(
         help = "Optional path prefix. Every object that is exported to the configured sink will have this path prepended to the resource destination."
     )
 
+    internal val exportKeys by option(
+        "-k",
+        "--export-keys",
+        help = "Export the encryption keys"
+    ).flag()
+
+
     override fun run() {
         "/v1/exporters/$streamName"
             .httpPut()
@@ -133,9 +151,10 @@ open class ExportersCreate : CliktCommand(
                     intervalSecs,
                     ExporterType.BATCH,
                     pathPrefix,
-                    null
+                    null,
+                    exportKeys
                 )
             )
             .printResponse()
     }
-}
+}

src/main/kotlin/io/streammachine/api/cli/commands/Outputs.kt

@@ -158,7 +158,8 @@ class OutputStreamExportersCreate : StreamExportersCreate() {
                     intervalSecs,
                     ExporterType.BATCH,
                     pathPrefix,
-                    null
+                    null,
+                    false
                 )
             )
             .printResponse()
@@ -177,4 +178,4 @@ class OutputStreamExportersDelete : StreamExportersDelete() {
             .httpDelete()
             .printResponse()
     }
-}
+}

src/main/kotlin/io/streammachine/api/cli/commands/Streams.kt

@@ -3,6 +3,7 @@ package io.streammachine.api.cli.commands
 import com.github.ajalt.clikt.core.CliktCommand
 import com.github.ajalt.clikt.core.subcommands
 import com.github.ajalt.clikt.parameters.arguments.argument
+import com.github.ajalt.clikt.parameters.options.flag
 import com.github.ajalt.clikt.parameters.options.multiple
 import com.github.ajalt.clikt.parameters.options.option
 import com.github.ajalt.clikt.parameters.options.required
@@ -156,6 +157,10 @@ open class StreamExportersCreate : CliktCommand(
         "--path-prefix",
         help = "Optional path prefix. Every object that is exported to the configured sink will have this path prepended to the resource destination."
     )
+    internal val exportKeys by option(
+        "-k",
+        "--export-keys"
+    ).flag()
 
     override fun run() {
         "/v1/streams/$streamName/exporters"
@@ -168,7 +173,8 @@ open class StreamExportersCreate : CliktCommand(
                     intervalSecs,
                     ExporterType.BATCH,
                     pathPrefix,
-                    null
+                    null,
+                    exportKeys
                 )
             )
             .printResponse()
@@ -186,9 +192,14 @@ open class StreamExportersDelete : CliktCommand(
         help = "Name of the stream that is linked to this exporter."
     ).required()
 
+    internal val exportKeys by option(
+        "-k",
+        "--export-keys"
+    ).flag()
+
     override fun run() {
-        "/v1/streams/$streamName/exporters/$name"
+        "/v1/streams/$streamName/exporters/$name?exportKeys=$exportKeys"
             .httpDelete()
             .printResponse()
     }
-}
+}

src/main/kotlin/io/streammachine/api/cli/common/Domain.kt

@@ -38,7 +38,8 @@ data class ExporterCreateRequest(
     val intervalSecs: Int,
     val type: ExporterType = ExporterType.BATCH,
     val pathPrefix: String?,
-    val extraConfig: String?
+    val extraConfig: String?,
+    val exportKeys: Boolean
 )
 
 enum class ExporterType {
@@ -57,5 +58,4 @@ enum class SinkType {
 data class ConsentLevelMappingCreateRequest(
     val id: Int,
     val name: String
-)
-
+)

src/main/resources/reflection.json

@@ -184,6 +184,10 @@
       {
         "name": "extraConfig",
         "allowWrite":  true
+      },
+      {
+        "name": "exportKeys",
+        "allowWrite":  true
       }
     ]
   },
@@ -301,4 +305,4 @@
       }
     ]
   }
-]
+]