主动重连

src/stores/ConversationStore.js

@@ -28,12 +28,12 @@ const initialConversationState = {
   // referenceMsg: {},
 };
 
-export const templatesSlice = (set) => ({
+const templatesSlice = (set) => ({
   templates: [],
   setTemplates: (templates) => set({ templates }),
 });
 
-export const websocketSlice = (set, get) => ({
+const websocketSlice = (set, get) => ({
   websocket: null,
   websocketOpened: null,
   websocketRetrying: null,
@@ -72,6 +72,13 @@ export const websocketSlice = (set, get) => ({
     websocket.disconnect();
     return set({ websocket: null });
   },
+  reconnectWebsocket: (userId) => {
+    const {disconnectWebsocket, connectWebsocket} = get();
+    disconnectWebsocket();
+    setTimeout(() => {
+      connectWebsocket(userId);
+    }, 500);
+  },
   handleMessage: (data) => {
     console.log('handleMessage------------------');
     console.log(data);
@@ -113,12 +120,12 @@ export const websocketSlice = (set, get) => ({
   },
 });
 
-export const referenceMsgSlice = (set) => ({
+const referenceMsgSlice = (set) => ({
   referenceMsg: {},
   setReferenceMsg: (referenceMsg) => set({ referenceMsg }),
 });
 
-export const conversationSlice = (set, get) => ({
+const conversationSlice = (set, get) => ({
   conversationsList: [],
   currentConversation: {},
 
@@ -166,7 +173,7 @@ export const conversationSlice = (set, get) => ({
   },
 });
 
-export const messageSlice = (set, get) => ({
+const messageSlice = (set, get) => ({
   msgListLoading: false,
   activeConversations: {},
   setMsgLoading: (msgListLoading) => set({ msgListLoading }),