]> juplo.de Git - demos/kafka/chat/commitdiff
test: refactor: Refined naming of `ChatHomeServiceIT` -- ALIGN
authorKai Moritz <kai@juplo.de>
Mon, 25 Mar 2024 23:01:49 +0000 (00:01 +0100)
committerKai Moritz <kai@juplo.de>
Mon, 25 Mar 2024 23:10:59 +0000 (00:10 +0100)
src/test/java/de/juplo/kafka/chat/backend/domain/AbstractChatHomeServiceIT.java
src/test/java/de/juplo/kafka/chat/backend/domain/AbstractChatHomeServiceWithShardsIT.java
src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/ShardedChatHomeServiceWithShardsIT.java
src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/SimpleChatHomeServiceIT.java
src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannelTest.java
src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceWithShardsIT.java

index 3be9a35af5295c8c3bedf548d65a87974d9cead4..1f4bc08d9f027cca260f75f8652a75b6e0a0cd84 100644 (file)
@@ -28,9 +28,9 @@ import static pl.rzrz.assertj.reactor.Assertions.assertThat;
     InMemoryServicesConfiguration.class,
     FilesStorageConfiguration.class,
     KafkaServicesConfiguration.class,
-    ChatHomeServiceTest.TestConfiguration.class })
+    AbstractChatHomeServiceIT.TestConfiguration.class })
 @EnableConfigurationProperties(ChatBackendProperties.class)
-public abstract class ChatHomeServiceTest
+public abstract class AbstractChatHomeServiceIT
 {
   @Autowired
   ChatHomeService chatHomeService;
index 6d156750da0a16be38f985d9139cdc42ecb3b675..27edcc103a3835382b5fee64b0a19489f0868594 100644 (file)
@@ -13,7 +13,7 @@ import java.util.UUID;
 import static pl.rzrz.assertj.reactor.Assertions.assertThat;
 
 
-public abstract class ChatHomeServiceWithShardsTest extends ChatHomeServiceTest
+public abstract class AbstractChatHomeServiceWithShardsIT extends AbstractChatHomeServiceIT
 {
   public static final int NUM_SHARDS = 10;
   public static final int OWNED_SHARD = 2;
index 95501ad97213af394f5b1b86a007a4f757efa6ad..293616fc25edc728291bdbba9a82f85137e6574d 100644 (file)
@@ -1,10 +1,10 @@
 package de.juplo.kafka.chat.backend.implementation.inmemory;
 
-import de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest;
+import de.juplo.kafka.chat.backend.domain.AbstractChatHomeServiceWithShardsIT;
 import org.springframework.test.context.TestPropertySource;
 
-import static de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest.NUM_SHARDS;
-import static de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest.OWNED_SHARD;
+import static de.juplo.kafka.chat.backend.domain.AbstractChatHomeServiceWithShardsIT.NUM_SHARDS;
+import static de.juplo.kafka.chat.backend.domain.AbstractChatHomeServiceWithShardsIT.OWNED_SHARD;
 
 
 @TestPropertySource(properties = {
@@ -13,6 +13,6 @@ import static de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest.O
     "chat.backend.inmemory.owned-shards=" + OWNED_SHARD,
     "chat.backend.inmemory.storage-strategy=files",
     "chat.backend.inmemory.storage-directory=target/test-classes/data/files" })
-public class ShardedChatHomeServiceTest extends ChatHomeServiceWithShardsTest
+public class ShardedChatHomeServiceWithShardsIT extends AbstractChatHomeServiceWithShardsIT
 {
 }
index 09369cba0e13307bc587c1c0f20cb423af601519..c73ecc39b64196aed57a7eab4078f7101b1fde6c 100644 (file)
@@ -1,6 +1,6 @@
 package de.juplo.kafka.chat.backend.implementation.inmemory;
 
-import de.juplo.kafka.chat.backend.domain.ChatHomeServiceTest;
+import de.juplo.kafka.chat.backend.domain.AbstractChatHomeServiceIT;
 import org.springframework.test.context.TestPropertySource;
 
 
@@ -8,6 +8,6 @@ import org.springframework.test.context.TestPropertySource;
     "chat.backend.inmemory.sharding-strategy=none",
     "chat.backend.inmemory.storage-strategy=files",
     "chat.backend.inmemory.storage-directory=target/test-classes/data/files" })
-public class SimpleChatHomeServiceTest extends ChatHomeServiceTest
+public class SimpleChatHomeServiceIT extends AbstractChatHomeServiceIT
 {
 }
index c651a5bdc074ad78856eeed4962ff9a401bd8c07..f8d11cd97d1b582e5e050f1c4e6d52deee05773d 100644 (file)
@@ -6,7 +6,6 @@ import de.juplo.kafka.chat.backend.ChatBackendProperties;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.common.TopicPartition;
 import org.awaitility.Awaitility;
-import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -14,7 +13,6 @@ import org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration;
 import org.springframework.boot.autoconfigure.task.TaskExecutionAutoConfiguration;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
-import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.test.context.EmbeddedKafka;
 import org.springframework.test.context.TestPropertySource;
 import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
@@ -23,9 +21,7 @@ import java.time.Clock;
 import java.time.Duration;
 import java.util.List;
 
-import static de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest.NUM_SHARDS;
-import static de.juplo.kafka.chat.backend.implementation.kafka.InfoChannelTest.DATA_TOPIC;
-import static de.juplo.kafka.chat.backend.implementation.kafka.InfoChannelTest.INFO_TOPIC;
+import static de.juplo.kafka.chat.backend.implementation.kafka.InfoChannelTest.*;
 import static org.assertj.core.api.Assertions.assertThat;
 
 
@@ -53,6 +49,7 @@ public class InfoChannelTest
 {
   final static String INFO_TOPIC = "INFO_CHANNEL_TEST_INFO";
   final static String DATA_TOPIC = "INFO_CHANNEL_TEST_DATA";
+  final static int NUM_SHARDS = 10;
 
 
   @Autowired
index 1fec5266e6009cc6cd7edf84f7ed9cbc9be2f944..de0a6ff1985c50c453c4cf7a5946793e67ae8a5d 100644 (file)
@@ -1,6 +1,6 @@
 package de.juplo.kafka.chat.backend.implementation.kafka;
 
-import de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest;
+import de.juplo.kafka.chat.backend.domain.AbstractChatHomeServiceWithShardsIT;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.common.TopicPartition;
 import org.junit.jupiter.api.BeforeAll;
@@ -16,9 +16,9 @@ import org.springframework.test.context.TestPropertySource;
 
 import java.util.List;
 
-import static de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest.NUM_SHARDS;
-import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServiceTest.DATA_TOPIC;
-import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServiceTest.INFO_TOPIC;
+import static de.juplo.kafka.chat.backend.domain.AbstractChatHomeServiceWithShardsIT.NUM_SHARDS;
+import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServiceWithShardsIT.DATA_TOPIC;
+import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServiceWithShardsIT.INFO_TOPIC;
 
 
 @ContextConfiguration(classes = {
@@ -39,7 +39,7 @@ import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServ
     topics = { INFO_TOPIC, DATA_TOPIC },
     partitions = NUM_SHARDS)
 @Slf4j
-public class KafkaChatHomeServiceTest extends ChatHomeServiceWithShardsTest
+public class KafkaChatHomeServiceWithShardsIT extends AbstractChatHomeServiceWithShardsIT
 {
   final static String INFO_TOPIC = "KAFKA_CHAT_HOME_TEST_INFO";
   final static String DATA_TOPIC = "KAFKA_CHAT_HOME_TEST_DATA";
@@ -61,7 +61,7 @@ public class KafkaChatHomeServiceTest extends ChatHomeServiceWithShardsTest
 
 
   @TestConfiguration
-  static class KafkaChatHomeServiceTestConfiguration
+  static class KafkaChatHomeServiceWithShardsITConfiguration
   {
     @Bean
     WorkAssignor infoChannelWorkAssignor()