-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathaccountUtils.js
More file actions
129 lines (115 loc) · 3.75 KB
/
accountUtils.js
File metadata and controls
129 lines (115 loc) · 3.75 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
const bcrypt = require("bcrypt");
class AccountUtils {
generatePasswordHash(password, done) {
bcrypt.hash(password, 10, (error, result) => {
if (error) {
done({ success: false, error });
return;
}
done({
success: true,
hash: result,
});
});
}
comparePasswordWithHash(password, hash, done) {
bcrypt.compare(password, hash, (error, result) => {
if (error) {
done({ success: false, error });
return;
}
done({
success: true,
isMatch: result,
});
});
}
addAccount(account, done) {
dbUtils.performQuery(
"INSERT INTO Users (username, passwordHash, emailAddress, score) VALUES (?, ?, ?, 0)",
[account.username, account.passwordHash, account.emailAddress],
(error) => {
if (error) {
done(dbUtils.convertSqlErrorToText(error));
return;
}
done(null);
},
);
}
getAccountByUsername(username, done) {
return niceUtils.performAsyncOperation((callback) => {
dbUtils.performQuery(
"SELECT * FROM Users WHERE username = ?",
[username],
(error, results) => {
if (error) {
callback(dbUtils.convertSqlErrorToText(error), null);
return;
}
if (results.length > 0) {
callback(null, results[0]);
} else {
callback(null, null);
}
},
);
}, 2, done);
}
updateAccount(uid, valueSet, done) {
const tempQueryTextList = [];
const tempValueList = [];
for (const name in valueSet) {
const tempValue = valueSet[name];
tempQueryTextList.push(name + " = ?");
tempValueList.push(tempValue);
}
const tempQueryText = tempQueryTextList.join(", ");
tempValueList.push(uid);
return niceUtils.performAsyncOperation((callback) => {
dbUtils.performQuery(
"UPDATE Users SET " + tempQueryText + " WHERE uid = ?",
tempValueList,
(error) => {
if (error) {
callback(dbUtils.convertSqlErrorToText(error));
return;
}
callback(null);
},
);
}, 1, done);
}
removeAccount(uid, done) {
return niceUtils.performAsyncOperation((callback) => {
dbUtils.performQuery(
"DELETE FROM Users WHERE uid = ?",
[uid],
(error) => {
if (error) {
callback(dbUtils.convertSqlErrorToText(error));
return;
}
callback(null);
},
);
}, 1, done);
}
getLeaderboardAccounts(amount, done) {
dbUtils.performQuery(
"SELECT * FROM Users ORDER BY score DESC LIMIT 20",
[],
(error, results) => {
if (error) {
done(dbUtils.convertSqlErrorToText(error), null);
return;
}
done(null, results);
},
);
}
}
const accountUtils = new AccountUtils();
module.exports = { accountUtils };
const { niceUtils } = require("./niceUtils");
const { dbUtils } = require("./dbUtils");