diff --git a/src/routes/channels/group_add_member.rs b/src/routes/channels/group_add_member.rs index 1bb6ef1a..59f87c38 100644 --- a/src/routes/channels/group_add_member.rs +++ b/src/routes/channels/group_add_member.rs @@ -1,15 +1,22 @@ -use revolt_quark::{Error, EmptyResponse, Result, models::{User, Channel}, Ref, Db, perms, ChannelPermission}; +use revolt_quark::{ + models::{Channel, User}, + perms, ChannelPermission, Db, EmptyResponse, Error, Ref, Result, +}; use mongodb::bson::doc; #[put("//recipients/")] -pub async fn req( - db: &Db, - user: User, target: Ref, member: Ref -) -> Result { +pub async fn req(db: &Db, user: User, target: Ref, member: Ref) -> Result { let channel = target.as_channel(db).await?; - if !perms(&user).channel(&channel).calc_channel(db).await.get_invite_others() { - return Err(Error::MissingPermission { permission: ChannelPermission::InviteOthers as i32 }) + if !perms(&user) + .channel(&channel) + .calc_channel(db) + .await + .get_invite_others() + { + return Err(Error::MissingPermission { + permission: ChannelPermission::InviteOthers as i32, + }); } match channel { @@ -18,6 +25,6 @@ pub async fn req( db.add_user_to_group(&id, &user.id).await?; Ok(EmptyResponse) } - _ => Err(Error::InvalidOperation) + _ => Err(Error::InvalidOperation), } } diff --git a/src/routes/channels/group_create.rs b/src/routes/channels/group_create.rs index 1410600a..0ce83310 100644 --- a/src/routes/channels/group_create.rs +++ b/src/routes/channels/group_create.rs @@ -35,7 +35,9 @@ pub async fn req(db: &Db, user: User, info: Json) -> Result> set.insert(user.id.clone()); if set.len() > *MAX_GROUP_SIZE { - return Err(Error::GroupTooLarge { max: *MAX_GROUP_SIZE }); + return Err(Error::GroupTooLarge { + max: *MAX_GROUP_SIZE, + }); } for target in &set { diff --git a/src/routes/channels/group_remove_member.rs b/src/routes/channels/group_remove_member.rs index e6a90232..dce8008c 100644 --- a/src/routes/channels/group_remove_member.rs +++ b/src/routes/channels/group_remove_member.rs @@ -1,18 +1,23 @@ -use revolt_quark::{Error, EmptyResponse, Result, Ref, Db, models::{Channel, User}}; +use revolt_quark::{ + models::{Channel, User}, + Db, EmptyResponse, Error, Ref, Result, +}; use mongodb::bson::doc; #[delete("//recipients/")] -pub async fn req( - db: &Db, - user: User, target: Ref, member: Ref -) -> Result { +pub async fn req(db: &Db, user: User, target: Ref, member: Ref) -> Result { let channel = target.as_channel(db).await?; match channel { - Channel::Group { id, owner, recipients, .. } => { + Channel::Group { + id, + owner, + recipients, + .. + } => { if user.id != owner { - return Err(Error::MissingPermission { permission: 0 }) + return Err(Error::MissingPermission { permission: 0 }); } let member = member.as_user(db).await?; @@ -27,6 +32,6 @@ pub async fn req( db.remove_user_from_group(&id, &member.id).await?; Ok(EmptyResponse) } - _ => Err(Error::InvalidOperation) + _ => Err(Error::InvalidOperation), } } diff --git a/src/routes/channels/message_send.rs b/src/routes/channels/message_send.rs index 27e85f43..5f01a202 100644 --- a/src/routes/channels/message_send.rs +++ b/src/routes/channels/message_send.rs @@ -1,4 +1,7 @@ -use revolt_quark::{models::message::Masquerade, Result}; +use revolt_quark::{ + models::{message::Masquerade, User}, + Ref, Result, +}; use mongodb::bson::doc; use regex::Regex; @@ -43,10 +46,6 @@ lazy_static! { } #[post("//messages", data = "")] -pub async fn message_send( - /*user: UserRef, _r: Ratelimiter, mut idempotency: IdempotencyKey, target: Ref,*/ - target: String, - message: Json, -) -> Result { +pub async fn message_send(user: User, target: Ref, message: Json) -> Result { todo!() } diff --git a/src/routes/channels/voice_join.rs b/src/routes/channels/voice_join.rs index 048c567e..14cc7c12 100644 --- a/src/routes/channels/voice_join.rs +++ b/src/routes/channels/voice_join.rs @@ -1,4 +1,4 @@ -use revolt_quark::{Result, models::User, Ref}; +use revolt_quark::{models::User, Ref, Result}; use rocket::serde::json::Value; use serde::{Deserialize, Serialize}; diff --git a/src/routes/root.rs b/src/routes/root.rs index 2f7daeea..eb6111e9 100644 --- a/src/routes/root.rs +++ b/src/routes/root.rs @@ -1,7 +1,7 @@ -use crate::util::{/*ratelimit::Ratelimiter,*/ variables::{ +use crate::util::variables::{ APP_URL, AUTUMN_URL, EXTERNAL_WS_URL, HCAPTCHA_SITEKEY, INVITE_ONLY, JANUARY_URL, USE_AUTUMN, USE_EMAIL, USE_HCAPTCHA, USE_JANUARY, USE_VOSO, VAPID_PUBLIC_KEY, VOSO_URL, VOSO_WS_HOST, -}}; +}; use mongodb::bson::doc; use rocket::{http::Status, serde::json::Value};