Reduce snapshots, add better logic check

src/state/messages/convo.ts

@@ -417,24 +417,19 @@ export class Convo {
 
   private async pollEvents() {
     if (
-      this.status !== ConvoStatus.Ready &&
-      this.status !== ConvoStatus.Backgrounded
-    )
-      return
+      this.status === ConvoStatus.Ready ||
+      this.status === ConvoStatus.Backgrounded
+    ) {
       if (this.pendingEventIngestion) return
 
       setTimeout(async () => {
-      logger.debug(
-        'Convo: poll',
-        {pollInterval: this.pollInterval},
-        logger.DebugContext.convo,
-      )
         this.pendingEventIngestion = this.ingestLatestEvents()
         await this.pendingEventIngestion
         this.pendingEventIngestion = undefined
         this.pollEvents()
       }, this.pollInterval)
     }
+  }
 
   async ingestLatestEvents() {
     const response = await this.agent.api.chat.bsky.convo.getLog(
@@ -449,6 +444,8 @@ export class Convo {
     )
     const {logs} = response.data
 
+    let needsCommit = false
+
     for (const log of logs) {
       /*
        * If there's a rev, we should handle it. If there's not a rev, we don't
@@ -479,6 +476,7 @@ export class Convo {
               this.newMessages.delete(log.message.id)
             }
             this.newMessages.set(log.message.id, log.message)
+            needsCommit = true
           } else if (
             ChatBskyConvoDefs.isLogDeleteMessage(log) &&
             ChatBskyConvoDefs.isDeletedMessageView(log.message)
@@ -496,14 +494,17 @@ export class Convo {
               this.pastMessages.delete(log.message.id)
               this.newMessages.delete(log.message.id)
               this.deletedMessages.delete(log.message.id)
+              needsCommit = true
             }
           }
         }
       }
     }
 
+    if (needsCommit) {
       this.commit()
     }
+  }
 
   async sendMessage(message: ChatBskyConvoSendMessage.InputSchema['message']) {
     // Ignore empty messages for now since they have no other purpose atm