/*
    * Copyright 2012-2025 CodeLibs Project and the Others.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    *     http://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
   * either express or implied. See the License for the specific language
   * governing permissions and limitations under the License.
   */
  package org.codelibs.fess.opensearch.client;
  
  import static org.codelibs.core.stream.StreamUtil.split;
  
  import org.codelibs.core.lang.StringUtil;
  import org.codelibs.fesen.client.HttpClient;
  import org.codelibs.fess.Constants;
  import org.codelibs.fess.crawler.client.FesenClient;
  import org.codelibs.fess.mylasta.direction.FessConfig;
  import org.codelibs.fess.util.ComponentUtil;
  import org.opensearch.common.settings.Settings;
  import org.opensearch.common.settings.Settings.Builder;
  import org.opensearch.transport.client.Client;
  
  /**
   * OpenSearch client implementation specifically for crawler operations.
   * Extends FesenClient to provide search engine connectivity for the crawler components.
   */
  public class CrawlerEngineClient extends FesenClient {
  
      /**
       * Creates a new instance of CrawlerEngineClient.
       */
      public CrawlerEngineClient() {
          super();
      }
  
      @Override
      protected Client createClient() {
          final FessConfig fessConfig = ComponentUtil.getFessConfig();
          final String[] hosts =
                  split(address, ",").get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n]));
          final Builder builder = Settings.builder()
                  .putList("http.hosts", hosts)
                  .put("processors", fessConfig.getCrawlerHttpProcessors())
                  .put("http.heartbeat_interval", fessConfig.getFesenHeartbeatInterval());
          final String username = fessConfig.getFesenUsername();
          final String password = fessConfig.getFesenPassword();
          if (StringUtil.isNotBlank(username) && StringUtil.isNotBlank(password)) {
              builder.put(Constants.FESEN_USERNAME, username);
              builder.put(Constants.FESEN_PASSWORD, password);
          }
          final String authorities = fessConfig.getFesenHttpSslCertificateAuthorities();
          if (StringUtil.isNotBlank(authorities)) {
              builder.put("http.ssl.certificate_authorities", authorities);
          }
          return new HttpClient(builder.build(), null);
      }
  }