// Should return -1 when auto-connect fails due to missing project ID
        long length = conn.getContentLengthLong();
        assertEquals(-1, length);
    }

    /**
     * Test that getContentType() attempts to connect if not connected.
     */
    public void test_getContentType_autoConnect() throws Exception {
        URL url = new URL("gcs://mybucket/object.txt");
        Handler handler = new Handler();

                }
                final String filename = entry.getName();
                final String mimeType = mimeTypeHelper.getContentType(null, filename);
                if (mimeType != null) {
                    final Extractor extractor = extractorFactory.getExtractor(mimeType);
                    if (extractor != null) {
                        try {

         */
        @Override
        public String getContentType() {
            try {
                if (!connected) {
                    connect();
                }
                final Blob blobObj = getBlob();
                return blobObj != null ? blobObj.getContentType() : null;
            } catch (final Exception e) {
                return null;
            }

                try (final InputStream is = responseData.getResponseBody()) {
                    responseData.setMimeType(mimeTypeHelper.getContentType(is, blob.getName()));
                } catch (final Exception e) {
                    responseData.setMimeType(mimeTypeHelper.getContentType(null, blob.getName()));
                }
            }
        } catch (final CrawlerSystemException e) {

        } catch (final IOException ex) {}
        return connection.getContentLength();
    }

    @Override
    public String getContentType() {
        try {
            handshake();
        } catch (final IOException ex) {}
        return connection.getContentType();
    }

    @Override
    public String getContentEncoding() {
        try {
            handshake();

        // Should return -1 when auto-connect fails due to missing endpoint
        long length = conn.getContentLengthLong();
        assertEquals(-1, length);
    }

    /**
     * Test that getContentType() attempts to connect if not connected.
     */
    public void test_getContentType_autoConnect() throws Exception {
        URL url = new URL("storage://mybucket/object.txt");
        Handler handler = new Handler();

                }
                final String filename = head.getPath();
                final String mimeType = mimeTypeHelper.getContentType(null, filename);
                if (mimeType != null) {
                    final Extractor extractor = extractorFactory.getExtractor(mimeType);
                    if (extractor != null) {

                try (final InputStream is = responseData.getResponseBody()) {
                    responseData.setMimeType(mimeTypeHelper.getContentType(is, path));
                } catch (final Exception e) {
                    responseData.setMimeType(mimeTypeHelper.getContentType(null, path));
                }
            }
        } catch (final CrawlerSystemException e) {
            CloseableUtil.closeQuietly(responseData);

        final MimeTypeHelper mimeTypeHelper = crawlerContainer.getComponent("mimeTypeHelper");
        try (InputStream is = getContentInputStream(out)) {
            return mimeTypeHelper.getContentType(is, filename);
        }
    }

    /**
     * Gets an input stream for the content in the deferred file output stream.
     *
     * @param out the deferred file output stream

                try (final InputStream is = responseData.getResponseBody()) {
                    responseData.setMimeType(mimeTypeHelper.getContentType(is, statObject.object()));
                } catch (final Exception e) {
                    responseData.setMimeType(mimeTypeHelper.getContentType(null, statObject.object()));
                }
            }
        } catch (final CrawlerSystemException e) {