summaryrefslogtreecommitdiff
path: root/src/services/db.rs
diff options
context:
space:
mode:
authormrw1593 <botahamec@outlook.com>2023-05-13 13:53:34 -0400
committermrw1593 <botahamec@outlook.com>2023-05-29 10:45:57 -0400
commit65a541fd0b32adc68f3bbbab14145ebf563b7ae1 (patch)
tree6b73e41bdca24eb85b05dd1c0b5684a225c93dd5 /src/services/db.rs
parentfdbc7ed756ce455c956dd7a5885db6b6eabfd578 (diff)
Change user_id to id
Diffstat (limited to 'src/services/db.rs')
-rw-r--r--src/services/db.rs32
1 files changed, 16 insertions, 16 deletions
diff --git a/src/services/db.rs b/src/services/db.rs
index d717594..6136a89 100644
--- a/src/services/db.rs
+++ b/src/services/db.rs
@@ -7,7 +7,7 @@ use crate::models::User;
use super::crypto::PasswordHash;
struct UserRow {
- user_id: Vec<u8>,
+ id: Vec<u8>,
username: String,
password_hash: Vec<u8>,
password_salt: Vec<u8>,
@@ -24,7 +24,7 @@ impl TryFrom<UserRow> for User {
row.password_version as u8,
);
let user = User {
- user_id: Uuid::from_slice(&row.user_id)?,
+ id: Uuid::from_slice(&row.id)?,
username: row.username.into_boxed_str(),
password,
};
@@ -42,7 +42,7 @@ pub async fn user_id_exists<'c>(
id: Uuid,
) -> Result<bool, RawUnexpected> {
let exists = query_scalar!(
- r#"SELECT EXISTS(SELECT user_id FROM users WHERE user_id = ?) as "e: bool""#,
+ r#"SELECT EXISTS(SELECT id FROM users WHERE id = ?) as "e: bool""#,
id
)
.fetch_one(conn)
@@ -56,7 +56,7 @@ pub async fn username_is_used<'c>(
username: &str,
) -> Result<bool, RawUnexpected> {
let exists = query_scalar!(
- r#"SELECT EXISTS(SELECT user_id FROM users WHERE username = ?) as "e: bool""#,
+ r#"SELECT EXISTS(SELECT id FROM users WHERE username = ?) as "e: bool""#,
username
)
.fetch_one(conn)
@@ -71,8 +71,8 @@ pub async fn get_user<'c>(
) -> Result<Option<User>, RawUnexpected> {
let record = query_as!(
UserRow,
- r"SELECT user_id, username, password_hash, password_salt, password_version
- FROM users WHERE user_id = ?",
+ r"SELECT id, username, password_hash, password_salt, password_version
+ FROM users WHERE id = ?",
user_id
)
.fetch_optional(conn)
@@ -89,7 +89,7 @@ pub async fn get_user_by_username<'c>(
) -> Result<Option<User>, RawUnexpected> {
let record = query_as!(
UserRow,
- r"SELECT user_id, username, password_hash, password_salt, password_version
+ r"SELECT id, username, password_hash, password_salt, password_version
FROM users WHERE username = ?",
username
)
@@ -108,7 +108,7 @@ pub async fn search_users<'c>(
let username = format!("%{username}%");
let records = query_as!(
UserRow,
- r"SELECT user_id, username, password_hash, password_salt, password_version
+ r"SELECT id, username, password_hash, password_salt, password_version
FROM users
WHERE LOCATE(?, username) != 0",
username,
@@ -131,7 +131,7 @@ pub async fn search_users_limit<'c>(
let username = format!("%{username}%");
let records = query_as!(
UserRow,
- r"SELECT user_id, username, password_hash, password_salt, password_version
+ r"SELECT id, username, password_hash, password_salt, password_version
FROM users
WHERE LOCATE(?, username) != 0
LIMIT ?
@@ -153,7 +153,7 @@ pub async fn get_username<'c>(
conn: impl Executor<'c, Database = MySql>,
user_id: Uuid,
) -> Result<Option<Box<str>>, RawUnexpected> {
- let username = query_scalar!(r"SELECT username FROM users where user_id = ?", user_id)
+ let username = query_scalar!(r"SELECT username FROM users where id = ?", user_id)
.fetch_optional(conn)
.await?
.map(String::into_boxed_str);
@@ -166,9 +166,9 @@ pub async fn new_user<'c>(
user: &User,
) -> Result<MySqlQueryResult, sqlx::Error> {
query!(
- r"INSERT INTO users (user_id, username, password_hash, password_salt, password_version)
+ r"INSERT INTO users (id, username, password_hash, password_salt, password_version)
VALUES (?, ?, ?, ?, ?)",
- user.user_id,
+ user.id,
user.username(),
user.password_hash(),
user.password_salt(),
@@ -188,12 +188,12 @@ pub async fn update_user<'c>(
password_hash = ?,
password_salt = ?,
password_version = ?
- WHERE user_id = ?",
+ WHERE id = ?",
user.username(),
user.password_hash(),
user.password_salt(),
user.password_version(),
- user.user_id
+ user.id
)
.execute(conn)
.await
@@ -205,7 +205,7 @@ pub async fn update_username<'c>(
username: &str,
) -> Result<MySqlQueryResult, sqlx::Error> {
query!(
- r"UPDATE users SET username = ? WHERE user_id = ?",
+ r"UPDATE users SET username = ? WHERE id = ?",
username,
user_id
)
@@ -223,7 +223,7 @@ pub async fn update_password<'c>(
password_hash = ?,
password_salt = ?,
password_version = ?
- WHERE user_id = ?",
+ WHERE id = ?",
password.hash(),
password.salt(),
password.version(),