[Server] Introduce admin stream channel

1 files changed, 5 insertions, 0 deletions

diff --git a/src/stream.ts b/src/stream.ts
index 596cb98e72..098d49ecd1 100644
--- a/src/stream.ts
+++ b/src/stream.ts
@@ -87,6 +87,10 @@ class Publisher {
 	public publishApLogStream = (log: any): void => {
 		this.publish('apLog', null, log);
 	}
+
+	public publishAdminStream = (userId: ID, type: string, value?: any): void => {
+		this.publish(`adminStream:${userId}`, type, typeof value === 'undefined' ? null : value);
+	}
 }
 
 const publisher = new Publisher();
@@ -107,3 +111,4 @@ export const publishHybridTimelineStream = publisher.publishHybridTimelineStream
 export const publishGlobalTimelineStream = publisher.publishGlobalTimelineStream;
 export const publishHashtagStream = publisher.publishHashtagStream;
 export const publishApLogStream = publisher.publishApLogStream;
+export const publishAdminStream = publisher.publishAdminStream;