Added data base reconnection

api/controllers/Issue.js

@@ -157,6 +157,53 @@ module.exports = function(router) {
 		});
   });
 
+  //=====================
+  // GET ISSUES COMMENTS BY STATION
+  //=====================
+  router.get('/api/issues/station/:name', function(request, response) {
+    let url = req && req.headers ? req.headers.host : '';
+    url = 'https://'+ url + '/api/sites?provider=tahmo&format=siteCodeObj';
+    url = 'https://tahmoissuetracker.mybluemix.net/api/sites?provider=tahmo&format=siteCodeObj';
+    let sites = {};
+    var name = request.params.name;
+    var status = {station: name};
+		fetch(url, {
+			method: 'GET',
+		})
+		.then(function(res) {
+			return res.json();
+		})
+		.then(function(response) {
+      if (response.success) {
+        sites = response.data;
+        Issue.find(status, function(err, issues) {
+          if (err) {
+            res
+              .status(200)
+              .send({success: false, message: 'Could not retrieve issues.'});
+          } else {
+            let data = modifyIssuesDate(issues, sites);
+            res.status(200).send({
+              success: true,
+              message: 'Issues retrieved successfully.',
+              count: data.length,
+              data: data
+            });
+          }
+        });
+      } else {
+        res
+          .status(200)
+          .send({success: false, message: 'Could not retrieve sites. Therefore no issues retrieved.'});
+      }
+		})
+		.catch(function(err) {
+      res
+        .status(200)
+        .send({success: false, message: 'Could not retrieve sites. Therefore no issues retrieved.'});
+		});
+   });
+
   //=====================
   // GET ISSUES COMMENTS BY ID
   //=====================

api/models/connections.js

@@ -1,32 +1,76 @@
 var variables = JSON.parse(process.env.VCAP_SERVICES || '{}')
 var db_1 = process.env.DB_1;
 var db_2 = process.env.DB_2;
-console.log('variables', variables);
 var mongoose = require('mongoose');
-// var opts = {uri_decode_auth: true};
 var opts = {useNewUrlParser: true, useUnifiedTopology: true};
 
 // Issue Tracker DB
 var issue_tracker_conn = mongoose.createConnection(db_1, opts, function(
   err,
   response
 ) {
-  if (err) console.log('Fail to connect to ' + db_1);
-  else console.log('Successfully connected to ' + db_1);
+  if (err) {
+    console.log('Fail to connect to ' + db_1);
+  }
+  else {
+    console.log('Successfully connected to ' + db_1);
+
+    // Handle database disconnection
+    issue_tracker_conn.on('disconnected', function() {
+      console.log('Lost connection to Issue Tracker DB');
+      reconnect(issue_tracker_conn, db_1, opts);
+    });
+  }
 });
 
 // Stations Info DB
 var sites_conn = mongoose.createConnection(db_2, opts, function(err, response) {
-  if (err) console.log('Fail to connect to ' + db_2);
-  else console.log('Successfully connected to ' + db_2);
+  if (err) {
+    console.log('Fail to connect to ' + db_2);
+  }
+  else {
+    console.log('Successfully connected to ' + db_2);
+
+    // Handle database disconnection
+    sites_conn.on('disconnected', function() {
+      console.log('Lost connection to Stations Info DB');
+      reconnect(sites_conn, db_2, opts);
+    });
+  }
 });
 
 // Fault Inbox DB
 var fault_inbox_db = '% DB string goes here %';
-var fault_inbox_conn = {}; // Your Fault Inbox DB connction code goes her;
+var fault_inbox_conn = {}; // Your Fault Inbox DB connction code goes here;
+
+function reconnect(conn, dbUrl, opts, attemptNum = 1) {
+  if (attemptNum > 10) {
+    console.log('Failed to reconnect to ' + dbUrl + ' after 10 attempts');
+    setTimeout(function() {
+      process.exit(1); // return non-zero to restart application
+    }, 240000); // wait for 4 minutes before returning non-zero exit code
+    return;
+  }
+
+  console.log('Attempting to reconnect to ' + dbUrl + ', attempt #' + attemptNum);
+  //mongoose.disconnect(); //conn.open() throws an error
+  setTimeout(function() {
+     mongoose.createConnection(dbUrl, opts, function(err) {
+      if (err) {
+        console.log('Reconnect attempt #' + attemptNum + ' to ' + dbUrl + ' failed');
+        reconnect(conn, dbUrl, opts, attemptNum + 1);
+      }
+      else {
+        console.log('Reconnected to ' + dbUrl + ' successfully');
+      }
+    });
+  }, 10000); // wait 10 seconds before each reconnection attempt
+}
 
 module.exports = {
   issue_tracker_conn,
   sites_conn,
   fault_inbox_conn
 };
+
+