Skip to content
Snippets Groups Projects
Commit 87ef7160 authored by OZGCloud's avatar OZGCloud
Browse files

Merge branch 'OZG-4453-SearchIndexOperator' of...

Merge branch 'OZG-4453-SearchIndexOperator' of git.ozg-sh.de:ozgcloud-devops/operator into OZG-4453-SearchIndexOperator
parents 2b14ef17 eb680262
No related branches found
No related tags found
No related merge requests found
......@@ -12,11 +12,21 @@ import lombok.Setter;
@Configuration
public class OzgCloudElasticsearchProperties {
private String namespace;
private String secretName;
private String secretDataKey;
private String secretCredentialsName;
private String host;
private int port;
private String scheme;
}
private String certificateSecretName;
private OzgCloudElasticsearchServerProperties serverProperties;
@Getter
@Setter
public class OzgCloudElasticsearchServerProperties {
private String namespace;
private String secretName;
private String secretDataKey;
private String secretCredentialsName;
private String host;
private int port;
private String scheme;
}
}
\ No newline at end of file
......@@ -34,7 +34,7 @@ public class OzgCloudElasticsearchSecretHelper {
}
private String buildSecretAddress() {
return String.format("%s:%s", properties.getHost(), properties.getPort());
return String.format("%s:%s", properties.getServerProperties().getHost(), properties.getServerProperties().getPort());
}
private String generatePassword() {
......
......@@ -28,7 +28,7 @@ public class ElasticsearchClientConfiguration {
@Bean
@Scope("singleton")
ElasticsearchClient createElasticsearchClient() {
var credentialsProvider = createCredentialsProvider(elasticSearchProperties.getSecretDataKey(), getPassword());
var credentialsProvider = createCredentialsProvider(elasticSearchProperties.getServerProperties().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.getHost(), elasticSearchProperties.getPort(), elasticSearchProperties.getScheme());
return new HttpHost(elasticSearchProperties.getServerProperties().getHost(), elasticSearchProperties.getServerProperties().getPort(), elasticSearchProperties.getServerProperties().getScheme());
}
private RestClientTransport createRestClientTransport(RestClient restClient) {
......@@ -55,8 +55,8 @@ public class ElasticsearchClientConfiguration {
}
String getPassword() {
var resource = kubernetesService.getSecretResource(elasticSearchProperties.getNamespace(), elasticSearchProperties.getSecretName());
var password = MapUtils.getString(resource.get().getStringData(), elasticSearchProperties.getSecretDataKey());
var resource = kubernetesService.getSecretResource(elasticSearchProperties.getServerProperties().getNamespace(), elasticSearchProperties.getServerProperties().getSecretName());
var password = MapUtils.getString(resource.get().getStringData(), elasticSearchProperties.getServerProperties().getSecretDataKey());
return password;
}
}
\ No newline at end of file
ozgcloud:
elasticsearch:
namespace: elastic-system
secretName: ozg-search-cluster-es-elastic-user
secretDataKey: elastic
secretCredentialsName: elasticsearch-credentials
host: ozg-search-cluster-es-http
port: 9200
scheme: https
certificateSecretName: elasticsearch-certificate
server:
namespace: elastic-system
secretName: ozg-search-cluster-es-elastic-user
secretDataKey: elastic
host: ozg-search-cluster-es-http
port: 9200
scheme: https
certificateSecretName: elasticsearch-certificate
management:
server:
......
......@@ -11,6 +11,7 @@ import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.Spy;
import de.ozgcloud.operator.OzgCloudElasticsearchProperties.OzgCloudElasticsearchServerProperties;
import de.ozgcloud.operator.common.kubernetes.NamespaceTestFactory;
import de.ozgcloud.operator.common.kubernetes.SecretTestFactory;
import io.fabric8.kubernetes.api.model.Secret;
......@@ -30,10 +31,14 @@ class ElasticsearchSecretBuilderTest {
private final static String HOST = "dummyHost";
private final static int PORT = 42;
@Mock
private OzgCloudElasticsearchServerProperties serverProperties;
@BeforeEach
void mockProperties() {
when(properties.getHost()).thenReturn(HOST);
when(properties.getPort()).thenReturn(PORT);
when(properties.getServerProperties()).thenReturn(serverProperties);
when(serverProperties.getHost()).thenReturn(HOST);
when(serverProperties.getPort()).thenReturn(PORT);
}
@Test
......@@ -77,14 +82,14 @@ class ElasticsearchSecretBuilderTest {
void shouldGetHostFromProperties() {
buildCredentialSecret();
verify(properties).getHost();
verify(serverProperties).getHost();
}
@Test
void shouldGetPortFromPorperties() {
buildCredentialSecret();
verify(properties).getPort();
verify(serverProperties).getPort();
}
}
......
ozgcloud:
elastic:
namespace: elastic-system
secretName: ozg-search-cluster-es-elastic-user
secretData: elastic
host: https://ozg-search-cluster-es-http
address: ozg-search-cluster-es-http.elastic-system
port: 9200
\ No newline at end of file
elasticsearch:
secretCredentialsName: elasticsearch-credentials
certificateSecretName: elasticsearch-certificate
server:
namespace: elastic-system
secretName: ozg-search-cluster-es-elastic-user
secretDataKey: elastic
host: ozg-search-cluster-es-http
port: 9200
scheme: https
certificateSecretName: elasticsearch-certificate
\ No newline at end of file
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment