URL url = new URL("gcs://mybucket/path/to/object.txt");
        Handler handler = new Handler();
        URLConnection conn = handler.openConnection(url);

        assertTrue(conn instanceof Handler.GcsURLConnection);
        Handler.GcsURLConnection gcsConn = (Handler.GcsURLConnection) conn;

        // Use reflection to access private fields for testing
        assertEquals("mybucket", getField(gcsConn, "bucketName"));

        URL url = new URL("storage://mybucket/path/to/object.txt");
        Handler handler = new Handler();
        URLConnection conn = handler.openConnection(url);

        assertTrue(conn instanceof Handler.StorageURLConnection);
        Handler.StorageURLConnection storageConn = (Handler.StorageURLConnection) conn;

        // Use reflection to access private fields for testing
        assertEquals("mybucket", getField(storageConn, "bucketName"));

     */
    private void mockResponse(HttpURLConnection conn, int code, String message, Map<String, List<String>> headers, InputStream stream)
            throws IOException {
        if (conn == null)
            return;

        String statusLine = "HTTP/1.1 " + code + " " + message;
        when(conn.getResponseCode()).thenReturn(code);
        when(conn.getResponseMessage()).thenReturn(message);

        for (final SmbTransportImpl conn : this.connections) {
            if (conn.matches(address, port, localAddr, localPort, hostName)
                    && (tc.getConfig().getSessionLimit() == 0 || conn.getNumSessions() < tc.getConfig().getSessionLimit())) {
                try {
                    if (conn.isFailed() || connectedOnly && conn.isDisconnected()) {
                        continue;

        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");

        // Multiple onConnect calls should work (last one wins)
        request.onConnect((req, conn) -> conn.setConnectTimeout(1000));
        request.onConnect((req, conn) -> conn.setReadTimeout(2000));

        assertNotNull(request);
    }

    @Test
    public void testSslSocketFactoryWithNull() {

                        return conn;
                    }
                }
            }

            conn = new SmbTransport(address, port, localAddr, localPort);
            CONNECTIONS.add(0, conn);
        }

        return conn;
    }

    class ServerData {
        byte flags;
        int flags2;
        int maxMpxCount;
        int maxBufferSize;

    }

    /**
     * Gets the path to configuration files. In Docker environments, checks /opt/fess first,
     * then falls back to system property FESS_CONF_PATH, and finally to WEB-INF/conf.
     *
     * @param names the path components to append to the configuration directory
     * @return the Path object pointing to the configuration file or directory
     */

                try {
                    if (con.getResponseCode() < 400) {
                        if (GZIP.equals(con.getContentEncoding())) {
                            return new GZIPInputStream(con.getInputStream());
                        } else {
                            return con.getInputStream();
                        }
                    } else if (Method.HEAD.toString().equalsIgnoreCase(con.getRequestMethod())) {

        assertThrows(SmbException.class, () -> {
            validator.validatePath("\\share\\CON");
        });
    }

    @Test
    public void testWindowsReservedNameWithExtension() throws Exception {
        assertThrows(SmbException.class, () -> {
            validator.validatePath("\\share\\CON.txt");
        });
    }

    @Test
    public void testWindowsReservedCOM() throws Exception {

    /** Configuration key for Kerberos configuration file path. */
    protected static final String SPNEGO_KRB5_CONF = "spnego.krb5.conf";

    /** Configuration key for login configuration file path. */
    protected static final String SPNEGO_LOGIN_CONF = "spnego.login.conf";

    /** Configuration key for SPNEGO logger level. */
    protected static final String SPNEGO_LOGGER_LEVEL = "spnego.logger.level";