From ded912f75371d6bffe7114a5a6a6b9cd4edd9660 Mon Sep 17 00:00:00 2001
From: moonrailgun <moonrailgun@gmail.com>
Date: Thu, 5 Aug 2021 20:20:46 +0800
Subject: [PATCH] =?UTF-8?q?refactor:=20=E6=B6=88=E6=81=AF=E4=BA=8B?=
 =?UTF-8?q?=E4=BB=B6=E6=8E=A5=E6=94=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 shared/model/message.ts |  2 ++
 shared/redux/setup.ts   | 12 ++++++++++--
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/shared/model/message.ts b/shared/model/message.ts
index 9693d0d3..3581a2df 100644
--- a/shared/model/message.ts
+++ b/shared/model/message.ts
@@ -11,6 +11,8 @@ export interface ChatMessage {
 
   converseId: string;
 
+  reactions?: any[];
+
   createdAt?: string;
 
   updatedAt?: string;
diff --git a/shared/redux/setup.ts b/shared/redux/setup.ts
index c46c895d..13f6f5df 100644
--- a/shared/redux/setup.ts
+++ b/shared/redux/setup.ts
@@ -2,10 +2,9 @@ import type { AppStore } from './store';
 import type { AppSocket } from '../api/socket';
 import { chatActions, groupActions, userActions } from './slices';
 import type { FriendRequest } from '../model/friend';
-import type { UserDMList } from '../model/user';
 import { getCachedConverseInfo } from '../cache/cache';
 import type { GroupInfo } from '../model/group';
-import { fetchConverseMessage } from '../model/message';
+import type { ChatMessage } from '../model/message';
 
 /**
  * 初始化 Redux 上下文
@@ -70,6 +69,15 @@ function listenNotify(socket: AppSocket, store: AppStore) {
     }
   );
 
+  socket.listen<ChatMessage>('chat.message.add', (message) => {
+    store.dispatch(
+      chatActions.appendConverseMessage({
+        converseId: message.converseId,
+        messages: [message],
+      })
+    );
+  });
+
   socket.listen<GroupInfo>('group.updateInfo', (groupInfo) => {
     store.dispatch(groupActions.updateGroup(groupInfo));
   });