admin streamingを廃止

src/server/api/endpoints/users/report-abuse.ts

@@ -3,7 +3,6 @@ import ID, { transform } from '../../../../misc/cafy-id';
 import define from '../../define';
 import User from '../../../../models/user';
 import AbuseUserReport from '../../../../models/abuse-user-report';
-import { publishAdminStream } from '../../../../services/stream';
 import { ApiError } from '../../error';
 import { getUser } from '../../common/getters';
 
@@ -86,25 +85,4 @@ export default define(meta, async (ps, me) => {
 		noteIds: ps.noteIds,
 		comment: ps.comment
 	});
-
-	// Publish event to moderators
-	setTimeout(async () => {
-		const moderators = await User.find({
-			$or: [{
-				isAdmin: true
-			}, {
-				isModerator: true
-			}]
-		});
-
-		for (const moderator of moderators) {
-			publishAdminStream(moderator._id, 'newAbuseUserReport', {
-				id: report._id,
-				userId: report.userId,
-				reporterId: report.reporterId,
-				noteIds: report.noteIds,
-				comment: report.comment
-			});
-		}
-	}, 1);
 });

src/server/api/stream/channels/index.ts

@@ -14,7 +14,6 @@ import messaging from './messaging';
 import messagingIndex from './messaging-index';
 import drive from './drive';
 import hashtag from './hashtag';
-import admin from './admin';
 import gamesReversi from './games/reversi';
 import gamesReversiGame from './games/reversi-game';
 
@@ -35,7 +34,6 @@ export default {
 	messagingIndex,
 	drive,
 	hashtag,
-	admin,
 	gamesReversi,
 	gamesReversiGame
 };

src/services/stream.ts

@@ -83,10 +83,6 @@ export function publishHotStream(note: PackedNote): void {
 	publish(`hotStream`, null, note);
 }
 
-export function publishAdminStream(userId: ID, type: string, value?: unknown): void {
-	publish(`adminStream:${userId}`, type, typeof value === 'undefined' ? null : value);
-}
-
 export function publishServerEvent(userId: ID | null, type: string, value?: unknown): void {
 	const name = userId ? `serverEvent:${userId}` : `serverEvent`;
 	publish(name, type, typeof value === 'undefined' ? null : value);