From 6c61b44731b4977bbb08cb24430b533ea9cc09bb Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 20 Oct 2022 14:34:57 +0200 Subject: [PATCH] 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()); } }