3 schema::local_user::dsl::{
11 actor_language::{LocalUserLanguage, SiteLanguage},
12 local_user::{LocalUser, LocalUserInsertForm, LocalUserUpdateForm},
15 utils::{get_conn, naive_now, DbPool},
17 use bcrypt::{hash, DEFAULT_COST};
18 use diesel::{dsl::insert_into, result::Error, ExpressionMethods, QueryDsl};
19 use diesel_async::RunQueryDsl;
22 pub async fn update_password(
24 local_user_id: LocalUserId,
26 ) -> Result<Self, Error> {
27 let conn = &mut get_conn(pool).await?;
28 let password_hash = hash(new_password, DEFAULT_COST).expect("Couldn't hash password");
30 diesel::update(local_user.find(local_user_id))
32 password_encrypted.eq(password_hash),
33 validator_time.eq(naive_now()),
35 .get_result::<Self>(conn)
39 pub async fn set_all_users_email_verified(pool: &DbPool) -> Result<Vec<Self>, Error> {
40 let conn = &mut get_conn(pool).await?;
41 diesel::update(local_user)
42 .set(email_verified.eq(true))
43 .get_results::<Self>(conn)
47 pub async fn set_all_users_registration_applications_accepted(
49 ) -> Result<Vec<Self>, Error> {
50 let conn = &mut get_conn(pool).await?;
51 diesel::update(local_user)
52 .set(accepted_application.eq(true))
53 .get_results::<Self>(conn)
59 impl Crud for LocalUser {
60 type InsertForm = LocalUserInsertForm;
61 type UpdateForm = LocalUserUpdateForm;
62 type IdType = LocalUserId;
63 async fn read(pool: &DbPool, local_user_id: LocalUserId) -> Result<Self, Error> {
64 let conn = &mut get_conn(pool).await?;
65 local_user.find(local_user_id).first::<Self>(conn).await
67 async fn delete(pool: &DbPool, local_user_id: LocalUserId) -> Result<usize, Error> {
68 let conn = &mut get_conn(pool).await?;
69 diesel::delete(local_user.find(local_user_id))
73 async fn create(pool: &DbPool, form: &Self::InsertForm) -> Result<Self, Error> {
74 let conn = &mut get_conn(pool).await?;
75 let mut form_with_encrypted_password = form.clone();
77 hash(&form.password_encrypted, DEFAULT_COST).expect("Couldn't hash password");
78 form_with_encrypted_password.password_encrypted = password_hash;
80 let local_user_ = insert_into(local_user)
81 .values(form_with_encrypted_password)
82 .get_result::<Self>(conn)
84 .expect("couldnt create local user");
86 let site_languages = SiteLanguage::read_local(pool).await;
87 if let Ok(langs) = site_languages {
88 // if site exists, init user with site languages
89 LocalUserLanguage::update(pool, langs, local_user_.id).await?;
91 // otherwise, init with all languages (this only happens during tests and
92 // for first admin user, which is created before site)
93 LocalUserLanguage::update(pool, vec![], local_user_.id).await?;
100 local_user_id: LocalUserId,
101 form: &Self::UpdateForm,
102 ) -> Result<Self, Error> {
103 let conn = &mut get_conn(pool).await?;
104 diesel::update(local_user.find(local_user_id))
106 .get_result::<Self>(conn)