Mlab 566

fix connection timeouts with regards to mysql

config/dbconn.ts

@@ -4,59 +4,34 @@ var env = process.env.NODE_ENV || 'testing'
 const config = require('./config')[env]
 
 // ==== USER ACOOUNT DB CONNECTION ====
-var userConnection = mysql.createConnection({
+const userConnection = mysql.createPool({
     host: config.database.host,
     user: config.database.user,
     password: config.database.password,
     port: config.database.port,
     database: config.database.dbUser,
-    multipleStatements: true
-})
+    waitForConnections: true,
+    connectionLimit: 10,
+    queueLimit: 0
+});
 
-userConnection.connect(function(err) {
-    if (err) throw err
-})
 userConnection.query('USE '+config.database.dbUser)
 
-// ALTERNATIVE approach: close db connection manually after every query
-/*
-var dbconn = function dbconn(query, values, next) {
-    var connection = mysql.createConnection({
-        host: config.database.host,
-        user: config.database.user,
-        password: config.database.password,
-        port: config.database.port,
-        database: config.database.db
-    })
-    connection.connect(function(err) {
-        if (err) throw err;
-    })
-    connection.query(query, values, function(err) {
-        connection.end(); // close the connection
-        if (err) {
-            throw err;
-        }
-        // Execute the callback
-        next.apply(this, arguments);
-    });
-}
-*/
-
 // ==== PROJECT DB CONNECTION ====
-var projectConnection = mysql.createConnection({
+const projectConnection = mysql.createPool({
     host: config.database.host_project,
     user: config.database.user,
     password: config.database.password,
     port: config.database.port,
-    database: config.database.dbProject
-})
+    database: config.database.dbProject,
+    waitForConnections: true,
+    connectionLimit: 10,
+    queueLimit: 0
+});
 
-projectConnection.connect(function(err) {
-    if (err) throw err
-})
 projectConnection.query('USE '+config.database.dbProject)
 
-var connection = {
+const connection = {
     user: userConnection,
     project: projectConnection
 }

routes/public.ts

@@ -237,9 +237,11 @@ export = function (app:any, config:any, lang:string) {
         // encrypt password
         bcrypt.genSalt(saltRounds, function(err, salt) {
           bcrypt.hash(newPwd, salt, async function(err:any, hash) {
-            var credentialData = {
+            let credentialData = {
               password: hash,
-              user_id: user.user_id
+              user_id: user.user_id,
+              resetPasswordToken: null,
+              resetPasswordExpires: null
             }
             // update password
             let result = await methods.updateCredential(credentialData)
@@ -248,7 +250,7 @@ export = function (app:any, config:any, lang:string) {
               res.flash('error', "Datenbankfehler: Passwort kann nicht geändert werden.")
             } else {
               res.flash('success', "Passwort aktualisiert!")
-              // send notifiaction email
+              // send notification email
               mailer.options.to = user.email
               mailer.options.subject = constants.updatePasswordMailSubject
               mailer.options.html = constants.updatePasswordMailContent+'<div>'+constants.mailSignature+'</div>'