package com.armedia.acm.services.search.model.solr;

/*-
 * #%L
 * ACM Service: Search
 * %%
 * Copyright (C) 2014 - 2018 ArkCase LLC
 * %%
 * This file is part of the ArkCase software. 
 * 
 * If the software was purchased under a paid ArkCase license, the terms of 
 * the paid license agreement will prevail.  Otherwise, the software is 
 * provided under the following open source license terms:
 * 
 * ArkCase 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.
 *  
 * ArkCase 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 ArkCase. If not, see <http://www.gnu.org/licenses/>.
 * #L%
 */

import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.ASSIGNEE_FULL_NAME_LCS;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.HIDDEN_B;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.PARENT_ID_S;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.PARENT_NUMBER_LCS;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.PARENT_REF_S;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.PARENT_TYPE_S;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.STATUS_LCS;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.TITLE_PARSEABLE;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.TITLE_PARSEABLE_LCS;
import static com.armedia.acm.services.search.model.solr.SolrAdditionalPropertiesConstants.TYPE_LCS;

import org.apache.commons.lang.StringUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

public class SolrContentDocument extends SolrAdvancedSearchDocument
{
    private transient final Logger log = LogManager.getLogger(getClass());

    private List<String> skipAdditionalPropertiesInURL;

    private String cmis_version_series_id_s;

    protected void listToUrlValues(Map<String, Object> values, List<? extends Object> list, String key)
    {
        if (list != null)
        {
            for (int a = 0; a < list.size(); a++)
            {
                values.put("literal." + key + "." + a, list.get(a));
            }
        }
    }

    /**
     * 
     * @return a map suitable for use in the Spring RestTemplate postForEntity method. The partner method
     *         buildUrlTemlpate() provides the template needed by Spring.
     */
    public Map<String, Object> buildUrlValues()
    {
        Map<String, Object> values = new HashMap<>();

        listToUrlValues(values, getAllow_group_ls(), "allow_group_ls");
        listToUrlValues(values, getDeny_group_ls(), "deny_group_ls");
        listToUrlValues(values, getAllow_user_ls(), "allow_user_ls");
        listToUrlValues(values, getDeny_user_ls(), "deny_user_ls");
        listToUrlValues(values, getParent_allow_group_ls(), "parent_allow_group_ls");
        listToUrlValues(values, getParent_deny_group_ls(), "parent_deny_group_ls");
        listToUrlValues(values, getParent_allow_user_ls(), "parent_allow_user_ls");
        listToUrlValues(values, getParent_deny_user_ls(), "parent_deny_user_ls");

        values.put("literal.hidden_b", getAdditionalProperties().get(HIDDEN_B));
        values.put("literal.parent_ref_s", getAdditionalProperties().get(PARENT_REF_S));
        values.put("literal.status_lcs", getAdditionalProperties().get(STATUS_LCS));
        values.put("literal.protected_object_b", isProtected_object_b());
        values.put("literal.public_doc_b", isPublic_doc_b());
        values.put("literal.id", getId());
        values.put("literal.object_type_s", getObject_type_s());
        values.put("literal.object_id_s", getObject_id_s());
        values.put("literal.modified_date_tdt", getModified_date_tdt()!=null?getModified_date_tdt().toInstant().toString():null);
        values.put("literal.modifier_lcs", getModifier_lcs());
        values.put("literal.create_date_tdt", getCreate_date_tdt()!=null?getCreate_date_tdt().toInstant().toString():null);
        values.put("literal.creator_lcs", getCreator_lcs());
        values.put("literal.name", getName());
        values.put("literal.parent_id_s", getAdditionalProperties().get(PARENT_ID_S));
        values.put("literal.parent_type_s", getAdditionalProperties().get(PARENT_TYPE_S));
        values.put("literal.parent_number_lcs", getAdditionalProperties().get(PARENT_NUMBER_LCS));
        values.put("literal.title_parseable", getAdditionalProperties().get(TITLE_PARSEABLE));
        values.put("literal.title_parseable_lcs", getAdditionalProperties().get(TITLE_PARSEABLE_LCS));
        values.put("literal.assignee_full_name_lcs", getAdditionalProperties().get(ASSIGNEE_FULL_NAME_LCS));
        values.put("literal.type_lcs", getAdditionalProperties().get(TYPE_LCS));

        if (getAdditionalProperties() != null)
        {
            for (Map.Entry<String, Object> entry : getAdditionalProperties().entrySet())
            {
                if (getSkipAdditionalPropertiesInURL() != null && !getSkipAdditionalPropertiesInURL().contains(entry.getKey()))
                {
                    values.put("literal." + entry.getKey(), entry.getValue());
                }
            }
        }

        return values;
    }

    /**
     * 
     * @return a URL template for use by the Spring Rest Template. You must also provide the values, via
     *         buildUrlValues().
     */
    public String buildUrlTemplate()
    {
        final List<String> multiValueProperties = Arrays.asList("literal.allow_user_ls", "literal.deny_user_ls",
                "literal.allow_group_ls", "literal.deny_group_ls", "literal.parent_allow_group_ls", "literal.parent_deny_group_ls",
                "literal.parent_allow_user_ls", "literal.parent_deny_user_ls");
        return buildUrlValues().keySet().stream().
        // Solr multivalued elements are represented in the buildUrlValues map as e.g. "literal.allow_group_ls.0",
        // "literal.deny_group_ls.1".
        // We want the URL template to be e.g. "literal.allow_group_ls={literal.allow_group_ls.0}",
        // "literal.deny_group_ls={literal.deny_group_ls.1}"
                map(k -> String.format("%s={%s}",
                        multiValueProperties.contains(StringUtils.substringBeforeLast(k, ".")) ? StringUtils.substringBeforeLast(k, ".")
                                : k,
                        k))
                .collect(Collectors.joining("&"));
    }

