[frontend] update to rest5

Author: guillaumejparis

openbas-api/pom.xml

@@ -23,7 +23,6 @@
         <apache-poi.version>5.4.1</apache-poi.version>
         <opentelemetry.version>1.50.0</opentelemetry.version>
         <opentelemetry-semconv.version>1.32.0</opentelemetry-semconv.version>
-        <elasticsearch.version>9.0.1</elasticsearch.version>
     </properties>
 
     <profiles>

openbas-model/pom.xml

@@ -13,10 +13,6 @@
     <name>OpenBAS model</name>
     <description>OpenBAS model</description>
 
-    <properties>
-        <elasticsearch.version>9.0.1</elasticsearch.version>
-    </properties>
-
     <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>

openbas-model/src/main/java/io/openbas/driver/ElasticDriver.java

@@ -13,7 +13,9 @@
 import co.elastic.clients.json.JsonData;
 import co.elastic.clients.json.jackson.JacksonJsonpMapper;
 import co.elastic.clients.transport.ElasticsearchTransport;
-import co.elastic.clients.transport.rest_client.RestClientTransport;
+import co.elastic.clients.transport.rest5_client.Rest5ClientTransport;
+import co.elastic.clients.transport.rest5_client.low_level.Rest5Client;
+import co.elastic.clients.transport.rest5_client.low_level.Rest5ClientBuilder;
 import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.SerializationFeature;
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
@@ -24,6 +26,7 @@
 import java.io.IOException;
 import java.lang.reflect.Field;
 import java.lang.reflect.ParameterizedType;
+import java.net.URISyntaxException;
 import java.security.cert.X509Certificate;
 import java.time.Instant;
 import java.util.HashMap;
@@ -34,15 +37,16 @@
 import javax.net.ssl.SSLContext;
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.lang3.ArrayUtils;
-import org.apache.http.HttpHost;
-import org.apache.http.auth.AuthScope;
-import org.apache.http.auth.UsernamePasswordCredentials;
-import org.apache.http.conn.ssl.NoopHostnameVerifier;
-import org.apache.http.impl.client.BasicCredentialsProvider;
-import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
-import org.apache.http.ssl.SSLContextBuilder;
-import org.elasticsearch.client.RestClient;
-import org.elasticsearch.client.RestClientBuilder;
+import org.apache.hc.client5.http.auth.AuthScope;
+import org.apache.hc.client5.http.auth.UsernamePasswordCredentials;
+import org.apache.hc.client5.http.impl.async.HttpAsyncClientBuilder;
+import org.apache.hc.client5.http.impl.auth.BasicCredentialsProvider;
+import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManager;
+import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManagerBuilder;
+import org.apache.hc.client5.http.ssl.DefaultClientTlsStrategy;
+import org.apache.hc.client5.http.ssl.NoopHostnameVerifier;
+import org.apache.hc.core5.http.HttpHost;
+import org.apache.hc.core5.ssl.SSLContextBuilder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.retry.annotation.Backoff;
@@ -68,14 +72,15 @@ public void setEsEngine(EsEngine esEngine) {
     this.esEngine = esEngine;
   }
 
-  public ElasticsearchClient getElasticClient() {
-    RestClientBuilder restClientBuilder = RestClient.builder(HttpHost.create(config.getUrl()));
+  public ElasticsearchClient getElasticClient() throws URISyntaxException {
+    Rest5ClientBuilder restClientBuilder = Rest5Client.builder(HttpHost.create(config.getUrl()));
     HttpAsyncClientBuilder clientBuilder = HttpAsyncClientBuilder.create();
     if (config.getUsername() != null) {
       BasicCredentialsProvider credsProv = new BasicCredentialsProvider();
       credsProv.setCredentials(
-          AuthScope.ANY,
-          new UsernamePasswordCredentials(config.getUsername(), config.getPassword()));
+          new AuthScope(null, -1),
+          new UsernamePasswordCredentials(
+              config.getUsername(), config.getPassword().toCharArray()));
       clientBuilder.setDefaultCredentialsProvider(credsProv);
     }
     if (!config.isRejectUnauthorized()) {
@@ -85,20 +90,24 @@ public ElasticsearchClient getElasticClient() {
             SSLContextBuilder.create()
                 .loadTrustMaterial(null, (X509Certificate[] chain, String authType) -> true)
                 .build();
-        clientBuilder
-            .setSSLContext(sslContext)
-            .setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE);
+        PoolingAsyncClientConnectionManager connectionManager =
+            PoolingAsyncClientConnectionManagerBuilder.create()
+                .setTlsStrategy(
+                    new DefaultClientTlsStrategy(sslContext, NoopHostnameVerifier.INSTANCE))
+                .build();
+
+        clientBuilder.setConnectionManager(connectionManager);
       } catch (Exception e) {
         throw new RuntimeException(e);
       }
     }
-    restClientBuilder.setHttpClientConfigCallback(hc -> clientBuilder);
-    RestClient restClient = restClientBuilder.build();
+    restClientBuilder.setHttpClient(clientBuilder.build());
+    Rest5Client restClient = restClientBuilder.build();
     JacksonJsonpMapper jsonpMapper = new JacksonJsonpMapper();
     jsonpMapper.objectMapper().registerModule(new JavaTimeModule());
     jsonpMapper.objectMapper().configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false);
     jsonpMapper.objectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
-    ElasticsearchTransport transport = new RestClientTransport(restClient, jsonpMapper);
+    ElasticsearchTransport transport = new Rest5ClientTransport(restClient, jsonpMapper);
     return new ElasticsearchClient(transport);
   }
 

pom.xml

@@ -29,6 +29,7 @@
         <jacoco-plugin.version>0.8.13</jacoco-plugin.version>
         <pyroscope.version>2.1.2</pyroscope.version>
         <spring-security-crypto.version>6.4.5</spring-security-crypto.version>
+        <elasticsearch.version>9.0.1</elasticsearch.version>
     </properties>
 
     <distributionManagement>