import com.google.common.io.BaseEncoding;

import jakarta.annotation.PostConstruct;
import jakarta.annotation.PreDestroy;

public class SearchEngineClient implements Client {

    private static final Logger logger = LogManager.getLogger(SearchEngineClient.class);

    private static final String DOC_INDEX = "fess";

    private static final String LOG_INDEX_PREFIX = "fess_log";

    }

    protected long deleteDocumentByQuery(final SearchEngineClient searchEngineClient, final String index, final QueryBuilder queryBuilder) {
        return searchEngineClient.deleteByQuery(index, queryBuilder);
    }

    public Map<String, Object> getDocument(final SearchEngineClient searchEngineClient, final String id, final String[] fields) {

            @Override
            protected long getDocumentSizeByQuery(final SearchEngineClient searchEngineClient, final QueryBuilder queryBuilder,
                    final FessConfig fessConfig) {
                return documentSizeByQuery;
            }

            @Override
            protected int refreshIndex(final SearchEngineClient searchEngineClient, final String index) {
                return 200;
            }
        };

        if (searchEngineClient.createIndex(docIndex, toIndex, numberOfShards, autoExpandReplicas, resetDictionaries)) {
            searchEngineClient.admin().cluster().prepareHealth(toIndex).setWaitForYellowStatus().execute(ActionListener.wrap(response -> {
                searchEngineClient.addMapping(docIndex, "doc", toIndex);

        protected final List<Path> deletedFileList = new ArrayList<>();

        protected final Path basePath;

        protected final String imageExtention;

        protected final SearchEngineClient searchEngineClient;

        protected final FessConfig fessConfig;

        FilePurgeVisitor(final Path basePath, final String imageExtention, final long expiry) {
            this.basePath = basePath;

    // Attribute
    // =========
    @Resource
    protected SearchHelper searchHelper;

    @Resource
    protected SearchEngineClient searchEngineClient;

    // ===================================================================================
    //                                                                      Search Execute

    // ===================================================================================
    // Attribute
    // =========

    @Resource
    protected SearchEngineClient searchEngineClient;

    @Resource
    protected QueryHelper queryHelper;

    @Resource
    protected SearchHelper searchHelper;

    @Resource
    protected HttpServletRequest request;

    // ===================================================================================
    // Attribute
    // =========
    @Resource
    protected SearchEngineClient searchEngineClient;

    // ===================================================================================
    // Search Execute
    //

    // POST /api/admin/documents/bulk
    @Execute

        contentFieldList = Arrays.asList(stream(fessConfig.getSuggestFieldContents()).get(stream -> stream.toArray(n -> new String[n])));

        final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
        searchEngineClient.admin().cluster().prepareHealth().setWaitForYellowStatus().execute()
                .actionGet(fessConfig.getIndexHealthTimeout());

import java.util.Map;
import java.util.function.Function;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.core.lang.StringUtil;
import org.codelibs.fess.es.client.SearchEngineClient;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.util.ComponentUtil;
import org.opensearch.action.bulk.BulkRequestBuilder;
import org.opensearch.action.bulk.BulkResponse;