diff --git a/services/aggregatorUsageEvents/ecolyo.js b/services/aggregatorUsageEvents/ecolyo.js index f390ede00d0ec5d0d72a661fbd66b9f0ec940cd3..fc296a5b812acaec891ba3921c88b81999a953fc 100644 --- a/services/aggregatorUsageEvents/ecolyo.js +++ b/services/aggregatorUsageEvents/ecolyo.js @@ -143,7 +143,9 @@ var __signature__ = typeof reactHotLoaderGlobal !== 'undefined' ? reactHotLoader const log = _cozyLogger.default.namespace('aggregatorUsageEvents'); // Store all id of events read during the process -const readUsageEvents = []; +const readUsageEvents = []; // Store error events + +const errorEvent = []; const sendIndicator = async (indicator, client) => { try { @@ -973,6 +975,17 @@ const AggregatorUsageEvents = async ({ const uniqueReadUsageEvents = (0, _lodash.uniq)(readUsageEvents); log('info', `Tag aggregated usage: total of ${uniqueReadUsageEvents.length} events`); await _usageEvent.default.updateUsageEventsAggregated(client, uniqueReadUsageEvents); + + if (errorEvent.length > 0) { + // Build error + let error = `Process end with ${errorEvent.length} errors : `; + errorEvent.forEach(el => { + error += `${el.doctype}, `; + }); + log('error', error); + throw error; + } + log('info', 'End of service'); }; @@ -988,6 +1001,7 @@ const AggregatorUsageEvents = async ({ reactHotLoader.register(log, "log", "/builds/web-et-numerique/llle_project/ecolyo/src/targets/services/aggregatorUsageEvents.ts"); reactHotLoader.register(readUsageEvents, "readUsageEvents", "/builds/web-et-numerique/llle_project/ecolyo/src/targets/services/aggregatorUsageEvents.ts"); + reactHotLoader.register(errorEvent, "errorEvent", "/builds/web-et-numerique/llle_project/ecolyo/src/targets/services/aggregatorUsageEvents.ts"); reactHotLoader.register(sendIndicator, "sendIndicator", "/builds/web-et-numerique/llle_project/ecolyo/src/targets/services/aggregatorUsageEvents.ts"); reactHotLoader.register(reduceEvents, "reduceEvents", "/builds/web-et-numerique/llle_project/ecolyo/src/targets/services/aggregatorUsageEvents.ts"); reactHotLoader.register(sendAggregatedEventByDay, "sendAggregatedEventByDay", "/builds/web-et-numerique/llle_project/ecolyo/src/targets/services/aggregatorUsageEvents.ts");