FediMovies/fedimovies
1
1
Fork 0
Code Issues 3 Pull requests Projects Releases Packages Activity

Ignore Announce() if repost already exists in database

Browse source
This commit is contained in:
silverpill 2021-12-11 21:21:52 +00:00
parent bcaf6a08c7
commit 164596989b
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/activitypub/receiver.rs
View file

@ -332,6 +332,12 @@ pub async fn receive_activity(
process_note(config, db_client, object.id.clone(), Some(object)).await?; process_note(config, db_client, object.id.clone(), Some(object)).await?;
}, },
(ANNOUNCE, _) => { (ANNOUNCE, _) => {
let repost_object_id = activity.id;
match get_post_by_object_id(db_client, &repost_object_id).await {
Ok(_) => return Ok(()), // Ignore if repost already exists
Err(DatabaseError::NotFound(_)) => (),
Err(other_error) => return Err(other_error.into()),
};
let author = get_or_fetch_profile_by_actor_id( let author = get_or_fetch_profile_by_actor_id(
db_client, db_client,
&config.instance(), &config.instance(),
@ -349,7 +355,7 @@ pub async fn receive_activity(
}; };
let repost_data = PostCreateData { let repost_data = PostCreateData {
repost_of_id: Some(post_id), repost_of_id: Some(post_id),
object_id: Some(activity.id), object_id: Some(repost_object_id),
..Default::default() ..Default::default()
}; };
create_post(db_client, &author.id, repost_data).await?; create_post(db_client, &author.id, repost_data).await?;