From 4c5ee3c5e97eb295ba26df786f0c6f3ce47e9955 Mon Sep 17 00:00:00 2001
From: git-directory-deploy <>
Date: Mon, 10 Jan 2022 11:39:11 +0100
Subject: [PATCH] publish: Merge branch 'feat/US609-Add-max-power-endpoint'
into 'dev'
generated from commit 8a1f9d71634e910bb5f839b2ae206d6a18195693
---
index.js | 19 +++++++++++++++++++
1 file changed, 19 insertions(+)
diff --git a/index.js b/index.js
index a13de52..1bb5201 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)
}
--
GitLab