Skip to content
Snippets Groups Projects
Commit 536469ab authored by OZGCloud's avatar OZGCloud
Browse files

OZG-4453 adjust properties naming

parent ec6bab9d
Branches
Tags
No related merge requests found
...@@ -15,7 +15,7 @@ public class OzgCloudElasticsearchProperties { ...@@ -15,7 +15,7 @@ public class OzgCloudElasticsearchProperties {
private String secretCredentialsName; private String secretCredentialsName;
private String certificateSecretName; private String certificateSecretName;
private OzgCloudElasticsearchServerProperties serverProperties; private OzgCloudElasticsearchServerProperties server;
@Getter @Getter
@Setter @Setter
......
...@@ -37,7 +37,7 @@ public class OzgCloudElasticsearchSecretHelper { ...@@ -37,7 +37,7 @@ public class OzgCloudElasticsearchSecretHelper {
} }
private String buildSecretAddress() { 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() { private String generatePassword() {
......
...@@ -135,13 +135,13 @@ public class OzgCloudElasticsearchService { ...@@ -135,13 +135,13 @@ public class OzgCloudElasticsearchService {
} }
void createCredentialSecret(String namespace, Resource<Secret> secretResource) { 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()))); createAdapter(secretResource).create(secretHelper.buildCertificateSecret(namespace, getSecretData(serverSecretResource.get())));
} }
private String getSecretData(Secret secret) { 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) { ResourceAdapter<Secret> createAdapter(Resource<Secret> resource) {
......
...@@ -28,7 +28,7 @@ public class ElasticsearchClientConfiguration { ...@@ -28,7 +28,7 @@ public class ElasticsearchClientConfiguration {
@Bean @Bean
@Scope("singleton") @Scope("singleton")
ElasticsearchClient createElasticsearchClient() { ElasticsearchClient createElasticsearchClient() {
var credentialsProvider = createCredentialsProvider(elasticSearchProperties.getServerProperties().getSecretDataKey(), getPassword()); var credentialsProvider = createCredentialsProvider(elasticSearchProperties.getServer().getSecretDataKey(), getPassword());
var restClient = buildRestClient(credentialsProvider); var restClient = buildRestClient(credentialsProvider);
var transport = createRestClientTransport(restClient); var transport = createRestClientTransport(restClient);
return new ElasticsearchClient(transport); return new ElasticsearchClient(transport);
...@@ -47,7 +47,7 @@ public class ElasticsearchClientConfiguration { ...@@ -47,7 +47,7 @@ public class ElasticsearchClientConfiguration {
} }
private HttpHost createHttpHost() { 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) { private RestClientTransport createRestClientTransport(RestClient restClient) {
...@@ -55,8 +55,8 @@ public class ElasticsearchClientConfiguration { ...@@ -55,8 +55,8 @@ public class ElasticsearchClientConfiguration {
} }
String getPassword() { String getPassword() {
var resource = kubernetesService.getSecretResource(elasticSearchProperties.getServerProperties().getNamespace(), elasticSearchProperties.getServerProperties().getSecretName()); var resource = kubernetesService.getSecretResource(elasticSearchProperties.getServer().getNamespace(), elasticSearchProperties.getServer().getSecretName());
var password = MapUtils.getString(resource.get().getStringData(), elasticSearchProperties.getServerProperties().getSecretDataKey()); var password = MapUtils.getString(resource.get().getStringData(), elasticSearchProperties.getServer().getSecretDataKey());
return password; return password;
} }
} }
\ No newline at end of file
...@@ -38,7 +38,7 @@ class OzgCloudElasticsearchSecretHelperTest { ...@@ -38,7 +38,7 @@ class OzgCloudElasticsearchSecretHelperTest {
@BeforeEach @BeforeEach
void mockProperties() { void mockProperties() {
when(properties.getServerProperties()).thenReturn(serverProperties); when(properties.getServer()).thenReturn(serverProperties);
when(serverProperties.getHost()).thenReturn(HOST); when(serverProperties.getHost()).thenReturn(HOST);
when(serverProperties.getPort()).thenReturn(PORT); when(serverProperties.getPort()).thenReturn(PORT);
} }
......
...@@ -381,7 +381,7 @@ class OzgCloudElasticsearchServiceTest { ...@@ -381,7 +381,7 @@ class OzgCloudElasticsearchServiceTest {
@BeforeEach @BeforeEach
void mock() { void mock() {
when(properties.getServerProperties()).thenReturn(serverProperties); when(properties.getServer()).thenReturn(serverProperties);
when(serverProperties.getNamespace()).thenReturn(SERVER_NAMESPACE); when(serverProperties.getNamespace()).thenReturn(SERVER_NAMESPACE);
when(serverProperties.getCertificateSecretName()).thenReturn(SERVER_CERTIFICATE_SECRET_NAME); when(serverProperties.getCertificateSecretName()).thenReturn(SERVER_CERTIFICATE_SECRET_NAME);
when(serverProperties.getCertificateSecretDataKey()).thenReturn(SERVER_CERTIFICATE_SECRET_DATA_KEY); when(serverProperties.getCertificateSecretDataKey()).thenReturn(SERVER_CERTIFICATE_SECRET_DATA_KEY);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment