if原始代碼在發(fā)送響應(yīng)之前并沒有等待兩個(gè)分支完成。由于嵌套，很難在回調(diào)中構(gòu)造這樣的代碼。
盡可能使用async函數(shù)await。它允許更多的可讀代碼和更容易的錯(cuò)誤處理。所以這個(gè)答案更多的是代碼審查，而不是針對您的問題的簡單修復(fù)。
拆分出一些在其他路由中有用的通用幫助代碼：
// Generate errors for the web, with context
function responseError(message, status, data){
? ? const error = new Error(message)
? ? error.status = status
? ? for (const key in data){
? ? ? ? error[key] = data[key]
? ? }
? ? return error
}
// Turn mysql callbacks into promises (or use util.promisify)
async function runQuery(query, values){
? ? return new Promise((resolve, reject) => {
? ? ? ? connection.query(query, values, function(error, results){
? ? ? ? ? ? if (error) return reject(error)
? ? ? ? ? ? return resolve(results)
? ? ? ? })
? ? })
}
async function runUpdateQuery(query, values){
? ? const results = await runQuery(query, values)
? ? if (!results) throw responseError('No update result', 500, { query })
? ? if (!results.affectedRows) throw responseError('No affected rows', 400, { query })
? ? return results
}
來自兩個(gè)條件的代碼if可以很容易地分開，以及其他帳戶操作。
async function apiAuthUserId(id, password){
? ? const results = await runQuery('SELECT * FROM accounts WHERE id = ?', id)
? ? if (!results.length) throw responseError('No account', 400, { id })
? ? const isMatch = await bcrypt.compare(password_current, results[0].password)
? ? if (!isMatch) throw responseError('Password doesn\'t match', 400)
? ? return true
}
async function apiUpdatePassword(id, password){
? ? let newPassword = req.body.password_new
? ? let hashed_password = await hashPassword(newPassword)
? ? await runUpdateQuery('UPDATE accounts SET password = ? WHERE id = ?', [hashed_password, req.body.id])
? ? return id
}
async function apiUpdateEmail(id, email){
? ? await runUpdateQuery('UPDATE accounts SET email = ? WHERE id = ?', [email, id])
? ? return email
}
async function apiUpdateLicenseKey(id, licenseKey){
? ? const response_license = await axios.get(`https://voltcloud.net/api/hosting/check-key/${licenseKey}`, {
? ? ? ? headers: {
? ? ? ? ? ? authorization: 'somekey'
? ? ? ? }
? ? })
? ? const data = response_license.data
? ? if (!data) {
? ? ? throw responseError('No license key response data', 500, { response: response_license })
? ? }
? ? if (data.active !== 1) {
? ? ? throw responseError('License key not active', 400,? { key: licenseKey })
? ? }
? ? const response_activate = await axios({
? ? ? ? method: 'post',
? ? ? ? url: `https://voltcloud.net/api/hosting/activate-key/${licenseKey}`,
? ? ? ? headers: {
? ? ? ? ? ? authorization: 'somekey'
? ? ? ? }
? ? })
? ? switch (response_activate.data){
? ? ? ? case 'License already active!':
? ? ? ? ? ? throw responseError('License key is already active!', 400, { response: response_activate })
? ? ? ? case 'Failed to update key.':
? ? ? ? ? ? throw responseError('Unable to save settings!', 400, { response: response_activate })
? ? ? ? case 'Success':
? ? ? ? ? ? await runUpdateQuery('UPDATE accounts SET license_key = ? WHERE id = ?', [licenseKey, req.body.id])
? ? ? ? ? ? return licenseKey
? ? ? ? default:
? ? ? ? ? ? throw responseError('Unable to save settings!', 500, { response: response_activate })
? ? }
}
這樣您的路由代碼就可以更簡潔一些，并顯示需要完成的工作，而不是如何完成所有工作。
app.post('/api/edit-profile', regularFunctions, async function (req, res) {
? ? const changed = []
? ? try {
? ? ? ? const { id, email, password_current } = req.body
? ? ? ? await apiAuthUserId(id, password_current)
? ? ? ? // Password matches
? ? ? ? if (req.body.password_new) {
? ? ? ? ? ? await apiUpdatePassword(id, req.body.password_new)
? ? ? ? ? ? changed.push('password')
? ? ? ? }
? ? ? ? // License key
? ? ? ? if (req.body.license_key) {
? ? ? ? ? ? await apiUpdateLicenseKey(id, req.body.license_key)
? ? ? ? ? ? changed.push('license key')
? ? ? ? }
? ? ? ? await apiUpdateEmail(id, email)
? ? ? ? changed.push('email')
? ? ? ? let finalTxt = `Successfully changed ${changed.join(' and ')}.`
? ? ? ? res.send(finalTxt)
? ? }
? ? catch (error) {
? ? ? ? // If your not using transactions, might need to deal with partial `changed` responses here.?
? ? ? ? console.error('Error /api/edit-profile', error)
? ? ? ? res.status(error.status||500).send(`Error: ${error.message}`)
? ? }
});
