ClustersPropertiesTest.java 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package com.provectus.kafka.ui.config;
  2. import static org.assertj.core.api.Assertions.assertThat;
  3. import static org.assertj.core.api.Assertions.assertThatThrownBy;
  4. import java.util.Collections;
  5. import org.junit.jupiter.api.Test;
  6. class ClustersPropertiesTest {
  7. @Test
  8. void clusterNamesShouldBeUniq() {
  9. ClustersProperties properties = new ClustersProperties();
  10. var c1 = new ClustersProperties.Cluster();
  11. c1.setName("test");
  12. var c2 = new ClustersProperties.Cluster();
  13. c2.setName("test"); //same name
  14. Collections.addAll(properties.getClusters(), c1, c2);
  15. assertThatThrownBy(properties::validateAndSetDefaults)
  16. .hasMessageContaining("Application config isn't valid");
  17. }
  18. @Test
  19. void clusterNamesShouldSetIfMultipleClustersProvided() {
  20. ClustersProperties properties = new ClustersProperties();
  21. var c1 = new ClustersProperties.Cluster();
  22. c1.setName("test1");
  23. var c2 = new ClustersProperties.Cluster(); //name not set
  24. Collections.addAll(properties.getClusters(), c1, c2);
  25. assertThatThrownBy(properties::validateAndSetDefaults)
  26. .hasMessageContaining("Application config isn't valid");
  27. }
  28. @Test
  29. void ifOnlyOneClusterProvidedNameIsOptionalAndSetToDefault() {
  30. ClustersProperties properties = new ClustersProperties();
  31. properties.getClusters().add(new ClustersProperties.Cluster());
  32. properties.validateAndSetDefaults();
  33. assertThat(properties.getClusters())
  34. .element(0)
  35. .extracting("name")
  36. .isEqualTo("Default");
  37. }
  38. }