mirror of
https://github.com/LemmyNet/lemmy.git
synced 2024-09-10 00:18:49 -06:00
393 lines
13 KiB
TypeScript
393 lines
13 KiB
TypeScript
jest.setTimeout(120000);
|
|
import {
|
|
alpha,
|
|
beta,
|
|
gamma,
|
|
setupLogins,
|
|
createPost,
|
|
getPost,
|
|
searchComment,
|
|
likeComment,
|
|
followBeta,
|
|
searchForBetaCommunity,
|
|
createComment,
|
|
updateComment,
|
|
deleteComment,
|
|
removeComment,
|
|
getMentions,
|
|
searchPost,
|
|
unfollowRemotes,
|
|
createCommunity,
|
|
registerUser,
|
|
API,
|
|
delay,
|
|
} from './shared';
|
|
import {
|
|
Comment,
|
|
} from 'lemmy-js-client';
|
|
|
|
import { PostResponse } from 'lemmy-js-client';
|
|
|
|
let postRes: PostResponse;
|
|
|
|
beforeAll(async () => {
|
|
await setupLogins();
|
|
await followBeta(alpha);
|
|
await followBeta(gamma);
|
|
let search = await searchForBetaCommunity(alpha);
|
|
await delay(10000);
|
|
postRes = await createPost(
|
|
alpha,
|
|
search.communities.filter(c => c.local == false)[0].id
|
|
);
|
|
});
|
|
|
|
afterAll(async () => {
|
|
await unfollowRemotes(alpha);
|
|
await unfollowRemotes(gamma);
|
|
});
|
|
|
|
function assertCommentFederation(
|
|
commentOne: Comment,
|
|
commentTwo: Comment) {
|
|
expect(commentOne.ap_id).toBe(commentOne.ap_id);
|
|
expect(commentOne.content).toBe(commentTwo.content);
|
|
expect(commentOne.creator_name).toBe(commentTwo.creator_name);
|
|
expect(commentOne.community_actor_id).toBe(commentTwo.community_actor_id);
|
|
expect(commentOne.published).toBe(commentTwo.published);
|
|
expect(commentOne.updated).toBe(commentOne.updated);
|
|
expect(commentOne.deleted).toBe(commentOne.deleted);
|
|
expect(commentOne.removed).toBe(commentOne.removed);
|
|
}
|
|
|
|
test('Create a comment', async () => {
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
expect(commentRes.comment.content).toBeDefined();
|
|
expect(commentRes.comment.community_local).toBe(false);
|
|
expect(commentRes.comment.creator_local).toBe(true);
|
|
expect(commentRes.comment.score).toBe(1);
|
|
await delay();
|
|
|
|
// Make sure that comment is liked on beta
|
|
let searchBeta = await searchComment(beta, commentRes.comment);
|
|
let betaComment = searchBeta.comments[0];
|
|
expect(betaComment).toBeDefined();
|
|
expect(betaComment.community_local).toBe(true);
|
|
expect(betaComment.creator_local).toBe(false);
|
|
expect(betaComment.score).toBe(1);
|
|
assertCommentFederation(betaComment, commentRes.comment);
|
|
});
|
|
|
|
test('Create a comment in a non-existent post', async () => {
|
|
let commentRes = await createComment(alpha, -1);
|
|
expect(commentRes).toStrictEqual({ error: 'couldnt_find_post' });
|
|
});
|
|
|
|
test('Update a comment', async () => {
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
// Federate the comment first
|
|
let searchBeta = await searchComment(beta, commentRes.comment);
|
|
assertCommentFederation(searchBeta.comments[0], commentRes.comment);
|
|
|
|
await delay();
|
|
let updateCommentRes = await updateComment(alpha, commentRes.comment.id);
|
|
expect(updateCommentRes.comment.content).toBe(
|
|
'A jest test federated comment update'
|
|
);
|
|
expect(updateCommentRes.comment.community_local).toBe(false);
|
|
expect(updateCommentRes.comment.creator_local).toBe(true);
|
|
await delay();
|
|
|
|
// Make sure that post is updated on beta
|
|
let searchBetaUpdated = await searchComment(beta, commentRes.comment);
|
|
assertCommentFederation(searchBetaUpdated.comments[0], updateCommentRes.comment);
|
|
});
|
|
|
|
test('Delete a comment', async () => {
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
await delay();
|
|
|
|
let deleteCommentRes = await deleteComment(
|
|
alpha,
|
|
true,
|
|
commentRes.comment.id
|
|
);
|
|
expect(deleteCommentRes.comment.deleted).toBe(true);
|
|
await delay();
|
|
|
|
// Make sure that comment is undefined on beta
|
|
let searchBeta = await searchComment(beta, commentRes.comment);
|
|
let betaComment = searchBeta.comments[0];
|
|
expect(betaComment).toBeUndefined();
|
|
await delay();
|
|
|
|
let undeleteCommentRes = await deleteComment(
|
|
alpha,
|
|
false,
|
|
commentRes.comment.id
|
|
);
|
|
expect(undeleteCommentRes.comment.deleted).toBe(false);
|
|
await delay();
|
|
|
|
// Make sure that comment is undeleted on beta
|
|
let searchBeta2 = await searchComment(beta, commentRes.comment);
|
|
let betaComment2 = searchBeta2.comments[0];
|
|
expect(betaComment2.deleted).toBe(false);
|
|
assertCommentFederation(searchBeta2.comments[0], undeleteCommentRes.comment);
|
|
});
|
|
|
|
test('Remove a comment from admin and community on the same instance', async () => {
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
await delay();
|
|
|
|
// Get the id for beta
|
|
let betaCommentId = (await searchComment(beta, commentRes.comment))
|
|
.comments[0].id;
|
|
|
|
// The beta admin removes it (the community lives on beta)
|
|
let removeCommentRes = await removeComment(beta, true, betaCommentId);
|
|
expect(removeCommentRes.comment.removed).toBe(true);
|
|
await delay();
|
|
|
|
// Make sure that comment is removed on alpha (it gets pushed since an admin from beta removed it)
|
|
let refetchedPost = await getPost(alpha, postRes.post.id);
|
|
expect(refetchedPost.comments[0].removed).toBe(true);
|
|
|
|
let unremoveCommentRes = await removeComment(beta, false, betaCommentId);
|
|
expect(unremoveCommentRes.comment.removed).toBe(false);
|
|
await delay();
|
|
|
|
// Make sure that comment is unremoved on beta
|
|
let refetchedPost2 = await getPost(alpha, postRes.post.id);
|
|
expect(refetchedPost2.comments[0].removed).toBe(false);
|
|
assertCommentFederation(refetchedPost2.comments[0], unremoveCommentRes.comment);
|
|
});
|
|
|
|
test('Remove a comment from admin and community on different instance', async () => {
|
|
let alphaUser = await registerUser(alpha);
|
|
let newAlphaApi: API = {
|
|
client: alpha.client,
|
|
auth: alphaUser.jwt,
|
|
};
|
|
|
|
// New alpha user creates a community, post, and comment.
|
|
let newCommunity = await createCommunity(newAlphaApi);
|
|
await delay();
|
|
let newPost = await createPost(newAlphaApi, newCommunity.community.id);
|
|
await delay();
|
|
let commentRes = await createComment(newAlphaApi, newPost.post.id);
|
|
expect(commentRes.comment.content).toBeDefined();
|
|
await delay();
|
|
|
|
// Beta searches that to cache it, then removes it
|
|
let searchBeta = await searchComment(beta, commentRes.comment);
|
|
let betaComment = searchBeta.comments[0];
|
|
let removeCommentRes = await removeComment(beta, true, betaComment.id);
|
|
expect(removeCommentRes.comment.removed).toBe(true);
|
|
await delay();
|
|
|
|
// Make sure its not removed on alpha
|
|
let refetchedPost = await getPost(newAlphaApi, newPost.post.id);
|
|
expect(refetchedPost.comments[0].removed).toBe(false);
|
|
assertCommentFederation(refetchedPost.comments[0], commentRes.comment);
|
|
});
|
|
|
|
test('Unlike a comment', async () => {
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
await delay();
|
|
let unlike = await likeComment(alpha, 0, commentRes.comment);
|
|
expect(unlike.comment.score).toBe(0);
|
|
await delay();
|
|
|
|
// Make sure that post is unliked on beta
|
|
let searchBeta = await searchComment(beta, commentRes.comment);
|
|
let betaComment = searchBeta.comments[0];
|
|
expect(betaComment).toBeDefined();
|
|
expect(betaComment.community_local).toBe(true);
|
|
expect(betaComment.creator_local).toBe(false);
|
|
expect(betaComment.score).toBe(0);
|
|
});
|
|
|
|
test('Federated comment like', async () => {
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
await delay();
|
|
|
|
// Find the comment on beta
|
|
let searchBeta = await searchComment(beta, commentRes.comment);
|
|
let betaComment = searchBeta.comments[0];
|
|
|
|
let like = await likeComment(beta, 1, betaComment);
|
|
expect(like.comment.score).toBe(2);
|
|
await delay();
|
|
|
|
// Get the post from alpha, check the likes
|
|
let post = await getPost(alpha, postRes.post.id);
|
|
expect(post.comments[0].score).toBe(2);
|
|
});
|
|
|
|
test('Reply to a comment', async () => {
|
|
// Create a comment on alpha, find it on beta
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
await delay();
|
|
let searchBeta = await searchComment(beta, commentRes.comment);
|
|
let betaComment = searchBeta.comments[0];
|
|
|
|
// find that comment id on beta
|
|
|
|
// Reply from beta
|
|
let replyRes = await createComment(beta, betaComment.post_id, betaComment.id);
|
|
expect(replyRes.comment.content).toBeDefined();
|
|
expect(replyRes.comment.community_local).toBe(true);
|
|
expect(replyRes.comment.creator_local).toBe(true);
|
|
expect(replyRes.comment.parent_id).toBe(betaComment.id);
|
|
expect(replyRes.comment.score).toBe(1);
|
|
await delay();
|
|
|
|
// Make sure that comment is seen on alpha
|
|
// TODO not sure why, but a searchComment back to alpha, for the ap_id of betas
|
|
// comment, isn't working.
|
|
// let searchAlpha = await searchComment(alpha, replyRes.comment);
|
|
let post = await getPost(alpha, postRes.post.id);
|
|
let alphaComment = post.comments[0];
|
|
expect(alphaComment.content).toBeDefined();
|
|
expect(alphaComment.parent_id).toBe(post.comments[1].id);
|
|
expect(alphaComment.community_local).toBe(false);
|
|
expect(alphaComment.creator_local).toBe(false);
|
|
expect(alphaComment.score).toBe(1);
|
|
assertCommentFederation(alphaComment, replyRes.comment);
|
|
});
|
|
|
|
test('Mention beta', async () => {
|
|
// Create a mention on alpha
|
|
let mentionContent = 'A test mention of @lemmy_beta@lemmy-beta:8551';
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
await delay();
|
|
let mentionRes = await createComment(
|
|
alpha,
|
|
postRes.post.id,
|
|
commentRes.comment.id,
|
|
mentionContent
|
|
);
|
|
expect(mentionRes.comment.content).toBeDefined();
|
|
expect(mentionRes.comment.community_local).toBe(false);
|
|
expect(mentionRes.comment.creator_local).toBe(true);
|
|
expect(mentionRes.comment.score).toBe(1);
|
|
await delay();
|
|
|
|
let mentionsRes = await getMentions(beta);
|
|
expect(mentionsRes.mentions[0].content).toBeDefined();
|
|
expect(mentionsRes.mentions[0].community_local).toBe(true);
|
|
expect(mentionsRes.mentions[0].creator_local).toBe(false);
|
|
expect(mentionsRes.mentions[0].score).toBe(1);
|
|
});
|
|
|
|
test('Comment Search', async () => {
|
|
let commentRes = await createComment(alpha, postRes.post.id);
|
|
await delay();
|
|
let searchBeta = await searchComment(beta, commentRes.comment);
|
|
assertCommentFederation(searchBeta.comments[0], commentRes.comment);
|
|
});
|
|
|
|
test('A and G subscribe to B (center) A posts, G mentions B, it gets announced to A', async () => {
|
|
// Create a local post
|
|
let alphaPost = await createPost(alpha, 2);
|
|
expect(alphaPost.post.community_local).toBe(true);
|
|
await delay();
|
|
|
|
// Make sure gamma sees it
|
|
let search = await searchPost(gamma, alphaPost.post);
|
|
let gammaPost = search.posts[0];
|
|
|
|
let commentContent =
|
|
'A jest test federated comment announce, lets mention @lemmy_beta@lemmy-beta:8551';
|
|
let commentRes = await createComment(
|
|
gamma,
|
|
gammaPost.id,
|
|
undefined,
|
|
commentContent
|
|
);
|
|
expect(commentRes.comment.content).toBe(commentContent);
|
|
expect(commentRes.comment.community_local).toBe(false);
|
|
expect(commentRes.comment.creator_local).toBe(true);
|
|
expect(commentRes.comment.score).toBe(1);
|
|
await delay();
|
|
|
|
// Make sure alpha sees it
|
|
let alphaPost2 = await getPost(alpha, alphaPost.post.id);
|
|
expect(alphaPost2.comments[0].content).toBe(commentContent);
|
|
expect(alphaPost2.comments[0].community_local).toBe(true);
|
|
expect(alphaPost2.comments[0].creator_local).toBe(false);
|
|
expect(alphaPost2.comments[0].score).toBe(1);
|
|
assertCommentFederation(alphaPost2.comments[0], commentRes.comment);
|
|
|
|
// Make sure beta has mentions
|
|
let mentionsRes = await getMentions(beta);
|
|
expect(mentionsRes.mentions[0].content).toBe(commentContent);
|
|
expect(mentionsRes.mentions[0].community_local).toBe(false);
|
|
expect(mentionsRes.mentions[0].creator_local).toBe(false);
|
|
// TODO this is failing because fetchInReplyTos aren't getting score
|
|
// expect(mentionsRes.mentions[0].score).toBe(1);
|
|
});
|
|
|
|
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 () => {
|
|
// Unfollow all remote communities
|
|
let followed = await unfollowRemotes(alpha);
|
|
expect(
|
|
followed.communities.filter(c => c.community_local == false).length
|
|
).toBe(0);
|
|
|
|
// B creates a post, and two comments, should be invisible to A
|
|
let postRes = await createPost(beta, 2);
|
|
expect(postRes.post.name).toBeDefined();
|
|
await delay();
|
|
|
|
let parentCommentContent = 'An invisible top level comment from beta';
|
|
let parentCommentRes = await createComment(
|
|
beta,
|
|
postRes.post.id,
|
|
undefined,
|
|
parentCommentContent
|
|
);
|
|
expect(parentCommentRes.comment.content).toBe(parentCommentContent);
|
|
await delay();
|
|
|
|
// B creates a comment, then a child one of that.
|
|
let childCommentContent = 'An invisible child comment from beta';
|
|
let childCommentRes = await createComment(
|
|
beta,
|
|
postRes.post.id,
|
|
parentCommentRes.comment.id,
|
|
childCommentContent
|
|
);
|
|
expect(childCommentRes.comment.content).toBe(childCommentContent);
|
|
await delay();
|
|
|
|
// Follow beta again
|
|
let follow = await followBeta(alpha);
|
|
expect(follow.community.local).toBe(false);
|
|
expect(follow.community.name).toBe('main');
|
|
await delay();
|
|
|
|
// An update to the child comment on beta, should push the post, parent, and child to alpha now
|
|
let updatedCommentContent = 'An update child comment from beta';
|
|
let updateRes = await updateComment(
|
|
beta,
|
|
childCommentRes.comment.id,
|
|
updatedCommentContent
|
|
);
|
|
expect(updateRes.comment.content).toBe(updatedCommentContent);
|
|
await delay();
|
|
|
|
// Get the post from alpha
|
|
let search = await searchPost(alpha, postRes.post);
|
|
let alphaPostB = search.posts[0];
|
|
await delay();
|
|
|
|
let alphaPost = await getPost(alpha, alphaPostB.id);
|
|
expect(alphaPost.post.name).toBeDefined();
|
|
assertCommentFederation(alphaPost.comments[1], parentCommentRes.comment);
|
|
assertCommentFederation(alphaPost.comments[0], updateRes.comment);
|
|
expect(alphaPost.post.community_local).toBe(false);
|
|
expect(alphaPost.post.creator_local).toBe(false);
|
|
});
|