package org.legrog.entities;

import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.inject.Inject;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

/**
 *
 */
public class AccountSearchRepositorySolrj implements AccountSearchRepository {
    Logger logger = LoggerFactory.getLogger(getClass());

    SolrClient solrClient;

    @Inject
    AccountSearchRepositorySolrj(SolrClient solrClient) {
        this.solrClient = solrClient;
    }

    //no args constructor to make it proxyable
    AccountSearchRepositorySolrj() {
    }

    @Override
    public List<IndexedAccount> search(String string) throws SearchingException {
        SolrQuery solrQuery = new SolrQuery(string);
        QueryResponse queryResponse;
        try {
            queryResponse = solrClient.query("accounts", solrQuery);
        } catch (IOException ioe) {
            throw new SearchingException(ioe);
        } catch (SolrServerException sse) {
            logger.error("SolrServerException {}", sse);
            throw new SearchingException(sse.getRootCause());
        }

        if (queryResponse != null) {
            return queryResponse.getBeans(IndexedAccount.class);
        } else {
            return new ArrayList<>();
        }
    }
}