/*
    * 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.config.cbean.bs;
  
  import java.util.ArrayList;
  import java.util.List;
  import java.util.Map;
  
  import org.codelibs.fess.opensearch.config.allcommon.EsAbstractConditionBean;
  import org.codelibs.fess.opensearch.config.bsentity.dbmeta.DataConfigDbm;
  import org.codelibs.fess.opensearch.config.cbean.DataConfigCB;
  import org.codelibs.fess.opensearch.config.cbean.ca.DataConfigCA;
  import org.codelibs.fess.opensearch.config.cbean.ca.bs.BsDataConfigCA;
  import org.codelibs.fess.opensearch.config.cbean.cq.DataConfigCQ;
  import org.codelibs.fess.opensearch.config.cbean.cq.bs.BsDataConfigCQ;
  import org.dbflute.cbean.ConditionQuery;
  import org.opensearch.action.search.SearchRequestBuilder;
  import org.opensearch.index.query.QueryBuilder;
  
  /**
   * @author ESFlute (using FreeGen)
   */
  public class BsDataConfigCB extends EsAbstractConditionBean {
  
      // ===================================================================================
      //                                                                           Attribute
      //                                                                           =========
      protected BsDataConfigCQ _conditionQuery;
      protected BsDataConfigCA _conditionAggregation;
      protected HpSpecification _specification;
  
      // ===================================================================================
      //                                                                             Control
      //                                                                             =======
      @Override
      public DataConfigDbm asDBMeta() {
          return DataConfigDbm.getInstance();
      }
  
      @Override
      public String asTableDbName() {
          return "data_config";
      }
  
      @Override
      public boolean hasSpecifiedColumn() {
          return _specification != null;
      }
  
      @Override
      public ConditionQuery localCQ() {
          return doGetConditionQuery();
      }
  
      // ===================================================================================
      //                                                                         Primary Key
      //                                                                         ===========
      public DataConfigCB acceptPK(String id) {
          assertObjectNotNull("id", id);
          BsDataConfigCB cb = this;
          cb.query().docMeta().setId_Equal(id);
          return (DataConfigCB) this;
      }
  
      @Override
      public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
          acceptPK((String) primaryKeyMap.get("_id"));
      }
  
      // ===================================================================================
      //                                                                               Build
      //                                                                               =====
  
      @Override
      public SearchRequestBuilder build(SearchRequestBuilder builder) {
          if (_conditionQuery != null) {
              QueryBuilder queryBuilder = _conditionQuery.getQuery();
              if (queryBuilder != null) {
                  builder.setQuery(queryBuilder);
              }
              _conditionQuery.getFieldSortBuilderList().forEach(sort -> {
                  builder.addSort(sort);
              });
          }
  
          if (_conditionAggregation != null) {
             _conditionAggregation.getAggregationBuilderList().forEach(builder::addAggregation);
         }
 
         if (_specification != null) {
             builder.setFetchSource(_specification.columnList.toArray(new String[_specification.columnList.size()]), null);
         }
 
         return builder;
     }
 
     // ===================================================================================
     //                                                                               Query
     //                                                                               =====
     public BsDataConfigCQ query() {
         assertQueryPurpose();
         return doGetConditionQuery();
     }
 
     protected BsDataConfigCQ doGetConditionQuery() {
         if (_conditionQuery == null) {
             _conditionQuery = createLocalCQ();
         }
         return _conditionQuery;
     }
 
     protected BsDataConfigCQ createLocalCQ() {
         return new DataConfigCQ();
     }
 
     // ===================================================================================
     //                                                                         Aggregation
     //                                                                         ===========
     public BsDataConfigCA aggregation() {
         assertAggregationPurpose();
         return doGetConditionAggregation();
     }
 
     protected BsDataConfigCA doGetConditionAggregation() {
         if (_conditionAggregation == null) {
             _conditionAggregation = createLocalCA();
         }
         return _conditionAggregation;
     }
 
     protected BsDataConfigCA createLocalCA() {
         return new DataConfigCA();
     }
 
     // ===================================================================================
     //                                                                             Specify
     //                                                                             =======
     public HpSpecification specify() {
         assertSpecifyPurpose();
         if (_specification == null) {
             _specification = new HpSpecification();
         }
         return _specification;
     }
 
     protected void assertQueryPurpose() {
     }
 
     protected void assertAggregationPurpose() {
     }
 
     protected void assertSpecifyPurpose() {
     }
 
     public static class HpSpecification {
         protected List<String> columnList = new ArrayList<>();
 
         public void doColumn(String name) {
             columnList.add(name);
         }
 
         public void columnId() {
             doColumn("_id");
         }
 
         public void columnAvailable() {
             doColumn("available");
         }
 
         public void columnBoost() {
             doColumn("boost");
         }
 
         public void columnCreatedBy() {
             doColumn("createdBy");
         }
 
         public void columnCreatedTime() {
             doColumn("createdTime");
         }
 
         public void columnDescription() {
             doColumn("description");
         }
 
         public void columnHandlerName() {
             doColumn("handlerName");
         }
 
         public void columnHandlerParameter() {
             doColumn("handlerParameter");
         }
 
         public void columnHandlerScript() {
             doColumn("handlerScript");
         }
 
         public void columnName() {
             doColumn("name");
         }
 
         public void columnPermissions() {
             doColumn("permissions");
         }
 
         public void columnSortOrder() {
             doColumn("sortOrder");
         }
 
         public void columnUpdatedBy() {
             doColumn("updatedBy");
         }
 
         public void columnUpdatedTime() {
             doColumn("updatedTime");
         }
 
         public void columnVirtualHosts() {
             doColumn("virtualHosts");
         }
     }
 }