lei import: keep sync info for Maildir and IMAP folders

[public-inbox.git] / lib / PublicInbox / LeiSearch.pm

diff --git a/lib/PublicInbox/LeiSearch.pm b/lib/PublicInbox/LeiSearch.pm
index 082176e7dbdda84e17784260baa82df8a333eb8f..cd28a700647bf62a37655108d9fb1467f776fbcc 100644 (file)
--- a/lib/PublicInbox/LeiSearch.pm
+++ b/lib/PublicInbox/LeiSearch.pm
@@ -103,8 +103,16 @@ sub kw_changed {
        my $xoids = xoids_for($self, $eml) // return;
        $docids //= [];
        @$docids = sort { $a <=> $b } values %$xoids;
-       my @cur_kw = msg_keywords($self, $docids->[0]);
-       join("\0", @$new_kw_sorted) eq join("\0", @cur_kw) ? 0 : 1;
+       my $cur_kw = msg_keywords($self, $docids->[0]);
+
+       # RFC 5550 sec 5.9 on the $Forwarded keyword states:
+       # "Once set, the flag SHOULD NOT be cleared"
+       if (exists($cur_kw->{forwarded}) &&
+                       !grep(/\Aforwarded\z/, @$new_kw_sorted)) {
+               delete $cur_kw->{forwarded};
+       }
+       $cur_kw = join("\0", sort keys %$cur_kw);
+       join("\0", @$new_kw_sorted) eq $cur_kw ? 0 : 1;
 }
 
 sub all_terms {
@@ -129,4 +137,11 @@ sub qparse_new {
        $qp
 }
 
+sub lms {
+       my ($self) = @_;
+       require PublicInbox::LeiMailSync;
+       my $f = "$self->{topdir}/mail_sync.sqlite3";
+       -f $f ? PublicInbox::LeiMailSync->new($f) : undef;
+}
+
 1;