node: ../deps/uv/src/uv-common.c:143: uv_err_name: Assertion `0' failed. about node-convergence-archive HOT 10 CLOSED

// ------------------------------------------------------------------------------------------------
// Functions
// ------------------------------------------------------------------------------------------------

function padd(n) {
    if (parseInt(n) < 10) {
        return 0 + n.toString();
    } else {
        return n;
    }
}

// ------------------------------------------------------------------------------------------------
// Global variables
// ------------------------------------------------------------------------------------------------

var fs = require('fs');
var chokidar = require('chokidar');
var mysql = require('mysql');
var xml2js = require('xml2js');
var io = require('socket.io');

var folder = '/mnt/rhotex320/HotFolders/PrintEvents';

var watcher = chokidar.watch(folder, {
  usePolling: true,
  useFsEvents: false,
  depth: 1,
  interval: 1,
  atomic: false
});

var parser = new xml2js.Parser({
    explicitArray: false,
    trim: true,
    mergeAttrs: true
});

var date = new Date();
var year = date.getFullYear();
var month = padd(date.getMonth() + 1);      // From 0 to 11
var day = padd(date.getDate())              // From 1 to 31
var hours = padd(date.getHours());          // From 0 to 23
var minutes = padd(date.getMinutes());      // From 0 to 59
var seconds = padd(date.getSeconds());      // From 0 to 59

var dateTime = year + "-" + month + "-" + day + " " + hours + ":" + minutes + ":" + seconds;

// MySQL connection
var pool = mysql.createPool({
    host: 'XX.XX.XX.XX',
    user: 'myser',
    database: 'mydb',
    password: 'mypassword'
});

// Socket.io
var socket = require('socket.io-client')('http://mydomain:3000');

// ------------------------------------------------------------------------------------------------
// Initialize Watcher
// ------------------------------------------------------------------------------------------------

watcher.on('ready', function() {
    watcher.on('add', function(path, stats) {   
        // Read the XML
        fs.readFile(path, function(err, data) {     
            // Parse the XML
            parser.parseString(data, function (err, result) {
                var job_state = path.split('_').slice(-1).pop().split('.')[0];
                if (job_state == 'printing' || job_state == 'done') {
                    pool.getConnection(function(err, connection) {

                        var resultJobState = result.sequence.sequence_entry.state;
                        var resultJobName = result.sequence.sequence_entry.job.job_name + '%';      
                        var resultPrintsDone = result.sequence.sequence_entry.job.number_prints_done;
                        var resultNrToPrint = result.sequence.sequence_entry.job.number_to_print;
                        var statusCode = (resultJobState == 'Done') ? 2 : 1;                        

                        if (parseInt(resultPrintsDone) === parseInt(resultNrToPrint)) {                     

                            // Here we want to update the status to done!
                            var q1a = connection.query('SELECT * FROM `nests` WHERE `job_name` LIKE ? AND `job_state` != ?',[ resultJobName, 'Done' ], function(error, results, fields) {                                                               
                                if (typeof(results[0]) == 'object') {
                                    var q1b = connection.query('UPDATE `nests` SET `printed_item` = ?, `nr_of_prints` = ?, `job_state` = ?, `statuscode` = ? WHERE `job_name` LIKE ?',
                                        [ resultPrintsDone, resultNrToPrint, resultJobState, statusCode, resultJobName ], function(err, result) {
                                        socket.emit(
                                            'Rhotex 320 - Job State', 
                                            [{
                                                path: path,
                                                job_name: resultJobName.split('%')[0].trim(),
                                                affected_rows: result.affectedRow,
                                                job_state: resultJobState
                                            }]
                                        );
                                    });
                                };
                            });

                        } else {

                            // Here we want to update the status to printing!
                            var q1a = connection.query('SELECT * FROM `nests` WHERE `job_name` LIKE ?',[ resultJobName ], function(error, results, fields) {                                                                
                                if (typeof(results[0]) == 'object') {
                                    var q1b = connection.query('UPDATE `nests` SET `printed_item` = ?, `nr_of_prints` = ?, `job_state` = ?, `statuscode` = ? WHERE `job_name` LIKE ?',
                                        [ resultPrintsDone, resultNrToPrint, resultJobState, statusCode, resultJobName ], function(err, result) {
                                        socket.emit(
                                            'Rhotex 320 - Job State', 
                                            [{
                                                nestcode: results[0].nestcode,
                                                path: path,
                                                job_name: resultJobName.split('%')[0].trim(),
                                                affected_rows: result.affectedRow,
                                                job_state: resultJobState
                                            }]
                                        );
                                    });
                                };
                            })                          

                        }
                    });
                }
            });
        });         
    });
});

// ------------------------------------------------------------------------------------------------```