diff --git a/src/targets/services/aggregatorUsageEvents.ts b/src/targets/services/aggregatorUsageEvents.ts index 800522f4a574d1b2fb4c2c0d5e8abcb8708e3376..489e1b76fbdc955ac551c1103a8cee0a2f3e476c 100644 --- a/src/targets/services/aggregatorUsageEvents.ts +++ b/src/targets/services/aggregatorUsageEvents.ts @@ -38,6 +38,9 @@ interface Indicator { // Store all id of events read during the process const readUsageEvents: UsageEvent[] = [] +// Store error events +const errorEvent: { error: any; doctype: string }[] = [] + const sendIndicator = async ( indicator: Indicator, client: Client @@ -943,6 +946,17 @@ const AggregatorUsageEvents = async ({ 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') }