diff --git a/modules/apps/gb32960-ingest-app/src/test/java/com/lingniu/ingest/gb32960app/Gb32960IngestAppDefaultsTest.java b/modules/apps/gb32960-ingest-app/src/test/java/com/lingniu/ingest/gb32960app/Gb32960IngestAppDefaultsTest.java new file mode 100644 index 00000000..52e96193 --- /dev/null +++ b/modules/apps/gb32960-ingest-app/src/test/java/com/lingniu/ingest/gb32960app/Gb32960IngestAppDefaultsTest.java @@ -0,0 +1,39 @@ +package com.lingniu.ingest.gb32960app; + +import org.junit.jupiter.api.Test; +import org.springframework.beans.factory.config.YamlPropertiesFactoryBean; +import org.springframework.core.io.ClassPathResource; + +import java.util.Properties; + +import static org.assertj.core.api.Assertions.assertThat; + +class Gb32960IngestAppDefaultsTest { + + @Test + void applicationDefaultsKeepGb32960IngestAsTcpKafkaProducerOnly() { + Properties properties = applicationProperties(); + + assertThat(properties) + .containsEntry("spring.application.name", "gb32960-ingest-app") + .containsEntry("lingniu.ingest.gb32960.enabled", true) + .containsEntry("lingniu.ingest.gb32960.server.enabled", true) + .containsEntry("lingniu.ingest.gb32960.port", "${GB32960_PORT:32960}") + .containsEntry("lingniu.ingest.sink.mq.enabled", "${KAFKA_ENABLED:true}") + .containsEntry("lingniu.ingest.sink.mq.consumer.enabled", false) + .containsEntry("lingniu.ingest.event-file-store.enabled", false) + .containsEntry("lingniu.ingest.event-history.enabled", false) + .containsEntry("lingniu.ingest.vehicle-state.enabled", false) + .containsEntry("lingniu.ingest.vehicle-stat.enabled", false); + } + + private static Properties applicationProperties() { + YamlPropertiesFactoryBean factory = new YamlPropertiesFactoryBean(); + factory.setResources(new ClassPathResource("application.yml")); + + Properties properties = factory.getObject(); + + assertThat(properties).isNotNull(); + return properties; + } +} diff --git a/modules/apps/vehicle-analytics-app/src/test/java/com/lingniu/ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java b/modules/apps/vehicle-analytics-app/src/test/java/com/lingniu/ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java new file mode 100644 index 00000000..2e91aba7 --- /dev/null +++ b/modules/apps/vehicle-analytics-app/src/test/java/com/lingniu/ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java @@ -0,0 +1,42 @@ +package com.lingniu.ingest.analyticsapp; + +import org.junit.jupiter.api.Test; +import org.springframework.beans.factory.config.YamlPropertiesFactoryBean; +import org.springframework.core.io.ClassPathResource; + +import java.util.Properties; + +import static org.assertj.core.api.Assertions.assertThat; + +class VehicleAnalyticsAppDefaultsTest { + + @Test + void applicationDefaultsKeepAnalyticsAsStatConsumerRuntime() { + Properties properties = applicationProperties(); + + assertThat(properties) + .containsEntry("spring.application.name", "vehicle-analytics-app") + .containsEntry("lingniu.ingest.gb32960.enabled", false) + .containsEntry("lingniu.ingest.sink.archive.enabled", false) + .containsEntry("lingniu.ingest.event-file-store.enabled", false) + .containsEntry("lingniu.ingest.event-history.enabled", false) + .containsEntry("lingniu.ingest.vehicle-stat.enabled", "${VEHICLE_STAT_ENABLED:true}") + .containsEntry("lingniu.ingest.vehicle-state.enabled", "${VEHICLE_STATE_ENABLED:false}") + .containsEntry( + "lingniu.ingest.sink.mq.consumer.bindings.vehicleStatEnvelopeConsumerProcessor.group-id", + "${KAFKA_GROUP_STAT:vehicle-stat}") + .containsEntry( + "lingniu.ingest.sink.mq.consumer.bindings.vehicleStateEnvelopeConsumerProcessor.group-id", + "${KAFKA_GROUP_STATE:vehicle-state}"); + } + + private static Properties applicationProperties() { + YamlPropertiesFactoryBean factory = new YamlPropertiesFactoryBean(); + factory.setResources(new ClassPathResource("application.yml")); + + Properties properties = factory.getObject(); + + assertThat(properties).isNotNull(); + return properties; + } +} diff --git a/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java b/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java new file mode 100644 index 00000000..0c0fed0a --- /dev/null +++ b/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java @@ -0,0 +1,46 @@ +package com.lingniu.ingest.historyapp; + +import org.junit.jupiter.api.Test; +import org.springframework.beans.factory.config.YamlPropertiesFactoryBean; +import org.springframework.core.io.ClassPathResource; + +import java.util.Properties; + +import static org.assertj.core.api.Assertions.assertThat; + +class VehicleHistoryAppDefaultsTest { + + @Test + void applicationDefaultsKeepHistoryAsDecoderConsumerAndStorageRuntime() { + Properties properties = applicationProperties(); + + assertThat(properties) + .containsEntry("spring.application.name", "vehicle-history-app") + .containsEntry("lingniu.ingest.gb32960.enabled", true) + .containsEntry("lingniu.ingest.gb32960.server.enabled", false) + .containsEntry("lingniu.ingest.sink.archive.enabled", "${SINK_ARCHIVE_ENABLED:true}") + .containsEntry("lingniu.ingest.event-file-store.enabled", "${EVENT_FILE_STORE_ENABLED:true}") + .containsEntry("lingniu.ingest.event-history.enabled", true) + .containsEntry("lingniu.ingest.vehicle-state.enabled", false) + .containsEntry("lingniu.ingest.vehicle-stat.enabled", false) + .containsEntry( + "lingniu.ingest.sink.mq.consumer.bindings.eventHistoryEnvelopeConsumerProcessor.group-id", + "${KAFKA_GROUP_HISTORY:vehicle-history}") + .containsEntry( + "lingniu.ingest.sink.mq.consumer.bindings.eventHistoryEnvelopeConsumerProcessor.topics[0]", + "${KAFKA_TOPIC_GB32960_EVENT:vehicle.event.gb32960.v1}") + .containsEntry( + "lingniu.ingest.sink.mq.consumer.bindings.eventHistoryEnvelopeConsumerProcessor.topics[1]", + "${KAFKA_TOPIC_GB32960_RAW:vehicle.raw.gb32960.v1}"); + } + + private static Properties applicationProperties() { + YamlPropertiesFactoryBean factory = new YamlPropertiesFactoryBean(); + factory.setResources(new ClassPathResource("application.yml")); + + Properties properties = factory.getObject(); + + assertThat(properties).isNotNull(); + return properties; + } +}