}

            @Override
            protected String getRepositoryContent(String url) {
                if (url.endsWith("/")) {
                    url = url + "index.html";
                }
                if (url.contains("plugin/repo1")) {
                    try (InputStream is = ResourceUtil.getResourceAsStream(url)) {
                        return new String(InputStreamUtil.getBytes(is), Constants.UTF_8);

    server.enqueue(MockResponse(body = "b"))
    val request = Request(server.url("/"))
    assertConnectionReused(request, request)
  }

  @Test
  fun connectionsAreReusedForPosts() {
    server.enqueue(MockResponse(body = "a"))
    server.enqueue(MockResponse(body = "b"))
    val request =
      Request(
        url = server.url("/"),
        body = "request body".toRequestBody("text/plain".toMediaType()),
      )

        /**
         * Constructs a new StorageURLConnection for the specified URL.
         * This constructor parses the URL to extract bucket and object names.
         *
         * @param url The storage URL to connect to
         */
        protected StorageURLConnection(final URL url) {
            super(url);
            final String[] values = url.toExternalForm().split("/", 2);
            if (values.length == 2) {

      response.isChunked -> newChunkedSource(response.request.url)
      else -> {
        val contentLength = response.headersContentLength()
        if (contentLength != -1L) {
          newFixedLengthSource(response.request.url, contentLength)
        } else {
          newUnknownLengthSource(response.request.url)
        }
      }
    }

    /**
     * Returns the access result for the given session ID and URL.
     *
     * @param sessionId the session ID
     * @param url the URL
     * @return the access result
     */
    RESULT getAccessResult(String sessionId, String url);

    /**
     * Returns a list of access results for the given URL.
     *
     * @param url the URL
     * @param hasData whether the access results should have data

  }

  @Test
  @Flaky
  fun testMockWebserverRequest() {
    enableTls()

    server.enqueue(MockResponse(body = "abc"))

    val request = Request.Builder().url(server.url("/")).build()

    val response = client.newCall(request).execute()

    response.use {
      assertEquals(200, response.code)
      assertEquals(
        "CN=localhost",

import java.io.IOException;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLStreamHandler;

import junit.framework.TestCase;

/**
 * @author koichik
 */
public class ZipFileUtilTest extends TestCase {

    /**
     * @throws Exception
     */
    public void testToJarFilePath() throws Exception {
        final URL url = new URL(null, "zip:/Program Files/foo.zip!/", new URLStreamHandler() {

        url = "http://hoge/index.html?a=1&b=2";
        assertEquals(url, htmlTransformer.normalizeUrl(url));

        url = "http://hoge/index.html#hoge";
        assertEquals("http://hoge/index.html", htmlTransformer.normalizeUrl(url));

        url = "http://hoge/index.html#";
        assertEquals("http://hoge/index.html", htmlTransformer.normalizeUrl(url));

        // Arrange & Act: constructing this URL triggers Handler.parseURL("smb://")
        Handler handler = newHandler();
        URL url = new URL(null, "smb://", handler);

        // Assert
        assertEquals("smb", url.getProtocol());
        assertEquals(SmbConstants.DEFAULT_PORT, url.getPort(), "Default port applied for root smb URL");
        assertNull(url.getRef(), "Ref should remain null for root URL");
    }

	if local == "" {
		local = "127.0.0.1"
	}

	u, err := url.Parse(updateURL)
	if err != nil {
		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
		return
	}

	content, err := downloadReleaseURL(u, updateTimeout, mode)
	if err != nil {
		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
		return
	}

	sha256Sum, lrTime, releaseInfo, err := parseReleaseData(content)