fix: Cannot read properties of null issue

Author: druzhchenko

lib/imAdapters.js

@@ -1,4 +1,3 @@
-
 /**
  * sendbird-utils v0.0.3
  * SendBird utils
@@ -15,7 +14,12 @@ function getParamsFromChannelName(channelName) {
   var params = channelName.split('#');
   var env = params[0];
 
-  if (env !== 'staging' && env !== 'development' && env !== 'production' && env !== 'local') {
+  if (
+    env !== 'staging' &&
+    env !== 'development' &&
+    env !== 'production' &&
+    env !== 'local'
+  ) {
     // $FlowFixMe
     return null;
   }
@@ -25,14 +29,14 @@ function getParamsFromChannelName(channelName) {
       env: env,
       companyId: params[1],
       documentId: params[2],
-      users: params.slice(-2).sort()
+      users: params.slice(-2).sort(),
     };
   }
 
   return {
     env: env,
     companyId: params[1],
-    users: params.slice(-2).sort()
+    users: params.slice(-2).sort(),
   };
 }
 function getParamsFromChannelNameWithEnv(buildEnv, channelName) {
@@ -43,15 +47,19 @@ function getParamsFromChannelNameWithEnv(buildEnv, channelName) {
   return null;
 }
 function getThreadFromChannelFactory(buildEnv) {
-  return function getThreadFromChannel(channel, documentChannelAdapter, generalChannelAdapter, n) {
+  return function getThreadFromChannel(
+    channel,
+    documentChannelAdapter,
+    generalChannelAdapter,
+    n
+  ) {
     var params = getParamsFromChannelNameWithEnv(buildEnv, channel.name);
 
     if (params) {
       if (params.documentId) {
         return documentChannelAdapter(channel, params);
       } // $FlowFixMe is real GeneralChannelParamsType
 
-
       return generalChannelAdapter(channel, params);
     }
 
@@ -63,17 +71,17 @@ function getThreadFromChannelFactory(buildEnv) {
 var SenderFactory = new immutable.Record({
   userId: '',
   nickname: '',
-  profileUrl: ''
+  profileUrl: '',
 });
 
 function senderAdapter(_ref) {
   var userId = _ref.userId,
-      nickname = _ref.nickname,
-      profileUrl = _ref.profileUrl;
+    nickname = _ref.nickname,
+    profileUrl = _ref.profileUrl;
   return SenderFactory({
     userId: userId,
     nickname: nickname,
-    profileUrl: profileUrl
+    profileUrl: profileUrl,
   });
 }
 
@@ -89,30 +97,30 @@ var MessageFactory = new immutable.Record({
   createdAt: null,
   updatedAt: null,
   sender: SenderFactory(),
-  data: ''
+  data: '',
 });
 
 function messageAdapter(userMessage) {
   /* $FlowFixMe FileMessage | AdminMessage is not implemented */
   var messageId = userMessage.messageId,
-      message = userMessage.message,
-      createdAt = userMessage.createdAt,
-      updatedAt = userMessage.updatedAt,
-      data = userMessage.data,
-      sender = userMessage.sender;
+    message = userMessage.message,
+    createdAt = userMessage.createdAt,
+    updatedAt = userMessage.updatedAt,
+    data = userMessage.data,
+    sender = userMessage.sender;
   return MessageFactory({
     messageId: messageId,
     message: message,
     createdAt: createdAt,
     updatedAt: updatedAt,
     data: data,
-    sender: senderAdapter(sender)
+    sender: senderAdapter(sender),
   });
 }
 
 function messagesListAdapter(userMessages) {
   return userMessages.reduce(function (a, v) {
-    return a.add(messageAdapter(v));
+    return v ? a.add(messageAdapter(v)) : a;
   }, new immutable.Set());
 }
 
