speed up loading of messages by not notify on every new message

ts/data/data.ts

@@ -566,24 +566,9 @@ export async function getConversationById(
 }
 
 export async function updateConversation(
-  id: string,
   data: ConversationType
 ): Promise<void> {
-  const existing = await getConversationById(id);
-  if (!existing) {
-    throw new Error(`Conversation ${id} does not exist!`);
-  }
-
-  const merged = _.merge({}, existing.attributes, data);
-
-  // Merging is a really bad idea and not what we want here, e.g.
-  // it will take a union of old and new members and that's not
-  // what we want for member deletion, so:
-  merged.members = data.members;
-
-  // Don't save the online status of the object
-  const cleaned = _.omit(merged, 'isOnline');
-  await channels.updateConversation(cleaned);
+  await channels.updateConversation(data);
 }
 
 export async function removeConversation(id: string): Promise<void> {

ts/models/conversation.ts

@@ -135,6 +135,7 @@ export class ConversationModel extends Backbone.Model<ConversationAttributes> {
   public updateLastMessage: () => any;
   public messageCollection: MessageCollection;
   public throttledBumpTyping: any;
+  public throttledNotify: any;
   public initialPromise: any;
 
   private typingRefreshTimer?: NodeJS.Timeout | null;
@@ -163,6 +164,7 @@ export class ConversationModel extends Backbone.Model<ConversationAttributes> {
       this.bouncyUpdateLastMessage.bind(this),
       1000
     );
+    this.throttledNotify = _.debounce(this.notify, 500, { maxWait: 1000 });
     // Listening for out-of-band data updates
     this.on('expired', this.onExpired);
 
@@ -982,7 +984,7 @@ export class ConversationModel extends Backbone.Model<ConversationAttributes> {
   }
 
   public async commit() {
-    await updateConversation(this.id, this.attributes);
+    await updateConversation(this.attributes);
     this.trigger('change', this);
   }
 
@@ -1587,7 +1589,7 @@ export class ConversationModel extends Backbone.Model<ConversationAttributes> {
     });
   }
 
-  public async notify(message: any) {
+  public async notify(message: MessageModel) {
     if (!message.isIncoming()) {
       return;
     }
@@ -1620,6 +1622,7 @@ export class ConversationModel extends Backbone.Model<ConversationAttributes> {
       title: convo.getTitle(),
     });
   }
+
   public async notifyTyping({ isTyping, sender }: any) {
     // We don't do anything with typing messages from our other devices
     if (UserUtils.isUsFromCache(sender)) {

ts/receiver/queuedJob.ts

@@ -525,7 +525,9 @@ export async function handleMessageJob(
         ourNumber
       );
     }
+
     const id = await message.commit();
+
     message.set({ id });
     window.Whisper.events.trigger('messageAdded', {
       conversationKey: conversation.id,
@@ -575,7 +577,7 @@ export async function handleMessageJob(
     }
 
     if (message.get('unread')) {
-      await conversation.notify(message);
+      await conversation.throttledNotify(message);
     }
 
     if (confirm) {
@@ -589,6 +591,7 @@ export async function handleMessageJob(
       'error:',
       errorForLog
     );
+
     throw error;
   }
 }

ts/session/types/OpenGroup.ts

@@ -122,7 +122,6 @@ export class OpenGroup {
 
     // Return OpenGroup if we're already connected
     conversation = OpenGroup.getConversation(prefixedServer);
-    console.warn(`Convo for ${prefixedServer}: ${conversation}`);
 
     if (conversation) {
       conversationId = conversation?.cid;
@@ -132,11 +131,6 @@ export class OpenGroup {
           channel: 1,
           conversationId,
         });
-      } else {
-        console.warn(
-          'NO conversationId = conversation?.cid',
-          conversation?.cid
-        );
       }
     }