dbController.ts

import { dbConnection } from '../config/dbconn'

const dbController = {
  // ===================== user db =====================
  registerNewUser: function (data: any, callback: any) {
    dbConnection.user.getConnection(function (err: any, thisconn: any) {
      thisconn.beginTransaction(function (err: any) { // START TRANSACTION
        if (err) { throw err }
        // insert profile
        thisconn.query('INSERT INTO user SET ?', data.profile, function (err: any, results: any, fields: any) {
          if (err) {
            return thisconn.rollback(function () {
              throw err
            })
          }
          const newUserId: number = results.insertId
          // set password
          const credentialData: any = {
            user_id: newUserId,
            password: data.password
          }
          thisconn.query('INSERT INTO credential SET ?', credentialData, function (err: any, results: any, fields: any) {
            if (err) {
              return thisconn.rollback(function () {
                throw err
              })
            }
            // set default user-project-role
            const projectRoleData: any = {
              project_id: 1, // M4_LAB
              role_id: 2, // USER
              user_id: newUserId
            }
            thisconn.query('INSERT INTO user_project_role SET ?', projectRoleData, function (err: any, results: any, fields: any) {
              if (err) {
                return thisconn.rollback(function () {
                  throw err
                })
              }
              // MLAB-129: INSERT verification token
              const verificationData: any = {
                user_id: newUserId,
                token: data.verificationToken
              }
              thisconn.query('INSERT INTO verification SET ?', verificationData, function (err: any, results: any, fields: any) {
                if (err) {
                  return thisconn.rollback(function () {
                    throw err
                  })
                }
                // COMMIT
                thisconn.commit(function (err: any) {
                  if (err) {
                    return thisconn.rollback(function () {
                      throw err
                    })
                  }
                })
              })
            })
          })
        })
	    })
      callback(err)
    })
  },
  getUserByEmail: async function (email: any) {
    try {
      const rows: any = await dbConnection.user.promise().query('SELECT id, verificationStatus, salutation, title, firstname, lastname, industry, organisation, speciality, m4lab_idp FROM user WHERE email = "' + email + '"')
      if (rows[0][0]) {