[camel-kafka-connector] 02/03: Slack Connector: Add the slack transformer from itest to the slack connector ootb - aligned it test

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch slack-transf
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 2831f6e5d8f73dfb604443f60046821b133cb6fe
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 14:55:38 2020 +0200

    Slack Connector: Add the slack transformer from itest to the slack connector ootb - aligned it test
---
 .../slack/source/CamelSourceSlackITCase.java       |  4 +-
 .../slack/source/SlackTransformer.java             | 72 ----------------------
 2 files changed, 2 insertions(+), 74 deletions(-)

diff --git a/tests/itests-slack/src/test/java/org/apache/camel/kafkaconnector/slack/source/CamelSourceSlackITCase.java b/tests/itests-slack/src/test/java/org/apache/camel/kafkaconnector/slack/source/CamelSourceSlackITCase.java
index 14ee2c8..8a24c7b 100644
--- a/tests/itests-slack/src/test/java/org/apache/camel/kafkaconnector/slack/source/CamelSourceSlackITCase.java
+++ b/tests/itests-slack/src/test/java/org/apache/camel/kafkaconnector/slack/source/CamelSourceSlackITCase.java
@@ -86,8 +86,8 @@ public class CamelSourceSlackITCase extends AbstractKafkaTest {
                 .withChannel(slackChannel)
                 .withMaxResults(1)
                 .withToken(token)
-                .withTransformsConfig("SlackTransformer")
-                    .withEntry("type", "org.apache.camel.kafkaconnector.slack.source.SlackTransformer")
+                .withTransformsConfig("SlackTransforms")
+                    .withEntry("type", "org.apache.camel.kafkaconnector.slack.transformers.SlackTransforms")
                     .end();
 
         factory.log();
diff --git a/tests/itests-slack/src/test/java/org/apache/camel/kafkaconnector/slack/source/SlackTransformer.java b/tests/itests-slack/src/test/java/org/apache/camel/kafkaconnector/slack/source/SlackTransformer.java
deleted file mode 100644
index cc144bd..0000000
--- a/tests/itests-slack/src/test/java/org/apache/camel/kafkaconnector/slack/source/SlackTransformer.java
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.camel.kafkaconnector.slack.source;
-
-import java.util.Map;
-
-import org.apache.camel.component.slack.helper.SlackMessage;
-import org.apache.camel.kafkaconnector.utils.SchemaHelper;
-import org.apache.kafka.common.config.ConfigDef;
-import org.apache.kafka.connect.connector.ConnectRecord;
-import org.apache.kafka.connect.transforms.Transformation;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class SlackTransformer <R extends ConnectRecord<R>> implements Transformation<R> {
-    public static final String FIELD_KEY_CONFIG = "key";
-    public static final ConfigDef CONFIG_DEF = new ConfigDef()
-            .define(FIELD_KEY_CONFIG, ConfigDef.Type.STRING, null, ConfigDef.Importance.MEDIUM,
-                    "Transforms String-based content from Kafka into a map");
-
-    private static final Logger LOG = LoggerFactory.getLogger(SlackTransformer.class);
-
-    @Override
-    public R apply(R r) {
-        Object value = r.value();
-
-        if (r.value() instanceof SlackMessage) {
-            LOG.debug("Converting record from SlackMessage to text");
-            SlackMessage message = (SlackMessage) r.value();
-
-            LOG.debug("Received text: {}", message.getText());
-
-            return r.newRecord(r.topic(), r.kafkaPartition(), null, r.key(),
-                    SchemaHelper.buildSchemaBuilderForType(message.getText()), message.getText(), r.timestamp());
-
-        } else {
-            LOG.debug("Unexpected message type: {}", r.value().getClass());
-
-            return r;
-        }
-    }
-
-    @Override
-    public ConfigDef config() {
-        return CONFIG_DEF;
-    }
-
-    @Override
-    public void close() {
-
-    }
-
-    @Override
-    public void configure(Map<String, ?> map) {
-
-    }
-}