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 2023/01/20 08:10:13 UTC
[camel-kamelets] branch main updated: isolate the verifyHeader method in testSupportedHeaders to allow customizations
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 09a5b3e6 isolate the verifyHeader method in testSupportedHeaders to allow customizations
09a5b3e6 is described below
commit 09a5b3e6009e04acf92d70e0f15200f162692c1b
Author: Claudio Miranda <cl...@claudius.com.br>
AuthorDate: Thu Jan 19 19:41:47 2023 -0300
isolate the verifyHeader method in testSupportedHeaders to allow customizations
---
.../kamelets/catalog/KameletsCatalogTest.java | 375 +++++++--------------
1 file changed, 129 insertions(+), 246 deletions(-)
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 94224ce8..f4243b5a 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
@@ -128,254 +128,137 @@ public class KameletsCatalogTest {
@Test
void testSupportedHeaders() throws Exception {
- List<ComponentModel.EndpointHeaderModel> headersSource = catalog.getKameletSupportedHeaders("aws-s3-source");
- assertEquals(18, headersSource.size());
- List<ComponentModel.EndpointHeaderModel> headersSink = catalog.getKameletSupportedHeaders("aws-s3-sink");
- assertEquals(25, headersSink.size());
- List<ComponentModel.EndpointHeaderModel> headersCloudtrailSource = catalog.getKameletSupportedHeaders("aws-cloudtrail-source");
- assertEquals(0, headersCloudtrailSource.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");
- assertEquals(2, headersAzureSink.size());
- List<ComponentModel.EndpointHeaderModel> headersAzureFunctionsSink = catalog.getKameletSupportedHeaders("azure-functions-sink");
- assertEquals(8, headersAzureFunctionsSink.size());
- List<ComponentModel.EndpointHeaderModel> headersAzureServicebusSource = catalog.getKameletSupportedHeaders("azure-servicebus-source");
- assertEquals(22, headersAzureServicebusSource.size());
- List<ComponentModel.EndpointHeaderModel> headersAzureStorageBlobSource = catalog.getKameletSupportedHeaders("azure-storage-blob-source");
- assertEquals(34, headersAzureStorageBlobSource.size());
- List<ComponentModel.EndpointHeaderModel> headersAzureStorageBlobSink = catalog.getKameletSupportedHeaders("azure-storage-blob-sink");
- assertEquals(33, headersAzureStorageBlobSink.size());
- List<ComponentModel.EndpointHeaderModel> headersAzureStorageBlobChangeefeedSource = catalog.getKameletSupportedHeaders("azure-storage-blob-changefeed-source");
- assertEquals(34, headersAzureStorageBlobChangeefeedSource.size());
- List<ComponentModel.EndpointHeaderModel> headersAzureStorageQueueSource = catalog.getKameletSupportedHeaders("azure-storage-queue-source");
- assertEquals(6, headersAzureStorageQueueSource.size());
- List<ComponentModel.EndpointHeaderModel> headersAzureStorageQueueSink = catalog.getKameletSupportedHeaders("azure-storage-queue-sink");
- assertEquals(16, headersAzureStorageQueueSink.size());
- List<ComponentModel.EndpointHeaderModel> headersCqlSink = catalog.getKameletSupportedHeaders("cassandra-sink");
- assertEquals(1, headersCqlSink.size());
- List<ComponentModel.EndpointHeaderModel> headersCqlSource = catalog.getKameletSupportedHeaders("cassandra-source");
- assertEquals(1, headersCqlSource.size());
- List<ComponentModel.EndpointHeaderModel> headersCouchbaseSink = catalog.getKameletSupportedHeaders("couchbase-sink");
- assertEquals(2, headersCouchbaseSink.size());
- List<ComponentModel.EndpointHeaderModel> headersDropboxSource = catalog.getKameletSupportedHeaders("dropbox-source");
- assertEquals(0, headersDropboxSource.size());
- List<ComponentModel.EndpointHeaderModel> headersDropboxSink = catalog.getKameletSupportedHeaders("dropbox-source");
- assertEquals(0, headersDropboxSink.size());
- List<ComponentModel.EndpointHeaderModel> headersESIndexSink = catalog.getKameletSupportedHeaders("elasticsearch-index-sink");
- assertEquals(8, headersESIndexSink.size());
- List<ComponentModel.EndpointHeaderModel> headersESSearchSource = catalog.getKameletSupportedHeaders("elasticsearch-search-source");
- assertEquals(8, headersESSearchSource.size());
- List<ComponentModel.EndpointHeaderModel> headersExecSink = catalog.getKameletSupportedHeaders("exec-sink");
- assertEquals(0, headersExecSink.size());
- List<ComponentModel.EndpointHeaderModel> headersFhirSource = catalog.getKameletSupportedHeaders("fhir-source");
- assertEquals(0, headersFhirSource.size());
- List<ComponentModel.EndpointHeaderModel> headersFileWatchSource = catalog.getKameletSupportedHeaders("file-watch-source");
- assertEquals(10, headersFileWatchSource.size());
- List<ComponentModel.EndpointHeaderModel> headersFtpSource = catalog.getKameletSupportedHeaders("ftp-source");
- assertEquals(10, headersFtpSource.size());
- List<ComponentModel.EndpointHeaderModel> headersFtpSink = catalog.getKameletSupportedHeaders("ftp-sink");
- assertEquals(8, headersFtpSink.size());
- List<ComponentModel.EndpointHeaderModel> headersFtpsSource = catalog.getKameletSupportedHeaders("ftps-source");
- assertEquals(10, headersFtpsSource.size());
- List<ComponentModel.EndpointHeaderModel> headersFtpsSink = catalog.getKameletSupportedHeaders("ftps-sink");
- assertEquals(8, headersFtpsSink.size());
- List<ComponentModel.EndpointHeaderModel> headersGhCommitSource = catalog.getKameletSupportedHeaders("github-commit-source");
- assertEquals(7, headersGhCommitSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGhEventSource = catalog.getKameletSupportedHeaders("github-event-source");
- assertEquals(7, headersGhEventSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGhPrCommentSource = catalog.getKameletSupportedHeaders("github-pullrequest-comment-source");
- assertEquals(7, headersGhPrCommentSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGhPrSource = catalog.getKameletSupportedHeaders("github-pullrequest-source");
- assertEquals(7, headersGhPrSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGhTagSource = catalog.getKameletSupportedHeaders("github-tag-source");
- assertEquals(7, headersGhTagSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGoogleBigquerySink = catalog.getKameletSupportedHeaders("google-bigquery-sink");
- assertEquals(4, headersGoogleBigquerySink.size());
- List<ComponentModel.EndpointHeaderModel> headersGoogleCalendarSource = catalog.getKameletSupportedHeaders("google-calendar-source");
- assertEquals(1, headersGoogleCalendarSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGoogleFunctionsSink = catalog.getKameletSupportedHeaders("google-functions-sink");
- assertEquals(5, headersGoogleFunctionsSink.size());
- List<ComponentModel.EndpointHeaderModel> headersGoogleMailSource = catalog.getKameletSupportedHeaders("google-mail-source");
- assertEquals(6, headersGoogleMailSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGooglePubsubSink = catalog.getKameletSupportedHeaders("google-pubsub-sink");
- assertEquals(3, headersGooglePubsubSink.size());
- List<ComponentModel.EndpointHeaderModel> headersGooglePubsubSource = catalog.getKameletSupportedHeaders("google-pubsub-source");
- assertEquals(4, headersGooglePubsubSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGoogleSheetsSource = catalog.getKameletSupportedHeaders("google-sheets-source");
- assertEquals(6, headersGoogleSheetsSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGoogleStorageSource = catalog.getKameletSupportedHeaders("google-storage-source");
- assertEquals(20, headersGoogleStorageSource.size());
- List<ComponentModel.EndpointHeaderModel> headersGoogleStorageSink = catalog.getKameletSupportedHeaders("google-storage-sink");
- assertEquals(13, headersGoogleStorageSink.size());
- List<ComponentModel.EndpointHeaderModel> headersHttpSource = catalog.getKameletSupportedHeaders("http-source");
- assertEquals(5, headersHttpSource.size());
- List<ComponentModel.EndpointHeaderModel> headersHttpSink = catalog.getKameletSupportedHeaders("http-sink");
- assertEquals(14, headersHttpSink.size());
- List<ComponentModel.EndpointHeaderModel> headersHttpSecuredSource = catalog.getKameletSupportedHeaders("http-secured-source");
- assertEquals(5, headersHttpSecuredSource.size());
- List<ComponentModel.EndpointHeaderModel> headersHttpSecuredSink = catalog.getKameletSupportedHeaders("http-secured-sink");
- assertEquals(14, headersHttpSecuredSink.size());
- List<ComponentModel.EndpointHeaderModel> headersInfinispanSource = catalog.getKameletSupportedHeaders("infinispan-source");
- assertEquals(6, headersInfinispanSource.size());
- List<ComponentModel.EndpointHeaderModel> headersInfinispanSink = catalog.getKameletSupportedHeaders("infinispan-sink");
- assertEquals(14, headersInfinispanSink.size());
- List<ComponentModel.EndpointHeaderModel> headersJiraAddCommentSink = catalog.getKameletSupportedHeaders("jira-add-comment-sink");
- assertEquals(16, headersJiraAddCommentSink.size());
- List<ComponentModel.EndpointHeaderModel> headersJiraAddIssueSink = catalog.getKameletSupportedHeaders("jira-add-issue-sink");
- assertEquals(16, headersJiraAddIssueSink.size());
- List<ComponentModel.EndpointHeaderModel> headersJiraSource= catalog.getKameletSupportedHeaders("jira-source");
- assertEquals(3, headersJiraSource.size());
- List<ComponentModel.EndpointHeaderModel> headersJiraOauthSource= catalog.getKameletSupportedHeaders("jira-oauth-source");
- assertEquals(3, headersJiraOauthSource.size());
- List<ComponentModel.EndpointHeaderModel> headersJmsAmqp10Source= catalog.getKameletSupportedHeaders("jms-amqp-10-source");
- assertEquals(14, headersJmsAmqp10Source.size());
- List<ComponentModel.EndpointHeaderModel> headersJmsAmqp10Sink= catalog.getKameletSupportedHeaders("jms-amqp-10-sink");
- assertEquals(17, headersJmsAmqp10Sink.size());
- List<ComponentModel.EndpointHeaderModel> headersActivemqSource= catalog.getKameletSupportedHeaders("jms-apache-activemq-source");
- assertEquals(14, headersActivemqSource.size());
- List<ComponentModel.EndpointHeaderModel> headersActivemqSink= catalog.getKameletSupportedHeaders("jms-apache-activemq-sink");
- assertEquals(17, headersActivemqSink.size());
- List<ComponentModel.EndpointHeaderModel> headersJmsArtemisSource= catalog.getKameletSupportedHeaders("jms-apache-artemis-source");
- assertEquals(14, headersJmsArtemisSource.size());
- List<ComponentModel.EndpointHeaderModel> headersJmsArtemisSink= catalog.getKameletSupportedHeaders("jms-apache-artemis-sink");
- assertEquals(17, headersJmsArtemisSink.size());
- List<ComponentModel.EndpointHeaderModel> headersJmsIBMSource= catalog.getKameletSupportedHeaders("jms-ibm-mq-source");
- assertEquals(14, headersJmsIBMSource.size());
- List<ComponentModel.EndpointHeaderModel> headersJmsIBMSink= catalog.getKameletSupportedHeaders("jms-ibm-mq-sink");
- assertEquals(17, headersJmsIBMSink.size());
- List<ComponentModel.EndpointHeaderModel> headersKafkaSource= catalog.getKameletSupportedHeaders("kafka-source");
- assertEquals(9, headersKafkaSource.size());
- List<ComponentModel.EndpointHeaderModel> headersKafkaSink= catalog.getKameletSupportedHeaders("kafka-sink");
- assertEquals(5, headersKafkaSink.size());
- List<ComponentModel.EndpointHeaderModel> headersKafkaSSLSource= catalog.getKameletSupportedHeaders("kafka-ssl-source");
- assertEquals(9, headersKafkaSSLSource.size());
- List<ComponentModel.EndpointHeaderModel> headersKafkaSSLSink= catalog.getKameletSupportedHeaders("kafka-ssl-sink");
- assertEquals(5, headersKafkaSSLSink.size());
- List<ComponentModel.EndpointHeaderModel> headersKafkaNotSecuredSource= catalog.getKameletSupportedHeaders("kafka-not-secured-source");
- assertEquals(9, headersKafkaNotSecuredSource.size());
- List<ComponentModel.EndpointHeaderModel> headersKafkaNotSecuredSink= catalog.getKameletSupportedHeaders("kafka-not-secured-sink");
- assertEquals(5, headersKafkaNotSecuredSink.size());
- List<ComponentModel.EndpointHeaderModel> headersKubeNamespacesSource= catalog.getKameletSupportedHeaders("kubernetes-namespaces-source");
- assertEquals(2, headersKubeNamespacesSource.size());
- List<ComponentModel.EndpointHeaderModel> headersKubeNodesSource= catalog.getKameletSupportedHeaders("kubernetes-nodes-source");
- assertEquals(2, headersKubeNodesSource.size());
- List<ComponentModel.EndpointHeaderModel> headersKubePodsSource= catalog.getKameletSupportedHeaders("kubernetes-pods-source");
- assertEquals(2, headersKubePodsSource.size());
- List<ComponentModel.EndpointHeaderModel> headersLogSink= catalog.getKameletSupportedHeaders("log-sink");
- assertEquals(0, headersLogSink.size());
- List<ComponentModel.EndpointHeaderModel> headersMailSource= catalog.getKameletSupportedHeaders("mail-source");
- assertEquals(0, headersMailSource.size());
- List<ComponentModel.EndpointHeaderModel> headersMailSink= catalog.getKameletSupportedHeaders("mail-sink");
- assertEquals(8, headersMailSink.size());
- List<ComponentModel.EndpointHeaderModel> headersMariaDBSource= catalog.getKameletSupportedHeaders("mariadb-source");
- assertEquals(0, headersMariaDBSource.size());
- List<ComponentModel.EndpointHeaderModel> headersMariaDBSink= catalog.getKameletSupportedHeaders("mariadb-sink");
- assertEquals(8, headersMariaDBSink.size());
- List<ComponentModel.EndpointHeaderModel> headersMinioSource= catalog.getKameletSupportedHeaders("minio-source");
- assertEquals(14, headersMinioSource.size());
- List<ComponentModel.EndpointHeaderModel> headersMinioSink= catalog.getKameletSupportedHeaders("minio-sink");
- assertEquals(21, headersMinioSink.size());
- List<ComponentModel.EndpointHeaderModel> headersMongodbChangesStreamSource= catalog.getKameletSupportedHeaders("mongodb-changes-stream-source");
- assertEquals(3, headersMongodbChangesStreamSource.size());
- List<ComponentModel.EndpointHeaderModel> headersMongoDbSink= catalog.getKameletSupportedHeaders("mongodb-sink");
- 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());
+ verifyHeaders("aws-s3-source", 18);
+ verifyHeaders("aws-s3-sink", 25);
+ verifyHeaders("aws-cloudtrail-source", 0);
+ verifyHeaders("aws-redshift-source", 0);
+ verifyHeaders("aws-not-exists", 0);
+ verifyHeaders("azure-eventhubs-sink", 2);
+ verifyHeaders("azure-functions-sink", 8);
+ verifyHeaders("azure-servicebus-source", 22);
+ verifyHeaders("azure-storage-blob-source", 34);
+ verifyHeaders("azure-storage-blob-sink", 33);
+ verifyHeaders("azure-storage-blob-changefeed-source", 34);
+ verifyHeaders("azure-storage-queue-source", 6);
+ verifyHeaders("azure-storage-queue-sink", 16);
+ verifyHeaders("cassandra-sink", 1);
+ verifyHeaders("cassandra-source", 1);
+ verifyHeaders("couchbase-sink", 2);
+ verifyHeaders("dropbox-source", 0);
+ verifyHeaders("dropbox-source", 0);
+ verifyHeaders("elasticsearch-index-sink", 8);
+ verifyHeaders("elasticsearch-search-source", 8);
+ verifyHeaders("exec-sink", 0);
+ verifyHeaders("fhir-source", 0);
+ verifyHeaders("file-watch-source", 10);
+ verifyHeaders("ftp-source", 10);
+ verifyHeaders("ftp-sink", 8);
+ verifyHeaders("ftps-source", 10);
+ verifyHeaders("ftps-sink", 8);
+ verifyHeaders("github-commit-source", 7);
+ verifyHeaders("github-event-source", 7);
+ verifyHeaders("github-pullrequest-comment-source", 7);
+ verifyHeaders("github-pullrequest-source", 7);
+ verifyHeaders("github-tag-source", 7);
+ verifyHeaders("google-bigquery-sink", 4);
+ verifyHeaders("google-calendar-source", 1);
+ verifyHeaders("google-functions-sink", 5);
+ verifyHeaders("google-mail-source", 6);
+ verifyHeaders("google-pubsub-sink", 3);
+ verifyHeaders("google-pubsub-source", 4);
+ verifyHeaders("google-sheets-source", 6);
+ verifyHeaders("google-storage-source", 20);
+ verifyHeaders("google-storage-sink", 13);
+ verifyHeaders("http-source", 5);
+ verifyHeaders("http-sink", 14);
+ verifyHeaders("http-secured-source", 5);
+ verifyHeaders("http-secured-sink", 14);
+ verifyHeaders("infinispan-source", 6);
+ verifyHeaders("infinispan-sink", 14);
+ verifyHeaders("jira-add-comment-sink", 16);
+ verifyHeaders("jira-add-issue-sink", 16);
+ verifyHeaders("jira-source", 3);
+ verifyHeaders("jira-oauth-source", 3);
+ verifyHeaders("jms-amqp-10-source", 14);
+ verifyHeaders("jms-amqp-10-sink", 17);
+ verifyHeaders("jms-apache-activemq-source", 14);
+ verifyHeaders("jms-apache-activemq-sink", 17);
+ verifyHeaders("jms-apache-artemis-source", 14);
+ verifyHeaders("jms-apache-artemis-sink", 17);
+ verifyHeaders("jms-ibm-mq-source", 14);
+ verifyHeaders("jms-ibm-mq-sink", 17);
+ verifyHeaders("kafka-source", 9);
+ verifyHeaders("kafka-sink", 5);
+ verifyHeaders("kafka-ssl-source", 9);
+ verifyHeaders("kafka-ssl-sink", 5);
+ verifyHeaders("kafka-not-secured-source", 9);
+ verifyHeaders("kafka-not-secured-sink", 5);
+ verifyHeaders("kubernetes-namespaces-source", 2);
+ verifyHeaders("kubernetes-nodes-source", 2);
+ verifyHeaders("kubernetes-pods-source", 2);
+ verifyHeaders("log-sink", 0);
+ verifyHeaders("mail-source", 0);
+ verifyHeaders("mail-sink", 8);
+ verifyHeaders("mariadb-source", 0);
+ verifyHeaders("mariadb-sink", 8);
+ verifyHeaders("minio-source", 14);
+ verifyHeaders("minio-sink", 21);
+ verifyHeaders("mongodb-changes-stream-source", 3);
+ verifyHeaders("mongodb-sink", 12);
+ verifyHeaders("mongodb-source", 3);
+ verifyHeaders("mqtt-sink", 3);
+ verifyHeaders("mqtt-source", 2);
+ verifyHeaders("mqtt5-sink", 3);
+ verifyHeaders("mqtt5-source", 2);
+ verifyHeaders("mysql-sink", 8);
+ verifyHeaders("mysql-source", 0);
+ verifyHeaders("nats-sink", 5);
+ verifyHeaders("nats-source", 5);
+ verifyHeaders("oracle-database-sink", 8);
+ verifyHeaders("oracle-database-source", 0);
+ verifyHeaders("postgresql-sink", 8);
+ verifyHeaders("postgresql-source", 0);
+ verifyHeaders("pulsar-sink", 3);
+ verifyHeaders("pulsar-source", 11);
+ verifyHeaders("rabbitmq-source", 23);
+ verifyHeaders("redis-sink", 29);
+ verifyHeaders("redis-source", 28);
+ verifyHeaders("rest-openapi-sink", 0);
+ verifyHeaders("salesforce-create-sink", 1);
+ verifyHeaders("salesforce-delete-sink", 1);
+ verifyHeaders("salesforce-update-sink", 1);
+ verifyHeaders("salesforce-source", 18);
+ verifyHeaders("scp-sink", 0);
+ verifyHeaders("sftp-sink", 8);
+ verifyHeaders("sftp-source", 10);
+ verifyHeaders("slack-sink", 0);
+ verifyHeaders("slack-source", 0);
+ verifyHeaders("solr-sink", 5);
+ verifyHeaders("solr-source", 5);
+ verifyHeaders("splunk-hec-sink", 1);
+ verifyHeaders("splunk-sink", 0);
+ verifyHeaders("splunk-source", 0);
+ verifyHeaders("sqlserver-sink", 8);
+ verifyHeaders("sqlserver-source", 0);
+ verifyHeaders("ssh-sink", 4);
+ verifyHeaders("ssh-source", 4);
+ verifyHeaders("telegram-sink", 6);
+ verifyHeaders("telegram-source", 5);
+ verifyHeaders("timer-source", 2);
+ verifyHeaders("twitter-directmessage-source", 2);
+ verifyHeaders("twitter-timeline-source", 1);
+ verifyHeaders("twitter-search-source", 7);
+ verifyHeaders("webhook-source", 0);
+ verifyHeaders("websocket-source", 4);
+ verifyHeaders("wttrin-source", 5);
}
+ void verifyHeaders(String name, int expected) {
+ List<ComponentModel.EndpointHeaderModel> headers = catalog.getKameletSupportedHeaders(name);
+ assertEquals(expected, headers.size());
+ }
+
+
@Test
void testGetKameletScheme() throws Exception {
assertEquals("aws2-s3", catalog.getKameletScheme("aws-s3"));