You've already forked AstralRinth
forked from didirus/AstralRinth
Initial work on site moderation improvements (#410)
This commit is contained in:
3
migrations/20220801184215_banned-users.sql
Normal file
3
migrations/20220801184215_banned-users.sql
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
CREATE TABLE banned_users (
|
||||||
|
github_id bigint NOT NULL PRIMARY KEY UNIQUE
|
||||||
|
)
|
||||||
@@ -838,6 +838,18 @@
|
|||||||
},
|
},
|
||||||
"query": "\n DELETE FROM notifications_actions\n WHERE notification_id = ANY($1)\n "
|
"query": "\n DELETE FROM notifications_actions\n WHERE notification_id = ANY($1)\n "
|
||||||
},
|
},
|
||||||
|
"28d5825964b0fddc43bd7d6851daf91845b79c9e88c82d5c7d97ae02502d0b4f": {
|
||||||
|
"describe": {
|
||||||
|
"columns": [],
|
||||||
|
"nullable": [],
|
||||||
|
"parameters": {
|
||||||
|
"Left": [
|
||||||
|
"Int8"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"query": "INSERT INTO banned_users (github_id) VALUES ($1);"
|
||||||
|
},
|
||||||
"292da3eec2cc7d7eb635fa123be1b1387e9e91466f007e10101053fdb9874e3f": {
|
"292da3eec2cc7d7eb635fa123be1b1387e9e91466f007e10101053fdb9874e3f": {
|
||||||
"describe": {
|
"describe": {
|
||||||
"columns": [
|
"columns": [
|
||||||
@@ -933,6 +945,18 @@
|
|||||||
},
|
},
|
||||||
"query": "\n INSERT INTO team_members (id, team_id, user_id, role, permissions, accepted)\n VALUES ($1, $2, $3, $4, $5, $6)\n "
|
"query": "\n INSERT INTO team_members (id, team_id, user_id, role, permissions, accepted)\n VALUES ($1, $2, $3, $4, $5, $6)\n "
|
||||||
},
|
},
|
||||||
|
"2f7c011654d15c85dbb614ac01ed5613a6872ea8c172ab38fdaa0eb38a7d6e4f": {
|
||||||
|
"describe": {
|
||||||
|
"columns": [],
|
||||||
|
"nullable": [],
|
||||||
|
"parameters": {
|
||||||
|
"Left": [
|
||||||
|
"Int8"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"query": "DELETE FROM banned_users WHERE github_id = $1;"
|
||||||
|
},
|
||||||
"33a965c7dc615d3b701c05299889357db8dd36d378850625d2602ba471af4885": {
|
"33a965c7dc615d3b701c05299889357db8dd36d378850625d2602ba471af4885": {
|
||||||
"describe": {
|
"describe": {
|
||||||
"columns": [],
|
"columns": [],
|
||||||
@@ -2520,6 +2544,26 @@
|
|||||||
},
|
},
|
||||||
"query": "\n SELECT v.id id, v.mod_id project_id FROM files f\n INNER JOIN versions v ON v.id = f.version_id\n WHERE f.url = $1\n "
|
"query": "\n SELECT v.id id, v.mod_id project_id FROM files f\n INNER JOIN versions v ON v.id = f.version_id\n WHERE f.url = $1\n "
|
||||||
},
|
},
|
||||||
|
"69bb839ea7fd5687538656e1907599d75e2c4948a54d58446bec8a90170ee618": {
|
||||||
|
"describe": {
|
||||||
|
"columns": [
|
||||||
|
{
|
||||||
|
"name": "user",
|
||||||
|
"ordinal": 0,
|
||||||
|
"type_info": "Name"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"nullable": [
|
||||||
|
null
|
||||||
|
],
|
||||||
|
"parameters": {
|
||||||
|
"Left": [
|
||||||
|
"Int8"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"query": "SELECT user FROM banned_users WHERE github_id = $1"
|
||||||
|
},
|
||||||
"6a7b7704c2a0c52a70f5d881a1e6d3e8e77ddaa83ecc5688cd86bf327775fb76": {
|
"6a7b7704c2a0c52a70f5d881a1e6d3e8e77ddaa83ecc5688cd86bf327775fb76": {
|
||||||
"describe": {
|
"describe": {
|
||||||
"columns": [
|
"columns": [
|
||||||
|
|||||||
@@ -50,6 +50,8 @@ pub enum AuthorizationError {
|
|||||||
Decoding(#[from] DecodingError),
|
Decoding(#[from] DecodingError),
|
||||||
#[error("Invalid callback URL specified")]
|
#[error("Invalid callback URL specified")]
|
||||||
Url,
|
Url,
|
||||||
|
#[error("User is not allowed to access Modrinth services")]
|
||||||
|
Banned,
|
||||||
}
|
}
|
||||||
impl actix_web::ResponseError for AuthorizationError {
|
impl actix_web::ResponseError for AuthorizationError {
|
||||||
fn status_code(&self) -> StatusCode {
|
fn status_code(&self) -> StatusCode {
|
||||||
@@ -67,6 +69,7 @@ impl actix_web::ResponseError for AuthorizationError {
|
|||||||
AuthorizationError::Decoding(..) => StatusCode::BAD_REQUEST,
|
AuthorizationError::Decoding(..) => StatusCode::BAD_REQUEST,
|
||||||
AuthorizationError::Authentication(..) => StatusCode::UNAUTHORIZED,
|
AuthorizationError::Authentication(..) => StatusCode::UNAUTHORIZED,
|
||||||
AuthorizationError::Url => StatusCode::BAD_REQUEST,
|
AuthorizationError::Url => StatusCode::BAD_REQUEST,
|
||||||
|
AuthorizationError::Banned => StatusCode::FORBIDDEN,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -84,6 +87,7 @@ impl actix_web::ResponseError for AuthorizationError {
|
|||||||
"authentication_error"
|
"authentication_error"
|
||||||
}
|
}
|
||||||
AuthorizationError::Url => "url_error",
|
AuthorizationError::Url => "url_error",
|
||||||
|
AuthorizationError::Banned => "user_banned",
|
||||||
},
|
},
|
||||||
description: &self.to_string(),
|
description: &self.to_string(),
|
||||||
})
|
})
|
||||||
@@ -215,6 +219,17 @@ pub async fn auth_callback(
|
|||||||
match user_result {
|
match user_result {
|
||||||
Some(_) => {}
|
Some(_) => {}
|
||||||
None => {
|
None => {
|
||||||
|
let banned_user = sqlx::query!(
|
||||||
|
"SELECT user FROM banned_users WHERE github_id = $1",
|
||||||
|
user.id as i64
|
||||||
|
)
|
||||||
|
.fetch_optional(&mut *transaction)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
if banned_user.is_some() {
|
||||||
|
return Err(AuthorizationError::Banned);
|
||||||
|
}
|
||||||
|
|
||||||
let user_id =
|
let user_id =
|
||||||
crate::database::models::generate_user_id(&mut transaction)
|
crate::database::models::generate_user_id(&mut transaction)
|
||||||
.await?;
|
.await?;
|
||||||
|
|||||||
@@ -151,7 +151,12 @@ pub fn notifications_config(cfg: &mut web::ServiceConfig) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub fn moderation_config(cfg: &mut web::ServiceConfig) {
|
pub fn moderation_config(cfg: &mut web::ServiceConfig) {
|
||||||
cfg.service(web::scope("moderation").service(moderation::get_projects));
|
cfg.service(
|
||||||
|
web::scope("moderation")
|
||||||
|
.service(moderation::get_projects)
|
||||||
|
.service(moderation::ban_user)
|
||||||
|
.service(moderation::unban_user),
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn reports_config(cfg: &mut web::ServiceConfig) {
|
pub fn reports_config(cfg: &mut web::ServiceConfig) {
|
||||||
|
|||||||
@@ -2,7 +2,7 @@ use super::ApiError;
|
|||||||
use crate::database;
|
use crate::database;
|
||||||
use crate::models::projects::ProjectStatus;
|
use crate::models::projects::ProjectStatus;
|
||||||
use crate::util::auth::check_is_moderator_from_headers;
|
use crate::util::auth::check_is_moderator_from_headers;
|
||||||
use actix_web::{get, web, HttpRequest, HttpResponse};
|
use actix_web::{delete, get, web, HttpRequest, HttpResponse};
|
||||||
use serde::Deserialize;
|
use serde::Deserialize;
|
||||||
use sqlx::PgPool;
|
use sqlx::PgPool;
|
||||||
|
|
||||||
@@ -54,3 +54,38 @@ pub async fn get_projects(
|
|||||||
|
|
||||||
Ok(HttpResponse::Ok().json(projects))
|
Ok(HttpResponse::Ok().json(projects))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[derive(Deserialize)]
|
||||||
|
pub struct BanUser {
|
||||||
|
pub id: i64,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[get("ban")]
|
||||||
|
pub async fn ban_user(
|
||||||
|
req: HttpRequest,
|
||||||
|
pool: web::Data<PgPool>,
|
||||||
|
id: web::Query<BanUser>,
|
||||||
|
) -> Result<HttpResponse, ApiError> {
|
||||||
|
check_is_moderator_from_headers(req.headers(), &**pool).await?;
|
||||||
|
|
||||||
|
sqlx::query!("INSERT INTO banned_users (github_id) VALUES ($1);", id.id)
|
||||||
|
.execute(&**pool)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
Ok(HttpResponse::NoContent().body(""))
|
||||||
|
}
|
||||||
|
|
||||||
|
#[delete("ban")]
|
||||||
|
pub async fn unban_user(
|
||||||
|
req: HttpRequest,
|
||||||
|
pool: web::Data<PgPool>,
|
||||||
|
id: web::Query<BanUser>,
|
||||||
|
) -> Result<HttpResponse, ApiError> {
|
||||||
|
check_is_moderator_from_headers(req.headers(), &**pool).await?;
|
||||||
|
|
||||||
|
sqlx::query!("DELETE FROM banned_users WHERE github_id = $1;", id.id)
|
||||||
|
.execute(&**pool)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
Ok(HttpResponse::NoContent().body(""))
|
||||||
|
}
|
||||||
|
|||||||
@@ -206,7 +206,7 @@ const DEFAULT_DISPLAYED_ATTRIBUTES: &[&str] = &[
|
|||||||
"license",
|
"license",
|
||||||
"client_side",
|
"client_side",
|
||||||
"server_side",
|
"server_side",
|
||||||
"gallery"
|
"gallery",
|
||||||
];
|
];
|
||||||
|
|
||||||
const DEFAULT_SEARCHABLE_ATTRIBUTES: &[&str] =
|
const DEFAULT_SEARCHABLE_ATTRIBUTES: &[&str] =
|
||||||
|
|||||||
Reference in New Issue
Block a user