/*
    * Copyright (c) 2002-2026 Gargoyle Software Inc.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    * https://www.apache.org/licenses/LICENSE-2.0
    *
    * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   */
  package org.htmlunit;
  
  import static org.junit.jupiter.api.Assertions.fail;
  
  import java.io.BufferedInputStream;
  import java.io.ByteArrayInputStream;
  import java.io.ByteArrayOutputStream;
  import java.io.File;
  import java.io.IOException;
  import java.io.InputStream;
  import java.io.OutputStream;
  import java.io.Writer;
  import java.lang.reflect.Field;
  import java.lang.reflect.Method;
  import java.net.URL;
  import java.util.ArrayList;
  import java.util.HashMap;
  import java.util.List;
  import java.util.Map;
  
  import org.apache.commons.io.IOUtils;
  import org.apache.commons.lang3.StringUtils;
  import org.apache.http.HttpEntity;
  import org.apache.http.HttpResponse;
  import org.apache.http.ProtocolVersion;
  import org.apache.http.StatusLine;
  import org.apache.http.client.methods.HttpUriRequest;
  import org.apache.http.entity.StringEntity;
  import org.apache.http.entity.mime.MultipartEntityBuilder;
  import org.apache.http.impl.client.HttpClientBuilder;
  import org.apache.http.message.BasicHttpResponse;
  import org.apache.http.message.BasicStatusLine;
  import org.htmlunit.html.HtmlPage;
  import org.htmlunit.http.HttpStatus;
  import org.htmlunit.util.KeyDataPair;
  import org.htmlunit.util.MimeType;
  import org.htmlunit.util.NameValuePair;
  import org.htmlunit.util.PrimitiveWebServer;
  import org.htmlunit.util.ServletContentWrapper;
  import org.junit.jupiter.api.Test;
  
  import jakarta.servlet.Servlet;
  import jakarta.servlet.ServletException;
  import jakarta.servlet.http.HttpServlet;
  import jakarta.servlet.http.HttpServletRequest;
  import jakarta.servlet.http.HttpServletResponse;
  
  /**
   * Tests methods in {@link HttpWebConnection}.
   *
   * @author David D. Kilzer
   * @author Marc Guillemot
   * @author Ahmed Ashour
   * @author Ronald Brill
   * @author Carsten Steul
   */
  public class HttpWebConnectionTest extends WebServerTestCase {
  
      /**
       * Assert that the two byte arrays are equal.
       * @param expected the expected value
       * @param actual the actual value
       */
      public static void assertEquals(final byte[] expected, final byte[] actual) {
          assertEquals(null, expected, actual, expected.length);
      }
  
      /**
       * Assert that the two byte arrays are equal.
       * @param message the message to display on failure
       * @param expected the expected value
       * @param actual the actual value
       * @param length How many characters at the beginning of each byte array will be compared
       */
      public static void assertEquals(
              final String message, final byte[] expected, final byte[] actual, final int length) {
          if (expected == null && actual == null) {
              return;
          }
          if (expected == null || expected.length < length) {
              fail(message);
          }
          if (actual == null || actual.length < length) {
              fail(message);
          }
         for (int i = 0; i < length; i++) {
             assertEquals(message, expected[i], actual[i]);
         }
     }
 
     /**
      * Assert that the two input streams are the same.
      * @param expected the expected value
      * @param actual the actual value
      * @throws IOException if an IO problem occurs during comparison
      */
     public static void assertEquals(final InputStream expected, final InputStream actual) throws IOException {
         assertEquals(null, expected, actual);
     }
 
     /**
      * Assert that the two input streams are the same.
      * @param message the message to display on failure
      * @param expected the expected value
      * @param actual the actual value
      * @throws IOException if an IO problem occurs during comparison
      */
     public static void assertEquals(final String message, final InputStream expected,
             final InputStream actual) throws IOException {
 
         if (expected == null && actual == null) {
             return;
         }
 
         if (expected == null || actual == null) {
             try {
                 fail(message);
             }
             finally {
                 try {
                     if (expected != null) {
                         expected.close();
                     }
                 }
                 finally {
                     if (actual != null) {
                         actual.close();
                     }
                 }
             }
         }
 
         try (InputStream expectedBuf = new BufferedInputStream(expected)) {
             try (InputStream actualBuf = new BufferedInputStream(actual)) {
 
                 final byte[] expectedArray = new byte[2048];
                 final byte[] actualArray = new byte[2048];
 
                 int expectedLength = expectedBuf.read(expectedArray);
                 while (true) {
 
                     final int actualLength = actualBuf.read(actualArray);
                     assertEquals(message, expectedLength, actualLength);
 
                     if (expectedLength == -1) {
                         break;
                     }
 
                     assertEquals(message, expectedArray, actualArray, expectedLength);
                     expectedLength = expectedBuf.read(expectedArray);
                 }
             }
         }
     }
 
     /**
      * Tests Jetty.
      * @throws Exception on failure
      */
     @Test
     public void jettyProofOfConcept() throws Exception {
         startWebServer("./");
 
         final WebClient client = getWebClient();
         final Page page = client.getPage(URL_FIRST + "src/test/resources/event_coordinates.html");
         final WebConnection defaultConnection = client.getWebConnection();
         assertTrue(
                 "HttpWebConnection should be the default",
                 defaultConnection instanceof HttpWebConnection);
         assertTrue("Response should be valid HTML", page instanceof HtmlPage);
     }
 
     /**
      * Test for feature request 1438216: HttpWebConnection should allow extension to create the HttpClient.
      * @throws Exception if the test fails
      */
     @Test
     public void designedForExtension() throws Exception {
         startWebServer("./");
 
         final WebClient webClient = getWebClient();
         final boolean[] tabCalled = {false};
         final WebConnection myWebConnection = new HttpWebConnection(webClient) {
             @Override
             protected HttpClientBuilder createHttpClientBuilder() {
                 tabCalled[0] = true;
 
                 final HttpClientBuilder builder = HttpClientBuilder.create();
                 builder.setConnectionManagerShared(true);
                 return builder;
             }
         };
 
         webClient.setWebConnection(myWebConnection);
         webClient.getPage(URL_FIRST + "LICENSE.txt");
         assertTrue("createHttpClient has not been called", tabCalled[0]);
     }
 
     /**
      * Test that the HttpClient is reinitialised after being shutdown.
      * @throws Exception if the test fails
      */
     @Test
     public void reinitialiseAfterClosing() throws Exception {
         startWebServer("./");
 
         final WebClient webClient = getWebClient();
         try (HttpWebConnection webConnection = new HttpWebConnection(webClient)) {
             webClient.setWebConnection(webConnection);
             webClient.getPage(URL_FIRST + "LICENSE.txt");
             webConnection.close();
             webClient.getPage(URL_FIRST + "pom.xml");
         }
     }
 
     /**
      * Test that the right file part is built for a file that doesn't exist.
      * @throws Exception if the test fails
      */
     @Test
     public void buildFilePart() throws Exception {
         final String encoding = "ISO8859-1";
         final KeyDataPair pair = new KeyDataPair("myFile", new File("this/doesnt_exist.txt"), "something",
                 MimeType.TEXT_PLAIN, encoding);
         final MultipartEntityBuilder builder = MultipartEntityBuilder.create().setLaxMode();
         try (HttpWebConnection webConnection = new HttpWebConnection(getWebClient())) {
             webConnection.buildFilePart(pair, builder);
         }
         final ByteArrayOutputStream baos = new ByteArrayOutputStream();
         builder.build().writeTo(baos);
         final String part = baos.toString(encoding);
 
         final String expected = "--(.*)\r\n"
                 + "Content-Disposition: form-data; name=\"myFile\"; filename=\"doesnt_exist.txt\"\r\n"
                 + "Content-Type: text/plain\r\n"
                 + "\r\n"
                 + "\r\n"
                 + "--\\1--\r\n";
         assertTrue(part, part.matches(expected));
     }
 
     /**
      * @throws Exception on failure
      */
     @Test
     public void unicode() throws Exception {
         startWebServer("./");
         final WebClient client = getWebClient();
         client.getPage(URL_FIRST + "src/test/resources/event_coordinates.html?param=\u00F6");
     }
 
     /**
      * @throws Exception if an error occurs
      */
     @Test
     public void emptyPut() throws Exception {
         final Map<String, Class<? extends Servlet>> servlets = new HashMap<>();
         servlets.put("/test", EmptyPutServlet.class);
         startWebServer("./", servlets);
 
         final String[] expectedAlerts = {"1"};
         final WebClient client = getWebClient();
         client.setAjaxController(new NicelyResynchronizingAjaxController());
         final List<String> collectedAlerts = new ArrayList<>();
         client.setAlertHandler(new CollectingAlertHandler(collectedAlerts));
 
         assertEquals(0, client.getCookieManager().getCookies().size());
         client.getPage(URL_FIRST + "test");
         assertEquals(expectedAlerts, collectedAlerts);
         assertEquals(1, client.getCookieManager().getCookies().size());
     }
 
     /**
      * Servlet for {@link #emptyPut()}.
      */
     public static class EmptyPutServlet extends ServletContentWrapper {
         /** Constructor. */
         public EmptyPutServlet() {
             super(DOCTYPE_HTML
                 + "<html>\n"
                 + "<head>\n"
                 + "  <script>\n"
                 + "    function test() {\n"
                 + "      var xhr = window.ActiveXObject?new ActiveXObject('Microsoft.XMLHTTP'):new XMLHttpRequest();\n"
                 + "      xhr.open('PUT', '" + URL_FIRST + "test" + "', true);\n"
                 + "      xhr.send();\n"
                 + "      alert(1);\n"
                 + "    }\n"
                 + "  </script>\n"
                 + "</head>\n"
                 + "<body onload='test()'></body>\n"
                 + "</html>");
         }
 
         @Override
         protected void doGet(final HttpServletRequest request,
                 final HttpServletResponse response)
             throws ServletException, IOException {
             request.getSession().setAttribute("trigger", "session");
             super.doGet(request, response);
         }
     }
 
     /**
      * @throws Exception if the test fails
      */
     @Test
     public void cookiesEnabledAfterDisable() throws Exception {
         final Map<String, Class<? extends Servlet>> servlets = new HashMap<>();
         servlets.put("/test1", Cookie1Servlet.class);
         servlets.put("/test2", Cookie2Servlet.class);
         startWebServer("./", servlets);
 
         final WebClient client = getWebClient();
 
         client.getCookieManager().setCookiesEnabled(false);
         HtmlPage page = client.getPage(URL_FIRST + "test1");
         assertTrue(page.asNormalizedText().contains("No Cookies"));
 
         client.getCookieManager().setCookiesEnabled(true);
         page = client.getPage(URL_FIRST + "test1");
         assertTrue(page.asNormalizedText().contains("key1=value1"));
     }
 
     /**
      * Servlet for {@link #cookiesEnabledAfterDisable()}.
      */
     public static class Cookie1Servlet extends HttpServlet {
 
         /**
          * {@inheritDoc}
          */
         @Override
         protected void doGet(final HttpServletRequest request, final HttpServletResponse response) throws IOException {
             response.addCookie(new jakarta.servlet.http.Cookie("key1", "value1"));
             response.setStatus(HttpServletResponse.SC_MOVED_TEMPORARILY);
             final String location = request.getRequestURL().toString().replace("test1", "test2");
             response.setHeader("Location", location);
         }
     }
 
     /**
      * Servlet for {@link #cookiesEnabledAfterDisable()}.
      */
     public static class Cookie2Servlet extends HttpServlet {
 
         /**
          * {@inheritDoc}
          */
         @Override
         protected void doGet(final HttpServletRequest request, final HttpServletResponse response) throws IOException {
             response.setContentType(MimeType.TEXT_HTML);
             final Writer writer = response.getWriter();
             if (request.getCookies() == null || request.getCookies().length == 0) {
                 writer.write("No Cookies");
             }
             else {
                 for (final jakarta.servlet.http.Cookie c : request.getCookies()) {
                     writer.write(c.getName() + '=' + c.getValue());
                 }
             }
         }
     }
 
     /**
      * @throws Exception if the test fails
      */
     @Test
     public void remotePort() throws Exception {
         final Map<String, Class<? extends Servlet>> servlets = new HashMap<>();
         servlets.put("/test", RemotePortServlet.class);
         startWebServer("./", servlets);
 
         final WebClient client = getWebClient();
 
         String firstPort = null;
 
         for (int i = 0; i < 5; i++) {
             final HtmlPage page = client.getPage(URL_FIRST + "test");
             final String port = page.asNormalizedText();
             if (firstPort == null) {
                 firstPort = port;
             }
             assertEquals(firstPort, port);
         }
     }
 
     /**
      * Servlet for {@link #remotePort()}.
      */
     public static class RemotePortServlet extends HttpServlet {
 
         /**
          * {@inheritDoc}
          */
         @Override
         protected void doGet(final HttpServletRequest request, final HttpServletResponse response) throws IOException {
             response.setContentType(MimeType.TEXT_HTML);
             response.getWriter().write(String.valueOf(request.getRemotePort()));
         }
     }
 
     /**
      * @throws Exception if an error occurs
      */
     @Test
     public void contentLengthSmallerThanContent() throws Exception {
         final String html = DOCTYPE_HTML
                 + "<html>\n"
                 + "<body>\n"
                 + "  <p>visible text</p>\n"
                 + "  <p>missing text</p>\n"
                 + "</body>\n"
                 + "</html>";
         int contentLenght = html.indexOf("<p>missing text</p>");
         final String response = "HTTP/1.1 200 OK\r\n"
                 + "Content-Length: " + contentLenght + "\r\n"
                 + "Content-Type: text/html\r\n"
                 + "\r\n"
                 + html;
 
         try (PrimitiveWebServer primitiveWebServer = new PrimitiveWebServer(null, response, null)) {
             final WebClient client = getWebClient();
 
             final HtmlPage page = client.getPage("http://localhost:" + primitiveWebServer.getPort());
             assertEquals("visible text", page.asNormalizedText());
         }
     }
 
     /**
      * @throws Exception if an error occurs
      */
     @Test
     public void contentLengthSmallerThanContentLargeContent() throws Exception {
         final String html = DOCTYPE_HTML
                 + "<html>\n"
                 + "<body>\n"
                 + "  <p>"
                 + StringUtils.repeat("HtmlUnit  ", 1024 * 1024)
                 + "</p>\n"
                 + "  <p>visible text</p>\n"
                 + "  <p>missing text</p>\n"
                 + "</body>\n"
                 + "</html>";
         int contentLenght = html.indexOf("<p>missing text</p>");
         final String response = "HTTP/1.1 200 OK\r\n"
                 + "Content-Length: " + contentLenght + "\r\n"
                 + "Content-Type: text/html\r\n"
                 + "\r\n"
                 + html;
 
         try (PrimitiveWebServer primitiveWebServer = new PrimitiveWebServer(null, response, null)) {
             final WebClient client = getWebClient();
 
             final HtmlPage page = client.getPage("http://localhost:" + primitiveWebServer.getPort());
             assertTrue(page.asNormalizedText(), page.asNormalizedText().endsWith("visible text"));
         }
     }
 
     /**
      * @throws Exception if an error occurs
      */
     @Test
     public void contentLengthLargerThanContent() throws Exception {
         final String response = "HTTP/1.1 200 OK\r\n"
                 + "Content-Length: 2000\r\n"
                 + "Content-Type: text/html\r\n"
                 + "\r\n"
                 + DOCTYPE_HTML + "<html><body><p>visible text</p></body></html>";
 
         try (PrimitiveWebServer primitiveWebServer = new PrimitiveWebServer(null, response, null)) {
             final WebClient client = getWebClient();
 
             final HtmlPage page = client.getPage("http://localhost:" + primitiveWebServer.getPort());
             assertEquals("visible text", page.asNormalizedText());
         }
     }
 
     /**
      * Test for bug #1861.
      *
      * @throws Exception if the test fails
      */
     @Test
     public void userAgent() throws Exception {
         final WebClient webClient = getWebClient();
         final HttpWebConnection connection = (HttpWebConnection) webClient.getWebConnection();
         final HttpClientBuilder builder = connection.getHttpClientBuilder();
         final String userAgent = get(builder, "userAgent");
         assertEquals(webClient.getBrowserVersion().getUserAgent(), userAgent);
     }
 
     @SuppressWarnings("unchecked")
     private static <T> T get(final Object o, final String fieldName) throws Exception {
         final Field field = o.getClass().getDeclaredField(fieldName);
         field.setAccessible(true);
         return (T) field.get(o);
     }
 
     /**
      * Tests creation of a web response.
      * @throws Exception if the test fails
      */
     @Test
     public void makeWebResponse() throws Exception {
         final URL url = new URL("http://htmlunit.sourceforge.net/");
         final String content = DOCTYPE_HTML + "<html><head></head><body></body></html>";
         final DownloadedContent downloadedContent = new DownloadedContent.InMemory(content.getBytes());
         final long loadTime = 500L;
 
         final ProtocolVersion protocolVersion = new ProtocolVersion("HTTP", 1, 0);
         final StatusLine statusLine = new BasicStatusLine(protocolVersion, HttpStatus.OK_200, null);
         final HttpResponse httpResponse = new BasicHttpResponse(statusLine);
 
         final HttpEntity responseEntity = new StringEntity(content);
         httpResponse.setEntity(responseEntity);
 
         try (HttpWebConnection connection = new HttpWebConnection(getWebClient())) {
             final Method method = connection.getClass().getDeclaredMethod("makeWebResponse",
                     HttpResponse.class, WebRequest.class, DownloadedContent.class, long.class);
             final WebResponse response = (WebResponse) method.invoke(connection,
                     httpResponse, new WebRequest(url), downloadedContent, Long.valueOf(loadTime));
 
             assertEquals(HttpStatus.OK_200, response.getStatusCode());
             assertEquals(url, response.getWebRequest().getUrl());
             assertEquals(loadTime, response.getLoadTime());
             assertEquals(content, response.getContentAsString());
             try (InputStream is = response.getContentAsStream()) {
                 assertEquals(content.getBytes(), IOUtils.toByteArray(is));
             }
             try (InputStream is = response.getContentAsStream()) {
                 assertEquals(new ByteArrayInputStream(content.getBytes()), is);
             }
         }
     }
 
     /**
      * Test for overwriting the
      * {@link HttpWebConnection#downloadResponse(HttpUriRequest, WebRequest, HttpResponse, long)}
      * method.
      *
      * @throws Exception if the test fails
      */
     @Test
     public void contentBlocking() throws Exception {
         final byte[] content = new byte[] {77, 44};
         final List<NameValuePair> headers = new ArrayList<>();
         headers.add(new NameValuePair("Content-Encoding", "gzip"));
         headers.add(new NameValuePair(HttpHeader.CONTENT_LENGTH, String.valueOf(content.length)));
 
         final MockWebConnection conn = getMockWebConnection();
         conn.setResponse(URL_FIRST, content, 200, "OK", MimeType.APPLICATION_JSON, headers);
 
         startWebServer(conn);
 
         final WebClient client = getWebClient();
         client.setWebConnection(new HttpWebConnection(client) {
             @Override
             protected WebResponse downloadResponse(final HttpUriRequest httpMethod,
                     final WebRequest webRequest, final HttpResponse httpResponse,
                     final long startTime) {
 
                 httpMethod.abort();
 
                 final DownloadedContent downloaded = new DownloadedContent.InMemory(null);
                 final long endTime = System.currentTimeMillis();
                 final WebResponse response = makeWebResponse(httpResponse, webRequest, downloaded, endTime - startTime);
                 response.markAsBlocked("test blocking");
                 return response;
             }
         });
 
         final UnexpectedPage page = client.getPage(URL_FIRST);
         assertTrue(page.getWebResponse().wasBlocked());
         assertEquals("test blocking", page.getWebResponse().getBlockReason());
     }
 
     /**
      * Test for overwriting the
      * {@link HttpWebConnection#downloadResponse(HttpUriRequest, WebRequest, HttpResponse, long)}
      * method.
      *
      * @throws Exception if the test fails
      */
     @Test
     public void contentSizeBlocking() throws Exception {
         stopWebServer();
 
         final Map<String, Class<? extends Servlet>> servlets = new HashMap<>();
         servlets.put("/big", BigContentServlet.class);
         startWebServer("./", servlets);
 
         BigContentServlet.CANCEL_ = false;
 
         final WebClient client = getWebClient();
         client.setWebConnection(new HttpWebConnection(client) {
             @Override
             protected WebResponse downloadResponse(final HttpUriRequest httpMethod,
                     final WebRequest webRequest, final HttpResponse httpResponse,
                     final long startTime) throws IOException {
 
                 final int contentLength = Integer.parseInt(
                         httpResponse.getFirstHeader(HttpHeader.CONTENT_LENGTH).getValue());
 
                 if (contentLength < 1_000) {
                     return super.downloadResponse(httpMethod, webRequest, httpResponse, startTime);
                 }
 
                 httpMethod.abort();
 
                 final DownloadedContent downloaded = new DownloadedContent.InMemory(null);
                 final long endTime = System.currentTimeMillis();
                 final WebResponse response = makeWebResponse(httpResponse, webRequest, downloaded, endTime - startTime);
                 response.markAsBlocked("blocking " + contentLength);
                 return response;
             }
         });
 
         final TextPage page = client.getPage(URL_FIRST + "big");
         assertTrue(page.getWebResponse().wasBlocked());
         assertEquals("blocking 10240000", page.getWebResponse().getBlockReason());
         assertTrue("blocks sent " + BigContentServlet.SENT_, BigContentServlet.SENT_ < 5000);
 
         BigContentServlet.CANCEL_ = true;
     }
 
     /**
      * Servlet for bigContent().
      */
     public static class BigContentServlet extends HttpServlet {
 
         /** Helper. */
         public static int SENT_;
         /** Helper. */
         public static boolean CANCEL_;
 
         /**
          * {@inheritDoc}
          */
         @Override
         protected void doGet(final HttpServletRequest request, final HttpServletResponse response) throws IOException {
             final int blockSize = 1024;
             final int blockCount = 10_000;
 
             response.setHeader(HttpHeader.CONTENT_LENGTH, String.valueOf(blockSize * blockCount));
 
             final byte[] buffer = new byte[blockSize];
             try (OutputStream out = response.getOutputStream()) {
                 for (int i = 0; i < blockCount && !CANCEL_; i++) {
                     SENT_++;
                     out.write(buffer);
                 }
             }
         }
     }
 }