mirror of
https://github.com/paricafe/misskey.git
synced 2024-12-11 15:26:44 -06:00
b990ae6b23
* test(backend): add federation test * fix(ci): install pnpm * fix(ci): cd * fix(ci): build entire project * fix(ci): skip frontend build * fix(ci): pull submodule when checkout * chore: show log for debugging * Revert "chore: show log for debugging" This reverts commit a930964b8d6ba550c23bce1e7fb45d92eab49ef9. * fix(ci): build entire project * chore: omit unused globals * refactor: use strictEqual and simplify some asserts * test: follow requests * refactor: add resolveRemoteNote function * refactor: refine resolveRemoteUser function * refactor: cache admin credentials * refactor: simplify assertion with excluded fields * refactor: use assert * test: note * chore: labeler detect federation * test: blocking * test: move * fix: use appropriate TLD * chore: shorter purge interval * fix(ci): change TLD * refactor: delete trivial comment * test(user): isCat * chore: use jest * chore: omit logs * chore: add memo * fix(ci): omit unnecessary build * test: pinning Note * fix: build daemon in container * style: indent * test(streaming): timeline * chore: rename * fix: delete role after test * refactor: resolve users by uri * fix: delete antenna after test * test: api timeline * test: Note deletion * refactor: sleep function * test: notification * style: indent * refactor: type-safe host * docs: update description * refactor: resolve function params * fix(block): wrong test name * fix: invalid type * fix: longer timeout for fire testing * test(timeline): hashtag * test(note): vote delivery * fix: wrong description * fix: hashtag channel param type * refactor: wrap basic cases * test(timeline): add homeTimeline tests * fix(timeline): correct wrong case and description * test(notification): add tests for Note * refactor(user): wrap profile consistency with describe * chore(note): add issue link * test(timeline): add test * test(user): suspension * test: emoji * refactor: fetch admin first * perf: faster tests * test(drive): sensitive flag * test(emoji): add tests * chore: ignore .config/docker.env * chore: hard-coded tester IP address * test(emoji): custom emoji are surrounded by zero width space * refactor: client and username as property * test(notification): mute * fix(notification): correct description * test(block): mention * refactor(emoji): addCustomEmoji function * fix: typo * test(note): add reaction tests * test(timeline): Note deletion * fix: unnecessary ts-expect-error * refactor: unnecessary fetch mocking * chore: add TODO comments * test(user): deletion * chore: enable --frozen-lockfile * fix(ci): copying configs * docs: update CONTRIBUTING.md * docs: fix typo * chore: set default sleep duration * fix(notification): omit flaky tests * fix(notification): correct type * test(notification): add api endpoint tests * chore: remove redundant mute test * refactor: use param client * fix: start timer after trigger * refactor: remove unnecessary any * chore: shorter timeout for checking if fired * fix(block): remove outdated comment * refactor: shorten remote user variable name * refactor(block): use existing function * refactor: file upload * docs: update description * test(user): ffVisibility * fix: `/api/signin` -> `/api/signin-flow` * test: abuse report * refactor: use existing type * refactor: extract duplicate configs to template file * fix: typo * fix: avoid conflict * refactor: change container dependency * perf: start misskey parallelly * fix: remove dependency * chore(backend): add typecheck * test: add check for #14728 * chore: enable eslint check * perf: don't start linked services when test * test(note): remote note deletion for moderation * chore: define config template * chore: write setup script * refactor: omit unnecessary conditional * refactor: clarify scope * refactor: omit type assertion * refactor: omit logs * style * refactor: redundant promise * refactor: unnecessary imports * refactor: use readable error code * refactor: cache set in signin function * refactor: optimize import
328 lines
12 KiB
TypeScript
328 lines
12 KiB
TypeScript
import { strictEqual } from 'assert';
|
|
import * as Misskey from 'misskey-js';
|
|
import { createAccount, fetchAdmin, isNoteUpdatedEventFired, isFired, type LoginUser, type Request, resolveRemoteUser, sleep, createRole } from './utils.js';
|
|
|
|
const bAdmin = await fetchAdmin('b.test');
|
|
|
|
describe('Timeline', () => {
|
|
let alice: LoginUser, bob: LoginUser;
|
|
let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
|
|
|
|
beforeAll(async () => {
|
|
[alice, bob] = await Promise.all([
|
|
createAccount('a.test'),
|
|
createAccount('b.test'),
|
|
]);
|
|
|
|
[bobInA, aliceInB] = await Promise.all([
|
|
resolveRemoteUser('b.test', bob.id, alice),
|
|
resolveRemoteUser('a.test', alice.id, bob),
|
|
]);
|
|
|
|
await bob.client.request('following/create', { userId: aliceInB.id });
|
|
await sleep();
|
|
});
|
|
|
|
type TimelineChannel = keyof Misskey.Channels & (`${string}Timeline` | 'antenna' | 'userList' | 'hashtag');
|
|
type TimelineEndpoint = keyof Misskey.Endpoints & (`${string}timeline` | 'antennas/notes' | 'roles/notes' | 'notes/search-by-tag');
|
|
const timelineMap = new Map<TimelineChannel, TimelineEndpoint>([
|
|
['antenna', 'antennas/notes'],
|
|
['globalTimeline', 'notes/global-timeline'],
|
|
['homeTimeline', 'notes/timeline'],
|
|
['hybridTimeline', 'notes/hybrid-timeline'],
|
|
['localTimeline', 'notes/local-timeline'],
|
|
['roleTimeline', 'roles/notes'],
|
|
['hashtag', 'notes/search-by-tag'],
|
|
['userList', 'notes/user-list-timeline'],
|
|
]);
|
|
|
|
async function postAndCheckReception<C extends TimelineChannel>(
|
|
timelineChannel: C,
|
|
expect: boolean,
|
|
noteParams: Misskey.entities.NotesCreateRequest = {},
|
|
channelParams: Misskey.Channels[C]['params'] = {},
|
|
) {
|
|
let note: Misskey.entities.Note | undefined;
|
|
const text = noteParams.text ?? crypto.randomUUID();
|
|
const streamingFired = await isFired(
|
|
'b.test', bob, timelineChannel,
|
|
async () => {
|
|
note = (await alice.client.request('notes/create', { text, ...noteParams })).createdNote;
|
|
},
|
|
'note', msg => msg.text === text,
|
|
channelParams,
|
|
);
|
|
strictEqual(streamingFired, expect);
|
|
|
|
const endpoint = timelineMap.get(timelineChannel)!;
|
|
const params: Misskey.Endpoints[typeof endpoint]['req'] =
|
|
endpoint === 'antennas/notes' ? { antennaId: (channelParams as Misskey.Channels['antenna']['params']).antennaId } :
|
|
endpoint === 'notes/user-list-timeline' ? { listId: (channelParams as Misskey.Channels['userList']['params']).listId } :
|
|
endpoint === 'notes/search-by-tag' ? { query: (channelParams as Misskey.Channels['hashtag']['params']).q } :
|
|
endpoint === 'roles/notes' ? { roleId: (channelParams as Misskey.Channels['roleTimeline']['params']).roleId } :
|
|
{};
|
|
|
|
await sleep();
|
|
const notes = await (bob.client.request as Request)(endpoint, params);
|
|
const noteInB = notes.filter(({ uri }) => uri === `https://a.test/notes/${note!.id}`).pop();
|
|
const endpointFired = noteInB != null;
|
|
strictEqual(endpointFired, expect);
|
|
|
|
// Let's check Delete reception
|
|
if (expect) {
|
|
const streamingFired = await isNoteUpdatedEventFired(
|
|
'b.test', bob, noteInB!.id,
|
|
async () => await alice.client.request('notes/delete', { noteId: note!.id }),
|
|
msg => msg.type === 'deleted' && msg.id === noteInB!.id,
|
|
);
|
|
strictEqual(streamingFired, true);
|
|
|
|
await sleep();
|
|
const notes = await (bob.client.request as Request)(endpoint, params);
|
|
const endpointFired = notes.every(({ uri }) => uri !== `https://a.test/notes/${note!.id}`);
|
|
strictEqual(endpointFired, true);
|
|
}
|
|
}
|
|
|
|
describe('homeTimeline', () => {
|
|
// NOTE: narrowing scope intentionally to prevent mistakes by copy-and-paste
|
|
const homeTimeline = 'homeTimeline';
|
|
|
|
describe('Check reception of remote followee\'s Note', () => {
|
|
test('Receive remote followee\'s Note', async () => {
|
|
await postAndCheckReception(homeTimeline, true);
|
|
});
|
|
|
|
test('Receive remote followee\'s home-only Note', async () => {
|
|
await postAndCheckReception(homeTimeline, true, { visibility: 'home' });
|
|
});
|
|
|
|
test('Receive remote followee\'s followers-only Note', async () => {
|
|
await postAndCheckReception(homeTimeline, true, { visibility: 'followers' });
|
|
});
|
|
|
|
test('Receive remote followee\'s visible specified-only Note', async () => {
|
|
await postAndCheckReception(homeTimeline, true, { visibility: 'specified', visibleUserIds: [bobInA.id] });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s localOnly Note', async () => {
|
|
await postAndCheckReception(homeTimeline, false, { localOnly: true });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s invisible specified-only Note', async () => {
|
|
await postAndCheckReception(homeTimeline, false, { visibility: 'specified' });
|
|
});
|
|
|
|
/**
|
|
* FIXME: can receive this
|
|
* @see https://github.com/misskey-dev/misskey/issues/14083
|
|
*/
|
|
test.failing('Don\'t receive remote followee\'s invisible and mentioned specified-only Note', async () => {
|
|
await postAndCheckReception(homeTimeline, false, { text: `@${bob.username}@b.test Hello`, visibility: 'specified' });
|
|
});
|
|
|
|
/**
|
|
* FIXME: cannot receive this
|
|
* @see https://github.com/misskey-dev/misskey/issues/14084
|
|
*/
|
|
test.failing('Receive remote followee\'s visible specified-only reply to invisible specified-only Note', async () => {
|
|
const note = (await alice.client.request('notes/create', { text: 'a', visibility: 'specified' })).createdNote;
|
|
await postAndCheckReception(homeTimeline, true, { replyId: note.id, visibility: 'specified', visibleUserIds: [bobInA.id] });
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('localTimeline', () => {
|
|
const localTimeline = 'localTimeline';
|
|
|
|
describe('Check reception of remote followee\'s Note', () => {
|
|
test('Don\'t receive remote followee\'s Note', async () => {
|
|
await postAndCheckReception(localTimeline, false);
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('hybridTimeline', () => {
|
|
const hybridTimeline = 'hybridTimeline';
|
|
|
|
describe('Check reception of remote followee\'s Note', () => {
|
|
test('Receive remote followee\'s Note', async () => {
|
|
await postAndCheckReception(hybridTimeline, true);
|
|
});
|
|
|
|
test('Receive remote followee\'s home-only Note', async () => {
|
|
await postAndCheckReception(hybridTimeline, true, { visibility: 'home' });
|
|
});
|
|
|
|
test('Receive remote followee\'s followers-only Note', async () => {
|
|
await postAndCheckReception(hybridTimeline, true, { visibility: 'followers' });
|
|
});
|
|
|
|
test('Receive remote followee\'s visible specified-only Note', async () => {
|
|
await postAndCheckReception(hybridTimeline, true, { visibility: 'specified', visibleUserIds: [bobInA.id] });
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('globalTimeline', () => {
|
|
const globalTimeline = 'globalTimeline';
|
|
|
|
describe('Check reception of remote followee\'s Note', () => {
|
|
test('Receive remote followee\'s Note', async () => {
|
|
await postAndCheckReception(globalTimeline, true);
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s home-only Note', async () => {
|
|
await postAndCheckReception(globalTimeline, false, { visibility: 'home' });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s followers-only Note', async () => {
|
|
await postAndCheckReception(globalTimeline, false, { visibility: 'followers' });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s visible specified-only Note', async () => {
|
|
await postAndCheckReception(globalTimeline, false, { visibility: 'specified', visibleUserIds: [bobInA.id] });
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('userList', () => {
|
|
const userList = 'userList';
|
|
|
|
let list: Misskey.entities.UserList;
|
|
|
|
beforeAll(async () => {
|
|
list = await bob.client.request('users/lists/create', { name: 'Bob\'s List' });
|
|
await bob.client.request('users/lists/push', { listId: list.id, userId: aliceInB.id });
|
|
await sleep();
|
|
});
|
|
|
|
describe('Check reception of remote followee\'s Note', () => {
|
|
test('Receive remote followee\'s Note', async () => {
|
|
await postAndCheckReception(userList, true, {}, { listId: list.id });
|
|
});
|
|
|
|
test('Receive remote followee\'s home-only Note', async () => {
|
|
await postAndCheckReception(userList, true, { visibility: 'home' }, { listId: list.id });
|
|
});
|
|
|
|
test('Receive remote followee\'s followers-only Note', async () => {
|
|
await postAndCheckReception(userList, true, { visibility: 'followers' }, { listId: list.id });
|
|
});
|
|
|
|
test('Receive remote followee\'s visible specified-only Note', async () => {
|
|
await postAndCheckReception(userList, true, { visibility: 'specified', visibleUserIds: [bobInA.id] }, { listId: list.id });
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('hashtag', () => {
|
|
const hashtag = 'hashtag';
|
|
|
|
describe('Check reception of remote followee\'s Note', () => {
|
|
test('Receive remote followee\'s Note', async () => {
|
|
const tag = crypto.randomUUID();
|
|
await postAndCheckReception(hashtag, true, { text: `#${tag}` }, { q: [[tag]] });
|
|
});
|
|
|
|
test('Receive remote followee\'s home-only Note', async () => {
|
|
const tag = crypto.randomUUID();
|
|
await postAndCheckReception(hashtag, true, { text: `#${tag}`, visibility: 'home' }, { q: [[tag]] });
|
|
});
|
|
|
|
test('Receive remote followee\'s followers-only Note', async () => {
|
|
const tag = crypto.randomUUID();
|
|
await postAndCheckReception(hashtag, true, { text: `#${tag}`, visibility: 'followers' }, { q: [[tag]] });
|
|
});
|
|
|
|
test('Receive remote followee\'s visible specified-only Note', async () => {
|
|
const tag = crypto.randomUUID();
|
|
await postAndCheckReception(hashtag, true, { text: `#${tag}`, visibility: 'specified', visibleUserIds: [bobInA.id] }, { q: [[tag]] });
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('roleTimeline', () => {
|
|
const roleTimeline = 'roleTimeline';
|
|
|
|
let role: Misskey.entities.Role;
|
|
|
|
beforeAll(async () => {
|
|
role = await createRole('b.test', {
|
|
name: 'Remote Users',
|
|
description: 'Remote users are assigned to this role.',
|
|
condFormula: {
|
|
/** TODO: @see https://github.com/misskey-dev/misskey/issues/14169 */
|
|
type: 'isRemote' as never,
|
|
},
|
|
});
|
|
await sleep();
|
|
});
|
|
|
|
describe('Check reception of remote followee\'s Note', () => {
|
|
test('Receive remote followee\'s Note', async () => {
|
|
await postAndCheckReception(roleTimeline, true, {}, { roleId: role.id });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s home-only Note', async () => {
|
|
await postAndCheckReception(roleTimeline, false, { visibility: 'home' }, { roleId: role.id });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s followers-only Note', async () => {
|
|
await postAndCheckReception(roleTimeline, false, { visibility: 'followers' }, { roleId: role.id });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s visible specified-only Note', async () => {
|
|
await postAndCheckReception(roleTimeline, false, { visibility: 'specified', visibleUserIds: [bobInA.id] }, { roleId: role.id });
|
|
});
|
|
});
|
|
|
|
afterAll(async () => {
|
|
await bAdmin.client.request('admin/roles/delete', { roleId: role.id });
|
|
});
|
|
});
|
|
|
|
// TODO: Cannot test
|
|
describe.skip('antenna', () => {
|
|
const antenna = 'antenna';
|
|
|
|
let bobAntenna: Misskey.entities.Antenna;
|
|
|
|
beforeAll(async () => {
|
|
bobAntenna = await bob.client.request('antennas/create', {
|
|
name: 'Bob\'s Egosurfing Antenna',
|
|
src: 'all',
|
|
keywords: [['Bob']],
|
|
excludeKeywords: [],
|
|
users: [],
|
|
caseSensitive: false,
|
|
localOnly: false,
|
|
withReplies: true,
|
|
withFile: true,
|
|
});
|
|
await sleep();
|
|
});
|
|
|
|
describe('Check reception of remote followee\'s Note', () => {
|
|
test('Receive remote followee\'s Note', async () => {
|
|
await postAndCheckReception(antenna, true, { text: 'I love Bob (1)' }, { antennaId: bobAntenna.id });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s home-only Note', async () => {
|
|
await postAndCheckReception(antenna, false, { text: 'I love Bob (2)', visibility: 'home' }, { antennaId: bobAntenna.id });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s followers-only Note', async () => {
|
|
await postAndCheckReception(antenna, false, { text: 'I love Bob (3)', visibility: 'followers' }, { antennaId: bobAntenna.id });
|
|
});
|
|
|
|
test('Don\'t receive remote followee\'s visible specified-only Note', async () => {
|
|
await postAndCheckReception(antenna, false, { text: 'I love Bob (4)', visibility: 'specified', visibleUserIds: [bobInA.id] }, { antennaId: bobAntenna.id });
|
|
});
|
|
});
|
|
|
|
afterAll(async () => {
|
|
await bob.client.request('antennas/delete', { antennaId: bobAntenna.id });
|
|
});
|
|
});
|
|
});
|