feat: retrive all banned users in a guild
This commit is contained in:
parent
3ad73f28fa
commit
7e10086753
6 changed files with 91 additions and 9 deletions
|
@ -3,5 +3,6 @@ CREATE TABLE guild_bans (
|
|||
guild_uuid uuid NOT NULL REFERENCES guilds(uuid) ON DELETE CASCADE,
|
||||
user_uuid uuid NOT NULL REFERENCES users(uuid),
|
||||
reason VARCHAR(200) DEFAULT NULL,
|
||||
ban_time TIMESTAMPTZ NOT NULL DEFAULT NOW(),
|
||||
PRIMARY KEY (user_uuid, guild_uuid)
|
||||
);
|
||||
|
|
24
src/api/v1/guilds/uuid/bans.rs
Normal file
24
src/api/v1/guilds/uuid/bans.rs
Normal file
|
@ -0,0 +1,24 @@
|
|||
use std::sync::Arc;
|
||||
|
||||
use axum::{extract::{Path, State}, http::{Extensions, StatusCode}, response::IntoResponse, Extension, Json};
|
||||
use uuid::Uuid;
|
||||
|
||||
use crate::{api::v1::auth::CurrentUser, error::Error, objects::{self, GuildBan, Member, Permissions}, utils::global_checks, AppState};
|
||||
|
||||
|
||||
pub async fn get(
|
||||
State(app_state): State<Arc<AppState>>,
|
||||
Path(guild_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 member = Member::check_membership(&mut conn, uuid, guild_uuid).await?;
|
||||
member.check_permission(&app_state, Permissions::BanMember).await?;
|
||||
|
||||
let all_guild_bans = GuildBan::fetch_all(&mut conn, guild_uuid).await?;
|
||||
|
||||
Ok((StatusCode::OK, Json(all_guild_bans)))
|
||||
}
|
|
@ -16,6 +16,7 @@ mod channels;
|
|||
mod invites;
|
||||
mod members;
|
||||
mod roles;
|
||||
mod bans;
|
||||
|
||||
use crate::{
|
||||
AppState,
|
||||
|
@ -42,6 +43,8 @@ pub fn router() -> Router<Arc<AppState>> {
|
|||
.route("/invites", post(invites::create))
|
||||
// Members
|
||||
.route("/members", get(members::get))
|
||||
// Bans
|
||||
.route("/bans", get(bans::get))
|
||||
}
|
||||
|
||||
/// `GET /api/v1/guilds/{uuid}` DESCRIPTION
|
||||
|
|
56
src/objects/bans.rs
Normal file
56
src/objects/bans.rs
Normal file
|
@ -0,0 +1,56 @@
|
|||
use diesel::{ExpressionMethods, QueryDsl, Queryable, Selectable, SelectableHelper};
|
||||
use serde::{Deserialize, Serialize};
|
||||
use uuid::Uuid;
|
||||
|
||||
use diesel_async::RunQueryDsl;
|
||||
|
||||
use crate::{
|
||||
error::Error, objects::{load_or_empty, Guild}, schema::guild_bans, Conn
|
||||
};
|
||||
|
||||
|
||||
#[derive(Selectable, Queryable, Serialize, Deserialize)]
|
||||
#[diesel(table_name = guild_bans)]
|
||||
#[diesel(check_for_backend(diesel::pg::Pg))]
|
||||
pub struct GuildBan {
|
||||
pub guild_uuid: Uuid,
|
||||
pub user_uuid: Uuid,
|
||||
pub reason: Option<String>,
|
||||
pub ban_time: chrono::DateTime<chrono::Utc>,
|
||||
}
|
||||
|
||||
|
||||
impl GuildBan {
|
||||
pub async fn fetch_one(conn: &mut Conn, guild_uuid: Uuid, user_uuid: Uuid) -> Result<GuildBan, Error> {
|
||||
use guild_bans::dsl;
|
||||
let guild_ban = dsl::guild_bans
|
||||
.filter(dsl::guild_uuid.eq(guild_uuid))
|
||||
.filter(dsl::user_uuid.eq(user_uuid))
|
||||
.select(GuildBan::as_select())
|
||||
.get_result(conn)
|
||||
.await?;
|
||||
|
||||
Ok(guild_ban)
|
||||
}
|
||||
|
||||
pub async fn fetch_all(conn: &mut Conn, guild_uuid: Uuid) -> Result<Vec<Self>, Error> {
|
||||
use guild_bans::dsl;
|
||||
let all_guild_bans = load_or_empty(dsl::guild_bans
|
||||
.filter(dsl::guild_uuid.eq(guild_uuid))
|
||||
.load(conn)
|
||||
.await
|
||||
)?;
|
||||
|
||||
Ok(all_guild_bans)
|
||||
}
|
||||
|
||||
pub async fn unban(self, conn: &mut Conn) -> Result<(), Error> {
|
||||
use guild_bans::dsl;
|
||||
diesel::delete(guild_bans::table)
|
||||
.filter(dsl::guild_uuid.eq(self.guild_uuid))
|
||||
.filter(dsl::user_uuid.eq(self.user_uuid))
|
||||
.execute(conn)
|
||||
.await?;
|
||||
Ok(())
|
||||
}
|
||||
}
|
|
@ -1,5 +1,5 @@
|
|||
use diesel::{
|
||||
ExpressionMethods, Insertable, QueryDsl, Queryable, Selectable, SelectableHelper, delete,
|
||||
ExpressionMethods, Insertable, QueryDsl, Queryable, Selectable, SelectableHelper,
|
||||
insert_into,
|
||||
};
|
||||
use diesel_async::RunQueryDsl;
|
||||
|
@ -9,11 +9,12 @@ use uuid::Uuid;
|
|||
use crate::{
|
||||
AppState, Conn,
|
||||
error::Error,
|
||||
objects::{Me, Permissions, Role},
|
||||
objects::{Me, Permissions, Role, GuildBan},
|
||||
schema::guild_bans,
|
||||
schema::guild_members,
|
||||
};
|
||||
|
||||
|
||||
use super::{User, load_or_empty};
|
||||
|
||||
#[derive(Serialize, Queryable, Selectable, Insertable)]
|
||||
|
@ -74,12 +75,6 @@ pub struct Member {
|
|||
user: User,
|
||||
}
|
||||
|
||||
#[derive(Serialize, Deserialize)]
|
||||
pub struct GuildBan {
|
||||
pub guild_uuid: Uuid,
|
||||
pub user_uuid: Uuid,
|
||||
pub reason: String,
|
||||
}
|
||||
|
||||
impl Member {
|
||||
pub async fn count(conn: &mut Conn, guild_uuid: Uuid) -> Result<i64, Error> {
|
||||
|
@ -208,7 +203,7 @@ impl Member {
|
|||
}
|
||||
|
||||
pub async fn delete(self, conn: &mut Conn) -> Result<(), Error> {
|
||||
delete(guild_members::table)
|
||||
diesel::delete(guild_members::table)
|
||||
.filter(guild_members::uuid.eq(self.uuid))
|
||||
.execute(conn)
|
||||
.await?;
|
||||
|
@ -235,4 +230,5 @@ impl Member {
|
|||
|
||||
Ok(())
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
@ -18,6 +18,7 @@ mod message;
|
|||
mod password_reset_token;
|
||||
mod role;
|
||||
mod user;
|
||||
mod bans;
|
||||
|
||||
pub use channel::Channel;
|
||||
pub use email_token::EmailToken;
|
||||
|
@ -32,6 +33,7 @@ pub use password_reset_token::PasswordResetToken;
|
|||
pub use role::Permissions;
|
||||
pub use role::Role;
|
||||
pub use user::User;
|
||||
pub use bans::GuildBan;
|
||||
|
||||
use crate::error::Error;
|
||||
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue