searchidx: store the primary MID in doc data for NNTP

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

diff --git a/lib/PublicInbox/SearchIdxPart.pm b/lib/PublicInbox/SearchIdxPart.pm
index 2f577ecff5a807d921ea9ddab0be7a802f008e25..6d8cb2a7e93748814eb0a24932735dc736f294ff 100644 (file)
--- a/lib/PublicInbox/SearchIdxPart.pm
+++ b/lib/PublicInbox/SearchIdxPart.pm
@@ -51,7 +51,7 @@ sub partition_worker_loop ($$$) {
                        $xdb = $txn = undef;
                } else {
                        chomp $line;
-                       my ($len, $artnum, $object_id) = split(/ /, $line);
+                       my ($len, $artnum, $oid, $mid0) = split(/ /, $line);
                        $xdb ||= $self->_xdb_acquire;
                        if (!$txn) {
                                $xdb->begin_transaction;
@@ -61,7 +61,7 @@ sub partition_worker_loop ($$$) {
                        $n == $len or die "short read: $n != $len\n";
                        my $mime = PublicInbox::MIME->new(\$msg);
                        $artnum = int($artnum);
-                       $self->add_message($mime, $n, $artnum, $object_id);
+                       $self->add_message($mime, $n, $artnum, $oid, $mid0);
                }
        }
        warn "$$ still in transaction\n" if $txn;
@@ -70,9 +70,9 @@ sub partition_worker_loop ($$$) {
 
 # called by V2Writable
 sub index_raw {
-       my ($self, $len, $msgref, $artnum, $object_id) = @_;
+       my ($self, $len, $msgref, $artnum, $object_id, $mid0) = @_;
        my $w = $self->{w};
-       print $w "$len $artnum $object_id\n", $$msgref or die
+       print $w "$len $artnum $object_id $mid0\n", $$msgref or die
                "failed to write partition $!\n";
        $w->flush or die "failed to flush: $!\n";
 }