From 9e9d378bf1301d4c3fcde08543be1014c71a87cd Mon Sep 17 00:00:00 2001
From: syuilo <syuilotan@yahoo.co.jp>
Date: Thu, 2 Apr 2020 22:17:17 +0900
Subject: feat(streaming): Add emoji added event

---
 src/server/api/stream/index.ts | 9 +++++++++
 1 file changed, 9 insertions(+)

(limited to 'src/server/api/stream/index.ts')

diff --git a/src/server/api/stream/index.ts b/src/server/api/stream/index.ts
index 2781d14bd9..b7cefcf5ab 100644
--- a/src/server/api/stream/index.ts
+++ b/src/server/api/stream/index.ts
@@ -39,6 +39,10 @@ export default class Connection {
 
 		this.wsConnection.on('message', this.onWsConnectionMessage);
 
+		this.subscriber.on('broadcast', async ({ type, body }) => {
+			this.onBroadcastMessage(type, body);
+		});
+
 		if (this.user) {
 			this.updateFollowing();
 			this.followingClock = setInterval(this.updateFollowing, 5000);
@@ -72,6 +76,11 @@ export default class Connection {
 		}
 	}
 
+	@autobind
+	private onBroadcastMessage(type: string, body: any) {
+		this.sendMessageToWs(type, body);
+	}
+
 	/**
 	 * APIリクエスト要求時
 	 */
-- 
cgit v1.2.3-freya