|
|
|
@ -75,7 +75,7 @@ impl GistDatabase for Database {
|
|
|
|
|
async fn email_login(&self, email: &str) -> DBResult<Creds> {
|
|
|
|
|
sqlx::query_as!(
|
|
|
|
|
Creds,
|
|
|
|
|
r#"SELECT username, password FROM admin_users WHERE email = ($1)"#,
|
|
|
|
|
r#"SELECT username, password FROM gists_users WHERE email = ($1)"#,
|
|
|
|
|
email,
|
|
|
|
|
)
|
|
|
|
|
.fetch_one(&self.pool)
|
|
|
|
@ -89,7 +89,7 @@ impl GistDatabase for Database {
|
|
|
|
|
async fn username_login(&self, username: &str) -> DBResult<Password> {
|
|
|
|
|
sqlx::query_as!(
|
|
|
|
|
Password,
|
|
|
|
|
r#"SELECT password FROM admin_users WHERE username = ($1)"#,
|
|
|
|
|
r#"SELECT password FROM gists_users WHERE username = ($1)"#,
|
|
|
|
|
username,
|
|
|
|
|
)
|
|
|
|
|
.fetch_one(&self.pool)
|
|
|
|
@ -102,7 +102,7 @@ impl GistDatabase for Database {
|
|
|
|
|
|
|
|
|
|
async fn email_register(&self, payload: &EmailRegisterPayload) -> DBResult<()> {
|
|
|
|
|
sqlx::query!(
|
|
|
|
|
"insert into admin_users
|
|
|
|
|
"insert into gists_users
|
|
|
|
|
(username , password, email, secret) values ($1, $2, $3, $4)",
|
|
|
|
|
payload.username,
|
|
|
|
|
payload.password,
|
|
|
|
@ -117,7 +117,7 @@ impl GistDatabase for Database {
|
|
|
|
|
|
|
|
|
|
async fn username_register(&self, payload: &UsernameRegisterPayload) -> DBResult<()> {
|
|
|
|
|
sqlx::query!(
|
|
|
|
|
"INSERT INTO admin_users
|
|
|
|
|
"INSERT INTO gists_users
|
|
|
|
|
(username , password, secret) VALUES ($1, $2, $3)",
|
|
|
|
|
payload.username,
|
|
|
|
|
payload.password,
|
|
|
|
@ -131,7 +131,7 @@ impl GistDatabase for Database {
|
|
|
|
|
|
|
|
|
|
async fn update_email(&self, payload: &UpdateEmailPayload) -> DBResult<()> {
|
|
|
|
|
let x = sqlx::query!(
|
|
|
|
|
"UPDATE admin_users set email = $1
|
|
|
|
|
"UPDATE gists_users set email = $1
|
|
|
|
|
WHERE username = $2",
|
|
|
|
|
payload.email,
|
|
|
|
|
payload.username,
|
|
|
|
@ -146,7 +146,7 @@ impl GistDatabase for Database {
|
|
|
|
|
}
|
|
|
|
|
async fn update_password(&self, payload: &Creds) -> DBResult<()> {
|
|
|
|
|
let x = sqlx::query!(
|
|
|
|
|
"UPDATE admin_users set password = $1
|
|
|
|
|
"UPDATE gists_users set password = $1
|
|
|
|
|
WHERE username = $2",
|
|
|
|
|
payload.password,
|
|
|
|
|
payload.username,
|
|
|
|
@ -161,7 +161,7 @@ impl GistDatabase for Database {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async fn email_exists(&self, email: &str) -> DBResult<bool> {
|
|
|
|
|
match sqlx::query!("SELECT id from admin_users WHERE email = $1", email)
|
|
|
|
|
match sqlx::query!("SELECT id from gists_users WHERE email = $1", email)
|
|
|
|
|
.fetch_one(&self.pool)
|
|
|
|
|
.await
|
|
|
|
|
{
|
|
|
|
@ -172,7 +172,7 @@ impl GistDatabase for Database {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async fn delete_account(&self, username: &str) -> DBResult<()> {
|
|
|
|
|
sqlx::query!("DELETE FROM admin_users WHERE username = ($1)", username,)
|
|
|
|
|
sqlx::query!("DELETE FROM gists_users WHERE username = ($1)", username,)
|
|
|
|
|
.execute(&self.pool)
|
|
|
|
|
.await
|
|
|
|
|
.map_err(|e| DBError::DBError(Box::new(e)))?;
|
|
|
|
@ -180,7 +180,7 @@ impl GistDatabase for Database {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async fn username_exists(&self, username: &str) -> DBResult<bool> {
|
|
|
|
|
match sqlx::query!("SELECT id from admin_users WHERE username = $1", username)
|
|
|
|
|
match sqlx::query!("SELECT id from gists_users WHERE username = $1", username)
|
|
|
|
|
.fetch_one(&self.pool)
|
|
|
|
|
.await
|
|
|
|
|
{
|
|
|
|
@ -192,7 +192,7 @@ impl GistDatabase for Database {
|
|
|
|
|
|
|
|
|
|
async fn update_username(&self, payload: &UpdateUsernamePayload) -> DBResult<()> {
|
|
|
|
|
let x = sqlx::query!(
|
|
|
|
|
"UPDATE admin_users set username = $1 WHERE username = $2",
|
|
|
|
|
"UPDATE gists_users set username = $1 WHERE username = $2",
|
|
|
|
|
payload.new_username,
|
|
|
|
|
payload.old_username,
|
|
|
|
|
)
|
|
|
|
@ -206,7 +206,7 @@ impl GistDatabase for Database {
|
|
|
|
|
}
|
|
|
|
|
async fn update_secret(&self, username: &str, secret: &str) -> DBResult<()> {
|
|
|
|
|
let x = sqlx::query!(
|
|
|
|
|
"UPDATE admin_users set secret = $1
|
|
|
|
|
"UPDATE gists_users set secret = $1
|
|
|
|
|
WHERE username = $2",
|
|
|
|
|
secret,
|
|
|
|
|
username,
|
|
|
|
@ -227,7 +227,7 @@ impl GistDatabase for Database {
|
|
|
|
|
}
|
|
|
|
|
let secret = sqlx::query_as!(
|
|
|
|
|
Secret,
|
|
|
|
|
r#"SELECT secret FROM admin_users WHERE username = ($1)"#,
|
|
|
|
|
r#"SELECT secret FROM gists_users WHERE username = ($1)"#,
|
|
|
|
|
username,
|
|
|
|
|
)
|
|
|
|
|
.fetch_one(&self.pool)
|
|
|
|
|