mirror/misskey
1
0
Fork 1
mirror of https://github.com/misskey-dev/misskey.git synced 2024-12-24 00:39:32 +09:00
Code Issues Actions Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
syuilo 2023-10-01 20:25:51 +09:00
parent 06cfe618bb
commit 3dd3c69303
2 changed files with 28 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
packages/backend/src/server/api/endpoints/notes/timeline.ts
View File

@ -14,6 +14,7 @@ import { NoteEntityService } from '@/core/entities/NoteEntityService.js';
import { DI } from '@/di-symbols.js';
import { IdService } from '@/core/IdService.js';
import { CacheService } from '@/core/CacheService.js';
import { isUserRelated } from '@/misc/is-user-related.js';
export const meta = {
tags: ['notes'],
@ -64,7 +65,13 @@ export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-
private cacheService: CacheService,
) {
super(meta, paramDef, async (ps, me) => {
const mutings = await this.cacheService.userMutingsCache.fetch(me.id);
const [
userIdsWhoMeMuting,
userIdsWhoMeMutingRenotes,
] = await Promise.all([
this.cacheService.userMutingsCache.fetch(me.id),
this.cacheService.renoteMutingsCache.fetch(me.id),
]);
let timeline: MiNote[] = [];
@ -99,22 +106,17 @@ export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-
// ミュート等考慮
timeline = timeline.filter(note => {
// TODO: インスタンスミュートの考慮
// TODO: リノートミュートの考慮
if (note.userId === me.id) {
return true;
}
if (note.renote) {
if (mutings.has(note.renote.userId)) return false;
}
if (note.reply) {
if (mutings.has(note.reply.userId)) return false;
}
if (ps.withRenotes === false) {
if (note.renoteId && note.text == null && note.fileIds.length === 0 && !note.hasPoll) return false;
if (isUserRelated(note, userIdsWhoMeMuting)) return false;
if (note.renoteId) {
if (note.text == null && note.fileIds.length === 0 && !note.hasPoll) {
if (isUserRelated(note, userIdsWhoMeMutingRenotes)) return false;
if (ps.withRenotes === false) return false;
}
}
return true;

30
packages/backend/src/server/api/endpoints/notes/user-list-timeline.ts
View File

@ -14,6 +14,7 @@ import ActiveUsersChart from '@/core/chart/charts/active-users.js';
import { DI } from '@/di-symbols.js';
import { CacheService } from '@/core/CacheService.js';
import { IdService } from '@/core/IdService.js';
import { isUserRelated } from '@/misc/is-user-related.js';
import { ApiError } from '../../error.js';
export const meta = {
@ -90,7 +91,13 @@ export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-
throw new ApiError(meta.errors.noSuchList);
}
const mutings = await this.cacheService.userMutingsCache.fetch(me.id);
const [
userIdsWhoMeMuting,
userIdsWhoMeMutingRenotes,
] = await Promise.all([
this.cacheService.userMutingsCache.fetch(me.id),
this.cacheService.renoteMutingsCache.fetch(me.id),
]);
let timeline: MiNote[] = [];
@ -125,22 +132,13 @@ export default class extends Endpoint<typeof meta, typeof paramDef> { // eslint-
// ミュート等考慮
timeline = timeline.filter(note => {
// TODO: インスタンスミュートの考慮
// TODO: リノートミュートの考慮
if (note.userId === me.id) {
return true;
}
if (note.renote) {
if (mutings.has(note.renote.userId)) return false;
}
if (note.reply) {
if (mutings.has(note.reply.userId)) return false;
}
if (ps.withRenotes === false) {
if (note.renoteId && note.text == null && note.fileIds.length === 0 && !note.hasPoll) return false;
if (isUserRelated(note, userIdsWhoMeMuting)) return false;
if (note.renoteId) {
if (note.text == null && note.fileIds.length === 0 && !note.hasPoll) {
if (isUserRelated(note, userIdsWhoMeMutingRenotes)) return false;
if (ps.withRenotes === false) return false;
}
}
return true;