80 lines
2.3 KiB
Rust
80 lines
2.3 KiB
Rust
use crate::db::{db_get_comments, db_new_comment};
|
|
use crate::jwt::Authentication;
|
|
use crate::types::{CommentQueryParams, NewComment};
|
|
use crate::ServerState;
|
|
|
|
use actix_web::get;
|
|
use actix_web::web::{Data, Query};
|
|
use actix_web::{post, web::Json, HttpResponse, Responder, Result};
|
|
use log::info;
|
|
|
|
#[get("/comments")]
|
|
pub async fn get_comments(
|
|
comment_filter: Query<CommentQueryParams>,
|
|
state: Data<ServerState>,
|
|
) -> Result<impl Responder> {
|
|
let post_id = comment_filter.post_id;
|
|
let limit = comment_filter.limit.unwrap_or(10);
|
|
let offset = comment_filter.offset.unwrap_or(0);
|
|
|
|
info!(
|
|
"Getting comments for post {} with limit {} and offset {}",
|
|
post_id, limit, offset
|
|
);
|
|
|
|
let comments = db_get_comments(&state.pool, post_id, limit, offset).await;
|
|
|
|
if comments.is_empty() {
|
|
info!("No comments found for post {}", post_id);
|
|
return Ok(HttpResponse::NotFound().json("No comments found"));
|
|
}
|
|
|
|
Ok(HttpResponse::Ok().json(comments))
|
|
}
|
|
|
|
#[post("/comments")]
|
|
pub async fn new_comment(
|
|
data: Json<NewComment>,
|
|
state: Data<ServerState>,
|
|
auth: Data<Authentication>,
|
|
) -> Result<impl Responder> {
|
|
let user_claims = auth.decode(&data.user_token);
|
|
|
|
// Bail if the token is invalid
|
|
if let Err(e) = user_claims {
|
|
info!("Error validating token: {}", e);
|
|
return Ok(HttpResponse::BadRequest().json("Error"));
|
|
}
|
|
|
|
let claims = user_claims.unwrap();
|
|
|
|
let content = data.content.clone();
|
|
let username = claims.sub.clone();
|
|
|
|
// This one is avoidable if we just store the user id in the token
|
|
let userid = sqlx::query!("SELECT id FROM users WHERE username = $1", username)
|
|
.fetch_one(&state.pool)
|
|
.await
|
|
.unwrap()
|
|
.id;
|
|
|
|
info!(
|
|
"User {:?}, with id {:?} is creating a new comment",
|
|
&claims.sub, userid
|
|
);
|
|
|
|
info!("Creating a new comment {:?}", &data);
|
|
|
|
let success = db_new_comment(&state.pool, data.parent_post_id, userid, &content).await;
|
|
|
|
match success {
|
|
true => {
|
|
info!("User {:?} created a new comment", &claims.sub);
|
|
Ok(HttpResponse::Ok().json("Successfully created comment"))
|
|
}
|
|
false => {
|
|
info!("User {:?} failed to create a new comment", &claims.sub);
|
|
Ok(HttpResponse::BadRequest().json("Failed to create comment"))
|
|
}
|
|
}
|
|
}
|