Avoid uncaught exceptions closing the nodejs processes.

Author: riclolsen

src/OPC-UA-Server/index.js

@@ -32,6 +32,8 @@ const AppDefs = require('./app-defs')
 const { LoadConfig, getMongoConnectionOptions } = require('./load-config')
 let HintMongoIsConnected = true
 
+process.on('uncaughtException', err => Log.log('Uncaught Exception:' + JSON.stringify(err)))
+
 ;(async () => {
   const jsConfig = LoadConfig() // load and parse config file
   Log.levelCurrent = jsConfig.LogLevel

src/alarm_beep/alarm_beep.js

@@ -27,6 +27,8 @@ const { MongoClient } = require('mongodb')
 const { setInterval } = require('timers')
 const sys = require('child_process')
 
+process.on('uncaughtException', err => Log.log('Uncaught Exception:' + JSON.stringify(err)))
+
 const WavFilesWin = [
   'c:\\windows\\media\\Windows Default.wav',
   'c:\\windows\\media\\Windows Background.wav',

src/cs_custom_processor/cs_custom_processor.js

@@ -25,6 +25,8 @@ const Redundancy = require('./redundancy')
 const { MongoClient } = require('mongodb')
 const CustomProcessor = require('./customized_module').CustomProcessor
 
+process.on('uncaughtException', err => Log.log('Uncaught Exception:' + JSON.stringify(err)))
+
 const args = process.argv.slice(2)
 let inst = null
 if (args.length > 0) inst = parseInt(args[0])

src/demo_simul/index.js

@@ -24,6 +24,8 @@ const AppDefs = require('./app-defs')
 const LoadConfig = require('./load-config')
 const { MongoClient, Double } = require('mongodb')
 
+process.on('uncaughtException', err => Log.log('Uncaught Exception:' + JSON.stringify(err)))
+
 const pipeline = [
   {
     $project: { documentKey: false },

src/grafana_alert2event/grafana_alert2event.js

@@ -46,6 +46,8 @@ const app = express()
 app.use(express.json())
 let soeQueue = new Queue() // queue of SOE events
 
+process.on('uncaughtException', err => console.log('Uncaught Exception:' + JSON.stringify(err)))
+
 app.listen(HTTP_PORT, IP_BIND, () => {
   console.log('listening on ' + IP_BIND + ':' + HTTP_PORT)
 })

src/mongofw/index.js

@@ -24,6 +24,8 @@ const Redundancy = require('./redundancy')
 const { MongoClient } = require('mongodb')
 const CustomProcessor = require('./customized_module').CustomProcessor
 
+process.on('uncaughtException', err => Log.log('Uncaught Exception:' + JSON.stringify(err)))
+
 const args = process.argv.slice(2)
 let inst = null
 if (args.length > 0) inst = parseInt(args[0])

src/mongowr/index.js

@@ -24,6 +24,8 @@ const Redundancy = require('./redundancy')
 const { MongoClient } = require('mongodb')
 const CustomProcessor = require('./customized_module').CustomProcessor
 
+process.on('uncaughtException', err => Log.log('Uncaught Exception:' + JSON.stringify(err)))
+
 const args = process.argv.slice(2)
 let inst = null
 if (args.length > 0) inst = parseInt(args[0])

src/mqtt-sparkplug/index.js

@@ -36,6 +36,8 @@ const AutoTag = require('./auto-tag')
 const { castSparkplugValue: castSparkplugValue } = require('./cast')
 const autoTag = require('./auto-tag')
 
+process.on('uncaughtException', err => Log.log('Uncaught Exception:' + JSON.stringify(err)))
+
 const SparkplugNS = 'spBv1.0'
 const DevicesList = [] // contains either EoN nodes or devices
 const ValuesQueue = new Queue() // queue of values to update acquisition

src/server_realtime_auth/index.js

@@ -58,6 +58,8 @@ const dbAuth = require('./app/models')
 const { authJwt } = require('./app/middlewares')
 const { canSendCommands } = require('./app/middlewares/authJwt.js')
 
+process.on('uncaughtException', err => Log.log('Uncaught Exception:' + JSON.stringify(err)))
+
 // Argument NOAUTH disables user authentication
 var args = process.argv.slice(2)
 if (args.length > 0) if (args[0] === 'NOAUTH') AUTHENTICATION = false

src/telegraf-listener/index.js

@@ -41,6 +41,8 @@ const serverUdpSocket = dgram.createSocket({ type: 'udp4' })
 let bindCount = 0
 const grpSep = '~'
 
+process.on('uncaughtException', err => console.log('Uncaught Exception:' + JSON.stringify(err)))
+
 let ListCreatedTags = []
 let ValuesQueue = new Queue() // queue of values to update