import org.opensearch.index.query.RangeQueryBuilder;

public class PurgeDocJobTest extends UnitFessTestCase {

    private PurgeDocJob purgeDocJob;
    private SearchEngineClient searchEngineClient;
    private FessConfig fessConfig;

    private boolean deleteByQueryCalled;
    private String deleteIndex;
    private QueryBuilder deleteQuery;
    private String expiresFieldName;
    private String documentUpdateIndex;

    @Override

        assertNotNull(fessConfig.getIndexFieldBoost());
        assertNotNull(fessConfig.getIndexFieldTitle());
        assertNotNull(fessConfig.getIndexFieldContent());
        assertNotNull(fessConfig.getIndexFieldCache());
        assertNotNull(fessConfig.getIndexFieldDigest());
        assertNotNull(fessConfig.getIndexFieldHost());
        assertNotNull(fessConfig.getIndexFieldSite());

 */
package org.codelibs.fess.score;

import java.util.Collections;
import java.util.HashMap;
import java.util.Map;

import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;
import org.opensearch.search.rescore.QueryRescorerBuilder;
import org.opensearch.search.rescore.RescorerBuilder;

    public void test_init() {
        ComponentUtil.setFessConfig(new MockFessConfig());
        sambaHelper.init();
        assertNotNull(sambaHelper.fessConfig);
    }

    public void test_getAccountId_differentSidTypes() throws SmbException {
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            @Override
            public String getSmbAvailableSidTypes() {
                return "1,2,4:2,5:1";
            }

                    EsStatusPostcard.droppedInto(postbox, postcard -> {
                        postcard.setFrom(fessConfig.getMailFromAddress(), fessConfig.getMailFromName());
                        postcard.addReplyTo(fessConfig.getMailReturnPath());
                        if (toAddresses.length > 0) {

        final FessConfig fessConfig = ComponentUtil.getFessConfig();

        if (!fessConfig.isAcceptedSearchReferer(request.getHeader("referer"))) {
            writeJsonResponse(HttpServletResponse.SC_BAD_REQUEST, escapeJsonKeyValue(MESSAGE_FIELD, "Referer is invalid."));
            return;
        }

        if (!fessConfig.isApiSearchScroll()) {

        MockletHttpServletRequest request = getMockRequest();
        request.setAttribute(FessConfig.VIRTUAL_HOST_VALUE, "cached_value");

        String key = virtualHostHelper.getVirtualHostKey();
        assertEquals("cached_value", key);
    }

    public void test_processVirtualHost() {
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            private static final long serialVersionUID = 1L;

        buf.append("[HOTTHREAD MONITOR] ");

        final FessConfig fessConfig = ComponentUtil.getFessConfig();

        buf.append('{');

        final boolean ignoreIdleThreads = Constants.TRUE.equalsIgnoreCase(fessConfig.getCrawlerHotthreadIgnoreIdleThreads());
        final TimeValue interval = TimeValue.parseTimeValue(fessConfig.getCrawlerHotthreadInterval(), "crawler.hotthread.interval");

        languageHelper = new TestLanguageHelper();
        searchEngineClient = new TestSearchEngineClient();
        ingestFactory = new TestIngestFactory();

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

            @Override
            public String getIndexerDataMaxDocumentRequestSize() {

                .map(org.codelibs.fess.crawler.util.FieldConfigs.Config::isCache)
                .orElse(false) || fessConfig.isCrawlerDocumentCacheEnabled()) && fessConfig.isSupportedDocumentCacheMimetypes(mimeType)) {
            if (responseData.getContentLength() > 0
                    && responseData.getContentLength() <= fessConfig.getCrawlerDocumentCacheMaxSizeAsInteger().longValue()) {