wip/kick #36
4 changed files with 106 additions and 1 deletions
16
src/api/v1/members/mod.rs
Normal file
16
src/api/v1/members/mod.rs
Normal file
|
@ -0,0 +1,16 @@
|
||||||
|
use std::sync::Arc;
|
||||||
|
|
||||||
|
use axum::{
|
||||||
|
Router,
|
||||||
|
routing::{delete, get},
|
||||||
|
};
|
||||||
|
|
||||||
|
use crate::AppState;
|
||||||
|
|
||||||
|
mod uuid;
|
||||||
|
|
||||||
|
pub fn router() -> Router<Arc<AppState>> {
|
||||||
|
Router::new()
|
||||||
|
.route("/{uuid}", get(uuid::get))
|
||||||
|
.route("/{uuid}", delete(uuid::delete))
|
||||||
|
}
|
60
src/api/v1/members/uuid/mod.rs
Normal file
60
src/api/v1/members/uuid/mod.rs
Normal file
|
@ -0,0 +1,60 @@
|
||||||
|
//! `/api/v1/members/{uuid}` Member specific endpoints
|
||||||
|
|
||||||
|
use std::sync::Arc;
|
||||||
|
|
||||||
|
use crate::{
|
||||||
|
AppState,
|
||||||
|
api::v1::auth::CurrentUser,
|
||||||
|
error::Error,
|
||||||
|
objects::{Me, Member, Permissions},
|
||||||
|
utils::global_checks,
|
||||||
|
};
|
||||||
|
use axum::{
|
||||||
|
Extension, Json,
|
||||||
|
extract::{Path, State},
|
||||||
|
http::StatusCode,
|
||||||
|
response::IntoResponse,
|
||||||
|
};
|
||||||
|
|
||||||
|
use uuid::Uuid;
|
||||||
|
|
||||||
|
pub async fn get(
|
||||||
|
State(app_state): State<Arc<AppState>>,
|
||||||
|
Path(member_uuid): Path<Uuid>,
|
||||||
|
Extension(CurrentUser(uuid)): Extension<CurrentUser<Uuid>>,
|
||||||
|
) -> Result<impl IntoResponse, Error> {
|
||||||
|
global_checks(&app_state, uuid).await?;
|
||||||
|
|
||||||
|
let mut conn = app_state.pool.get().await?;
|
||||||
|
|
||||||
|
let me = Me::get(&mut conn, uuid).await?;
|
||||||
|
|
||||||
|
let member = Member::fetch_one_with_member(&app_state, &me, member_uuid).await?;
|
||||||
|
Member::check_membership(&mut conn, uuid, member.guild_uuid).await?;
|
||||||
|
|
||||||
|
Ok((StatusCode::OK, Json(member)))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn delete(
|
||||||
|
State(app_state): State<Arc<AppState>>,
|
||||||
|
Path(member_uuid): Path<Uuid>,
|
||||||
|
Extension(CurrentUser(uuid)): Extension<CurrentUser<Uuid>>,
|
||||||
|
) -> Result<impl IntoResponse, Error> {
|
||||||
|
global_checks(&app_state, uuid).await?;
|
||||||
|
|
||||||
|
let mut conn = app_state.pool.get().await?;
|
||||||
|
|
||||||
|
let me = Me::get(&mut conn, uuid).await?;
|
||||||
|
|
||||||
|
let member = Member::fetch_one_with_member(&app_state, &me, member_uuid).await?;
|
||||||
|
|
||||||
|
let deleter = Member::check_membership(&mut conn, uuid, member.guild_uuid).await?;
|
||||||
|
|
||||||
|
deleter
|
||||||
|
.check_permission(&app_state, Permissions::ManageMember)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
member.delete(&mut conn).await?;
|
||||||
|
|
||||||
|
Ok(StatusCode::OK)
|
||||||
|
}
|
|
@ -11,6 +11,7 @@ mod channels;
|
||||||
mod guilds;
|
mod guilds;
|
||||||
mod invites;
|
mod invites;
|
||||||
mod me;
|
mod me;
|
||||||
|
mod members;
|
||||||
mod stats;
|
mod stats;
|
||||||
mod users;
|
mod users;
|
||||||
|
|
||||||
|
@ -19,6 +20,7 @@ pub fn router(app_state: Arc<AppState>) -> Router<Arc<AppState>> {
|
||||||
.nest("/users", users::router())
|
.nest("/users", users::router())
|
||||||
.nest("/guilds", guilds::router())
|
.nest("/guilds", guilds::router())
|
||||||
.nest("/invites", invites::router())
|
.nest("/invites", invites::router())
|
||||||
|
.nest("/members", members::router())
|
||||||
.nest("/me", me::router())
|
.nest("/me", me::router())
|
||||||
.layer(from_fn_with_state(
|
.layer(from_fn_with_state(
|
||||||
app_state.clone(),
|
app_state.clone(),
|
||||||
|
|
|
@ -1,5 +1,6 @@
|
||||||
use diesel::{
|
use diesel::{
|
||||||
ExpressionMethods, Insertable, QueryDsl, Queryable, Selectable, SelectableHelper, insert_into,
|
ExpressionMethods, Insertable, QueryDsl, Queryable, Selectable, SelectableHelper, delete,
|
||||||
|
insert_into,
|
||||||
};
|
};
|
||||||
use diesel_async::RunQueryDsl;
|
use diesel_async::RunQueryDsl;
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
|
@ -119,6 +120,23 @@ impl Member {
|
||||||
member.build(app_state, Some(me)).await
|
member.build(app_state, Some(me)).await
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn fetch_one_with_member(
|
||||||
|
app_state: &AppState,
|
||||||
|
me: &Me,
|
||||||
|
uuid: Uuid,
|
||||||
|
) -> Result<Self, Error> {
|
||||||
|
let mut conn = app_state.pool.get().await?;
|
||||||
|
|
||||||
|
use guild_members::dsl;
|
||||||
|
let member: MemberBuilder = dsl::guild_members
|
||||||
|
.filter(dsl::uuid.eq(uuid))
|
||||||
|
.select(MemberBuilder::as_select())
|
||||||
|
.get_result(&mut conn)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
member.build(app_state, Some(me)).await
|
||||||
|
}
|
||||||
|
|
||||||
pub async fn fetch_all(
|
pub async fn fetch_all(
|
||||||
app_state: &AppState,
|
app_state: &AppState,
|
||||||
me: &Me,
|
me: &Me,
|
||||||
|
@ -168,4 +186,13 @@ impl Member {
|
||||||
|
|
||||||
member.build(app_state, None).await
|
member.build(app_state, None).await
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn delete(self, conn: &mut Conn) -> Result<(), Error> {
|
||||||
|
delete(guild_members::table)
|
||||||
|
.filter(guild_members::uuid.eq(self.uuid))
|
||||||
|
.execute(conn)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue