use crate::PerformCrud;
use actix_web::web::Data;
-use lemmy_api_common::{blocking, check_community_ban, get_local_user_view_from_jwt, post::*};
-use lemmy_apub::{generate_apub_endpoint, ApubLikeableType, ApubObjectType, EndpointType};
+use lemmy_api_common::{
+ blocking,
+ check_community_ban,
+ get_local_user_view_from_jwt,
+ mark_post_as_read,
+ post::*,
+};
+use lemmy_apub::{
+ activities::{
+ post::create_or_update::CreateOrUpdatePost,
+ voting::vote::{Vote, VoteType},
+ CreateOrUpdateType,
+ },
+ fetcher::post_or_comment::PostOrComment,
+ generate_apub_endpoint,
+ EndpointType,
+};
use lemmy_db_queries::{source::post::Post_, Crud, Likeable};
use lemmy_db_schema::source::post::*;
-use lemmy_db_views::post_view::PostView;
use lemmy_utils::{
- request::fetch_iframely_and_pictrs_data,
- utils::{check_slurs, check_slurs_opt, is_valid_post_title},
+ request::fetch_site_data,
+ utils::{check_slurs, check_slurs_opt, clean_url_params, is_valid_post_title},
ApiError,
ConnectionId,
LemmyError,
};
-use lemmy_websocket::{messages::SendPost, LemmyContext, UserOperation};
+use lemmy_websocket::{send::send_post_ws_message, LemmyContext, UserOperationCrud};
#[async_trait::async_trait(?Send)]
impl PerformCrud for CreatePost {
context: &Data<LemmyContext>,
websocket_id: Option<ConnectionId>,
) -> Result<PostResponse, LemmyError> {
- let data: &CreatePost = &self;
+ let data: &CreatePost = self;
let local_user_view = get_local_user_view_from_jwt(&data.auth, context.pool()).await?;
check_slurs(&data.name)?;
check_community_ban(local_user_view.person.id, data.community_id, context.pool()).await?;
- // Fetch Iframely and pictrs cached image
+ // Fetch post links and pictrs cached image
let data_url = data.url.as_ref();
- let (iframely_title, iframely_description, iframely_html, pictrs_thumbnail) =
- fetch_iframely_and_pictrs_data(context.client(), data_url).await;
+ let (metadata_res, pictrs_thumbnail) = fetch_site_data(context.client(), data_url).await;
+ let (embed_title, embed_description, embed_html) = metadata_res
+ .map(|u| (u.title, u.description, u.html))
+ .unwrap_or((None, None, None));
let post_form = PostForm {
name: data.name.trim().to_owned(),
- url: data_url.map(|u| u.to_owned().into()),
+ url: data_url.map(|u| clean_url_params(u.to_owned()).into()),
body: data.body.to_owned(),
community_id: data.community_id,
creator_id: local_user_view.person.id,
- removed: None,
- deleted: None,
nsfw: data.nsfw,
- locked: None,
- stickied: None,
- updated: None,
- embed_title: iframely_title,
- embed_description: iframely_description,
- embed_html: iframely_html,
+ embed_title,
+ embed_description,
+ embed_html,
thumbnail_url: pictrs_thumbnail.map(|u| u.into()),
- ap_id: None,
- local: true,
- published: None,
+ ..PostForm::default()
};
let inserted_post =
};
let inserted_post_id = inserted_post.id;
- let updated_post = match blocking(context.pool(), move |conn| -> Result<Post, LemmyError> {
+ let updated_post = blocking(context.pool(), move |conn| -> Result<Post, LemmyError> {
let apub_id = generate_apub_endpoint(EndpointType::Post, &inserted_post_id.to_string())?;
Ok(Post::update_ap_id(conn, inserted_post_id, apub_id)?)
})
.await?
- {
- Ok(post) => post,
- Err(_e) => return Err(ApiError::err("couldnt_create_post").into()),
- };
+ .map_err(|_| ApiError::err("couldnt_create_post"))?;
- updated_post
- .send_create(&local_user_view.person, context)
- .await?;
+ CreateOrUpdatePost::send(
+ &updated_post,
+ &local_user_view.person,
+ CreateOrUpdateType::Create,
+ context,
+ )
+ .await?;
// They like their own post by default
+ let person_id = local_user_view.person.id;
+ let post_id = inserted_post.id;
let like_form = PostLikeForm {
- post_id: inserted_post.id,
- person_id: local_user_view.person.id,
+ post_id,
+ person_id,
score: 1,
};
return Err(ApiError::err("couldnt_like_post").into());
}
- updated_post
- .send_like(&local_user_view.person, context)
- .await?;
-
- // Refetch the view
- let inserted_post_id = inserted_post.id;
- let post_view = match blocking(context.pool(), move |conn| {
- PostView::read(conn, inserted_post_id, Some(local_user_view.person.id))
- })
- .await?
- {
- Ok(post) => post,
- Err(_e) => return Err(ApiError::err("couldnt_find_post").into()),
- };
-
- let res = PostResponse { post_view };
-
- context.chat_server().do_send(SendPost {
- op: UserOperation::CreatePost,
- post: res.clone(),
+ // Mark the post as read
+ mark_post_as_read(person_id, post_id, context.pool()).await?;
+
+ let object = PostOrComment::Post(Box::new(updated_post));
+ Vote::send(
+ &object,
+ &local_user_view.person,
+ inserted_post.community_id,
+ VoteType::Like,
+ context,
+ )
+ .await?;
+
+ send_post_ws_message(
+ inserted_post.id,
+ UserOperationCrud::CreatePost,
websocket_id,
- });
-
- Ok(res)
+ Some(local_user_view.person.id),
+ context,
+ )
+ .await
}
}