@@ -123,15 +131,15 @@ var documentThreadFactory = new immutable.Record({
   members: new immutable.List(),
   name: '',
   unreadMessageCount: 0,
-  messages: new immutable.Set()
+  messages: new immutable.Set(),
 });
 function documentThreadAdapter(channel, messages, params) {
   var url = channel.url,
-      name = channel.name,
-      unreadMessageCount = channel.unreadMessageCount,
-      members = channel.members;
+    name = channel.name,
+    unreadMessageCount = channel.unreadMessageCount,
+    members = channel.members;
   var companyId = params.companyId,
-      documentId = params.documentId;
+    documentId = params.documentId;
   var membersList = membersAdapter(members);
   var messagesList = messagesListAdapter(messages);
   return documentThreadFactory({
@@ -141,7 +149,7 @@ function documentThreadAdapter(channel, messages, params) {
     members: membersList,
     name: name,
     unreadMessageCount: unreadMessageCount,
-    messages: messagesList
+    messages: messagesList,
   });
 }
 var generalThreadFactory = new immutable.Record({
@@ -150,14 +158,14 @@ var generalThreadFactory = new immutable.Record({
   members: new immutable.List(),
   name: '',
   unreadMessageCount: 0,
-  messages: new immutable.Set()
+  messages: new immutable.Set(),
 });
 function generalThreadAdapter(channel, messages, _ref2) {
   var companyId = _ref2.companyId;
   var url = channel.url,
-      name = channel.name,
-      unreadMessageCount = channel.unreadMessageCount,
-      members = channel.members;
+    name = channel.name,
+    unreadMessageCount = channel.unreadMessageCount,
+    members = channel.members;
   var membersList = membersAdapter(members);
   var messagesList = messagesListAdapter(messages);
   return generalThreadFactory({
@@ -166,7 +174,7 @@ function generalThreadAdapter(channel, messages, _ref2) {
     members: membersList,
     name: name,
     unreadMessageCount: unreadMessageCount,
-    messages: messagesList
+    messages: messagesList,
   });
 }
 
@@ -184,26 +192,36 @@ function channelsFactory(env) {
   var getThreadFromChannel = getThreadFromChannelFactory(env);
   return function (a, channel) {
     var lastMessage = channel.lastMessage;
-    return getThreadFromChannel(channel, function (_, params) {
-      return dth(a, channel, lastMessage, params);
-    }, function (_, params) {
-      return gth(a, channel, lastMessage, params);
-    }, function () {
-      return a;
-    });
+    return getThreadFromChannel(
+      channel,
+      function (_, params) {
+        return dth(a, channel, lastMessage, params);
+      },
+      function (_, params) {
+        return gth(a, channel, lastMessage, params);
+      },
+      function () {
+        return a;
+      }
+    );
   };
 }
 
 function messageReceiveFactory(env) {
   var getThreadFromChannel = getThreadFromChannelFactory(env);
   return function (channel, messages) {
-    return getThreadFromChannel(channel, function (_, params) {
-      return documentThreadAdapter(channel, messages, params);
-    }, function (_, params) {
-      return generalThreadAdapter(channel, messages, params);
-    }, function () {
-      return null;
-    });
+    return getThreadFromChannel(
+      channel,
+      function (_, params) {
+        return documentThreadAdapter(channel, messages, params);
+      },
+      function (_, params) {
+        return generalThreadAdapter(channel, messages, params);
+      },
+      function () {
+        return null;
+      }
+    );
   };
 }
 function channelsToThreads(env, channels) {
@@ -212,7 +230,7 @@ function channelsToThreads(env, channels) {
 
 /*  */
 var chatStateFactory = new immutable.Record({
-  threads: new immutable.Map()
+  threads: new immutable.Map(),
 });
 
 function messagesMerge(oldValue, newValue, key) {
@@ -221,10 +239,12 @@ function messagesMerge(oldValue, newValue, key) {
 }
 
 function receiveMessageMergeTpState(state, thread) {
-  return state.updateIn(['threads', thread.name], // $FlowFixMe
-  function (u) {
-    return u ? u.mergeWith(messagesMerge, thread) : thread;
-  });
+  return state.updateIn(
+    ['threads', thread.name], // $FlowFixMe
+    function (u) {
+      return u ? u.mergeWith(messagesMerge, thread) : thread;
+    }
+  );
 }
 
 exports.channelsToThreads = channelsToThreads;