Add users.add()

This commit is contained in:
Johannes Zellner 2016-08-11 13:15:51 +02:00
parent dff9996fda
commit 3f86ad2945

View file

@ -84,6 +84,29 @@ module.exports.findByUsername = (username, callback) => {
});
};
module.exports.add = (username, password, email, callback) => {
db.getConnection((err, connection) => {
if (err) {
return callback(err);
}
connection.query('INSERT INTO `users` (`username`, `password`, `email`, `created`) VALUES (?, ?, ?, NOW())', [username, password, email], (err, result) => {
connection.release();
if (err) {
return callback(err);
}
let id = result && result.insertId;
if (!id) {
return callback(new Error('Could not store user row'));
}
return callback(null, id);
});
});
};
/**
* Fetches user by username and password
*