import autobind from 'autobind-decorator'; import Mute from '../../../../models/mute'; import { pack } from '../../../../models/note'; import shouldMuteThisNote from '../../../../misc/should-mute-this-note'; import Channel from '../channel'; export default class extends Channel { public readonly chName = 'localTimeline'; public static shouldShare = true; public static requireCredential = false; private mutedUserIds: string[] = []; @autobind public async init(params: any) { // Subscribe events this.subscriber.on('localTimeline', this.onNote); const mute = this.user ? await Mute.find({ muterId: this.user._id }) : null; this.mutedUserIds = mute ? mute.map(m => m.muteeId.toString()) : []; } @autobind private async onNote(note: any) { // Renoteなら再pack if (note.renoteId != null) { note.renote = await pack(note.renoteId, this.user, { detail: true }); } // 流れてきたNoteがミュートしているユーザーが関わるものだったら無視する if (shouldMuteThisNote(note, this.mutedUserIds)) return; this.send('note', note); } @autobind public dispose() { // Unsubscribe events this.subscriber.off('localTimeline', this.onNote); } }