[camel-kamelets] branch main updated: Camel-Kamelets-Catalog: Added get flow method

[acosentino]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 986fc42  Camel-Kamelets-Catalog: Added get flow method
986fc42 is described below

commit 986fc4225c47a1f20bb458f2f115cd922cf18625
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Apr 28 11:31:17 2021 +0200

    Camel-Kamelets-Catalog: Added get flow method
---
 .../org/apache/camel/kamelets/catalog/KameletsCatalog.java     | 10 ++++++++++
 .../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java |  8 ++++++++
 2 files changed, 18 insertions(+)

diff --git 
a/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
 
b/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
index 9cdd82c..d28e2d4 100644
--- 
a/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
+++ 
b/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
@@ -17,6 +17,7 @@
 package org.apache.camel.kamelets.catalog;
 
 import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
 import io.fabric8.camelk.v1alpha1.Kamelet;
@@ -130,4 +131,13 @@ public class KameletsCatalog {
             return null;
         }
     }
+
+    public JsonNode getKameletFlow(String name) {
+        Kamelet kamelet = kameletModels.get(name);
+        if (kamelet != null) {
+            return kamelet.getSpec().getFlow();
+        } else {
+            return null;
+        }
+    }
 }
diff --git 
a/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
 
b/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
index dce0c52..5846729 100644
--- 
a/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
+++ 
b/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
@@ -16,6 +16,7 @@
  */
 package org.apache.camel.kamelets.catalog;
 
+import com.fasterxml.jackson.databind.JsonNode;
 import io.fabric8.camelk.v1alpha1.Kamelet;
 import io.fabric8.kubernetes.api.model.apiextensions.v1.JSONSchemaProps;
 import org.apache.camel.kamelets.catalog.model.KameletTypeEnum;
@@ -26,6 +27,7 @@ import java.io.IOException;
 import java.util.List;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
@@ -93,4 +95,10 @@ public class KameletsCatalogTest {
         assertEquals(1, deps.size());
         assertEquals("camel:jackson", deps.get(0));
     }
+
+    @Test
+    void testGetKameletsFlow() throws Exception {
+        JsonNode flow = catalog.getKameletFlow("aws-sqs-source");
+        assertNotNull(flow);
+    }
 }