refactor: use await in updatePassword API

Author: venki91

lib/index.js

@@ -629,25 +629,29 @@ class ErrsolePostgres extends EventEmitter {
     }
 
     const query = 'SELECT * FROM errsole_users WHERE email = $1';
-    return new Promise((resolve, reject) => {
-      this.pool.query(query, [email], async (err, results) => {
-        if (err) return reject(err);
-        if (!results.rows.length) return reject(new Error('User not found.'));
+    const { rows } = await this.pool.query(query, [email]);
 
-        const user = results.rows[0];
-        const isPasswordCorrect = await bcrypt.compare(currentPassword, user.hashed_password);
-        if (!isPasswordCorrect) return reject(new Error('Current password is incorrect.'));
+    if (!rows.length) {
+      throw new Error('User not found.');
+    }
 
-        const hashedPassword = await bcrypt.hash(newPassword, 10);
-        const updateQuery = 'UPDATE errsole_users SET hashed_password = $1 WHERE email = $2';
-        this.pool.query(updateQuery, [hashedPassword, email], (err, updateResults) => {
-          if (err) return reject(err);
-          if (updateResults.rowCount === 0) return reject(new Error('Password update failed.'));
-          delete user.hashed_password;
-          resolve({ item: user });
-        });
-      });
-    });
+    const user = rows[0];
+    const isPasswordCorrect = await bcrypt.compare(currentPassword, user.hashed_password);
+
+    if (!isPasswordCorrect) {
+      throw new Error('Current password is incorrect.');
+    }
+
+    const hashedPassword = await bcrypt.hash(newPassword, 10);
+    const updateQuery = 'UPDATE errsole_users SET hashed_password = $1 WHERE email = $2';
+    const updateResults = await this.pool.query(updateQuery, [hashedPassword, email]);
+
+    if (updateResults.rowCount === 0) {
+      throw new Error('Password update failed.');
+    }
+
+    delete user.hashed_password;
+    return { item: user };
   }
 
   /**