summaryrefslogtreecommitdiff
path: root/src/server/api/stream/channels/main.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2021-11-12 02:02:25 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2021-11-12 02:02:25 +0900
commit0e4a111f81cceed275d9bec2695f6e401fb654d8 (patch)
tree40874799472fa07416f17b50a398ac33b7771905 /src/server/api/stream/channels/main.ts
parentupdate deps (diff)
downloadmisskey-0e4a111f81cceed275d9bec2695f6e401fb654d8.tar.gz
misskey-0e4a111f81cceed275d9bec2695f6e401fb654d8.tar.bz2
misskey-0e4a111f81cceed275d9bec2695f6e401fb654d8.zip
refactoring
Resolve #7779
Diffstat (limited to 'src/server/api/stream/channels/main.ts')
-rw-r--r--src/server/api/stream/channels/main.ts43
1 files changed, 0 insertions, 43 deletions
diff --git a/src/server/api/stream/channels/main.ts b/src/server/api/stream/channels/main.ts
deleted file mode 100644
index 131ac30472..0000000000
--- a/src/server/api/stream/channels/main.ts
+++ /dev/null
@@ -1,43 +0,0 @@
-import autobind from 'autobind-decorator';
-import Channel from '../channel';
-import { Notes } from '@/models/index';
-
-export default class extends Channel {
- public readonly chName = 'main';
- public static shouldShare = true;
- public static requireCredential = true;
-
- @autobind
- public async init(params: any) {
- // Subscribe main stream channel
- this.subscriber.on(`mainStream:${this.user!.id}`, async data => {
- switch (data.type) {
- case 'notification': {
- if (data.body.userId && this.muting.has(data.body.userId)) return;
-
- if (data.body.note && data.body.note.isHidden) {
- const note = await Notes.pack(data.body.note.id, this.user, {
- detail: true
- });
- this.connection.cacheNote(note);
- data.body.note = note;
- }
- break;
- }
- case 'mention': {
- if (this.muting.has(data.body.userId)) return;
- if (data.body.isHidden) {
- const note = await Notes.pack(data.body.id, this.user, {
- detail: true
- });
- this.connection.cacheNote(note);
- data.body = note;
- }
- break;
- }
- }
-
- this.send(data.type, data.body);
- });
- }
-}