(camel) branch main updated: camel-jbang - Add --mask to browse command

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new d95de5d5da3 camel-jbang - Add --mask to browse command
d95de5d5da3 is described below

commit d95de5d5da3a1ce69504784f6194f897b55e96df
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Wed Sep 11 14:23:26 2024 +0200

    camel-jbang - Add --mask to browse command
---
 .../dsl/jbang/core/commands/action/CamelBrowseAction.java     | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git 
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelBrowseAction.java
 
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelBrowseAction.java
index d31961a7468..6587a46f409 100644
--- 
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelBrowseAction.java
+++ 
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelBrowseAction.java
@@ -31,6 +31,7 @@ import org.apache.camel.dsl.jbang.core.common.ProcessHelper;
 import org.apache.camel.util.FileUtil;
 import org.apache.camel.util.IOHelper;
 import org.apache.camel.util.TimeUtils;
+import org.apache.camel.util.URISupport;
 import org.apache.camel.util.json.JsonArray;
 import org.apache.camel.util.json.JsonObject;
 import org.fusesource.jansi.Ansi;
@@ -67,6 +68,10 @@ public class CamelBrowseAction extends ActionBaseCommand {
                         description = "List endpoint URI in full details")
     boolean wideUri;
 
+    @CommandLine.Option(names = { "--mask" },
+                        description = "Whether to mask endpoint URIs to avoid 
printing sensitive information such as password or access keys")
+    boolean mask;
+
     @CommandLine.Option(names = { "--dump" }, defaultValue = "false",
                         description = "Whether to include message dumps")
     boolean dump;
@@ -174,6 +179,9 @@ public class CamelBrowseAction extends ActionBaseCommand {
                 for (int i = 0; arr != null && i < arr.size(); i++) {
                     JsonObject o = (JsonObject) arr.get(i);
                     row.uri = o.getString("endpointUri");
+                    if (mask) {
+                        row.uri = URISupport.sanitizeUri(row.uri);
+                    }
                     row.queueSize = o.getInteger("queueSize");
                     row.limit = o.getInteger("limit");
                     row.position = o.getInteger("position");
@@ -225,6 +233,9 @@ public class CamelBrowseAction extends ActionBaseCommand {
                             message.remove("body");
                         }
                     }
+                    if (mask) {
+                        row.uri = URISupport.sanitizeUri(row.uri);
+                    }
                     JsonObject ep = new JsonObject();
                     ep.put("endpoint", row.uri);
                     String table = tableHelper.getDataAsTable(exchangeId, 
null, ep, null, message, null);