    /**
     * This method is no longer used in the content-file-to-Solr flow. Kept for backwards compatibility.
     * 
     * @deprecated use buildUrlTemplate and buildUrlValues
     * @return
     */
    @Deprecated
    public String getUrl()
    {
        StringBuilder url = new StringBuilder(
                "&literal.allow_user_ls="
                        + (getAllow_user_ls() == null ? null
                        : getAllow_user_ls().stream().map(Object::toString)
                        .collect(Collectors.joining("&literal.allow_user_ls=")))
                        + "&literal.deny_user_ls="
                        + (getDeny_user_ls() == null ? null
                        : getDeny_user_ls().stream().map(Object::toString)
                        .collect(Collectors.joining("&literal.deny_user_ls=")))
                        + "&literal.allow_group_ls="
                        + (getAllow_group_ls() == null ? null
                        : getAllow_group_ls().stream().map(Object::toString)
                        .collect(Collectors.joining("&literal.allow_group_ls")))
                        + "&literal.deny_group_ls="
                        + (getDeny_group_ls() == null ? null
                        : getDeny_group_ls().stream().map(Object::toString)
                        .collect(Collectors.joining("&literal.deny_group_ls")))
                        + "&literal.parent_allow_group_ls="
                        + (getParent_allow_group_ls() == null ? null
                        : getParent_allow_group_ls().stream().map(Object::toString)
                        .collect(Collectors.joining("&literal.parent_allow_group_ls")))
                        + "&literal.parent_deny_group_ls="
                        + (getParent_deny_group_ls() == null ? null
                        : getParent_deny_group_ls().stream().map(Object::toString)
                        .collect(Collectors.joining("&literal.parent_deny_group_ls")))
                        + "&literal.parent_allow_user_ls="
                        + (getParent_allow_user_ls() == null ? null
                        : getParent_allow_user_ls().stream().map(Object::toString)
                        .collect(Collectors.joining("&literal.parent_allow_user_ls")))
                        + "&literal.parent_deny_user_ls="
                        + (getParent_deny_user_ls() == null ? null
                        : getParent_deny_user_ls().stream().map(Object::toString)
                        .collect(Collectors.joining("&literal.parent_deny_user_ls")))
                        +
                        "&literal.hidden_b=" + getAdditionalProperties().get(HIDDEN_B) +
                        "&literal.parent_ref_s=" + encode(getAdditionalProperties().get(PARENT_REF_S).toString()) +
                        "&literal.status_lcs=" + encode(getAdditionalProperties().get(STATUS_LCS).toString()) +
                        "&literal.protected_object_b=" + isProtected_object_b() +
                        "&literal.public_doc_b=" + isPublic_doc_b() +
                        "&literal.id=" + encode(getId()) +
                        "&literal.object_type_s=" + encode(getObject_type_s()) +
                        "&literal.object_id_s=" + encode(getObject_id_s()) +
                        "&literal.modified_date_tdt=" + getModified_date_tdt().toInstant().toString() +
                "&literal.modifier_lcs=" + encode(getModifier_lcs()) +
                "&literal.create_date_tdt=" + getCreate_date_tdt().toInstant().toString() +
                "&literal.creator_lcs=" + encode(getCreator_lcs()) +
                "&literal.name=" + encode(getName()) +
                        "&literal.parent_id_s=" + encode(getAdditionalProperties().get(PARENT_ID_S).toString()) +
                        "&literal.parent_type_s=" + encode(getAdditionalProperties().get(PARENT_TYPE_S).toString()) +
                        "&literal.parent_number_lcs=" + encode(getAdditionalProperties().get(PARENT_NUMBER_LCS).toString()) +
                        "&literal.title_parseable=" + encode(getAdditionalProperties().get(TITLE_PARSEABLE).toString()) +
                        "&literal.title_parseable_lcs=" + encode(getAdditionalProperties().get(TITLE_PARSEABLE_LCS).toString()) +
                        "&literal.assignee_full_name_lcs=" + encode(getAdditionalProperties().get(ASSIGNEE_FULL_NAME_LCS).toString()) +
                        "&literal.type_lcs=" + encode(getAdditionalProperties().get(TYPE_LCS).toString()));

        if (getAdditionalProperties() != null)
        {
            for (Map.Entry<String, Object> entry : getAdditionalProperties().entrySet())
            {
                if (getSkipAdditionalPropertiesInURL() != null && !getSkipAdditionalPropertiesInURL().contains(entry.getKey()))
                {

                    url.append("&literal.").append(entry.getKey()).append("=")
                            .append(entry.getValue() instanceof String ? encode((String) entry.getValue()) : entry.getValue());
                }
            }
        }

        return url.toString();
    }

    private String encode(String str)
    {
        String encodedStr = "";

        if (str == null)
        {
            return encodedStr;
        }

        try
        {
            encodedStr = URLEncoder.encode(str, "UTF-8");
        }
        catch (UnsupportedEncodingException e)
        {
            log.warn("Unsupported 'UTF-8' encoding for text [{}]. Empty string will be used instead.", str);
        }

        return encodedStr;
    }

    public List<String> getSkipAdditionalPropertiesInURL()
    {
        return skipAdditionalPropertiesInURL;
    }

    public void setSkipAdditionalPropertiesInURL(List<String> skipAdditionalPropertiesInURL)
    {
        this.skipAdditionalPropertiesInURL = skipAdditionalPropertiesInURL;
    }
}