diff --git a/src/api/v1/servers/uuid/invites/id.rs b/src/api/v1/servers/uuid/invites/id.rs index e69de29..ffd2547 100644 --- a/src/api/v1/servers/uuid/invites/id.rs +++ b/src/api/v1/servers/uuid/invites/id.rs @@ -0,0 +1,43 @@ +use actix_web::{delete, web, Error, HttpRequest, HttpResponse}; +use uuid::Uuid; + +use crate::{api::v1::auth::check_access_token, structs::{Invite, Member}, utils::get_auth_header, Data}; + +#[delete("{uuid}/invites/{id}")] +pub async fn delete(req: HttpRequest, path: web::Path<(Uuid, String)>, data: web::Data) -> Result { + let headers = req.headers(); + + let auth_header = get_auth_header(headers); + + if let Err(error) = auth_header { + return Ok(error) + } + + let (guild_uuid, invite_id) = path.into_inner(); + + let authorized = check_access_token(auth_header.unwrap(), &data.pool).await; + + if let Err(error) = authorized { + return Ok(error) + } + + let uuid = authorized.unwrap(); + + if let Err(error) = Member::fetch_one(&data.pool, uuid, guild_uuid).await { + return Ok(error) + } + + let result = Invite::fetch_one(&data.pool, invite_id).await; + + if let Err(error) = result { + return Ok(error) + } + + let invite = result.unwrap(); + + if let Err(error) = invite.delete(&data.pool).await { + return Ok(error) + } + + Ok(HttpResponse::Ok().finish()) +} diff --git a/src/api/v1/servers/uuid/invites/mod.rs b/src/api/v1/servers/uuid/invites/mod.rs index 94b81b0..b0706d7 100644 --- a/src/api/v1/servers/uuid/invites/mod.rs +++ b/src/api/v1/servers/uuid/invites/mod.rs @@ -2,6 +2,8 @@ use actix_web::{get, post, web, Error, HttpRequest, HttpResponse}; use serde::Deserialize; use uuid::Uuid; +mod id; + use crate::{api::v1::auth::check_access_token, structs::{Guild, Member}, utils::get_auth_header, Data}; #[derive(Deserialize)] diff --git a/src/structs.rs b/src/structs.rs index 44862c0..a1dee9f 100644 --- a/src/structs.rs +++ b/src/structs.rs @@ -612,4 +612,19 @@ impl Invite { Ok(invite.unwrap().build()) } + + pub async fn delete(self, pool: &Pool) -> Result<(), HttpResponse> { + let invite: Result = sqlx::query_as("DELETE FROM invites WHERE id = $1") + .bind(self.id) + .fetch_one(pool) + .await; + + if let Err(error) = invite { + error!("{}", error); + + return Err(HttpResponse::InternalServerError().finish()) + } + + Ok(()) + } }