/*
 * This file is a part of EpnTAPClient.
 * This program aims to provide EPN-TAP support for software clients, like CASSIS spectrum analyzer.
 * See draft specifications: https://voparis-confluence.obspm.fr/pages/viewpage.action?pageId=559861
 * Copyright (C) 2016 Institut de Recherche en Astrophysique et Planétologie.
 *
 * This program is free software: you can
 * redistribute it and/or modify it under the terms of the GNU 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 General Public License for more details. You should have received a copy of
 * the GNU General Public License along with this program. If not, see
 * <http://www.gnu.org/licenses/>.
 */

package eu.omp.irap.vespa.epntapclient;

import java.text.ParseException;
import java.util.ArrayList;
import java.util.List;

import eu.omp.irap.vespa.epntapclient.granule.Granule;
import eu.omp.irap.vespa.epntapclient.granule.GranuleCtrl;
import eu.omp.irap.vespa.epntapclient.service.Queries;
import eu.omp.irap.vespa.epntapclient.service.ServiceCore;
import eu.omp.irap.vespa.epntapclient.service.ServiceCtrl;
import eu.omp.irap.vespa.epntapclient.voresource.VOResourceCtrl;
import eu.omp.irap.vespa.epntapclient.voresource.VOResourceException;
import eu.omp.irap.vespa.epntapclient.voresource.model.Resource;
import eu.omp.irap.vespa.epntapclient.votable.model.VOTABLE;
import eu.omp.irap.vespa.votable.controller.VOTableController;
import eu.omp.irap.vespa.votable.controller.VOTableException;
import eu.omp.irap.vespa.votable.controller.VOTableException.CantParseVOTableException;
import eu.omp.irap.vespa.votable.utils.StringJoiner;
import eu.omp.irap.vespa.votable.votabledata.VOTableData;

/**
 * @author N. Jourdane
 */
public class EpnTapConnection implements EpnTapInterface {

	// *** Resource ***

	@Override
	public Resource getEPNVOresource(String ivoid) throws VOResourceException {
		return VOResourceCtrl.getVOresource(ivoid);
	}

	// *** Resources ***

	@Override
	public List<Resource> getEPNVOResources() throws VOResourceException {
		List<String> ivoids = VOResourceCtrl.getIvoidResources(ServiceCore.EPNCORE);
		return VOResourceCtrl.getVOResources(ivoids);
	}

	@Override
	public List<Resource> getEPNVOResources(List<String> keywords)
			throws VOResourceException {
		List<String> ivoids = VOResourceCtrl.getVOResources(ServiceCore.EPNCORE, keywords);
		return VOResourceCtrl.getVOResources(ivoids);
	}

	// *** Service ***

	@Override
	public VOTABLE getEPNService(String ivoid) throws VOTableException {
		String query = String.format(Queries.SELECT_ALL_TAP_SERVICES_WHERE_IVOID, ivoid);
		return ServiceCtrl.getVoTable(query);
	}

	@Override
	public VOTABLE getEPNService(String ivoid, List<String> attributes)
			throws VOTableException {
		String select = StringJoiner.join(attributes);
		String query = String.format(Queries.SELECT_TAP_SERVICES_WHERE_IVOID, select, ivoid);
		return ServiceCtrl.getVoTable(query);
	}

	// *** Services ***

	@Override
	public VOTABLE getEPNServices() throws VOTableException {
		String query = String.format(Queries.SELECT_ALL_TAP_SERVICES_WHERE_CORE,
				ServiceCore.EPNCORE);
		return ServiceCtrl.getVoTable(query);
	}

	@Override
	public VOTABLE getEPNServices(List<String> attributes) throws VOTableException {
		String select = StringJoiner.join(attributes);
		String query = String.format(Queries.SELECT_TAP_SERVICES, select);
		return ServiceCtrl.getVoTable(query);
	}

	@Override
	public VOTABLE getEPNServices(List<String> keywords, List<String> attributes)
			throws VOTableException {
		attributes.add("res_subject");
		String select = StringJoiner.join(attributes);
		List<String> whereList = new ArrayList<>();
		for (String keyword : keywords) {
			whereList.add("res_subject = '" + keyword + "'");
		}
		String where = StringJoiner.join(whereList, " OR ");
		String query = String.format(Queries.SELECT_TAP_SERVICES_WHERE_SUBJECT, select, where);
		return ServiceCtrl.getVoTable(query);
	}

	// *** Getters ***

	@Override
	public String getEPNCoreTableName(String ivoid) throws VOTableException {
		return (String) ServiceCtrl.getParameter(ivoid, "table_name");
	}

	@Override
	public String getTAPURL(String ivoid) throws VOTableException {
		return (String) ServiceCtrl.getParameter(ivoid, "access_url");
	}

	// *** Queries ***

	@Override
	public List<Granule> sendADQLQuery(String tapURL, String adqlQuery)
			throws VOTableException {
		VOTableController voTableCtrl = new VOTableController(tapURL, adqlQuery);
		voTableCtrl.readTable();
		VOTableData data = voTableCtrl.getVOTableData();

		List<Granule> granules;
		try {
			GranuleCtrl gc = new GranuleCtrl(data);
			granules = gc.getGranules();
		} catch (ParseException e) {
			throw new CantParseVOTableException("Parsing error on a granule.", e);
		}
		return granules;
	}

	@Override
	public List<Granule> sendQuery(String tapURL, String schemaName, Query enumeratedQuery)
			throws VOTableException {
		String query = String.format(enumeratedQuery.toString(), schemaName);
		VOTableController voTableCtrl = new VOTableController(tapURL, query);
		voTableCtrl.readTable();
		VOTableData data = voTableCtrl.getVOTableData();

		List<Granule> granules;
		try {
			GranuleCtrl gc = new GranuleCtrl(data);
			granules = gc.getGranules();
		} catch (ParseException e) {
			throw new CantParseVOTableException("Parsing error on a granule.", e);
		}
		return granules;
	}

}