2 files changed, 24 insertions, 0 deletions
diff --git a/src/utils/index.ts b/src/utils/index.ts
index 739e6fb8..4ff9afac 100644
--- a/src/utils/index.ts
+++ b/src/utils/index.ts
@@ -4,3 +4,4 @@ export * from './common';
 export * from './users';
 export * from './friends';
 export * from './search';
+export * from './messages';
diff --git a/src/utils/messages.ts b/src/utils/messages.ts
index d63f2b7a..0ef56edb 100644
--- a/src/utils/messages.ts
+++ b/src/utils/messages.ts
@@ -1,4 +1,7 @@
+import AsyncStorage from '@react-native-community/async-storage';
 import moment from 'moment';
+import {updateChatClientReady} from '../store/actions';
+import {AppDispatch} from '../store/configureStore';
 import {RootState} from '../store/rootReducer';
 import {ChannelGroupedType} from '../types';
 
@@ -81,3 +84,23 @@ export const getMember = (
     : [];
   return otherMembers.length === 1 ? otherMembers[0] : undefined;
 };
+
+export const connectChatAccount = async (
+  loggedInUserId: string,
+  chatClient,
+  dispatch: AppDispatch,
+) => {
+  try {
+    const chatToken = await AsyncStorage.getItem('chatToken');
+    chatClient.connectUser(
+      {
+        id: loggedInUserId,
+      },
+      chatToken,
+    );
+    dispatch(updateChatClientReady(true));
+  } catch (err) {
+    dispatch(updateChatClientReady(true));
+    console.log('Error while connecting user to Stream: ', err);
+  }
+};