Add Apache HttpClient5 implementation for HTTP client (#4410)

Author: dliubarskyi

http-clients/langchain4j-http-client-apache/src/main/java/dev/langchain4j/http/client/apache/MultipartBodyPublisher.java

@@ -14,7 +14,7 @@
 import org.apache.hc.core5.http.message.BasicNameValuePair;
 
 @Experimental
-public class MultipartBodyPublisher {
+class MultipartBodyPublisher {
 
     private static final String BOUNDARY = "----LangChain4j";
     private static final String CRLF = "\r\n";

http-clients/langchain4j-http-client-apache/src/test/java/dev/langchain4j/http/client/apache/ApacheHttpClientIT.java

@@ -12,4 +12,9 @@ class ApacheHttpClientIT extends HttpClientIT {
     protected List<HttpClient> clients() {
         return List.of(ApacheHttpClient.builder().build());
     }
+
+    @Override
+    protected String incorrectUrl() {
+        return "https://example.com";
+    }
 }

http-clients/langchain4j-http-client-apache/src/test/java/dev/langchain4j/http/client/apache/ApacheHttpClientTimeoutIT.java

@@ -8,11 +8,6 @@
 
 class ApacheHttpClientTimeoutIT extends HttpClientTimeoutIT {
 
-    @Override
-    protected int readTimeoutMillis() {
-        return 1000;
-    }
-
     @Override
     protected List<HttpClient> clients(Duration readTimeout) {
         return List.of(ApacheHttpClient.builder().readTimeout(readTimeout).build());
@@ -23,6 +18,11 @@ protected Class<? extends Exception> expectedReadTimeoutRootCauseExceptionType()
         return SocketTimeoutException.class;
     }
 
+    @Override
+    protected int readTimeoutMillis() {
+        return 1000;
+    }
+
     @Override
     protected String[] readAsyncMessageKeywords() {
         return new String[] {"1000", "MILLISECONDS"};

langchain4j-http-client/src/test/java/dev/langchain4j/http/client/HttpClientIT.java

@@ -29,6 +29,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicReference;
+
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
 import org.mockito.InOrder;
@@ -756,10 +757,7 @@ void should_call_listener_onError_when_fails_to_connect() throws Exception {
         for (HttpClient client : clients()) {
 
             // given
-            // if the URL of the ip cannot be found or there is other verification logic that cannot pass the initial
-            // verification.(The request has not been submitted to the I/O thread yet.) (e.g., https://banana)
-            // Apache HttpClient will execute `callback.failed(ex)` in main thread.
-            String incorrectUrl = "https://example.com";
+            String incorrectUrl = incorrectUrl();
 
             HttpRequest request = HttpRequest.builder()
                     .method(POST)
@@ -829,6 +827,10 @@ public void onClose() {
         }
     }
 
+    protected String incorrectUrl() {
+        return "http://banana";
+    }
+
     @Test
     protected void should_return_successful_http_response_sync_form_data() throws Exception {
         Path audioPath =

langchain4j-http-client/src/test/java/dev/langchain4j/http/client/HttpClientTimeoutIT.java

@@ -36,6 +36,10 @@ public abstract class HttpClientTimeoutIT {
 
     private WireMockServer wireMockServer;
 
+    protected int readTimeoutMillis() {
+        return 250;
+    }
+
     protected String[] readAsyncMessageKeywords() {
         return new String[] {"time", "out"};
     }
@@ -44,10 +48,6 @@ protected String[] readSyncMessageKeywords() {
         return readAsyncMessageKeywords();
     }
 
-    protected int readTimeoutMillis() {
-        return 250;
-    }
-
     @BeforeEach
     void beforeEach() {
         wireMockServer = new WireMockServer(WireMockConfiguration.options().port(WIREMOCK_PORT));