Add tests for actions/local/post (#8083)
This commit is contained in:
Joram Wilander
GitHub
parent
8fb0b32d89
commit
3c6d5aa4ae
1 changed files with 338 additions and 0 deletions
338
app/actions/local/post.test.ts
Normal file
338
app/actions/local/post.test.ts
Normal file
|
|
@ -0,0 +1,338 @@
|
|||
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
||||
// See LICENSE.txt for license information.
|
||||
|
||||
import {ActionType, Post} from '@app/constants';
|
||||
import {COMBINED_USER_ACTIVITY} from '@app/utils/post_list';
|
||||
import {SYSTEM_IDENTIFIERS} from '@constants/database';
|
||||
import DatabaseManager from '@database/manager';
|
||||
import TestHelper from '@test/test_helper';
|
||||
|
||||
import {
|
||||
sendAddToChannelEphemeralPost,
|
||||
sendEphemeralPost,
|
||||
removePost,
|
||||
markPostAsDeleted,
|
||||
storePostsForChannel,
|
||||
getPosts,
|
||||
addPostAcknowledgement,
|
||||
removePostAcknowledgement,
|
||||
deletePosts,
|
||||
getUsersCountFromMentions,
|
||||
} from './post';
|
||||
|
||||
import type ServerDataOperator from '@database/operator/server_data_operator';
|
||||
import type UserModel from '@typings/database/models/servers/user';
|
||||
|
||||
const serverUrl = 'baseHandler.test.com';
|
||||
let operator: ServerDataOperator;
|
||||
|
||||
let mockGenerateId: jest.Mock;
|
||||
jest.mock('@utils/general', () => {
|
||||
const original = jest.requireActual('@utils/general');
|
||||
mockGenerateId = jest.fn(() => 'testpostid');
|
||||
return {
|
||||
...original,
|
||||
generateId: mockGenerateId,
|
||||
};
|
||||
});
|
||||
|
||||
const channelId = 'channelid1';
|
||||
const user: UserProfile = {
|
||||
id: 'userid',
|
||||
username: 'username',
|
||||
roles: '',
|
||||
} as UserProfile;
|
||||
|
||||
beforeEach(async () => {
|
||||
await DatabaseManager.init([serverUrl]);
|
||||
operator = DatabaseManager.serverDatabases[serverUrl]!.operator;
|
||||
});
|
||||
|
||||
afterEach(async () => {
|
||||
await DatabaseManager.destroyServerDatabase(serverUrl);
|
||||
});
|
||||
|
||||
describe('sendAddToChannelEphemeralPost', () => {
|
||||
it('handle not found database', async () => {
|
||||
const {posts, error} = await sendAddToChannelEphemeralPost('foo', {} as UserModel, ['username2'], ['added username2'], channelId, '');
|
||||
expect(posts).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
const users = await operator.handleUsers({users: [user], prepareRecordsOnly: false});
|
||||
|
||||
const {posts, error} = await sendAddToChannelEphemeralPost(serverUrl, users[0], ['username2'], ['added username2'], channelId, '');
|
||||
expect(error).toBeUndefined();
|
||||
expect(posts).toBeDefined();
|
||||
expect(posts?.length).toBe(1);
|
||||
expect(posts![0].message).toBe('added username2');
|
||||
});
|
||||
});
|
||||
|
||||
describe('sendEphemeralPost', () => {
|
||||
it('handle not found database', async () => {
|
||||
const {post, error} = await sendEphemeralPost('foo', 'message', channelId, '', user.id);
|
||||
expect(post).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('handle no channel', async () => {
|
||||
const {post, error} = await sendEphemeralPost(serverUrl, 'newmessage', '', '', user.id);
|
||||
expect(post).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('handle no user', async () => {
|
||||
await operator.handleSystem({systems: [{id: SYSTEM_IDENTIFIERS.CURRENT_USER_ID, value: 'useridcurrent'}], prepareRecordsOnly: false});
|
||||
|
||||
const {post, error} = await sendEphemeralPost(serverUrl, 'newmessage', channelId, '');
|
||||
expect(error).toBeUndefined();
|
||||
expect(post).toBeDefined();
|
||||
expect(post?.user_id).toBe('useridcurrent');
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
const {post, error} = await sendEphemeralPost(serverUrl, 'newmessage', channelId, '', user.id);
|
||||
expect(error).toBeUndefined();
|
||||
expect(post).toBeDefined();
|
||||
expect(post?.message).toBe('newmessage');
|
||||
});
|
||||
});
|
||||
|
||||
describe('removePost', () => {
|
||||
const post = {...TestHelper.fakePost(channelId), id: 'postid'};
|
||||
|
||||
it('handle not found database', async () => {
|
||||
const {post: rPost, error} = await removePost('foo', post);
|
||||
expect(rPost).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
await operator.handlePosts({
|
||||
actionType: ActionType.POSTS.RECEIVED_IN_CHANNEL,
|
||||
order: [post.id],
|
||||
posts: [post],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const {post: rPost, error} = await removePost(serverUrl, post);
|
||||
expect(error).toBeUndefined();
|
||||
expect(rPost).toBeDefined();
|
||||
});
|
||||
|
||||
it('base case - system message', async () => {
|
||||
const systemPost = {...TestHelper.fakePost(channelId), id: `${COMBINED_USER_ACTIVITY}id1_id2`, type: Post.POST_TYPES.COMBINED_USER_ACTIVITY as PostType, props: {system_post_ids: ['id1']}};
|
||||
|
||||
await operator.handlePosts({
|
||||
actionType: ActionType.POSTS.RECEIVED_IN_CHANNEL,
|
||||
order: [post.id, 'id1'],
|
||||
posts: [systemPost, {...TestHelper.fakePost(channelId), id: 'id1'}],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const {post: rPost, error} = await removePost(serverUrl, systemPost);
|
||||
expect(error).toBeUndefined();
|
||||
expect(rPost).toBeDefined();
|
||||
});
|
||||
});
|
||||
|
||||
describe('markPostAsDeleted', () => {
|
||||
const post = TestHelper.fakePost(channelId);
|
||||
|
||||
it('handle not found database', async () => {
|
||||
const {model, error} = await markPostAsDeleted('foo', post);
|
||||
expect(model).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('handle no post', async () => {
|
||||
const {model, error} = await markPostAsDeleted(serverUrl, post, false);
|
||||
expect(model).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
await operator.handlePosts({
|
||||
actionType: ActionType.POSTS.RECEIVED_IN_CHANNEL,
|
||||
order: [post.id],
|
||||
posts: [post],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const {model, error} = await markPostAsDeleted(serverUrl, post, false);
|
||||
expect(error).toBeUndefined();
|
||||
expect(model).toBeDefined();
|
||||
expect(model?.deleteAt).toBeGreaterThan(0);
|
||||
});
|
||||
});
|
||||
|
||||
describe('storePostsForChannel', () => {
|
||||
const post = TestHelper.fakePost(channelId);
|
||||
post.user_id = user.id;
|
||||
const teamId = 'tId1';
|
||||
const channel: Channel = {
|
||||
id: channelId,
|
||||
team_id: teamId,
|
||||
total_msg_count: 0,
|
||||
} as Channel;
|
||||
const channelMember: ChannelMembership = {
|
||||
id: 'id',
|
||||
channel_id: channelId,
|
||||
msg_count: 0,
|
||||
} as ChannelMembership;
|
||||
|
||||
it('handle not found database', async () => {
|
||||
const {models, error} = await storePostsForChannel('foo', channelId, [post], [post.id], '', ActionType.POSTS.RECEIVED_IN_CHANNEL, [user], false);
|
||||
expect(models).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
await operator.handleMyChannel({channels: [channel], myChannels: [channelMember], prepareRecordsOnly: false});
|
||||
await operator.handleConfigs({
|
||||
configs: [
|
||||
{id: 'CollapsedThreads', value: 'default_on'},
|
||||
{id: 'FeatureFlagCollapsedThreads', value: 'true'},
|
||||
],
|
||||
configsToDelete: [],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const {models, error} = await storePostsForChannel(serverUrl, channelId, [post], [post.id], '', ActionType.POSTS.RECEIVED_IN_CHANNEL, [user], false);
|
||||
expect(error).toBeUndefined();
|
||||
expect(models).toBeDefined();
|
||||
expect(models?.length).toBe(5); // Post, PostsInChannel, User, MyChannel, Thread
|
||||
});
|
||||
});
|
||||
|
||||
describe('getPosts', () => {
|
||||
const post = TestHelper.fakePost(channelId);
|
||||
|
||||
it('handle not found database', async () => {
|
||||
const posts = await getPosts('foo', [post.id]);
|
||||
expect(posts).toBeDefined();
|
||||
expect(posts?.length).toBe(0);
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
await operator.handlePosts({
|
||||
actionType: ActionType.POSTS.RECEIVED_IN_CHANNEL,
|
||||
order: [post.id],
|
||||
posts: [post],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const posts = await getPosts(serverUrl, [post.id]);
|
||||
expect(posts).toBeDefined();
|
||||
expect(posts.length).toBe(1);
|
||||
});
|
||||
});
|
||||
|
||||
describe('addPostAcknowledgement', () => {
|
||||
const post = TestHelper.fakePost(channelId);
|
||||
|
||||
it('handle not found database', async () => {
|
||||
const {model, error} = await addPostAcknowledgement('foo', post.id, user.id, 123, false);
|
||||
expect(model).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('handle no post', async () => {
|
||||
const {model, error} = await addPostAcknowledgement(serverUrl, post.id, user.id, 123, false);
|
||||
expect(error).toBeDefined();
|
||||
expect(model).toBeUndefined();
|
||||
});
|
||||
|
||||
it('handle already acked', async () => {
|
||||
await operator.handlePosts({
|
||||
actionType: ActionType.POSTS.RECEIVED_IN_CHANNEL,
|
||||
order: [post.id],
|
||||
posts: [{...post, metadata: {acknowledgements: [{user_id: user.id, post_id: post.id, acknowledged_at: 1}]}}],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const {model, error} = await addPostAcknowledgement(serverUrl, post.id, user.id, 123, false);
|
||||
expect(error).toBeDefined();
|
||||
expect(error).toBe(false);
|
||||
expect(model).toBeUndefined();
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
await operator.handlePosts({
|
||||
actionType: ActionType.POSTS.RECEIVED_IN_CHANNEL,
|
||||
order: [post.id],
|
||||
posts: [post],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const {model, error} = await addPostAcknowledgement(serverUrl, post.id, user.id, 123, false);
|
||||
expect(error).toBeUndefined();
|
||||
expect(model).toBeDefined();
|
||||
});
|
||||
});
|
||||
|
||||
describe('removePostAcknowledgement', () => {
|
||||
const post = TestHelper.fakePost(channelId);
|
||||
|
||||
it('handle not found database', async () => {
|
||||
const {model, error} = await removePostAcknowledgement('foo', post.id, user.id, false);
|
||||
expect(model).toBeUndefined();
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('handle no post', async () => {
|
||||
const {model, error} = await removePostAcknowledgement(serverUrl, post.id, user.id, false);
|
||||
expect(error).toBeDefined();
|
||||
expect(model).toBeUndefined();
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
await operator.handlePosts({
|
||||
actionType: ActionType.POSTS.RECEIVED_IN_CHANNEL,
|
||||
order: [post.id],
|
||||
posts: [{...post, metadata: {acknowledgements: [{user_id: user.id, post_id: post.id, acknowledged_at: 1}]}}],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const {model, error} = await removePostAcknowledgement(serverUrl, post.id, user.id, false);
|
||||
expect(error).toBeUndefined();
|
||||
expect(model).toBeDefined();
|
||||
});
|
||||
});
|
||||
|
||||
describe('deletePosts', () => {
|
||||
const post = TestHelper.fakePost(channelId);
|
||||
|
||||
it('handle not found database', async () => {
|
||||
const {error} = await deletePosts('foo', [post.id]);
|
||||
expect(error).toBeTruthy();
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
await operator.handlePosts({
|
||||
actionType: ActionType.POSTS.RECEIVED_IN_CHANNEL,
|
||||
order: [post.id],
|
||||
posts: [post],
|
||||
prepareRecordsOnly: false,
|
||||
});
|
||||
|
||||
const {error} = await deletePosts(serverUrl, [post.id, 'id2']);
|
||||
expect(error).toBeDefined();
|
||||
});
|
||||
});
|
||||
|
||||
describe('getUsersCountFromMentions', () => {
|
||||
it('handle not found database', async () => {
|
||||
const num = await getUsersCountFromMentions('foo', []);
|
||||
expect(num).toBe(0);
|
||||
});
|
||||
|
||||
it('base case', async () => {
|
||||
await operator.handleUsers({users: [user], prepareRecordsOnly: false});
|
||||
|
||||
const num = await getUsersCountFromMentions(serverUrl, [user.username]);
|
||||
expect(num).toBe(1);
|
||||
});
|
||||
});
|
||||
Loading…
Reference in a new issue