Plume/src/routes/comments.rs

73 lines
2.3 KiB
Rust
Raw Normal View History

2018-06-04 21:57:03 +02:00
use rocket::{
request::Form,
response::{Redirect, Flash}
};
2018-05-10 11:44:57 +02:00
use rocket_contrib::Template;
use serde_json;
2018-05-10 11:44:57 +02:00
2018-06-21 12:38:07 +02:00
use activity_pub::{broadcast, inbox::Inbox};
2018-05-10 11:44:57 +02:00
use db_conn::DbConn;
2018-05-19 09:39:59 +02:00
use models::{
blogs::Blog,
2018-05-19 09:39:59 +02:00
comments::*,
instance::Instance,
2018-05-19 09:39:59 +02:00
posts::Post,
users::User
};
2018-05-10 11:44:57 +02:00
2018-06-04 21:57:03 +02:00
use utils;
#[get("/~/<blog>/<slug>/comment")]
fn new(blog: String, slug: String, user: User, conn: DbConn) -> Template {
may_fail!(Blog::find_by_fqn(&*conn, blog), "Couldn't find this blog", |blog| {
may_fail!(Post::find_by_slug(&*conn, slug, blog.id), "Couldn't find this post", |post| {
Template::render("comments/new", json!({
"post": post,
"account": user
}))
})
})
2018-05-10 11:44:57 +02:00
}
2018-06-04 21:57:03 +02:00
#[get("/~/<blog>/<slug>/comment", rank=2)]
fn new_auth(blog: String, slug: String) -> Flash<Redirect>{
utils::requires_login("You need to be logged in order to post a comment", uri!(new: blog = blog, slug = slug))
2018-06-04 21:57:03 +02:00
}
#[derive(FromForm)]
struct CommentQuery {
responding_to: Option<i32>
}
2018-05-10 11:44:57 +02:00
#[derive(FromForm)]
struct NewCommentForm {
pub content: String
2018-05-10 11:44:57 +02:00
}
// See: https://github.com/SergioBenitez/Rocket/pull/454
#[post("/~/<blog_name>/<slug>/comment", data = "<data>")]
fn create(blog_name: String, slug: String, data: Form<NewCommentForm>, user: User, conn: DbConn) -> Redirect {
create_response(blog_name, slug, None, data, user, conn)
}
#[post("/~/<blog_name>/<slug>/comment?<query>", data = "<data>")]
fn create_response(blog_name: String, slug: String, query: Option<CommentQuery>, data: Form<NewCommentForm>, user: User, conn: DbConn) -> Redirect {
let blog = Blog::find_by_fqn(&*conn, blog_name.clone()).unwrap();
let post = Post::find_by_slug(&*conn, slug.clone(), blog.id).unwrap();
2018-05-10 11:44:57 +02:00
let form = data.get();
2018-05-19 00:04:30 +02:00
let (new_comment, id) = NewComment::build()
.content(form.content.clone())
.in_response_to_id(query.and_then(|q| q.responding_to))
.post(post)
.author(user.clone())
.create(&*conn);
// Comment::notify(&*conn, new_comment, user.clone().into_id());
let instance = Instance::get_local(&*conn).unwrap();
instance.received(&*conn, serde_json::to_value(new_comment.clone()).expect("JSON serialization error"));
broadcast(&*conn, &user, new_comment, user.get_followers(&*conn));
2018-05-10 17:36:32 +02:00
Redirect::to(format!("/~/{}/{}/#comment-{}", blog_name, slug, id))
2018-05-10 11:44:57 +02:00
}