M app.go → app.go

@@ -85,6 +85,15 @@ app.Log("Update failed: %v", err).Stdout().StatusLine()
 			}
 		}
 	}()
+	go func() {
+		ticker := time.NewTicker(5 * time.Second)
+		defer ticker.Stop()
+		for range ticker.C {
+			if err := app.syncMessages(); err != nil {
+				app.Log("Sync failed: %v", err).Stdout().StatusLine()
+			}
+		}
+	}()
 	app.EstablishMailConnections()
 	return
 }

M email.go → email.go

@@ -410,3 +410,9 @@ }
 
 	return parts, nil
 }
+
+func (app *App) messageExistsByServerID(serverID string) bool {
+    var count int64
+    app.DB.Model(&Message{}).Where("server_message_id = ?", serverID).Count(&count)
+    return count > 0
+}

M mailaccount.go → mailaccount.go

@@ -240,6 +240,14 @@ }
 	}
 }
 
+type MailboxSyncState struct {
+    gorm.Model
+    EmailAddressID uint
+    EmailAddress   EmailAddress
+    MailboxName    string
+    LastUID        uint32
+}
+
 func (app *App) organizeMailboxesForAccount(conn MailAccountConnection) error {
 	for _, mailbox := range SourceMailboxes {
 		if _, err := conn.ImapClient.Select(mailbox, nil).Wait(); err != nil {
@@ -269,6 +277,8 @@ }
 
 	return nil
 }
+
+
 func (app *App) syncMailbox(email EmailAddress, conn MailAccountConnection) error {
 	if err := app.organizeMailboxesForAccount(conn); err != nil {
 		return err

M releases → releases

@@ -1,3 +1,4 @@
+prerelease.8
 prerelease.7
 prerelease.6
 prerelease.5