async/await over callback

functions/methods.js

@@ -71,46 +71,45 @@ var methods = {
             return rows[0][0]
         } catch (err) {
             console.error(err)
-            return err
         }
+        return null
     },
-    getUserById: function(userId, callback) {
-        dbconn_OBSOLETE.user.query('SELECT verificationStatus, email, salutation, title, firstname, lastname, industry, organisation, speciality FROM user WHERE id = ' +userId, function (err, rows, fields) {
-            let user
-            if (err) { throw err }
-            else {
-                if ( rows.length > 0) {
-                    user = rows[0];
+    getUserEmailById: async function(userId) {
+        try {
+            let rows = await dbconn.user.promise().query('SELECT email FROM user WHERE id = ' +userId)
+            if (rows[0]) {
+                return rows[0][0].email
             }
+            else { return null }
+        } catch (err) {
+            console.error(err)
         }
-            callback(user, err);
-        });
+        return null
     },
-	checkUserEmail: function(email, callback) {
-        let user
-        dbconn_OBSOLETE.user.query('SELECT id, email FROM user WHERE email = "' +email+'"', function (err, rows) {
-            if (err) { throw err }
-            else {
-                if ( rows.length > 0) {
-                    user = rows[0];
+    checkUserEmail: async function(email) {
+        try {
+            let rows = await dbconn.user.promise().query('SELECT id, email FROM user WHERE email = "' +email+'"')
+            if (rows[0]) {
+                return rows[0][0]
             }
+            else { return null }
+        } catch (err) {
+            console.error(err)
         }
-            callback(err, user)
-        });
+        return null
     },
-    getUserByToken: function(token, callback) {
-        let user
-        dbconn_OBSOLETE.user.query('SELECT t1.user_id, t2.email FROM userdb.credential AS t1 INNER JOIN userdb.user AS t2 ON t1.user_id = t2.id AND t1.resetPasswordToken = "'
-            +token+'" and resetPasswordExpires > '+Date.now(), function (err, rows, fields) {
-                if (err) { throw err }
-                else {
-                    if ( rows.length > 0) {
-                        user = rows[0]
-                    }
+    getUserByToken: async function(token) {
+        try {
+            let rows = await dbconn.user.promise().query('SELECT t1.user_id, t2.email FROM userdb.credential AS t1 INNER JOIN userdb.user AS t2 ON t1.user_id = t2.id AND t1.resetPasswordToken = "'
+                +token+'" and resetPasswordExpires > '+Date.now())
+            if (rows[0]) {
+                return rows[0][0]
             }
-                callback(err, user)
+            else { return null }
+        } catch (err) {
+            console.error(err)
         }
-        )
+        return null
     },
 	updateUserById: function(userData, callback) {
 		dbconn_OBSOLETE.user.query('UPDATE user SET ? WHERE id = ' +userData.id, userData, function (err, rows, fields) {
@@ -124,7 +123,7 @@ var methods = {
             callback(err)
         })
     },
-    getUserIdByEmail: function(email, callback) {
+    getUserIdByEmail_OBSOLETE: function(email, callback) {
         let userId
         dbconn_OBSOLETE.user.query('SELECT id FROM user WHERE email = "' +email+'"', function (err, rows, fields) {
             if (err) {
@@ -138,7 +137,7 @@ var methods = {
             callback(userId, err)
         });
     },
-    getUserProjectRole: function(userId, callback) {
+    getUserProjectRole_OBSOLETE: function(userId, callback) {
         dbconn_OBSOLETE.user.query('SELECT project_id, role_id FROM user_project_role WHERE user_id = "' +userId+'"', function (err, rows, fields) {
             if (err) throw err
             callback(rows, err)
@@ -150,31 +149,31 @@ var methods = {
             callback(err)
         })
     },
-    getVerificationTokenByUserId: function(userId, callback) {
-        let token
-        dbconn_OBSOLETE.user.query('SELECT token FROM verification WHERE user_id = "' +userId+'"', function (err, rows, fields) {
-            if (err) {
-                throw err
-            }
-            else {
-                if (rows.length > 0) {
-                    token = rows[0].token
+    getVerificationTokenByUserId: async function(userId) {
+        try {
+            let rows = await dbconn.user.promise().query('SELECT token FROM verification WHERE user_id = "' +userId+'"')
+            if (rows[0]) {
+                return rows[0][0].token
             }
+            else { return null }
+        } catch (err) {
+            console.error(err)
         }
-            callback(token, err)
-        })
+        return null
     },
-    getUserIdByVerificationToken: function(token, callback) {
-        let userId
-        dbconn_OBSOLETE.user.query('SELECT user_id FROM verification WHERE token = "' +token+'"', function (err, rows, fields) {
-            if (err) {
-                throw err
+    getUserIdByVerificationToken: async function(token) {
+        try {
+            let rows = await dbconn.user.promise().query('SELECT user_id FROM verification WHERE token = "' +token+'"')
+            if (rows[0]) {
+                return rows[0][0].user_id
+            }
+            else {
+                return null
             }
-            else if(rows[0]) {
-                userId = rows[0].user_id
+        } catch (err) {
+            console.error(err)
         }
-            callback(userId, err)
-        })
+        return null
     },
     verifyUserAccount: function(userData, callback) {
         dbconn_OBSOLETE.user.beginTransaction(function(err) { // START TRANSACTION

routes/account.js

@@ -89,6 +89,10 @@ module.exports = function (app, config, passport, lang) {
 
   async function getLoggedInUserData(email) {
     let user = await methods.getUserByEmail(email)
+    if (!user) {
+      console.log('no user found')
+      return null
+    } else {
       let loggedInUser = new portalUser(
         user.id, email, user.salutation, user.title, user.firstname, user.lastname, user.industry, user.organisation, user.speciality, user.m4lab_idp, null, user.verificationStatus
       )
@@ -97,9 +101,9 @@ module.exports = function (app, config, passport, lang) {
       if (userGitlabId) {
         loggedInUser.setGitlabUserId(userGitlabId)
       }
-
       return loggedInUser
     }
+  }
 
   app.get('/', async function (req, res) {
     if ( !req.isAuthenticated() ) {
@@ -330,16 +334,18 @@ module.exports = function (app, config, passport, lang) {
     }
   });
   
-  app.get("/resendVerificationEmail", function(req, res){
-    if (req.isAuthenticated()) {
-      var emailAddress = req.user.email
-      
-      methods.getUserIdByEmail(req.user.email, function(userId, err) {
-        if (!err) {
-          // get token
-          methods.getVerificationTokenByUserId(userId, function(token, err){
-            if (!err) {
-              if (token) {
+  app.get('/resendVerificationEmail', async function(req, res){
+    if (!req.isAuthenticated) {
+      res.redirect('/login')
+    } else {
+      let loggedInUser = await getLoggedInUserData(req.user.email)
+      if (!loggedInUser) {
+        res.redirect('/login')
+      } else {
+        let token = await methods.getVerificationTokenByUserId(loggedInUser.id)
+        if (!token) {
+          res.send(false)
+        } else {
           // send email
           var emailSubject = "Bitte bestätigen Sie Ihr M4_LAB Benutzerkonto"
           var emailContent = '<div>Lieber Nutzer,<br/><br/>' +
@@ -348,7 +354,7 @@ module.exports = function (app, config, passport, lang) {
             '<br/><br/>' +
             'Ohne Bestätigung Ihres Kontos müssen wir Ihr Konto leider nach 7 Tagen löschen.</p><br/>' + constants.mailSignature +
             '</div>';
-                mailer.options.to = emailAddress;
+          mailer.options.to = loggedInUser.email;
           mailer.options.subject = emailSubject;
           mailer.options.html = emailContent;
           mailer.transport.sendMail(mailer.options, function(err) {
@@ -359,30 +365,8 @@ module.exports = function (app, config, passport, lang) {
           })
           res.send(true)
         }
-              else {
-                res.send(false)
-              }
       }
-            else {
-              console.log(err)
-            }
-          })
-        }
-      })
-    }
-  })
-
-  app.get('/email/:email', function(req, res) {
-    methods.checkUserEmail(req.params.email, function(err, user){
-      if (!err) {
-        if (user) {
-          res.send(false)
     }
-        else {
-          res.send(true)
-        }  
-      }
-    })
   })
 
   // ============= NEW GITLAB PAGES ===========================

routes/public.js

@@ -98,56 +98,55 @@ module.exports = function (app, config, lang) {
 
     // =================== USERS VERIFICATION =========================
 
-    app.get("/verifyAccount", function(req, res){
-      methods.getUserIdByVerificationToken(req.query.token, function(userId, err){
-        if (userId) {
+    app.get("/verifyAccount", async function(req, res){
+      let userId = await methods.getUserIdByVerificationToken(req.query.token)
+      if (!userId) {
+        // no user found
+        res.render(lang+'/account/verification', {
+          status: null
+        })
+      } else {
+        // a user found, verify the account
         let userData = {
           id: userId,
           verificationStatus: 1
         }
-          methods.verifyUserAccount(userData, function(err){
+        methods.verifyUserAccount(userData, async function(err){
           if (err) {
             console.log("Error: "+err)
             res.render(lang+'/account/verification', {
               status: false
             });
-            }
-            else {
+          } else {
             // send welcome email after successful account verification
-              methods.getUserById(userId, function(data, err){
-                if (err) {
-                  console.log("Error: "+err)
-                }
-                else {
+            let userEmail = await methods.getUserEmailById(userId)
+            if (!userEmail) {
+              res.render(lang+'/account/verification', {
+                status: false
+              })
+            } else {
               // send email
               var emailSubject = "Herzlich willkommen"
                 var emailContent = '<div>Lieber Nutzer,<br/><br/>' +
                   '<p>herzlich willkommen beim Transferportal der HFT Stuttgart!<br/>' +
                   'Sie können nun alle Dienste des Portals nutzen.<p/><br/>' + constants.mailSignature;
-                  mailer.options.to = data.email;
-                  mailer.options.subject = emailSubject;
-                  mailer.options.html = emailContent;
+                mailer.options.to = userEmail
+                mailer.options.subject = emailSubject
+                mailer.options.html = emailContent
                 mailer.transport.sendMail(mailer.options, function(err) {
                   if (err) {
                     console.log('cannot send email')
                     throw err
                   }
                 })
-                }
-              })
     
                 res.render(lang+'/account/verification', {
                   status: true
-              });
-            }
                 })
             }
-        else {
-          res.render(lang+'/account/verification', {
-            status: null
-          });
           }
         })        
+      }
     })
 
     // ==================== FORGOT PASSWORD ===========================
@@ -157,7 +156,7 @@ module.exports = function (app, config, lang) {
         user: req.user
       })
     })
-    app.post('/forgotPwd', function(req, res, next) {
+    app.post('/forgotPwd', function(req, res) {
       let emailAddress = req.body.inputEmail
       async.waterfall([
         function(done) {
@@ -166,9 +165,11 @@ module.exports = function (app, config, lang) {
             done(err, token)
           })
         },
-        function(token, done) {
-          methods.checkUserEmail(emailAddress, function(err, user){
-            if (user) {
+        async function(token) {
+          let user = await methods.checkUserEmail(emailAddress)
+          if (!user) {
+            console.log('no user found')
+          } else {
             var emailSubject = "Ihre Passwort-Anfrage an das Transferportal der HFT Stuttgart";
             var emailContent = '<div>Lieber Nutzer,<br/><br/>' +
               '<p>wir haben Ihre Anfrage zur Erneuerung Ihres Passwortes erhalten. Falls Sie diese Anfrage nicht gesendet haben, ignorieren Sie bitte diese E-Mail.<br/><br/>' +
@@ -181,7 +182,7 @@ module.exports = function (app, config, lang) {
               resetPasswordExpires: Date.now() + 3600000 // 1 hour
             }
             methods.updateCredential(credentialData, function(err) {
-                done(err, token, user);
+              if (err) { console.error(err) }
             })
   
             // send email
@@ -189,13 +190,9 @@ module.exports = function (app, config, lang) {
             mailer.options.subject = emailSubject
             mailer.options.html = emailContent
             mailer.transport.sendMail(mailer.options, function(err) {
-                done(err, 'done')
-              });
-            }
-            else {
-              done(err, 'no user found')
+              if (err) { console.error(err) }
+            })
           }
-          });
         }
       ], function(err) {
         if (err) {
@@ -205,12 +202,12 @@ module.exports = function (app, config, lang) {
           res.flash('success', 'Wenn Ihre E-Mail-Adresse registriert ist, wurde eine E-Mail mit dem weiteren Vorgehen an ' + emailAddress + ' versendet.')
         }
         res.redirect('/account/forgotPwd')
-      });
+      })
     })
 
     // reset
-    app.get('/reset/:token', function(req, res) {
-      methods.getUserByToken(req.params.token, function(err, user){
+    app.get('/reset/:token', async function(req, res) {
+      let user = await methods.getUserByToken(req.params.token)
       if (!user) {
         res.flash('error', 'Der Schlüssel zum zurücksetzen des Passworts ist ungültig oder abgelaufen.')
         res.redirect('/account/forgotPwd')
@@ -218,11 +215,14 @@ module.exports = function (app, config, lang) {
         res.render(lang+'/account/reset')
       }
     })
-    })
-    app.post('/reset/:token', function(req, res) {
+    app.post('/reset/:token', async function(req, res) {
       var newPwd = req.body.inputNewPwd
-      methods.getUserByToken(req.params.token, function(err, user){
-        if (user) {
+
+      let user = await methods.getUserByToken(req.params.token)
+      if (!user) {
+        res.flash('error', "User not found.")
+        res.redirect('/login')
+      } else {
         // encrypt password
         bcrypt.genSalt(saltRounds, function(err, salt) {
           bcrypt.hash(newPwd, salt, function(err, hash) {
@@ -235,30 +235,24 @@ module.exports = function (app, config, lang) {
               if (err) {
                 res.flash('error', "Datenbankfehler: Passwort kann nicht geändert werden.")
                 throw err
-                }
-                else {
+              } else {
                 res.flash('success', "Passwort aktualisiert!")
+                
                 // send notifiaction email
                 mailer.options.to = user.email
                 mailer.options.subject = constants.updatePasswordMailSubject
                 mailer.options.html = constants.updatePasswordMailContent+'<div>'+constants.mailSignature+'</div>'
                 mailer.transport.sendMail(mailer.options, function(err) {
-                    if (err) {
-                      console.log(err)
-                    }
-                  });
-                  // redirect to login page
+                  if (err) { console.log(err) }
+                })
+                
                 res.redirect('/login')
               }
             })
           });
         });
       }
-        else {
-          res.flash('error', "User not found.")
-          res.redirect('/login')
-        }
-      })
+
     })
 
     // ======================= CONTACT FORM ===========================