(camel) branch main updated: CAMEL-20217: camel-jbang - You can now camel init a pipe file.

[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 ca77c1a11c8 CAMEL-20217: camel-jbang - You can now camel init a pipe 
file.
ca77c1a11c8 is described below

commit ca77c1a11c8e1a85d25dfef61bac8dfe8e3d055b
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon May 20 10:47:21 2024 +0200

    CAMEL-20217: camel-jbang - You can now camel init a pipe file.
---
 .../org/apache/camel/dsl/jbang/core/commands/Init.java  |  6 ++++++
 .../apache/camel/dsl/jbang/core/commands/bind/Bind.java |  3 ---
 .../src/main/resources/templates/init-pipe.yaml.tmpl    | 17 +++++++++++++++++
 3 files changed, 23 insertions(+), 3 deletions(-)

diff --git 
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Init.java
 
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Init.java
index 42ab2a55335..2c03f571d75 100644
--- 
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Init.java
+++ 
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Init.java
@@ -69,6 +69,10 @@ public class Init extends CamelCommand {
             description = "When creating a yaml file should it be created as a 
Camel K Integration CRD")
     private boolean integration;
 
+    @Option(names = { "--pipe" },
+            description = "When creating a yaml file should it be created as a 
Camel K Pipe CRD")
+    private boolean pipe;
+
     public Init(CamelJBangMain main) {
         super(main);
     }
@@ -96,6 +100,8 @@ public class Init extends CamelCommand {
         String ext = FileUtil.onlyExt(file, false);
         if ("yaml".equals(ext) && integration) {
             ext = "integration.yaml";
+        } else if ("yaml".equals(ext) && pipe) {
+            ext = "init-pipe.yaml";
         }
 
         if (fromKamelet != null && !"kamelet.yaml".equals(ext)) {
diff --git 
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/bind/Bind.java
 
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/bind/Bind.java
index e1236d39574..c81351c9fa9 100644
--- 
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/bind/Bind.java
+++ 
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/bind/Bind.java
@@ -245,9 +245,6 @@ public class Bind extends CamelCommand {
     /**
      * Extracts properties from given property arguments. Filter properties by 
given prefix. This way each component in
      * pipe (source, sink, errorHandler, step[1-n]) can have its individual 
properties.
-     *
-     * @param  keyPrefix
-     * @return
      */
     private Map<String, Object> getProperties(String keyPrefix) {
         Map<String, Object> props = new HashMap<>();
diff --git 
a/dsl/camel-jbang/camel-jbang-core/src/main/resources/templates/init-pipe.yaml.tmpl
 
b/dsl/camel-jbang/camel-jbang-core/src/main/resources/templates/init-pipe.yaml.tmpl
new file mode 100644
index 00000000000..9e9beffcc07
--- /dev/null
+++ 
b/dsl/camel-jbang/camel-jbang-core/src/main/resources/templates/init-pipe.yaml.tmpl
@@ -0,0 +1,17 @@
+apiVersion: camel.apache.org/v1
+kind: Pipe
+metadata:
+  name: {{ .Name }}
+spec:
+  source:
+    ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1
+      name: timer-source
+    properties:
+      message: Hello World
+  sink:
+    ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1
+      name: log-sink
\ No newline at end of file