allow to create users

src/model/user/regular.rs

@@ -1,13 +1,66 @@
-use super::User;
+use super::{ManageUserUser, User};
 use crate::{
-    model::{activity::ActivityBuilder, mail::Mail},
-    special_user,
+    model::{activity::ActivityBuilder, mail::Mail, notification::Notification, role::Role},
+    special_user, NonEmptyString,
 };
-use rocket::async_trait;
+use chrono::NaiveDate;
+use rocket::{async_trait, fs::TempFile, tokio::io::AsyncReadExt};
 use sqlx::SqlitePool;
 
 special_user!(RegularUser, +"Donau Linz");
 
+pub trait ClubMember {
+    async fn create_member(
+        db: &SqlitePool,
+        created_by: &ManageUserUser,
+        role: &Role,
+        name: NonEmptyString,
+        mail: &str,
+        financial: Option<Role>,
+        birthdate: &NaiveDate,
+        member_since: &NaiveDate,
+        phone: NonEmptyString,
+        address: NonEmptyString,
+        membership_pdf: &TempFile<'_>,
+    ) -> Result<User, String> {
+        if membership_pdf.len() == 0 {
+            return Err("Keine Beitrittserklärung mitgeschickt.".to_string());
+        }
+
+        let mut stream = membership_pdf.open().await.unwrap();
+        let mut buffer = Vec::new();
+        stream.read_to_end(&mut buffer).await.unwrap();
+
+        let name = name.as_str();
+        let phone = phone.as_str();
+        let address = address.as_str();
+
+        sqlx::query!(
+            "INSERT INTO user(name, member_since_date, birthdate, mail, phone, address, membership_pdf)
+            VALUES (?,?,?,?,?,?,?)",
+            name, member_since, birthdate, mail, phone, address,buffer
+        )
+        .execute(db)
+        .await
+        .map_err(|e| e.to_string())?;
+
+        let user = User::find_by_name(db, name).await.unwrap();
+        user.change_financial(db, created_by, financial).await?;
+        user.add_role(db, created_by, role).await?;
+
+        ActivityBuilder::new(&format!(
+            "{created_by} hat Mitglied {user} mit der Rolle {role} angelegt."
+        ))
+        .relevant_for_user(&user)
+        .save(db)
+        .await;
+
+        Ok(user)
+    }
+}
+
+impl ClubMember for RegularUser {}
+
 impl RegularUser {
     pub(crate) async fn send_welcome_mail_to_user(
         &self,
@@ -47,10 +100,54 @@ ASKÖ Ruderverein Donau Linz", self.name),
         ).await?;
 
         ActivityBuilder::new(&format!("Willkommensmail für {self} wurde an {mail} verschickt (Handbuch, Signal-Gruppe, App-Info, Fingerprint, WLAN)."))
-                .relevant_for_user(&self)
+                .relevant_for_user(self)
                 .save(db)
                 .await;
 
         Ok(())
     }
+
+    pub(crate) async fn create(
+        db: &SqlitePool,
+        created_by: &ManageUserUser,
+        smtp_pw: &str,
+        name: NonEmptyString,
+        mail: &str,
+        financial: Option<Role>,
+        birthdate: &NaiveDate,
+        member_since: &NaiveDate,
+        phone: NonEmptyString,
+        address: NonEmptyString,
+        membership_pdf: &TempFile<'_>,
+    ) -> Result<(), String> {
+        let role = Role::find_by_name(db, "Donau Linz").await.unwrap();
+        let user = Self::create_member(
+            db,
+            created_by,
+            &role,
+            name,
+            mail,
+            financial,
+            birthdate,
+            member_since,
+            phone,
+            address,
+            membership_pdf,
+        )
+        .await?;
+
+        let user = Self::new(db, &user).await.unwrap();
+        user.send_welcome_mail_to_user(db, smtp_pw).await?;
+
+        Notification::create_for_steering_people(
+            db,
+            &format!("Liebe Steuerberechtigte, es gibt ein neues Mitglied: {user} 🎉"),
+            "Neues Vereinsmitglied",
+            None,
+            None,
+        )
+        .await;
+
+        Ok(())
+    }
 }