diff --git a/index.js b/index.js index a13de52dfed62a60f29ab8cd189f9df193c1f907..1bb520150f5c116d1e77357b92b647257e0928ef 100644 --- a/index.js +++ b/index.js @@ -109,15 +109,19 @@ moment.tz.setDefault('Europe/Paris') // set the timezone /*** Connector Constants ***/ const manualExecution = process.env.COZY_JOB_MANUAL_EXECUTION === 'true' ? true : false +// Period for daily data const startDailyDate = manualExecution ? moment().subtract(12, 'month') : moment().subtract(32, 'month') const startDailyDateString = startDailyDate.format('YYYY-MM-DD') +// Period for half and hour data const startLoadDate = moment().subtract(7, 'day') const startLoadDateString = startLoadDate.format('YYYY-MM-DD') +// Period to define if the history is loaded const checkHistoryDate = moment().subtract(8, 'day') const endDate = moment() const endDateString = endDate.format('YYYY-MM-DD') +// Endpoints config const baseUrl = 'https://gw.prd.api.enedis.fr' const dailyDataURL = `${baseUrl}/v4/metering_data/daily_consumption` const loadCurveURL = `${baseUrl}/v4/metering_data/consumption_load_curve` @@ -449,10 +453,20 @@ async function processData(data, doctype, filterKeys) { const parsedData = JSON.parse(data) const intervalData = parsedData.meter_reading.interval_reading const formatedData = await formateData(intervalData, doctype) + log( + 'debug', + 'TTTTTTTTTTTTTTTTTTTTTTTTTTTT - formatedData :', + formatedData.length + ) // Remove data for existing days into the DB const filteredData = await hydrateAndFilter(formatedData, doctype, { keys: filterKeys, }) + log( + 'debug', + 'TTTTTTTTTTTTTTTTTTTTTTTTTTTT - filteredData :', + filteredData.length + ) // Store new day data await storeData(filteredData, doctype, filterKeys) return filteredData @@ -500,6 +514,11 @@ async function storeData(data, doctype, filterKeys) { const filteredDocuments = await hydrateAndFilter(data, doctype, { keys: filterKeys, }) + log( + 'debug', + 'TTTTTTTTTTTTTTTTTTTTTTTTTTTT - filteredDocuments :', + filteredDocuments.length + ) return await addData(filteredDocuments, doctype) }