e2111652fd
Remove CF Acceptance tests Convert local sample tests as e2e tests for the various sample apps Polishing
224 lines
7.2 KiB
Bash
Executable File
224 lines
7.2 KiB
Bash
Executable File
|
|
#!/bin/bash
|
|
|
|
pushd () {
|
|
command pushd "$@" > /dev/null
|
|
}
|
|
|
|
popd () {
|
|
command popd "$@" > /dev/null
|
|
}
|
|
|
|
function prepare_jdbc_source_with_kafka_and_rabbit_binders() {
|
|
pushd ../source-samples/jdbc-source
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/sample-jdbc-source-*-SNAPSHOT-kafka.jar /tmp/jdbc-source-kafka-sample.jar
|
|
|
|
./mvnw clean package -U -P rabbit-binder -DskipTests
|
|
|
|
cp target/sample-jdbc-source-*-SNAPSHOT-rabbit.jar /tmp/jdbc-source-rabbit-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_jdbc_sink_with_kafka_and_rabbit_binders() {
|
|
pushd ../sink-samples/jdbc-sink
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/sample-jdbc-sink-*-SNAPSHOT-kafka.jar /tmp/jdbc-sink-kafka-sample.jar
|
|
|
|
./mvnw clean package -U -P rabbit-binder -DskipTests
|
|
|
|
cp target/sample-jdbc-sink-*-SNAPSHOT-rabbit.jar /tmp/jdbc-sink-rabbit-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_dynamic_source_with_kafka_and_rabbit_binders() {
|
|
pushd ../source-samples/dynamic-destination-source
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/dynamic-destination-source-*-SNAPSHOT-kafka.jar /tmp/dynamic-destination-source-kafka-sample.jar
|
|
|
|
./mvnw clean package -U -P rabbit-binder -DskipTests
|
|
|
|
cp target/dynamic-destination-source-*-SNAPSHOT-rabbit.jar /tmp/dynamic-destination-source-rabbit-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_multi_binder_with_kafka_rabbit() {
|
|
pushd ../multibinder-samples/multibinder-kafka-rabbit
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/multibinder-kafka-rabbit-*-SNAPSHOT.jar /tmp/multibinder-kafka-rabbit-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_multi_binder_with_two_kafka_clusters() {
|
|
pushd ../multibinder-samples/multibinder-two-kafka-clusters
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/multibinder-two-kafka-clusters-*-SNAPSHOT.jar /tmp/multibinder-two-kafka-clusters-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_kafka_streams_word_count() {
|
|
pushd ../kafka-streams-samples/kafka-streams-word-count
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/kafka-streams-word-count-*-SNAPSHOT.jar /tmp/kafka-streams-word-count-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_streamlistener_basic_with_kafka_rabbit_binders() {
|
|
pushd ../processor-samples/streamlistener-basic
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/streamlistener-basic-*-SNAPSHOT-kafka.jar /tmp/streamlistener-basic-kafka-sample.jar
|
|
|
|
./mvnw clean package -U -P rabbit-binder -DskipTests
|
|
|
|
cp target/streamlistener-basic-*-SNAPSHOT-rabbit.jar /tmp/streamlistener-basic-rabbit-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_reactive_processor_with_kafka_rabbit_binders() {
|
|
pushd ../processor-samples/reactive-processor
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/reactive-processor-*-SNAPSHOT-kafka.jar /tmp/reactive-processor-kafka-sample.jar
|
|
|
|
./mvnw clean package -U -P rabbit-binder -DskipTests
|
|
|
|
cp target/reactive-processor-*-SNAPSHOT-rabbit.jar /tmp/reactive-processor-rabbit-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_sensor_average_reactive_with_kafka_rabbit_binders() {
|
|
pushd ../processor-samples/sensor-average-reactive
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp target/sensor-average-reactive-*-SNAPSHOT-kafka.jar /tmp/sensor-average-reactive-kafka-sample.jar
|
|
|
|
./mvnw clean package -U -P rabbit-binder -DskipTests
|
|
|
|
cp target/sensor-average-reactive-*-SNAPSHOT-rabbit.jar /tmp/sensor-average-reactive-rabbit-sample.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_schema_registry_vanilla_with_kafka_rabbit_binders() {
|
|
pushd ../schema-registry-samples/schema-registry-vanilla
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp schema-registry-vanilla-server/target/schema-registry-vanilla-server-*-SNAPSHOT.jar /tmp/schema-registry-vanilla-registry-kafka.jar
|
|
cp schema-registry-vanilla-consumer/target/schema-registry-vanilla-consumer-*-kafka.jar /tmp/schema-registry-vanilla-consumer-kafka.jar
|
|
cp schema-registry-vanilla-producer1/target/schema-registry-vanilla-producer1-*-kafka.jar /tmp/schema-registry-vanilla-producer1-kafka.jar
|
|
cp schema-registry-vanilla-producer2/target/schema-registry-vanilla-producer2-*-kafka.jar /tmp/schema-registry-vanilla-producer2-kafka.jar
|
|
|
|
./mvnw clean package -U -P rabbit-binder -DskipTests
|
|
|
|
cp schema-registry-vanilla-server/target/schema-registry-vanilla-server-*-SNAPSHOT.jar /tmp/schema-registry-vanilla-registry-rabbit.jar
|
|
cp schema-registry-vanilla-consumer/target/schema-registry-vanilla-consumer-*-rabbit.jar /tmp/schema-registry-vanilla-consumer-rabbit.jar
|
|
cp schema-registry-vanilla-producer1/target/schema-registry-vanilla-producer1-*-rabbit.jar /tmp/schema-registry-vanilla-producer1-rabbit.jar
|
|
cp schema-registry-vanilla-producer2/target/schema-registry-vanilla-producer2-*-rabbit.jar /tmp/schema-registry-vanilla-producer2-rabbit.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
function prepare_partitioning_with_kafka_rabbit_binders() {
|
|
pushd ../partitioning-samples
|
|
./mvnw clean package -U -DskipTests
|
|
|
|
cp partitioning-producer-sample/target/partitioning-producer-sample-*-kafka.jar /tmp/partitioning-producer-kafka.jar
|
|
cp partitioning-consumer-sample-kafka/target/partitioning-consumer-sample-kafka-*-SNAPSHOT.jar /tmp/partitioning-consumer-kafka.jar
|
|
|
|
./mvnw clean package -U -DskipTests -P rabbit-binder -pl :partitioning-producer-sample
|
|
|
|
cp partitioning-producer-sample/target/partitioning-producer-sample-*-rabbit.jar /tmp/partitioning-producer-rabbit.jar
|
|
cp partitioning-consumer-sample-rabbit/target/partitioning-consumer-sample-rabbit-*-SNAPSHOT.jar /tmp/partitioning-consumer-rabbit.jar
|
|
|
|
popd
|
|
|
|
}
|
|
|
|
#Main script starting
|
|
|
|
echo "Prepare artifacts for testing"
|
|
|
|
prepare_jdbc_source_with_kafka_and_rabbit_binders
|
|
prepare_jdbc_sink_with_kafka_and_rabbit_binders
|
|
prepare_dynamic_source_with_kafka_and_rabbit_binders
|
|
prepare_multi_binder_with_kafka_rabbit
|
|
prepare_multi_binder_with_two_kafka_clusters
|
|
prepare_streamlistener_basic_with_kafka_rabbit_binders
|
|
prepare_reactive_processor_with_kafka_rabbit_binders
|
|
prepare_sensor_average_reactive_with_kafka_rabbit_binders
|
|
prepare_kafka_streams_word_count
|
|
|
|
prepare_schema_registry_vanilla_with_kafka_rabbit_binders
|
|
|
|
prepare_partitioning_with_kafka_rabbit_binders
|
|
|
|
echo "Starting components in docker containers..."
|
|
|
|
docker-compose up -d
|
|
|
|
echo "Running tests"
|
|
|
|
./mvnw clean package -Dmaven.test.skip=false
|
|
BUILD_RETURN_VALUE=$?
|
|
|
|
docker-compose down
|
|
|
|
# Post cleanup
|
|
|
|
rm /tmp/jdbc-source-kafka-sample.jar
|
|
rm /tmp/jdbc-source-rabbit-sample.jar
|
|
rm /tmp/jdbc-sink-kafka-sample.jar
|
|
rm /tmp/jdbc-sink-rabbit-sample.jar
|
|
rm /tmp/dynamic-destination-source-kafka-sample.jar
|
|
rm /tmp/dynamic-destination-source-rabbit-sample.jar
|
|
rm /tmp/multibinder-kafka-rabbit-sample.jar
|
|
rm /tmp/multibinder-two-kafka-clusters-sample.jar
|
|
rm /tmp/kafka-streams-word-count-sample.jar
|
|
rm /tmp/streamlistener-basic-kafka-sample.jar
|
|
rm /tmp/streamlistener-basic-rabbit-sample.jar
|
|
rm /tmp/reactive-processor-kafka-sample.jar
|
|
rm /tmp/reactive-processor-rabbit-sample.jar
|
|
rm /tmp/sensor-average-reactive-kafka-sample.jar
|
|
rm /tmp/sensor-average-reactive-rabbit-sample.jar
|
|
|
|
rm /tmp/schema-registry-vanilla-registry-kafka.jar
|
|
rm /tmp/schema-registry-vanilla-consumer-kafka.jar
|
|
rm /tmp/schema-registry-vanilla-producer1-kafka.jar
|
|
rm /tmp/schema-registry-vanilla-producer2-kafka.jar
|
|
rm /tmp/schema-registry-vanilla-registry-rabbit.jar
|
|
rm /tmp/schema-registry-vanilla-consumer-rabbit.jar
|
|
rm /tmp/schema-registry-vanilla-producer1-rabbit.jar
|
|
rm /tmp/schema-registry-vanilla-producer2-rabbit.jar
|
|
|
|
rm /tmp/partitioning-producer-kafka.jar
|
|
rm /tmp/partitioning-consumer-kafka.jar
|
|
|
|
rm /tmp/partitioning-producer-rabbit.jar
|
|
rm /tmp/partitioning-consumer-rabbit.jar
|
|
|
|
exit $BUILD_RETURN_VALUE |