diff --git a/index.js b/index.js index 52f0262500a916a8b6e8d64ee602d9fe9cf3061b..751ef5a7c6b4df51d723d3ba263a494cf2bfc647 100644 --- a/index.js +++ b/index.js @@ -453,21 +453,9 @@ 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 + const storedData = await storeData(formatedData, doctype, filterKeys) + return storedData } /** @@ -512,10 +500,6 @@ 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) }