Admin系Streamingを廃止

src/client/app/admin/views/dashboard.ap-log.vue

@@ -29,25 +29,10 @@ export default Vue.extend({
 	data() {
 		return {
 			logs: [],
-			connection: null,
 			faBolt, faExchangeAlt
 		};
 	},
 
-	mounted() {
-		this.connection = this.$root.stream.useSharedConnection('apLog');
-		this.connection.on('log', this.onLog);
-		this.connection.on('logs', this.onLogs);
-		this.connection.send('requestLog', {
-			id: Math.random().toString().substr(2, 8),
-			length: 50
-		});
-	},
-
-	beforeDestroy() {
-		this.connection.dispose();
-	},
-
 	methods: {
 		onLog(log) {
 			log.id = Math.random();

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

@@ -1,7 +1,6 @@
 import $ from 'cafy';
 import { ID } from '../../../../misc/cafy-id';
 import define from '../../define';
-import { publishAdminStream } from '../../../../services/stream';
 import { ApiError } from '../../error';
 import { getUser } from '../../common/getters';
 import { AbuseUserReports, Users } from '../../../../models';
@@ -76,24 +75,4 @@ export default define(meta, async (ps, me) => {
 		reporterId: me.id,
 		comment: ps.comment
 	});
-
-	// Publish event to moderators
-	setTimeout(async () => {
-		const moderators = await Users.find({
-			where: [{
-				isAdmin: true
-			}, {
-				isModerator: true
-			}]
-		});
-
-		for (const moderator of moderators) {
-			publishAdminStream(moderator.id, 'newAbuseUserReport', {
-				id: report.id,
-				userId: report.userId,
-				reporterId: report.reporterId,
-				comment: report.comment
-			});
-		}
-	}, 1);
 });

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

@@ -11,8 +11,6 @@ import messaging from './messaging';
 import messagingIndex from './messaging-index';
 import drive from './drive';
 import hashtag from './hashtag';
-import apLog from './ap-log';
-import admin from './admin';
 import gamesReversi from './games/reversi';
 import gamesReversiGame from './games/reversi-game';
 
@@ -30,8 +28,6 @@ export default {
 	messagingIndex,
 	drive,
 	hashtag,
-	apLog,
-	admin,
 	gamesReversi,
 	gamesReversiGame
 };

src/services/stream.ts

@@ -61,14 +61,6 @@ class Publisher {
 		this.publish('notesStream', null, note);
 	}
 
-	public publishApLogStream = (log: any): void => {
-		this.publish('apLog', null, log);
-	}
-
-	public publishAdminStream = (userId: User['id'], type: string, value?: any): void => {
-		this.publish(`adminStream:${userId}`, type, typeof value === 'undefined' ? null : value);
-	}
-
 	public publishServerEvent = (userId: User['id'] | null, type: string, value?: any): void => {
 		const name = userId ? `serverEvent:${userId}` : `serverEvent`;
 		this.publish(name, type, typeof value === 'undefined' ? null : value);
@@ -89,6 +81,4 @@ export const publishGroupMessagingStream = publisher.publishGroupMessagingStream
 export const publishMessagingIndexStream = publisher.publishMessagingIndexStream;
 export const publishReversiStream = publisher.publishReversiStream;
 export const publishReversiGameStream = publisher.publishReversiGameStream;
-export const publishApLogStream = publisher.publishApLogStream;
-export const publishAdminStream = publisher.publishAdminStream;
 export const publishServerEvent = publisher.publishServerEvent;