/**
 * This file is part of the Meeds project (https://meeds.io/).
 *
 * Copyright (C) 2020 - 2025 Meeds Association contact@meeds.io
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 3 of the License, or (at your option) any later version.
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
 */
package io.meeds.task.search;

import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.exoplatform.commons.search.es.ElasticSearchException;
import org.exoplatform.commons.search.es.client.ElasticSearchingClient;
import org.exoplatform.services.log.ExoLogger;
import org.exoplatform.services.log.Log;
import org.exoplatform.task.model.TaskSearchFilter;
import org.json.simple.JSONArray;
import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser;
import org.json.simple.parser.ParseException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;

@Component
public class TaskSearchConnector {

  private static final Log       LOG                           = ExoLogger.getLogger(TaskSearchConnector.class);

  @Autowired
  private ElasticSearchingClient client;

  @Value("${task.es.index:task_alias}")
  private String                 index;

  @Value("${task.search.type:task}")
  private String                 searchType;

  private static final String    SEARCH_QUERY                  = """
      {
        "from": @offset@,
        "size": @limit@,
        "query": {
          "bool": {
            "must": [
              @term_query@
              @permission_query@
            ]
          }
        }
      }
      """;

  private static final String    SEARCH_QUERY_TERM             = """
      {
        "query_string": {
          "fields": ["title", "description"],
          "default_operator": "AND",
          "query": "@term@"
        }
      },
      """;

  private static final String    PERMISSIONS_QUERY             = """
      {
        "terms": {
          "permissions": [@permissions@]
        }
      }
      """;

  private static final String    COUNT_QUERY                   = """
      {
        "query": {
          "bool": {
            "must": [
              @term_query@
              @permission_query@
            ]
          }
        }
      }
      """;

  private static final String    OFFSET_REPLACEMENT            = "@offset@";

  private static final String    LIMIT_REPLACEMENT             = "@limit@";

  private static final String    TERM_REPLACEMENT              = "@term@";

  private static final String    TERM_QUERY_REPLACEMENT        = "@term_query@";

  private static final String    PERMISSIONS_QUERY_REPLACEMENT = "@permission_query@";

  private static final String    PERMISSIONS_REPLACEMENT       = "@permissions@";

  public List<Long> search(TaskSearchFilter filter) {
    String esQuery = buildSearchQuery(SEARCH_QUERY, filter);
    String jsonResponse = client.sendRequest(esQuery, index);
    return buildResult(jsonResponse);
  }

  public Long count(TaskSearchFilter filter) {
    filter.setLimit(0);
    filter.setOffset(0);
    String esQuery = buildSearchQuery(COUNT_QUERY, filter);
    String jsonResponse = client.countRequest(esQuery, index);
    return buildCount(jsonResponse);
  }

  private String buildSearchQuery(String queryBase, TaskSearchFilter filter) {
    String query = queryBase.replace(OFFSET_REPLACEMENT, String.valueOf(filter.getOffset()))
                            .replace(LIMIT_REPLACEMENT, String.valueOf(Math.max(filter.getLimit(), 10)));

    // Term search
    if (StringUtils.isNotBlank(filter.getTerm())) {
      query = query.replace(TERM_QUERY_REPLACEMENT, SEARCH_QUERY_TERM.replace(TERM_REPLACEMENT, escapeJson(filter.getTerm())));
    } else {
      query = query.replace(TERM_QUERY_REPLACEMENT, "");
    }

    // Permissions filter
    if (CollectionUtils.isNotEmpty(filter.getPermissions())) {
      String permissions = "\"" + String.join("\",\"", filter.getPermissions()) + "\"";
      query = query.replace(PERMISSIONS_QUERY_REPLACEMENT, PERMISSIONS_QUERY.replace(PERMISSIONS_REPLACEMENT, permissions));
    } else {
      query = query.replace(PERMISSIONS_QUERY_REPLACEMENT, "");
    }

    return query;
  }

  @SuppressWarnings("rawtypes")
  private List<Long> buildResult(String jsonResponse) {
    JSONParser parser = new JSONParser();
    Map json;
    try {
      json = (Map) parser.parse(jsonResponse);
    } catch (ParseException e) {
      throw new ElasticSearchException("Unable to parse JSON response", e);
    }

    JSONObject hitsObj = (JSONObject) json.get("hits");
    if (hitsObj == null) {
      return Collections.emptyList();
    }

    JSONArray hits = (JSONArray) hitsObj.get("hits");
    List<Long> result = new ArrayList<>();
    for (Object hit : hits) {
      try {
        JSONObject hitObj = (JSONObject) hit;
        result.add(parseLong(hitObj, "_id"));
      } catch (Exception e) {
        LOG.warn("Error parsing hit item: {}", hit, e);
      }
    }
    return result;
  }

  @SuppressWarnings({ "rawtypes", "unchecked" })
  private long buildCount(String jsonResponse) {
    JSONParser parser = new JSONParser();
    try {
      Map json = (Map) parser.parse(jsonResponse);
      String countString = json.getOrDefault("count", "0").toString();
      return Long.parseLong(countString);
    } catch (ParseException e) {
      throw new ElasticSearchException("Unable to parse JSON response", e);
    }
  }

  private Long parseLong(JSONObject hitSource, String key) {
    String value = (String) hitSource.get(key);
    return StringUtils.isBlank(value) ? null : Long.parseLong(value);
  }

  private String escapeJson(String text) {
    return text.replaceAll("([\\Q+-!():^[]\"{}~*?|&/\\E])", " ").trim();
  }
}
