feat: invite deletion #14
3 changed files with 60 additions and 0 deletions
|
@ -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<Data>) -> Result<HttpResponse, Error> {
|
||||||
|
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())
|
||||||
|
}
|
|
@ -2,6 +2,8 @@ use actix_web::{Error, HttpRequest, HttpResponse, get, post, web};
|
||||||
use serde::Deserialize;
|
use serde::Deserialize;
|
||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
|
|
||||||
|
mod id;
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
Data,
|
Data,
|
||||||
api::v1::auth::check_access_token,
|
api::v1::auth::check_access_token,
|
||||||
|
|
|
@ -760,6 +760,21 @@ impl Invite {
|
||||||
|
|
||||||
Ok(invite.unwrap().build())
|
Ok(invite.unwrap().build())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn delete(self, pool: &Pool<Postgres>) -> Result<(), HttpResponse> {
|
||||||
|
let invite: Result<InviteBuilder, sqlx::Error> = 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(())
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Deserialize)]
|
#[derive(Deserialize)]
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue