LemmyNet/lemmy
2
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2024-11-26 22:31:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fixing shared inbox bug. Fixes #1865

Browse source
This commit is contained in:
Dessalines 2021-10-27 17:50:55 -04:00
parent b92ee7ffe8
commit edf19300e9
2 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
api_tests/src/comment.spec.ts
View file

@ -357,14 +357,14 @@ test('Check 3 instance shared inbox bug', async () => {
// Make sure alpha sees it
let alphaPost2 = await getPost(alpha, alphaPost.post.id);
// TODO remove this after
console.log(alphaPost2);
expect(alphaPost2.comments[0].comment.content).toBe(commentContent);
expect(alphaPost2.comments[0].community.local).toBe(true);
expect(alphaPost2.comments[0].community.local).toBe(false);
expect(alphaPost2.comments[0].creator.local).toBe(false);
expect(alphaPost2.comments[0].counts.score).toBe(1);
assertCommentFederation(alphaPost2.comments[0], commentRes.comment_view);
await unfollowRemotes(alpha);
await unfollowRemotes(gamma);
});
test('Fetch in_reply_tos: A is unsubbed from B, B makes a post, and some embedded comments, A subs to B, B updates the lowest level comment, A fetches both the post and all the inreplyto comments for that post.', async () => {

12
crates/apub/src/http/community.rs
View file

@ -79,12 +79,6 @@ pub async fn community_inbox(
receive_group_inbox(activity.clone(), request, &context).await?;
if let GroupInboxActivities::AnnouncableActivities(announcable) = activity {
let community = extract_community(&announcable.cc(), &context, &mut 0).await?;
if community.local {
AnnounceActivity::send(announcable, &community, vec![], &context).await?;
}
}
Ok(HttpResponse::Ok().finish())
}
@ -93,6 +87,12 @@ pub(in crate::http) async fn receive_group_inbox(
request: HttpRequest,
context: &LemmyContext,
) -> Result<HttpResponse, LemmyError> {
if let GroupInboxActivities::AnnouncableActivities(announcable) = activity.clone() {
let community = extract_community(&announcable.cc(), context, &mut 0).await?;
if community.local {
AnnounceActivity::send(announcable, &community, vec![], context).await?;
}
}
receive_activity(request, activity.clone(), context).await
}