Refactored Demo Simul.

riclolsen · Jul 15, 2023 · 9a9d4bc · 9a9d4bc
1 parent 90454f5
commit 9a9d4bc
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/src/demo_simul/index.js b/src/demo_simul/index.js
@@ -40,11 +40,13 @@ const pipeline = [
 ]
 
 const jsConfig = LoadConfig()
+let HintMongoIsConnected = true
 Log.log('Connecting to ' + jsConfig.mongoConnectionString)
 ;(async () => {
   let collection = null
   let cntUpd = 1
   let clientMongo = null
+  HintMongoIsConnected = true
 
   setInterval(async function () {
     if (clientMongo !== null && HintMongoIsConnected) {
@@ -167,6 +169,12 @@ Log.log('Connecting to ' + jsConfig.mongoConnectionString)
                   },
                 }
               )
+              .catch((err) => {
+                Log.log(err)
+                if (err.message.indexOf('ECONNREFUSED') > -1) {
+                  clientMongo = null
+                }
+              })
             Log.log(
               'Digital matchedCount: ' +
                 res2?.matchedCount +
@@ -394,7 +402,7 @@ Log.log('Connecting to ' + jsConfig.mongoConnectionString)
             .on('error', (err) => {
               if (clientMongo) clientMongo.close()
               clientMongo = null
-                  Log.log(err)
+              Log.log(err)
             })
         })
         .catch(function (err) {
@@ -422,13 +430,11 @@ Log.log('Connecting to ' + jsConfig.mongoConnectionString)
 })()
 
 // test mongoDB connectivity
-const CheckMongoConnectionTimeout = 1000
-let HintMongoIsConnected = true
 async function checkConnectedMongo(client) {
   if (!client) {
     return false
   }
-
+  const CheckMongoConnectionTimeout = 1000
   const tr = setTimeout(() => {
     Log.log('Mongo ping timeout error!')
     HintMongoIsConnected = false