- `org.codelibs.curl.CurlRequest`: builder for HTTP requests.
- `org.codelibs.curl.CurlResponse`: wrapper for HTTP responses.
- `org.codelibs.curl.CurlException`: unchecked exception for errors.
- `org.codelibs.curl.io.ContentCache` and `ContentOutputStream`: internal utilities for streaming and caching.

Refer to the Javadoc for full API details.

## Building and Testing

```bash

 */
@Deprecated
class NewestConflictResolverTest extends AbstractConflictResolverTest {
    // constructors -----------------------------------------------------------

    NewestConflictResolverTest() throws Exception {
        super("newest");
    }

    // tests ------------------------------------------------------------------

    /**
     * Tests that <code>a:2.0</code> wins in the scenario:
     * <pre>
     * a:1.0

/**
 * @author shinsuke
 *
 */
public class EncodingHelperTest extends PlainTestCase {
    public EncodingHelper encodingHelper;

    @Override
    protected void setUp() throws Exception {
        super.setUp();
        StandardCrawlerContainer container = new StandardCrawlerContainer().singleton("encodingHelper", EncodingHelper.class);
        encodingHelper = container.getComponent("encodingHelper");
    }

        @Test
        @DisplayName("Should throw exception when stripping more than consumed")
        void testStripMoreThanConsumed() {
            setupReferralDataWithPathConsumed(5);

            IllegalArgumentException exception = assertThrows(IllegalArgumentException.class, () -> referralData.stripPathConsumed(10));
            assertEquals("Stripping more than consumed", exception.getMessage());
        }

import org.opensearch.index.query.QueryBuilder;

public class QueryCommandTest extends UnitFessTestCase {
    private QueryCommand queryCommand;

    @Override
    public void setUp() throws Exception {
        super.setUp();

        // Setup FessConfig with proper initialization
        FessConfig.SimpleImpl fessConfig = new FessConfig.SimpleImpl() {
            private static final long serialVersionUID = 1L;

    }

    public void test_callbackExceptionHandling() throws IOException, InterruptedException {
        Process mockProcess = createMockProcess("exception test");
        Consumer<String> faultyCallback = line -> {
            throw new RuntimeException("Callback exception");
        };

        JobProcess jobProcess = new JobProcess(mockProcess, 10, faultyCallback);

import org.codelibs.fess.entity.QueryContext;
import org.codelibs.fess.entity.SearchRequestParams.SearchRequestType;
import org.codelibs.fess.exception.FessSystemException;
import org.codelibs.fess.exception.InvalidQueryException;
import org.codelibs.fess.exception.ResultOffsetExceededException;
import org.codelibs.fess.exception.SearchQueryException;
import org.codelibs.fess.helper.DocumentHelper;
import org.codelibs.fess.helper.QueryHelper;

        try {
            MemoryUtil.byteCountToDisplaySize(-1L);
            // If no exception, verify it handles negative as expected
        } catch (Exception e) {
            // Expected for negative values
        }

        // Test boundary values
        assertEquals("1bytes", MemoryUtil.byteCountToDisplaySize(1L));

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.core.lang.StringUtil;
import org.codelibs.core.timer.TimeoutTask;
import org.codelibs.fess.Constants;
import org.codelibs.fess.exception.JobProcessingException;
import org.codelibs.fess.exec.ThumbnailGenerator;
import org.codelibs.fess.helper.ProcessHelper;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.util.ComponentUtil;

                this.socket.close();
                log.trace("Socket closed");
            } else {
                log.trace("Not yet initialized");
            }
        } catch (final Exception e) {
            log.debug("Exception in disconnect", e);
        } finally {
            this.socket = null;
            this.digest = null;
            this.tconHostName = null;