From 3f18438c29664d88515003b38e83292a0863371f Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:03:33 +0200 Subject: [PATCH 01/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 4562db9ca..a14e2a7eb 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -88,7 +88,8 @@ public enum KameletPrefixSchemeEnum { mariadb("mariadb", "sql"), minio("minio", "minio"), mongodb_changes_stream("mongodb-changes-stream", "mongodb"), - mongodb("mongodb", "mongodb"); + mongodb("mongodb", "mongodb"), + mqtt("mqtt", "paho"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index cb8944806..a133a2ce7 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -280,5 +280,9 @@ void testSupportedHeaders() throws Exception { assertEquals(12, headersMongoDbSink.size()); List headersMongoDbSource= catalog.getKameletSupportedHeaders("mongodb-source"); assertEquals(3, headersMongoDbSource.size()); + List headersMQTTSink= catalog.getKameletSupportedHeaders("mqtt-sink"); + assertEquals(3, headersMQTTSink.size()); + List headersMQTTSource= catalog.getKameletSupportedHeaders("mqtt-source"); + assertEquals(2, headersMQTTSource.size()); } } From ef32277c4ecace3ac9b9580a334119807e761c0b Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:08:46 +0200 Subject: [PATCH 02/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT5 Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index a14e2a7eb..58923c506 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -89,7 +89,8 @@ public enum KameletPrefixSchemeEnum { minio("minio", "minio"), mongodb_changes_stream("mongodb-changes-stream", "mongodb"), mongodb("mongodb", "mongodb"), - mqtt("mqtt", "paho"); + mqtt("mqtt", "paho"), + mqtt5("mqtt5", "paho-mqtt5"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index a133a2ce7..78c974384 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -284,5 +284,9 @@ void testSupportedHeaders() throws Exception { assertEquals(3, headersMQTTSink.size()); List headersMQTTSource= catalog.getKameletSupportedHeaders("mqtt-source"); assertEquals(2, headersMQTTSource.size()); + List headersMQTT5Sink= catalog.getKameletSupportedHeaders("mqtt5-sink"); + assertEquals(3, headersMQTT5Sink.size()); + List headersMQTT5Source= catalog.getKameletSupportedHeaders("mqtt5-source"); + assertEquals(2, headersMQTT5Source.size()); } } From fd71ab24bd3a553128d126ce4393e80cea273aba Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:12:23 +0200 Subject: [PATCH 03/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MySQL Signed-off-by: Andrea Cosentino --- .../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++ 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 58923c506..dc78471ba 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -90,7 +90,8 @@ public enum KameletPrefixSchemeEnum { mongodb_changes_stream("mongodb-changes-stream", "mongodb"), mongodb("mongodb", "mongodb"), mqtt("mqtt", "paho"), - mqtt5("mqtt5", "paho-mqtt5"); + mqtt5("mqtt5", "paho-mqtt5"), + mysql("mysql", "sql"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 78c974384..d474574ad 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -132,6 +132,8 @@ void testSupportedHeaders() throws Exception { assertEquals(18, headersSource.size()); List headersSink = catalog.getKameletSupportedHeaders("aws-s3-sink"); assertEquals(25, headersSink.size()); + List headersRedshiftSource = catalog.getKameletSupportedHeaders("aws-redshift-source"); + assertEquals(0, headersRedshiftSource.size()); List headerNotExistent = catalog.getKameletSupportedHeaders("aws-not-exists"); assertEquals(0, headerNotExistent.size()); List headersAzureSink = catalog.getKameletSupportedHeaders("azure-eventhubs-sink"); @@ -288,5 +290,9 @@ void testSupportedHeaders() throws Exception { assertEquals(3, headersMQTT5Sink.size()); List headersMQTT5Source= catalog.getKameletSupportedHeaders("mqtt5-source"); assertEquals(2, headersMQTT5Source.size()); + List headersMySQLSink= catalog.getKameletSupportedHeaders("mysql-sink"); + assertEquals(8, headersMySQLSink.size()); + List headersMySQLSource= catalog.getKameletSupportedHeaders("mysql-source"); + assertEquals(0, headersMySQLSource.size()); } } From a20421ce29ab00d40ebd002e514561c06f699026 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:15:07 +0200 Subject: [PATCH 04/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - NATS Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index dc78471ba..8b1cdc539 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -91,7 +91,8 @@ public enum KameletPrefixSchemeEnum { mongodb("mongodb", "mongodb"), mqtt("mqtt", "paho"), mqtt5("mqtt5", "paho-mqtt5"), - mysql("mysql", "sql"); + mysql("mysql", "sql"), + nats("nats", "nats"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index d474574ad..681f673a2 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -294,5 +294,9 @@ void testSupportedHeaders() throws Exception { assertEquals(8, headersMySQLSink.size()); List headersMySQLSource= catalog.getKameletSupportedHeaders("mysql-source"); assertEquals(0, headersMySQLSource.size()); + List headersNatsSink= catalog.getKameletSupportedHeaders("nats-sink"); + assertEquals(5, headersNatsSink.size()); + List headersNatsSource= catalog.getKameletSupportedHeaders("nats-source"); + assertEquals(5, headersNatsSource.size()); } } From cc8700905caa5ce785986c5995bfc8180f29facb Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:21:18 +0200 Subject: [PATCH 05/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Oracle Database Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 8b1cdc539..9cfd9d0f1 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -92,7 +92,8 @@ public enum KameletPrefixSchemeEnum { mqtt("mqtt", "paho"), mqtt5("mqtt5", "paho-mqtt5"), mysql("mysql", "sql"), - nats("nats", "nats"); + nats("nats", "nats"), + oracle_database("oracle-database", "sql"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 681f673a2..1375cb1d3 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -298,5 +298,9 @@ void testSupportedHeaders() throws Exception { assertEquals(5, headersNatsSink.size()); List headersNatsSource= catalog.getKameletSupportedHeaders("nats-source"); assertEquals(5, headersNatsSource.size()); + List headersOracleDBSink= catalog.getKameletSupportedHeaders("oracle-database-sink"); + assertEquals(8, headersOracleDBSink.size()); + List headersOracleDBSource= catalog.getKameletSupportedHeaders("oracle-database-source"); + assertEquals(0, headersOracleDBSource.size()); } } From 9db6b8fecef22bab58abe3b94a2093253783cc7b Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:22:59 +0200 Subject: [PATCH 06/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - PostgreSQL Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 9cfd9d0f1..426bf3a56 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -93,7 +93,8 @@ public enum KameletPrefixSchemeEnum { mqtt5("mqtt5", "paho-mqtt5"), mysql("mysql", "sql"), nats("nats", "nats"), - oracle_database("oracle-database", "sql"); + oracle_database("oracle-database", "sql"), + postgresql("postgresql", "sql"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 1375cb1d3..0b274170f 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -302,5 +302,9 @@ void testSupportedHeaders() throws Exception { assertEquals(8, headersOracleDBSink.size()); List headersOracleDBSource= catalog.getKameletSupportedHeaders("oracle-database-source"); assertEquals(0, headersOracleDBSource.size()); + List headersPostgreSQLSink= catalog.getKameletSupportedHeaders("postgresql-sink"); + assertEquals(8, headersPostgreSQLSink.size()); + List headersPostgreSQLSource= catalog.getKameletSupportedHeaders("postgresql-source"); + assertEquals(0, headersPostgreSQLSource.size()); } } From 05ceb865c02655d765caa82db5f4ac43de0ce2db Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:26:50 +0200 Subject: [PATCH 07/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Pulsar Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 426bf3a56..d3ae68608 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -94,7 +94,8 @@ public enum KameletPrefixSchemeEnum { mysql("mysql", "sql"), nats("nats", "nats"), oracle_database("oracle-database", "sql"), - postgresql("postgresql", "sql"); + postgresql("postgresql", "sql"), + pulsar("pulsar", "pulsar"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 0b274170f..da1cac324 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -306,5 +306,9 @@ void testSupportedHeaders() throws Exception { assertEquals(8, headersPostgreSQLSink.size()); List headersPostgreSQLSource= catalog.getKameletSupportedHeaders("postgresql-source"); assertEquals(0, headersPostgreSQLSource.size()); + List headersPulsarSink= catalog.getKameletSupportedHeaders("pulsar-sink"); + assertEquals(3, headersPulsarSink.size()); + List headersPulsarSource= catalog.getKameletSupportedHeaders("pulsar-source"); + assertEquals(11, headersPulsarSource.size()); } } From a59b99aba284a6a2393c76250d934ae74e147108 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:29:26 +0200 Subject: [PATCH 08/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - RabbitMQ Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 2 ++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index d3ae68608..b87cd45a9 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -95,7 +95,8 @@ public enum KameletPrefixSchemeEnum { nats("nats", "nats"), oracle_database("oracle-database", "sql"), postgresql("postgresql", "sql"), - pulsar("pulsar", "pulsar"); + pulsar("pulsar", "pulsar"), + rabbitmq("rabbitmq", "rabbitmq"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index da1cac324..9cd3fa962 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -310,5 +310,7 @@ void testSupportedHeaders() throws Exception { assertEquals(3, headersPulsarSink.size()); List headersPulsarSource= catalog.getKameletSupportedHeaders("pulsar-source"); assertEquals(11, headersPulsarSource.size()); + List headersRabbitMQSource= catalog.getKameletSupportedHeaders("rabbitmq-source"); + assertEquals(23, headersRabbitMQSource.size()); } } From 661acad1756b0b8fd72b2df6eccc000d0139cc2c Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:33:20 +0200 Subject: [PATCH 09/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Redis Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index b87cd45a9..17ca34064 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -96,7 +96,8 @@ public enum KameletPrefixSchemeEnum { oracle_database("oracle-database", "sql"), postgresql("postgresql", "sql"), pulsar("pulsar", "pulsar"), - rabbitmq("rabbitmq", "rabbitmq"); + rabbitmq("rabbitmq", "rabbitmq"), + redis("redis", "spring-redis"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 9cd3fa962..9dbcea0cc 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -312,5 +312,9 @@ void testSupportedHeaders() throws Exception { assertEquals(11, headersPulsarSource.size()); List headersRabbitMQSource= catalog.getKameletSupportedHeaders("rabbitmq-source"); assertEquals(23, headersRabbitMQSource.size()); + List headersRedisSink= catalog.getKameletSupportedHeaders("redis-sink"); + assertEquals(29, headersRedisSink.size()); + List headersRedisSource= catalog.getKameletSupportedHeaders("redis-source"); + assertEquals(28, headersRedisSource.size()); } } From 3c3177596b3e92373dc2b4474dc984a6006087d7 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:35:12 +0200 Subject: [PATCH 10/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Rest OpenAPI Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 2 ++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 17ca34064..e8e195c31 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -97,7 +97,8 @@ public enum KameletPrefixSchemeEnum { postgresql("postgresql", "sql"), pulsar("pulsar", "pulsar"), rabbitmq("rabbitmq", "rabbitmq"), - redis("redis", "spring-redis"); + redis("redis", "spring-redis"), + rest_openapi("rest-openapi", "rest-openapi"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 9dbcea0cc..8a6f27a8e 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -316,5 +316,7 @@ void testSupportedHeaders() throws Exception { assertEquals(29, headersRedisSink.size()); List headersRedisSource= catalog.getKameletSupportedHeaders("redis-source"); assertEquals(28, headersRedisSource.size()); + List headersRestOpenAPISink= catalog.getKameletSupportedHeaders("rest-openapi-sink"); + assertEquals(0, headersRestOpenAPISink.size()); } } From a84306a05d98f4aa2f2ba77b9b836df402eb8177 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:40:20 +0200 Subject: [PATCH 11/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Salesforce Signed-off-by: Andrea Cosentino --- .../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 6 +++++- .../camel/kamelets/catalog/KameletsCatalogTest.java | 8 ++++++++ 2 files changed, 13 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index e8e195c31..c52437962 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -98,7 +98,11 @@ public enum KameletPrefixSchemeEnum { pulsar("pulsar", "pulsar"), rabbitmq("rabbitmq", "rabbitmq"), redis("redis", "spring-redis"), - rest_openapi("rest-openapi", "rest-openapi"); + rest_openapi("rest-openapi", "rest-openapi"), + salesforce_create("salesforce-create", "salesforce"), + salesforce_delete("salesforce-delete", "salesforce"), + salesforce_update("salesforce-update", "salesforce"), + salesforce("salesforce", "salesforce"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 8a6f27a8e..f6c4483f2 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -318,5 +318,13 @@ void testSupportedHeaders() throws Exception { assertEquals(28, headersRedisSource.size()); List headersRestOpenAPISink= catalog.getKameletSupportedHeaders("rest-openapi-sink"); assertEquals(0, headersRestOpenAPISink.size()); + List headersSalesforceCreateSink= catalog.getKameletSupportedHeaders("salesforce-create-sink"); + assertEquals(1, headersSalesforceCreateSink.size()); + List headersSalesforceDeleteSink= catalog.getKameletSupportedHeaders("salesforce-delete-sink"); + assertEquals(1, headersSalesforceDeleteSink.size()); + List headersSalesforceUpdateSink= catalog.getKameletSupportedHeaders("salesforce-update-sink"); + assertEquals(1, headersSalesforceUpdateSink.size()); + List headersSalesforceSource= catalog.getKameletSupportedHeaders("salesforce-source"); + assertEquals(18, headersSalesforceSource.size()); } } From 273437e83d45a35fac1e68c68785af2abcd48e91 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:46:01 +0200 Subject: [PATCH 12/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SCP/SFTP Signed-off-by: Andrea Cosentino --- .../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 4 +++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index c52437962..b7e2af76a 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -102,7 +102,9 @@ public enum KameletPrefixSchemeEnum { salesforce_create("salesforce-create", "salesforce"), salesforce_delete("salesforce-delete", "salesforce"), salesforce_update("salesforce-update", "salesforce"), - salesforce("salesforce", "salesforce"); + salesforce("salesforce", "salesforce"), + scp("scp", "scp"), + sftp("sftp", "sftp"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index f6c4483f2..ca0d20b61 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -326,5 +326,11 @@ void testSupportedHeaders() throws Exception { assertEquals(1, headersSalesforceUpdateSink.size()); List headersSalesforceSource= catalog.getKameletSupportedHeaders("salesforce-source"); assertEquals(18, headersSalesforceSource.size()); + List headersSCPSink= catalog.getKameletSupportedHeaders("scp-sink"); + assertEquals(0, headersSCPSink.size()); + List headersSFTPSink= catalog.getKameletSupportedHeaders("sftp-sink"); + assertEquals(8, headersSFTPSink.size()); + List headersSFTPSource= catalog.getKameletSupportedHeaders("sftp-source"); + assertEquals(10, headersSFTPSource.size()); } } From 7476bb2bad44e1438b8a1f1cc6fdf8ba85f64e7e Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:48:04 +0200 Subject: [PATCH 13/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Slack Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index b7e2af76a..d52d46bca 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -104,7 +104,8 @@ public enum KameletPrefixSchemeEnum { salesforce_update("salesforce-update", "salesforce"), salesforce("salesforce", "salesforce"), scp("scp", "scp"), - sftp("sftp", "sftp"); + sftp("sftp", "sftp"), + slack("slack", "slack"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index ca0d20b61..8bb1286d8 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -332,5 +332,9 @@ void testSupportedHeaders() throws Exception { assertEquals(8, headersSFTPSink.size()); List headersSFTPSource= catalog.getKameletSupportedHeaders("sftp-source"); assertEquals(10, headersSFTPSource.size()); + List headersSlackSink= catalog.getKameletSupportedHeaders("slack-sink"); + assertEquals(0, headersSlackSink.size()); + List headersSlackSource= catalog.getKameletSupportedHeaders("slack-source"); + assertEquals(0, headersSlackSource.size()); } } From 820ef3c968140064c00e7a16e0b1c86e5ddf866b Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:51:02 +0200 Subject: [PATCH 14/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Solr Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index d52d46bca..c0ff9d4cc 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -105,7 +105,8 @@ public enum KameletPrefixSchemeEnum { salesforce("salesforce", "salesforce"), scp("scp", "scp"), sftp("sftp", "sftp"), - slack("slack", "slack"); + slack("slack", "slack"), + solr("solr", "solr"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 8bb1286d8..f59985cb1 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -336,5 +336,9 @@ void testSupportedHeaders() throws Exception { assertEquals(0, headersSlackSink.size()); List headersSlackSource= catalog.getKameletSupportedHeaders("slack-source"); assertEquals(0, headersSlackSource.size()); + List headersSolrSink= catalog.getKameletSupportedHeaders("solr-sink"); + assertEquals(5, headersSolrSink.size()); + List headersSolrSource= catalog.getKameletSupportedHeaders("solr-source"); + assertEquals(5, headersSolrSource.size()); } } From ef94a58a70725de0f500560ef129e8828569cfd4 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:54:05 +0200 Subject: [PATCH 15/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Splunk Signed-off-by: Andrea Cosentino --- .../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 4 +++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index c0ff9d4cc..21b587703 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -106,7 +106,9 @@ public enum KameletPrefixSchemeEnum { scp("scp", "scp"), sftp("sftp", "sftp"), slack("slack", "slack"), - solr("solr", "solr"); + solr("solr", "solr"), + splunk_hec("splunk-hec", "splunk-hec"), + splunk("splunk", "splunk"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index f59985cb1..c0e66b78b 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -340,5 +340,11 @@ void testSupportedHeaders() throws Exception { assertEquals(5, headersSolrSink.size()); List headersSolrSource= catalog.getKameletSupportedHeaders("solr-source"); assertEquals(5, headersSolrSource.size()); + List headersSplunkHecSink= catalog.getKameletSupportedHeaders("splunk-hec-sink"); + assertEquals(1, headersSplunkHecSink.size()); + List headersSplunkSink= catalog.getKameletSupportedHeaders("splunk-sink"); + assertEquals(0, headersSplunkSink.size()); + List headersSplunkSource= catalog.getKameletSupportedHeaders("splunk-source"); + assertEquals(0, headersSplunkSource.size()); } } From ed09668d9fa22fa234b689e16ef650631dd31ce6 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 13:56:56 +0200 Subject: [PATCH 16/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQLServer Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 21b587703..35711f659 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -108,7 +108,8 @@ public enum KameletPrefixSchemeEnum { slack("slack", "slack"), solr("solr", "solr"), splunk_hec("splunk-hec", "splunk-hec"), - splunk("splunk", "splunk"); + splunk("splunk", "splunk"), + sqlserver("sqlserver", "sql"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index c0e66b78b..20c689dbb 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -346,5 +346,9 @@ void testSupportedHeaders() throws Exception { assertEquals(0, headersSplunkSink.size()); List headersSplunkSource= catalog.getKameletSupportedHeaders("splunk-source"); assertEquals(0, headersSplunkSource.size()); + List headersSqlServerSink= catalog.getKameletSupportedHeaders("sqlserver-sink"); + assertEquals(8, headersSqlServerSink.size()); + List headersSqlServerSource= catalog.getKameletSupportedHeaders("sqlserver-source"); + assertEquals(0, headersSqlServerSource.size()); } } From a31db7b2d5e48cb34368ce8bb65fa5beed0606da Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 14:06:57 +0200 Subject: [PATCH 17/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SSH Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 35711f659..d00a3c8c8 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -109,7 +109,8 @@ public enum KameletPrefixSchemeEnum { solr("solr", "solr"), splunk_hec("splunk-hec", "splunk-hec"), splunk("splunk", "splunk"), - sqlserver("sqlserver", "sql"); + sqlserver("sqlserver", "sql"), + ssh("ssh", "ssh"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 20c689dbb..eaedd684c 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -350,5 +350,9 @@ void testSupportedHeaders() throws Exception { assertEquals(8, headersSqlServerSink.size()); List headersSqlServerSource= catalog.getKameletSupportedHeaders("sqlserver-source"); assertEquals(0, headersSqlServerSource.size()); + List headersSSHSink= catalog.getKameletSupportedHeaders("ssh-sink"); + assertEquals(4, headersSSHSink.size()); + List headersSSHSource= catalog.getKameletSupportedHeaders("ssh-source"); + assertEquals(4, headersSSHSource.size()); } } From 44094ceafcf54fb7f90219df51df647d8aaba5b3 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 14:10:11 +0200 Subject: [PATCH 18/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Telegram Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index d00a3c8c8..3eb87bfdc 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -110,7 +110,8 @@ public enum KameletPrefixSchemeEnum { splunk_hec("splunk-hec", "splunk-hec"), splunk("splunk", "splunk"), sqlserver("sqlserver", "sql"), - ssh("ssh", "ssh"); + ssh("ssh", "ssh"), + telegram("telegram", "telegram"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index eaedd684c..449ee46c3 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -354,5 +354,9 @@ void testSupportedHeaders() throws Exception { assertEquals(4, headersSSHSink.size()); List headersSSHSource= catalog.getKameletSupportedHeaders("ssh-source"); assertEquals(4, headersSSHSource.size()); + List headersTelegramSink= catalog.getKameletSupportedHeaders("telegram-sink"); + assertEquals(6, headersTelegramSink.size()); + List headersTelegramSource= catalog.getKameletSupportedHeaders("telegram-source"); + assertEquals(5, headersTelegramSource.size()); } } From 80ab71ebb51c46343b068a83ce98f3fbad00b7a0 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 14:11:44 +0200 Subject: [PATCH 19/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Timer Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 2 ++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 3eb87bfdc..a1e70f833 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -111,7 +111,8 @@ public enum KameletPrefixSchemeEnum { splunk("splunk", "splunk"), sqlserver("sqlserver", "sql"), ssh("ssh", "ssh"), - telegram("telegram", "telegram"); + telegram("telegram", "telegram"), + timer("timer", "timer"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 449ee46c3..d622fa511 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -358,5 +358,7 @@ void testSupportedHeaders() throws Exception { assertEquals(6, headersTelegramSink.size()); List headersTelegramSource= catalog.getKameletSupportedHeaders("telegram-source"); assertEquals(5, headersTelegramSource.size()); + List headersTimerSource= catalog.getKameletSupportedHeaders("timer-source"); + assertEquals(2, headersTimerSource.size()); } } From 740f7d732dbf73001de383887ab04a7a92c7893f Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 14:15:23 +0200 Subject: [PATCH 20/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Twitter Signed-off-by: Andrea Cosentino --- .../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 5 ++++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index a1e70f833..26f665a6d 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -112,7 +112,10 @@ public enum KameletPrefixSchemeEnum { sqlserver("sqlserver", "sql"), ssh("ssh", "ssh"), telegram("telegram", "telegram"), - timer("timer", "timer"); + timer("timer", "timer"), + twitter_directmessage("twitter-directmessage", "twitter-directmessage"), + twitter_timeline("twitter-timeline", "twitter-timeline"), + twitter_search("twitter-search", "twitter-search"),; public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index d622fa511..287eb7111 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -360,5 +360,11 @@ void testSupportedHeaders() throws Exception { assertEquals(5, headersTelegramSource.size()); List headersTimerSource= catalog.getKameletSupportedHeaders("timer-source"); assertEquals(2, headersTimerSource.size()); + List headersTwitterDMSource= catalog.getKameletSupportedHeaders("twitter-directmessage-source"); + assertEquals(2, headersTwitterDMSource.size()); + List headersTwitterTimelineSource= catalog.getKameletSupportedHeaders("twitter-timeline-source"); + assertEquals(1, headersTwitterTimelineSource.size()); + List headersTwitterSearchSource= catalog.getKameletSupportedHeaders("twitter-search-source"); + assertEquals(7, headersTwitterSearchSource.size()); } } From ef715c0f25927c44438b76592742811bd66a1826 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 14:34:57 +0200 Subject: [PATCH 21/21] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Webhook, Websocket and Wttrin Signed-off-by: Andrea Cosentino --- .../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 5 ++++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 26f665a6d..ed52ee896 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -115,7 +115,10 @@ public enum KameletPrefixSchemeEnum { timer("timer", "timer"), twitter_directmessage("twitter-directmessage", "twitter-directmessage"), twitter_timeline("twitter-timeline", "twitter-timeline"), - twitter_search("twitter-search", "twitter-search"),; + twitter_search("twitter-search", "twitter-search"), + webhook("webhook", "platform-http"), + websocket("websocket", "websocket"), + wttrin("wttrin", "https"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 287eb7111..84ddf8eab 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -366,5 +366,11 @@ void testSupportedHeaders() throws Exception { assertEquals(1, headersTwitterTimelineSource.size()); List headersTwitterSearchSource= catalog.getKameletSupportedHeaders("twitter-search-source"); assertEquals(7, headersTwitterSearchSource.size()); + List headersWebhookSource= catalog.getKameletSupportedHeaders("webhook-source"); + assertEquals(0, headersWebhookSource.size()); + List headersWebsocketSource= catalog.getKameletSupportedHeaders("websocket-source"); + assertEquals(4, headersWebsocketSource.size()); + List headersWttrinSource= catalog.getKameletSupportedHeaders("wttrin-source"); + assertEquals(5, headersWttrinSource.size()); } }