Actually query by username instead of just delegate to get() in getByUsername()

2016-04-01 21:43:48 +02:00
parent 0b1dcd2940
commit a112e614e6
1 changed files with 6 additions and 2 deletions
--- a/src/userdb.js
+++ b/src/userdb.js
@@ -41,8 +41,12 @@ function getByUsername(username, callback) {
    assert.strictEqual(typeof username, 'string');
    assert.strictEqual(typeof callback, 'function');

-    // currently username is also our id
-    get(username, callback);
+    database.query('SELECT ' + USERS_FIELDS + ' FROM users WHERE username = ?', [ username ], function (error, result) {
+        if (error) return callback(new DatabaseError(DatabaseError.INTERNAL_ERROR, error));
+        if (result.length === 0) return callback(new DatabaseError(DatabaseError.NOT_FOUND));
+
+        callback(null, result[0]);
+    });
 }

 function getByEmail(email, callback) {