diff --git a/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchProperties.java b/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchProperties.java index f2434ecf59f586297b8e1f791f5f15b302b5e523..b5903c0769ebafd7ed40b68d0f9e950620ec7c79 100644 --- a/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchProperties.java +++ b/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchProperties.java @@ -15,7 +15,7 @@ public class OzgCloudElasticsearchProperties { private String secretCredentialsName; private String certificateSecretName; - private OzgCloudElasticsearchServerProperties serverProperties; + private OzgCloudElasticsearchServerProperties server; @Getter @Setter diff --git a/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchSecretHelper.java b/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchSecretHelper.java index eff6653a0c4f49d4df43a8057e212b143280c3bd..73a11bf04f65f0e5bb8886b3621f562a2b915f0e 100644 --- a/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchSecretHelper.java +++ b/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchSecretHelper.java @@ -37,7 +37,7 @@ public class OzgCloudElasticsearchSecretHelper { } private String buildSecretAddress() { - return String.format("%s:%s", properties.getServerProperties().getHost(), properties.getServerProperties().getPort()); + return String.format("%s:%s", properties.getServer().getHost(), properties.getServer().getPort()); } private String generatePassword() { diff --git a/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchService.java b/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchService.java index ac6b827b95f36f7838629757f665cc2b88494525..84a98e644a42a3e10dd457f16192d2783c6277fc 100644 --- a/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchService.java +++ b/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/OzgCloudElasticsearchService.java @@ -135,13 +135,13 @@ public class OzgCloudElasticsearchService { } void createCredentialSecret(String namespace, Resource<Secret> secretResource) { - var serverSecretResource = kubernetesService.getSecretResource(properties.getServerProperties().getNamespace(), properties.getServerProperties().getCertificateSecretName()); + var serverSecretResource = kubernetesService.getSecretResource(properties.getServer().getNamespace(), properties.getServer().getCertificateSecretName()); createAdapter(secretResource).create(secretHelper.buildCertificateSecret(namespace, getSecretData(serverSecretResource.get()))); } private String getSecretData(Secret secret) { - return MapUtils.getString(secret.getStringData(), properties.getServerProperties().getCertificateSecretDataKey()); + return MapUtils.getString(secret.getStringData(), properties.getServer().getCertificateSecretDataKey()); } ResourceAdapter<Secret> createAdapter(Resource<Secret> resource) { diff --git a/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/common/elasticsearch/ElasticsearchClientConfiguration.java b/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/common/elasticsearch/ElasticsearchClientConfiguration.java index fdea2f3ed87f2d0a033e9c688b62a5a359ed98bc..ac83002f4e9d11b351574b952f6c652bd7624357 100644 --- a/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/common/elasticsearch/ElasticsearchClientConfiguration.java +++ b/ozgcloud-elasticsearch-operator/src/main/java/de/ozgcloud/operator/common/elasticsearch/ElasticsearchClientConfiguration.java @@ -28,7 +28,7 @@ public class ElasticsearchClientConfiguration { @Bean @Scope("singleton") ElasticsearchClient createElasticsearchClient() { - var credentialsProvider = createCredentialsProvider(elasticSearchProperties.getServerProperties().getSecretDataKey(), getPassword()); + var credentialsProvider = createCredentialsProvider(elasticSearchProperties.getServer().getSecretDataKey(), getPassword()); var restClient = buildRestClient(credentialsProvider); var transport = createRestClientTransport(restClient); return new ElasticsearchClient(transport); @@ -47,7 +47,7 @@ public class ElasticsearchClientConfiguration { } private HttpHost createHttpHost() { - return new HttpHost(elasticSearchProperties.getServerProperties().getHost(), elasticSearchProperties.getServerProperties().getPort(), elasticSearchProperties.getServerProperties().getScheme()); + return new HttpHost(elasticSearchProperties.getServer().getHost(), elasticSearchProperties.getServer().getPort(), elasticSearchProperties.getServer().getScheme()); } private RestClientTransport createRestClientTransport(RestClient restClient) { @@ -55,8 +55,8 @@ public class ElasticsearchClientConfiguration { } String getPassword() { - var resource = kubernetesService.getSecretResource(elasticSearchProperties.getServerProperties().getNamespace(), elasticSearchProperties.getServerProperties().getSecretName()); - var password = MapUtils.getString(resource.get().getStringData(), elasticSearchProperties.getServerProperties().getSecretDataKey()); + var resource = kubernetesService.getSecretResource(elasticSearchProperties.getServer().getNamespace(), elasticSearchProperties.getServer().getSecretName()); + var password = MapUtils.getString(resource.get().getStringData(), elasticSearchProperties.getServer().getSecretDataKey()); return password; } } \ No newline at end of file diff --git a/ozgcloud-elasticsearch-operator/src/test/java/de/ozgcloud/operator/OzgCloudElasticsearchSecretHelperTest.java b/ozgcloud-elasticsearch-operator/src/test/java/de/ozgcloud/operator/OzgCloudElasticsearchSecretHelperTest.java index 34e6ae631173cc9dda2f9f58a565523d368bcb7f..a9d14d90de94e8e35ac9b613bfb9ec0c5c77bd48 100644 --- a/ozgcloud-elasticsearch-operator/src/test/java/de/ozgcloud/operator/OzgCloudElasticsearchSecretHelperTest.java +++ b/ozgcloud-elasticsearch-operator/src/test/java/de/ozgcloud/operator/OzgCloudElasticsearchSecretHelperTest.java @@ -38,7 +38,7 @@ class OzgCloudElasticsearchSecretHelperTest { @BeforeEach void mockProperties() { - when(properties.getServerProperties()).thenReturn(serverProperties); + when(properties.getServer()).thenReturn(serverProperties); when(serverProperties.getHost()).thenReturn(HOST); when(serverProperties.getPort()).thenReturn(PORT); } diff --git a/ozgcloud-elasticsearch-operator/src/test/java/de/ozgcloud/operator/OzgCloudElasticsearchServiceTest.java b/ozgcloud-elasticsearch-operator/src/test/java/de/ozgcloud/operator/OzgCloudElasticsearchServiceTest.java index 953b78c2de93388d908b251d77d18143ffc0bf5c..f5e230757b8635c97bb5e186531cb92c44a6de4b 100644 --- a/ozgcloud-elasticsearch-operator/src/test/java/de/ozgcloud/operator/OzgCloudElasticsearchServiceTest.java +++ b/ozgcloud-elasticsearch-operator/src/test/java/de/ozgcloud/operator/OzgCloudElasticsearchServiceTest.java @@ -381,7 +381,7 @@ class OzgCloudElasticsearchServiceTest { @BeforeEach void mock() { - when(properties.getServerProperties()).thenReturn(serverProperties); + when(properties.getServer()).thenReturn(serverProperties); when(serverProperties.getNamespace()).thenReturn(SERVER_NAMESPACE); when(serverProperties.getCertificateSecretName()).thenReturn(SERVER_CERTIFICATE_SECRET_NAME); when(serverProperties.getCertificateSecretDataKey()).thenReturn(SERVER_CERTIFICATE_SECRET_DATA_KEY);