feat: use new ServerCreate events

src/routes/bots/invite.rs

@@ -1,5 +1,5 @@
 use revolt_quark::{
-    models::{server_member::MemberCompositeKey, Channel, Member, User},
+    models::{Channel, User},
     perms, Db, EmptyResponse, Error, Permission, Ref, Result,
 };
 
@@ -51,15 +51,11 @@ pub async fn invite_bot(
                 .throw_permission(db, Permission::ManageServer)
                 .await?;
 
-            let member = Member {
+            let user = db.fetch_user(&bot.id).await?;
-                id: MemberCompositeKey {
+            server
-                    server: server.id,
+                .create_member(db, user, None)
-                    user: bot.id,
+                .await
-                },
+                .map(|_| EmptyResponse)
-                ..Default::default()
-            };
-
-            db.insert_member(&member).await.map(|_| EmptyResponse)
         }
         InviteBotDestination::Group { group } => {
             let channel = db.fetch_channel(&group).await?;

src/routes/servers/roles_create.rs

@@ -69,6 +69,6 @@ pub async fn req(
 
     Ok(Json(NewRoleResponse {
         id: role.create(db, &server.id).await?,
-        role: role,
+        role,
     }))
 }

src/routes/servers/server_create.rs

@@ -1,7 +1,7 @@
 use std::collections::HashMap;
 
 use revolt_quark::{
-    models::{server_member::MemberCompositeKey, Channel, Member, Server, User},
+    models::{Channel, Server, User},
     Db, Error, Result, DEFAULT_PERMISSION_SERVER,
 };
 
@@ -13,7 +13,7 @@ use validator::Validate;
 use crate::util::variables::MAX_SERVER_COUNT;
 
 /// # Server Data
-#[derive(Validate, Serialize, Deserialize, JsonSchema)]
+#[derive(Validate, Deserialize, JsonSchema)]
 pub struct DataCreateServer {
     /// Server name
     #[validate(length(min = 1, max = 32))]
@@ -26,12 +26,25 @@ pub struct DataCreateServer {
     nsfw: Option<bool>,
 }
 
+/// # Create Server Response
+#[derive(Validate, Serialize, JsonSchema)]
+pub struct CreateServerResponse {
+    /// Server object
+    server: Server,
+    /// Default channels
+    channels: Vec<Channel>,
+}
+
 /// # Create Server
 ///
 /// Create a new server.
 #[openapi(tag = "Server Information")]
 #[post("/create", data = "<info>")]
-pub async fn req(db: &Db, user: User, info: Json<DataCreateServer>) -> Result<Json<Server>> {
+pub async fn req(
+    db: &Db,
+    user: User,
+    info: Json<DataCreateServer>,
+) -> Result<Json<CreateServerResponse>> {
     let info = info.into_inner();
     info.validate()
         .map_err(|error| Error::FailedValidation { error })?;
@@ -67,9 +80,11 @@ pub async fn req(db: &Db, user: User, info: Json<DataCreateServer>) -> Result<Js
         nsfw: nsfw.unwrap_or(false),
     };
 
+    db.insert_channel(&channel).await?;
+
     let server = Server {
-        id: server_id,
+        id: server_id.clone(),
-        owner: user.id,
+        owner: user.id.clone(),
         name,
         description,
         channels: vec![channel_id],
@@ -78,18 +93,6 @@ pub async fn req(db: &Db, user: User, info: Json<DataCreateServer>) -> Result<Js
         ..Default::default()
     };
 
-    let member = Member {
+    let channels = server.create_member(db, user, Some(vec![channel])).await?;
-        id: MemberCompositeKey {
+    Ok(Json(CreateServerResponse { server, channels }))
-            server: server.id.clone(),
-            user: server.owner.clone(),
-        },
-        ..Default::default()
-    };
-
-    db.insert_channel(&channel).await?;
-
-    server.create(db).await?;
-    member.create(db).await?;
-
-    Ok(Json(server))
 }