mirrors/mCaptcha
1
0
Fork 0
mirror of https://github.com/mCaptcha/mCaptcha.git synced 2025-05-04 06:02:49 +03:00
Code Issues Projects Releases Packages Wiki Activity

feat: implement user registration for postgres via sqlx

Browse source
This commit is contained in:
realaravinth 2022-05-11 00:53:47 +05:30
parent 8dde022851
commit 26a0935e5f
No known key found for this signature in database
GPG key ID: AD9F0F08E855ED88
3 changed files with 36 additions and 31 deletions
db/db-sqlx-postgres/src
errors.rslib.rs

9
db/db-sqlx-postgres/src/errors.rs
View file

@ -26,8 +26,13 @@ pub fn map_register_err(e: Error) -> DBError {
if let Error::Database(err) = e {
if err.code() == Some(Cow::from("23505")) {
let msg = err.message();
if msg.contains("mcaptcha_users_username_key") {
unimplemented!();
println!("{}", msg);
if msg.contains("mcaptcha_users_name_key") {
DBError::UsernameTaken
} else if msg.contains("mcaptcha_users_email_key") {
DBError::EmailTaken
} else if msg.contains("mcaptcha_users_secret_key") {
DBError::SecretTaken
} else {
DBError::DBError(Box::new(Error::Database(err)))
}

29
db/db-sqlx-postgres/src/lib.rs
View file

@ -100,6 +100,35 @@ impl MCDatabase for Database {
false
}
}
/// register a new user
async fn register(&self, p: &Register) -> DBResult<()> {
let res;
if let Some(email) = &p.email {
res = sqlx::query!(
"insert into mcaptcha_users
(name , password, email, secret) values ($1, $2, $3, $4)",
&p.username,
&p.hash,
&email,
&p.secret,
)
.execute(&self.pool)
.await;
} else {
res = sqlx::query!(
"INSERT INTO mcaptcha_users
(name , password, secret) VALUES ($1, $2, $3)",
&p.username,
&p.hash,
&p.secret,
)
.execute(&self.pool)
.await;
};
res.map_err(map_register_err)?;
Ok(())
}
}
fn now_unix_time_stamp() -> i64 {