diff --git a/src/subscribers/ioSubscriber.js b/src/subscribers/ioSubscriber.js index e4dcd2c..6eb4f4c 100644 --- a/src/subscribers/ioSubscriber.js +++ b/src/subscribers/ioSubscriber.js @@ -39,6 +39,17 @@ const configure = (socket) => { emitter.on('parse.error', ({ filepath, columns, error }) => { socket.emit('parse.error', { event: 'parse.error', message: 'Erreur lors du traitement' }); }); + + let processed = 0; + let limit = 10000; + emitter.on('parse.data', ({ filepath, columns, data, index }) => { + processed++; + + if ( processed == limit ) { + socket.emit('parse.data', { message: `[${index} lignes] traités` }); + processed = 0; + } + }); } module.exports = configure; \ No newline at end of file