const axios = require('axios')
const _ = require('lodash')

// TODO: Automatically retrieve dates via aviable Data and get rid of random dates
const rangeStartDate = '2010-01' // If no date is given, this date will be used as startDate
const rangeEndDate = '2018-12'// If no date is given, this date will be used as endDate

// TODO: call method periodically, not over API
module.exports = async (dbConn, startDate = rangeStartDate, endDate = rangeEndDate) => {
  console.log('update climate with:', startDate, endDate);

  const result = await dbConn.query(`SELECT * FROM regions WHERE meteostat_id IS NOT NULL`)

  const climateObject = await Promise.all(result.map(src => {
    return createClimateObjectFrom(src, startDate, endDate)
  }))
  const climateObjectArr = climateObject.reduce((total, element) => total.concat(element), [])

  await writeToDatabase(dbConn, climateObjectArr)

  const res = `region_climate update complete. see backend logs for info.`
  return res
}

async function createClimateObjectFrom(src, startDate, endDate) {
  let res
  if (src.meteostat_id === '') {
    console.log("skipping: no meteostat id ")
    return []
  }
  try {
    res = await axios.get(`https://api.meteostat.net/v1/history/monthly?station=${src.meteostat_id}&start=${startDate}&end=${endDate}&key=${process.env.METEOSTAT_API_KEY}`)
  } catch (error) {
    console.log("error while getting data from meteostat: couldn't find results for following region: ")
    console.log(src.region + " with meteostat_id " + src.meteostat_id)
    console.log(error)
    return []
  }
  if (!res.data.data) {
    console.log("skipping: no data for station with meteostat_id " + src.meteostat_id + " (" + src.region + ")")
    return []
  }
  const retVal = res.data.data.map(element => {
    let result = {
      region: src.region,
      region_id: src.id,
      year: element.month.split("-")[0],
      month: element.month.split("-")[1],
      temperature: element.temperature_mean,
      temperature_min: element.temperature_mean_min,
      temperature_max: element.temperature_mean_max,
      precipitation: element.precipitation,
      raindays: element.raindays,
      sunshine: element.sunshine,
      humidity: element.humidity ? element.humidity : null
    }
    //console.log(result)
    return result
  })
  return retVal
}

async function writeToDatabase(dbConn, climateObjArr) {
  for (const element of climateObjArr) {
    //console.log(element)
    try {
      await dbConn.query(`
      INSERT INTO region_climate 
      (region_id, year, month, temperature_mean, temperature_mean_min, temperature_mean_max, precipitation, sunshine, humidity, raindays)
      VALUES (${element.region_id}, ${element.year}, ${element.month}, ${element.temperature}, ${element.temperature_min}, ${element.temperature_max}, ${element.precipitation}, ${element.sunshine}, ${element.humidity}, ${element.raindays})
      ON DUPLICATE KEY UPDATE
      temperature_mean = ${element.temperature}, 
      temperature_mean_min = ${element.temperature_min}, 
      temperature_mean_max = ${element.temperature_max}, 
      precipitation = ${element.precipitation}, 
      sunshine = ${element.sunshine}, 
      humidity = ${element.humidity}, 
      raindays = ${element.raindays};`)
    } catch (error) {
      if (error.code !== 'ER_DUP_ENTRY') {
        console.log("element which causes problems: ")
        console.log(element)
        console.log("query which causes problems: ")
        console.log(error)
      } else {
        console.log(element.region + ": " + error.sqlMessage)
      }
    }
  }
};