5f43c2faa2
* Never return broken notifications #409
Since notifications are stored in Redis, we can't expect relational
integrity: deleting a user will *not* delete notifications that
mention it.
But if we return notifications with missing bits (a `follow` without a
`user`, for example), the frontend will get very confused and throw an
exception while trying to render them.
This change makes sure we never expose those broken notifications. For
uniformity, I've applied the same logic to notes and roles mentioned
in notifications, even if nobody reported breakage in those cases.
Tested by creating a few types of notifications with a `notifierId`,
then deleting their user.
(cherry picked from commit 421f8d49e5)
* Update Changelog
* Update CHANGELOG.md
* enhance: 通知がミュートを考慮するようにする
* enhance: 通知が凍結も考慮するようにする
* fix: notifierIdがない通知が消えてしまう問題
* Add tests (通知がミュートを考慮しているかどうか)
* fix: notifierIdがない通知が消えてしまう問題 (grouped)
* Remove unused import
* Fix: typo
* Revert "enhance: 通知が凍結も考慮するようにする"
This reverts commit b1e57e571dfd9a7d8b2430294473c2053cc3ea33.
* Revert API handling
* Remove unused imports
* enhance: Check if notifierId is valid in NotificationEntityService
* 通知作成時にpackしてnullになったらあとの処理をやめる
* Remove duplication of valid notifier check
* add filter notification is not null
* Revert "Remove duplication of valid notifier check"
This reverts commit 239a6952f717add53d52c3e701e7362eb1987645.
* Improve performance
* Fix packGrouped
* Refactor: 判定部分を共通化
* Fix condition
* use isNotNull
* Update CHANGELOG.md
* filterの改善
* Refactor: DONT REPEAT YOURSELF
Note: GroupedNotificationはNotificationの拡張なのでその例外だけ書けば基本的に共通の処理になり複雑な個別の処理は増えにくいと思われる
* Add groupedNotificationTypes
* Update misskey-js typedef
* Refactor: less sql calls
* refactor
* clean up
* filter notes to mark as read
* packed noteがmapなのでそちらを使う
* if (notesToRead.size > 0)
* if (notes.length === 0) return;
* fix
* Revert "if (notes.length === 0) return;"
This reverts commit 22e2324f9633bddba50769ef838bc5ddb4564c88.
* 🎨
* console.error
* err
* remove try-catch
* 不要なジェネリクスを除去
* Revert (既読処理をpack内で行うものを元に戻す)
* Clean
* Update packages/backend/src/core/entities/NotificationEntityService.ts
* Update packages/backend/src/core/entities/NotificationEntityService.ts
* Update packages/backend/src/core/entities/NotificationEntityService.ts
* Update packages/backend/src/core/entities/NotificationEntityService.ts
* Update packages/backend/src/core/NotificationService.ts
* Clean
---------
Co-authored-by: dakkar <dakkar@thenautilus.net>
Co-authored-by: kakkokari-gtyih <daisho7308+f@gmail.com>
Co-authored-by: かっこかり <67428053+kakkokari-gtyih@users.noreply.github.com>
Co-authored-by: tamaina <tamaina@hotmail.co.jp>
Co-authored-by: syuilo <4439005+syuilo@users.noreply.github.com>
300 lines
13 KiB
TypeScript
300 lines
13 KiB
TypeScript
/*
|
|
* SPDX-FileCopyrightText: syuilo and misskey-project
|
|
* SPDX-License-Identifier: AGPL-3.0-only
|
|
*/
|
|
|
|
process.env.NODE_ENV = 'test';
|
|
|
|
import * as assert from 'assert';
|
|
import { api, post, react, signup, waitFire } from '../utils.js';
|
|
import type * as misskey from 'misskey-js';
|
|
|
|
describe('Mute', () => {
|
|
// alice mutes carol
|
|
let alice: misskey.entities.SignupResponse;
|
|
let bob: misskey.entities.SignupResponse;
|
|
let carol: misskey.entities.SignupResponse;
|
|
|
|
beforeAll(async () => {
|
|
alice = await signup({ username: 'alice' });
|
|
bob = await signup({ username: 'bob' });
|
|
carol = await signup({ username: 'carol' });
|
|
}, 1000 * 60 * 2);
|
|
|
|
test('ミュート作成', async () => {
|
|
const res = await api('/mute/create', {
|
|
userId: carol.id,
|
|
}, alice);
|
|
|
|
assert.strictEqual(res.status, 204);
|
|
});
|
|
|
|
test('「自分宛ての投稿」にミュートしているユーザーの投稿が含まれない', async () => {
|
|
const bobNote = await post(bob, { text: '@alice hi' });
|
|
const carolNote = await post(carol, { text: '@alice hi' });
|
|
|
|
const res = await api('/notes/mentions', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
assert.strictEqual(res.body.some((note: any) => note.id === bobNote.id), true);
|
|
assert.strictEqual(res.body.some((note: any) => note.id === carolNote.id), false);
|
|
});
|
|
|
|
test('ミュートしているユーザーからメンションされても、hasUnreadMentions が true にならない', async () => {
|
|
// 状態リセット
|
|
await api('/i/read-all-unread-notes', {}, alice);
|
|
|
|
await post(carol, { text: '@alice hi' });
|
|
|
|
const res = await api('/i', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(res.body.hasUnreadMentions, false);
|
|
});
|
|
|
|
test('ミュートしているユーザーからメンションされても、ストリームに unreadMention イベントが流れてこない', async () => {
|
|
// 状態リセット
|
|
await api('/i/read-all-unread-notes', {}, alice);
|
|
|
|
const fired = await waitFire(alice, 'main', () => post(carol, { text: '@alice hi' }), msg => msg.type === 'unreadMention');
|
|
|
|
assert.strictEqual(fired, false);
|
|
});
|
|
|
|
test('ミュートしているユーザーからメンションされても、ストリームに unreadNotification イベントが流れてこない', async () => {
|
|
// 状態リセット
|
|
await api('/i/read-all-unread-notes', {}, alice);
|
|
await api('/notifications/mark-all-as-read', {}, alice);
|
|
|
|
const fired = await waitFire(alice, 'main', () => post(carol, { text: '@alice hi' }), msg => msg.type === 'unreadNotification');
|
|
|
|
assert.strictEqual(fired, false);
|
|
});
|
|
|
|
describe('Timeline', () => {
|
|
test('タイムラインにミュートしているユーザーの投稿が含まれない', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
const bobNote = await post(bob, { text: 'hi' });
|
|
const carolNote = await post(carol, { text: 'hi' });
|
|
|
|
const res = await api('/notes/local-timeline', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
assert.strictEqual(res.body.some((note: any) => note.id === aliceNote.id), true);
|
|
assert.strictEqual(res.body.some((note: any) => note.id === bobNote.id), true);
|
|
assert.strictEqual(res.body.some((note: any) => note.id === carolNote.id), false);
|
|
});
|
|
|
|
test('タイムラインにミュートしているユーザーの投稿のRenoteが含まれない', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
const carolNote = await post(carol, { text: 'hi' });
|
|
const bobNote = await post(bob, {
|
|
renoteId: carolNote.id,
|
|
});
|
|
|
|
const res = await api('/notes/local-timeline', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
assert.strictEqual(res.body.some((note: any) => note.id === aliceNote.id), true);
|
|
assert.strictEqual(res.body.some((note: any) => note.id === bobNote.id), false);
|
|
assert.strictEqual(res.body.some((note: any) => note.id === carolNote.id), false);
|
|
});
|
|
});
|
|
|
|
describe('Notification', () => {
|
|
test('通知にミュートしているユーザーの通知が含まれない(リアクション)', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
await react(bob, aliceNote, 'like');
|
|
await react(carol, aliceNote, 'like');
|
|
|
|
const res = await api('/i/notifications', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
test('通知にミュートしているユーザーからのリプライが含まれない', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
await post(bob, { text: '@alice hi', replyId: aliceNote.id });
|
|
await post(carol, { text: '@alice hi', replyId: aliceNote.id });
|
|
|
|
const res = await api('/i/notifications', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからのリプライが含まれない', async () => {
|
|
await post(alice, { text: 'hi' });
|
|
await post(bob, { text: '@alice hi' });
|
|
await post(carol, { text: '@alice hi' });
|
|
|
|
const res = await api('/i/notifications', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからの引用リノートが含まれない', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
await post(bob, { text: 'hi', renoteId: aliceNote.id });
|
|
await post(carol, { text: 'hi', renoteId: aliceNote.id });
|
|
|
|
const res = await api('/i/notifications', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからのリノートが含まれない', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
await post(bob, { renoteId: aliceNote.id });
|
|
await post(carol, { renoteId: aliceNote.id });
|
|
|
|
const res = await api('/i/notifications', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからのフォロー通知が含まれない', async () => {
|
|
await api('/i/follow', { userId: alice.id }, bob);
|
|
await api('/i/follow', { userId: alice.id }, carol);
|
|
|
|
const res = await api('/i/notifications', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからのフォローリクエストが含まれない', async () => {
|
|
await api('/i/update/', { isLocked: true }, alice);
|
|
await api('/following/create', { userId: alice.id }, bob);
|
|
await api('/following/create', { userId: alice.id }, carol);
|
|
|
|
const res = await api('/i/notifications', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
});
|
|
|
|
describe('Notification (Grouped)', () => {
|
|
test('通知にミュートしているユーザーの通知が含まれない(リアクション)', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
await react(bob, aliceNote, 'like');
|
|
await react(carol, aliceNote, 'like');
|
|
|
|
const res = await api('/i/notifications-grouped', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
test('通知にミュートしているユーザーからのリプライが含まれない', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
await post(bob, { text: '@alice hi', replyId: aliceNote.id });
|
|
await post(carol, { text: '@alice hi', replyId: aliceNote.id });
|
|
|
|
const res = await api('/i/notifications-grouped', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからのリプライが含まれない', async () => {
|
|
await post(alice, { text: 'hi' });
|
|
await post(bob, { text: '@alice hi' });
|
|
await post(carol, { text: '@alice hi' });
|
|
|
|
const res = await api('/i/notifications-grouped', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからの引用リノートが含まれない', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
await post(bob, { text: 'hi', renoteId: aliceNote.id });
|
|
await post(carol, { text: 'hi', renoteId: aliceNote.id });
|
|
|
|
const res = await api('/i/notifications-grouped', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからのリノートが含まれない', async () => {
|
|
const aliceNote = await post(alice, { text: 'hi' });
|
|
await post(bob, { renoteId: aliceNote.id });
|
|
await post(carol, { renoteId: aliceNote.id });
|
|
|
|
const res = await api('/i/notifications-grouped', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからのフォロー通知が含まれない', async () => {
|
|
await api('/i/follow', { userId: alice.id }, bob);
|
|
await api('/i/follow', { userId: alice.id }, carol);
|
|
|
|
const res = await api('/i/notifications-grouped', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
|
|
test('通知にミュートしているユーザーからのフォローリクエストが含まれない', async () => {
|
|
await api('/i/update/', { isLocked: true }, alice);
|
|
await api('/following/create', { userId: alice.id }, bob);
|
|
await api('/following/create', { userId: alice.id }, carol);
|
|
|
|
const res = await api('/i/notifications-grouped', {}, alice);
|
|
|
|
assert.strictEqual(res.status, 200);
|
|
assert.strictEqual(Array.isArray(res.body), true);
|
|
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === bob.id), true);
|
|
assert.strictEqual(res.body.some((notification: any) => notification.userId === carol.id), false);
|
|
});
|
|
});
|
|
});
|