Chapter 5: Kafka: use dev services (#103)

Author: edeandrea

chapter-5/chapter-5-quarkus-kafka-streams/pom.xml

@@ -16,7 +16,6 @@
     <quarkus.platform.group-id>io.quarkus</quarkus.platform.group-id>
     <quarkus.platform.version>2.0.3.Final</quarkus.platform.version>
     <surefire-plugin.version>3.0.0-M5</surefire-plugin.version>
-    <testcontainers.version>1.16.0</testcontainers.version>
   </properties>
   <dependencyManagement>
     <dependencies>
@@ -27,13 +26,6 @@
         <type>pom</type>
         <scope>import</scope>
       </dependency>
-      <dependency>
-        <groupId>org.testcontainers</groupId>
-        <artifactId>testcontainers-bom</artifactId>
-        <version>${testcontainers.version}</version>
-        <type>pom</type>
-        <scope>import</scope>
-      </dependency>
     </dependencies>
   </dependencyManagement>
   <dependencies>
@@ -70,8 +62,8 @@
       <scope>test</scope>
     </dependency>
     <dependency>
-      <groupId>org.testcontainers</groupId>
-      <artifactId>testcontainers</artifactId>
+      <groupId>org.assertj</groupId>
+      <artifactId>assertj-core</artifactId>
       <scope>test</scope>
     </dependency>
   </dependencies>

chapter-5/chapter-5-quarkus-kafka-streams/src/main/java/org/acme/service/PriceConverter.java

@@ -13,7 +13,7 @@
  */
 @ApplicationScoped
 public class PriceConverter {
-    private static final double CONVERSION_RATE = 0.88;
+    static final double CONVERSION_RATE = 0.88;
 
     // Consume from the `prices` channel and produce to the `my-data-stream` channel
     @Incoming("prices")

chapter-5/chapter-5-quarkus-kafka-streams/src/test/java/org/acme/DockerComposeResource.java

@@ -12,16 +12,13 @@
 import javax.ws.rs.client.WebTarget;
 import javax.ws.rs.sse.SseEventSource;
 
-import org.acme.DockerComposeResource;
 import org.junit.jupiter.api.Test;
 
-import io.quarkus.test.common.QuarkusTestResource;
 import io.quarkus.test.common.http.TestHTTPEndpoint;
 import io.quarkus.test.common.http.TestHTTPResource;
 import io.quarkus.test.junit.QuarkusTest;
 
 @QuarkusTest
-@QuarkusTestResource(DockerComposeResource.class)
 class PriceResourceTest {
     @TestHTTPEndpoint(PriceResource.class)
     @TestHTTPResource("/stream")

chapter-5/chapter-5-quarkus-kafka-streams/src/test/java/org/acme/rest/PriceResourceTest.java

@@ -0,0 +1,19 @@
+package org.acme.service;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.ValueSource;
+
+class PriceConverterTests {
+	PriceConverter priceConverter = new PriceConverter();
+
+	@ParameterizedTest(name = ParameterizedTest.DISPLAY_NAME_PLACEHOLDER + "[" + ParameterizedTest.INDEX_PLACEHOLDER + "] (" + ParameterizedTest.ARGUMENTS_WITH_NAMES_PLACEHOLDER + ")")
+	@ValueSource(ints = { 1, 2 })
+	@DisplayName("process")
+	public void process(int price) {
+		assertThat(this.priceConverter.process(price))
+			.isEqualTo(price * PriceConverter.CONVERSION_RATE);
+	}
+}

chapter-5/chapter-5-quarkus-kafka-streams/src/test/java/org/acme/service/PriceConverterTests.java

@@ -0,0 +1,34 @@
+package org.acme.service;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import java.time.Duration;
+import java.util.List;
+import java.util.function.Predicate;
+
+import org.junit.jupiter.api.Test;
+
+import io.smallrye.mutiny.helpers.test.AssertSubscriber;
+
+class PriceGeneratorTests {
+	PriceGenerator priceGenerator = new PriceGenerator();
+
+	private static final Predicate<Integer> VALUE_TEST =
+		value -> (value >= 0) && (value < 100);
+
+	@Test
+	public void generatesProperly() {
+		List<Integer> prices = this.priceGenerator.generate()
+			.select().first(2)
+			.subscribe().withSubscriber(AssertSubscriber.create(2))
+			.assertSubscribed()
+			.awaitItems(2, Duration.ofSeconds(10))
+			.awaitCompletion(Duration.ofSeconds(15))
+			.assertCompleted()
+			.getItems();
+
+		assertThat(prices)
+			.hasSize(2)
+			.allMatch(VALUE_TEST);
+	}
+}