You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/04/27 15:28:54 UTC
[camel-kamelets] 02/02: Camel-Kamelets-Catalog: More methods
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
commit b981e023197abd0bf417a7eb5d228617eaa9c9df
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Apr 27 17:28:34 2021 +0200
Camel-Kamelets-Catalog: More methods
---
.../org/apache/camel/kamelets/catalog/KameletsCatalog.java | 10 +++++++++-
.../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 8 ++++++++
2 files changed, 17 insertions(+), 1 deletion(-)
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 083bf43..cc97425 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
@@ -32,7 +32,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
-import java.util.stream.Stream;
public class KameletsCatalog {
@@ -91,4 +90,13 @@ public class KameletsCatalog {
return null;
}
}
+
+ public List<String> getKameletRequiredProperties(String name) {
+ Kamelet kamelet = kameletModels.get(name);
+ if (kamelet != null) {
+ return kamelet.getSpec().getDefinition().getRequired();
+ } 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 787493c..55297e0 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
@@ -22,6 +22,7 @@ import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import java.io.IOException;
+import java.util.List;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNull;
@@ -58,6 +59,13 @@ public class KameletsCatalogTest {
}
@Test
+ void testGetKameletsRequiredProperties() throws Exception {
+ List<String> props = catalog.getKameletRequiredProperties("aws-sqs-source");
+ assertEquals(4, props.size());
+ assertTrue(props.contains("queueNameOrArn"));
+ }
+
+ @Test
void testGetKameletsDefinitionNotExists() throws Exception {
JSONSchemaProps props = catalog.getKameletDefinition("word");
assertNull(props);