*/
    @Override
    public synchronized void mark(final int readlimit) {
        inputStream.mark(readlimit);
    }

    /**
     * Tests if this input stream supports the mark and reset methods.
     *
     * @return true if this stream instance supports the mark and reset methods; false otherwise
     */
    @Override
    public boolean markSupported() {
        return inputStream.markSupported();
    }

    /**

        // Default constructor
    }

    /**
     * Wraps a query string with wildcard characters to enable partial matching.
     * This method ensures that the query string is surrounded by asterisks (*)
     * to support prefix and suffix matching in search operations.
     *
     * @param query the query string to wrap with wildcards
     * @return the wrapped query string with leading and trailing asterisks
     */

import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;

/**
 * Test suite for jcifs.smb1.https.Handler class.
 * Tests HTTPS URL stream handler functionality with NTLM authentication support.
 */
@DisplayName("SMB1 HTTPS Handler Tests")
class HandlerTest {

    private Handler handler;

    @BeforeEach
    void setUp() {
        handler = new Handler();
    }

    @Nested

     *
     * @return the stream response
     */
    public StreamResponse asStream() {
        if (osddFile == null) {
            throw ComponentUtil.getResponseManager().new404("Unsupported Open Search Description Document response.");
        }

        return new StreamResponse(osddFile.getName()).contentType(contentType + "; charset=" + encoding).stream(out -> {

        assertEquals("NTLM", request.getAuthType());
        verify(mockPrincipal, times(1)).getName();
    }

    @ParameterizedTest
    @ValueSource(strings = { "", "   ", "unknown" })
    @DisplayName("supports multiple principal name variants")
    void testPrincipalNameVariants(String name, @Mock HttpServletRequest mockRequest, @Mock Principal mockPrincipal) {
        when(mockPrincipal.getName()).thenReturn(name);

 *   <li>readTimeout - Read timeout in milliseconds (default: 10000)</li>
 * </ul>
 *
 * <p>The client supports URLs in the format: {@code storage://bucket-name/object-path}
 *
 * <p>Features:
 * <ul>
 *   <li>Automatic initialization of MinIO client</li>
 *   <li>Support for HEAD and GET operations</li>
 *   <li>Content length validation</li>
 *   <li>MIME type detection</li>

 * This processor extends DefaultResponseProcessor to provide additional
 * processing capabilities through the ingest framework, allowing for
 * custom data transformation and enrichment during the crawling process.
 *
 * <p>It supports pluggable ingesters that can modify the result data
 * before it is stored in the search index.</p>
 */
public class FessResponseProcessor extends DefaultResponseProcessor {
    /**
     * Default constructor.
     */

        super(crawlerConfig);
    }

    /**
     * Fetches URL queue list for the specified session with configurable ordering strategy.
     * Supports sequential (default) and random ordering based on crawling configuration.
     *
     * @param sessionId the crawling session identifier
     * @return list of URL queue entries for processing
     */
    @Override

     * Test that ZipExtractor returns empty content for archive with no extractable files.
     */
    public void test_ZipExtractor_noExtractableEntries_returnsEmptyContent() throws IOException {
        // Create a ZIP with an unsupported file type
        final ByteArrayOutputStream baos = new ByteArrayOutputStream();
        try (final ZipOutputStream zos = new ZipOutputStream(baos)) {
            final ZipEntry entry = new ZipEntry("unknown.xyz");

        verify(configuration, atLeastOnce()).getOemEncoding();
        verifyNoMoreInteractions(cifsContext, configuration);
    }

    @Test
    @DisplayName("getPreNTLMResponse: unsupported OEM encoding propagates as runtime exception")
    void testGetPreNTLMResponse_invalidEncoding() {
        // Arrange
        when(cifsContext.getConfig()).thenReturn(configuration);