// Import the FetchService module
const { fetchAndParseHTML, fetchAndParseCSV } = require('../../utils/parse.js');
const { getDomainFromUrl } = require("../../utils/url.js");

/**
 * Represents Datos Abiertos class, which extends the FetchService class.
 * This class provides methods to interact with the Datos Abiertos Datasets.
 * <br /><br />Full API specs: <a href="https://datos.gob.do/" target="_blank">https://datos.gob.do/</a>
 * 
 * @category Gob.do
 */
class DatosAbiertos {
  /**
   * Create an instance of the Datos Abiertos service.
   * @param {string} apiKey - The API key for authentication.
   */
  constructor(apiKey) {
    // Set the API domain for Datos Abiertos
    this.apiDomain = "https://datos.gob.do/dataset";
  }

  /**
  * Retrieves and parses the dataset Datos Abiertos from the API.
  * @param {string} dataset - The name of the dataset to retrieve.
  * @returns {Promise} A promise that resolves to the fetched Datos Abiertos data.
  * @example
  * // Example: Retrieve fuel prices for the Dominican Republic
  * // Full documentation: https://datos.gob.do/
  * async function getDatosAbiertosDatasets() {
  *     try {
  *         const dataset = 'recaudaciones-sirite-2021-2022';
  *         const daData = await aletheiaSDK.opendata.gob('datos-abiertos').getDatasetJSON(dataset);
  *         console.log('Datos Abiertos Data:', daData.datasetJSON);
  *     } catch (error) {
  *         console.error('Error retrieving Datos Abiertos data:', error);
  *     }
  * }
  * getDatosAbiertosDatasets();
  * @returns {Object} Returns the fetched data from Datos Abiertos.
  */
  async getDatasetJSON(dataset) {
    const endpoint = `${this.apiDomain}/${dataset}`;

    try {
      const datasetLink = await this.getDatasetCSVUrls(dataset);

      if (datasetLink.length > 1) {
        const promises = datasetLink.map(async (link) => {
          const datasetJSON = await fetchAndParseCSV(link);
          return {
            datasetJSON,
            provider: getDomainFromUrl(endpoint),
            datasetURL: link,
            endpoint,
          };
        });

        return Promise.all(promises);
      } else if (datasetLink.length === 1) {
        const datasetJSON = await fetchAndParseCSV(datasetLink[0]);
        return {
          datasetJSON,
          provider: getDomainFromUrl(endpoint),
          datasetURL: datasetLink,
          endpoint,
        };
      } else {
        // Adjust this part based on your requirements when no datasetLink is available
        throw new Error('No dataset link available.');
      }
    } catch (error) {
      throw error;
    }
  }

  /**
  * Retrieves and parses the dataset URLs for Datos Abiertos from the API.
  * @param {string} dataset - The name of the dataset to retrieve URLs for.
  * @returns {Promise} A promise that resolves to an array of dataset URLs.
  * @example
  * // Example: Retrieve fuel prices for the Dominican Republic
  * // Full documentation: https://datos.gob.do/
  * async function getDatasetCSVUrls() {
  *     try {
  *         // const dataset = 'nomina-miembros-policiales-2019';
  *         // const dataset = 'trafico-2020';
  *         const dataset = 'recaudaciones-sirite-2021-2022';
  *         const daData = await aletheiaSDK.opendata.gob('datos-abiertos').getDatasetCSVUrls(dataset);
  *         console.log('Datos Abiertos Data:', daData);
  *     } catch (error) {
  *         console.error('Error retrieving Datos Abiertos data:', error);
  *     }
  * }
  * getDatasetCSVUrls();
  * @returns {Object} Returns an array of dataset URLs.
  */
  async getDatasetCSVUrls(dataset) {
    const endpoint = `${this.apiDomain}/${dataset}`;
    try {
      const datasetLink = await fetchAndParseHTML(endpoint, 'resource-url-analytics');
      return datasetLink;
    } catch (error) {
      throw error;
    }
  }
}

// Export the DatosAbiertos class for use in other modules
module.exports = DatosAbiertos;