forked from Plume/Plume
39 lines
1.3 KiB
Rust
39 lines
1.3 KiB
Rust
use rocket::response::{Redirect, Flash};
|
|
|
|
use activity_pub::{broadcast, IntoId, inbox::Notify};
|
|
use db_conn::DbConn;
|
|
use models::{
|
|
posts::Post,
|
|
reshares::*,
|
|
users::User
|
|
};
|
|
|
|
use utils;
|
|
|
|
#[get("/~/<blog>/<slug>/reshare")]
|
|
fn create(blog: String, slug: String, user: User, conn: DbConn) -> Redirect {
|
|
let post = Post::find_by_slug(&*conn, slug.clone()).unwrap();
|
|
|
|
if !user.has_reshared(&*conn, &post) {
|
|
let reshare = Reshare::insert(&*conn, NewReshare {
|
|
post_id: post.id,
|
|
user_id: user.id,
|
|
ap_url: "".to_string()
|
|
});
|
|
reshare.update_ap_url(&*conn);
|
|
|
|
Reshare::notify(&*conn, reshare.into_activity(&*conn), user.clone().into_id());
|
|
broadcast(&*conn, &user, reshare.into_activity(&*conn), user.get_followers(&*conn));
|
|
} else {
|
|
let reshare = Reshare::find_by_user_on_post(&*conn, user.id, post.id).unwrap();
|
|
let delete_act = reshare.delete(&*conn);
|
|
broadcast(&*conn, &user, delete_act, user.get_followers(&*conn));
|
|
}
|
|
|
|
Redirect::to(format!("/~/{}/{}/", blog, slug))
|
|
}
|
|
|
|
#[get("/~/<blog>/<slug>/reshare", rank=1)]
|
|
fn create_auth(blog: String, slug: String) -> Flash<Redirect> {
|
|
utils::requires_login("You need to be logged in order to reshare a post", &format!("/~/{}/{}/reshare",blog, slug))
|
|
}
|