Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet

library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java

@@ -88,7 +88,37 @@ 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"),
+    mqtt5("mqtt5", "paho-mqtt5"),
+    mysql("mysql", "sql"),
+    nats("nats", "nats"),
+    oracle_database("oracle-database", "sql"),
+    postgresql("postgresql", "sql"),
+    pulsar("pulsar", "pulsar"),
+    rabbitmq("rabbitmq", "rabbitmq"),
+    redis("redis", "spring-redis"),
+    rest_openapi("rest-openapi", "rest-openapi"),
+    salesforce_create("salesforce-create", "salesforce"),
+    salesforce_delete("salesforce-delete", "salesforce"),
+    salesforce_update("salesforce-update", "salesforce"),
+    salesforce("salesforce", "salesforce"),
+    scp("scp", "scp"),
+    sftp("sftp", "sftp"),
+    slack("slack", "slack"),
+    solr("solr", "solr"),
+    splunk_hec("splunk-hec", "splunk-hec"),
+    splunk("splunk", "splunk"),
+    sqlserver("sqlserver", "sql"),
+    ssh("ssh", "ssh"),
+    telegram("telegram", "telegram"),
+    timer("timer", "timer"),
+    twitter_directmessage("twitter-directmessage", "twitter-directmessage"),
+    twitter_timeline("twitter-timeline", "twitter-timeline"),
+    twitter_search("twitter-search", "twitter-search"),
+    webhook("webhook", "platform-http"),
+    websocket("websocket", "websocket"),
+    wttrin("wttrin", "https");
 
     public final String name;
     public final String scheme;

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<ComponentModel.EndpointHeaderModel> headersSink = catalog.getKameletSupportedHeaders("aws-s3-sink");
         assertEquals(25, headersSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersRedshiftSource = catalog.getKameletSupportedHeaders("aws-redshift-source");
+        assertEquals(0, headersRedshiftSource.size());
         List<ComponentModel.EndpointHeaderModel> headerNotExistent = catalog.getKameletSupportedHeaders("aws-not-exists");
         assertEquals(0, headerNotExistent.size());
         List<ComponentModel.EndpointHeaderModel> headersAzureSink = catalog.getKameletSupportedHeaders("azure-eventhubs-sink");
@@ -280,5 +282,95 @@ void testSupportedHeaders() throws Exception {
         assertEquals(12, headersMongoDbSink.size());
         List<ComponentModel.EndpointHeaderModel> headersMongoDbSource= catalog.getKameletSupportedHeaders("mongodb-source");
         assertEquals(3, headersMongoDbSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersMQTTSink= catalog.getKameletSupportedHeaders("mqtt-sink");
+        assertEquals(3, headersMQTTSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersMQTTSource= catalog.getKameletSupportedHeaders("mqtt-source");
+        assertEquals(2, headersMQTTSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersMQTT5Sink= catalog.getKameletSupportedHeaders("mqtt5-sink");
+        assertEquals(3, headersMQTT5Sink.size());
+        List<ComponentModel.EndpointHeaderModel> headersMQTT5Source= catalog.getKameletSupportedHeaders("mqtt5-source");
+        assertEquals(2, headersMQTT5Source.size());
+        List<ComponentModel.EndpointHeaderModel> headersMySQLSink= catalog.getKameletSupportedHeaders("mysql-sink");
+        assertEquals(8, headersMySQLSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersMySQLSource= catalog.getKameletSupportedHeaders("mysql-source");
+        assertEquals(0, headersMySQLSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersNatsSink= catalog.getKameletSupportedHeaders("nats-sink");
+        assertEquals(5, headersNatsSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersNatsSource= catalog.getKameletSupportedHeaders("nats-source");
+        assertEquals(5, headersNatsSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersOracleDBSink= catalog.getKameletSupportedHeaders("oracle-database-sink");
+        assertEquals(8, headersOracleDBSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersOracleDBSource= catalog.getKameletSupportedHeaders("oracle-database-source");
+        assertEquals(0, headersOracleDBSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersPostgreSQLSink= catalog.getKameletSupportedHeaders("postgresql-sink");
+        assertEquals(8, headersPostgreSQLSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersPostgreSQLSource= catalog.getKameletSupportedHeaders("postgresql-source");
+        assertEquals(0, headersPostgreSQLSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersPulsarSink= catalog.getKameletSupportedHeaders("pulsar-sink");
+        assertEquals(3, headersPulsarSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersPulsarSource= catalog.getKameletSupportedHeaders("pulsar-source");
+        assertEquals(11, headersPulsarSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersRabbitMQSource= catalog.getKameletSupportedHeaders("rabbitmq-source");
+        assertEquals(23, headersRabbitMQSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersRedisSink= catalog.getKameletSupportedHeaders("redis-sink");
+        assertEquals(29, headersRedisSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersRedisSource= catalog.getKameletSupportedHeaders("redis-source");
+        assertEquals(28, headersRedisSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersRestOpenAPISink= catalog.getKameletSupportedHeaders("rest-openapi-sink");
+        assertEquals(0, headersRestOpenAPISink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSalesforceCreateSink= catalog.getKameletSupportedHeaders("salesforce-create-sink");
+        assertEquals(1, headersSalesforceCreateSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSalesforceDeleteSink= catalog.getKameletSupportedHeaders("salesforce-delete-sink");
+        assertEquals(1, headersSalesforceDeleteSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSalesforceUpdateSink= catalog.getKameletSupportedHeaders("salesforce-update-sink");
+        assertEquals(1, headersSalesforceUpdateSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSalesforceSource= catalog.getKameletSupportedHeaders("salesforce-source");
+        assertEquals(18, headersSalesforceSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersSCPSink= catalog.getKameletSupportedHeaders("scp-sink");
+        assertEquals(0, headersSCPSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSFTPSink= catalog.getKameletSupportedHeaders("sftp-sink");
+        assertEquals(8, headersSFTPSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSFTPSource= catalog.getKameletSupportedHeaders("sftp-source");
+        assertEquals(10, headersSFTPSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersSlackSink= catalog.getKameletSupportedHeaders("slack-sink");
+        assertEquals(0, headersSlackSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSlackSource= catalog.getKameletSupportedHeaders("slack-source");
+        assertEquals(0, headersSlackSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersSolrSink= catalog.getKameletSupportedHeaders("solr-sink");
+        assertEquals(5, headersSolrSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSolrSource= catalog.getKameletSupportedHeaders("solr-source");
+        assertEquals(5, headersSolrSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersSplunkHecSink= catalog.getKameletSupportedHeaders("splunk-hec-sink");
+        assertEquals(1, headersSplunkHecSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSplunkSink= catalog.getKameletSupportedHeaders("splunk-sink");
+        assertEquals(0, headersSplunkSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSplunkSource= catalog.getKameletSupportedHeaders("splunk-source");
+        assertEquals(0, headersSplunkSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersSqlServerSink= catalog.getKameletSupportedHeaders("sqlserver-sink");
+        assertEquals(8, headersSqlServerSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSqlServerSource= catalog.getKameletSupportedHeaders("sqlserver-source");
+        assertEquals(0, headersSqlServerSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersSSHSink= catalog.getKameletSupportedHeaders("ssh-sink");
+        assertEquals(4, headersSSHSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersSSHSource= catalog.getKameletSupportedHeaders("ssh-source");
+        assertEquals(4, headersSSHSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersTelegramSink= catalog.getKameletSupportedHeaders("telegram-sink");
+        assertEquals(6, headersTelegramSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersTelegramSource= catalog.getKameletSupportedHeaders("telegram-source");
+        assertEquals(5, headersTelegramSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersTimerSource= catalog.getKameletSupportedHeaders("timer-source");
+        assertEquals(2, headersTimerSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersTwitterDMSource= catalog.getKameletSupportedHeaders("twitter-directmessage-source");
+        assertEquals(2, headersTwitterDMSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersTwitterTimelineSource= catalog.getKameletSupportedHeaders("twitter-timeline-source");
+        assertEquals(1, headersTwitterTimelineSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersTwitterSearchSource= catalog.getKameletSupportedHeaders("twitter-search-source");
+        assertEquals(7, headersTwitterSearchSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersWebhookSource= catalog.getKameletSupportedHeaders("webhook-source");
+        assertEquals(0, headersWebhookSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersWebsocketSource= catalog.getKameletSupportedHeaders("websocket-source");
+        assertEquals(4, headersWebsocketSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersWttrinSource= catalog.getKameletSupportedHeaders("wttrin-source");
+        assertEquals(5, headersWttrinSource.size());
     }
 }