v2writable: deduplicate detection on add

This is a bit expensive in a multi-process situation because
we need to make our indices and packs visible to the read-only
pieces.

1 files changed, 16 insertions, 0 deletions

diff --git a/lib/PublicInbox/Search.pm b/lib/PublicInbox/Search.pm
index 21c72b6f..c074410c 100644
--- a/lib/PublicInbox/Search.pm
+++ b/lib/PublicInbox/Search.pm
@@ -371,6 +371,22 @@ sub lookup_mail { # no ghosts!
         });
 }
 
+sub each_smsg_by_mid {
+        my ($self, $mid, $cb) = @_;
+        $mid = mid_clean($mid);
+        my $xdb = $self->{xdb};
+        # XXX retry_reopen isn't necessary for V2Writable, but the PSGI
+        # interface will need it...
+        my ($head, $tail) = $self->find_doc_ids('XMID' . $mid);
+        for (; $head->nequal($tail); $head->inc) {
+                my $doc_id = $head->get_docid;
+                my $doc = $xdb->get_document($doc_id);
+                my $smsg = PublicInbox::SearchMsg->wrap($doc, $mid);
+                $smsg->{doc_id} = $doc_id;
+                $cb->($smsg) or return;
+        }
+}
+
 sub find_unique_doc_id {
         my ($self, $termval) = @_;