]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/Inbox.pm
view: depend on SearchMsg for Message-ID
[public-inbox.git] / lib / PublicInbox / Inbox.pm
index e7856e3cd4d20af2aca0eea03142abba727b736b..b1ea8dc7bce215b06fe3f7a4715d53f7846c3b84 100644 (file)
@@ -8,6 +8,7 @@ use warnings;
 use PublicInbox::Git;
 use PublicInbox::MID qw(mid2path);
 use Devel::Peek qw(SvREFCNT);
+use PublicInbox::MIME;
 
 my $cleanup_timer;
 eval {
@@ -29,6 +30,7 @@ sub cleanup_task () {
 
 sub _cleanup_later ($) {
        my ($self) = @_;
+       return unless PublicInbox::EvCleanup::enabled();
        $cleanup_timer ||= PublicInbox::EvCleanup::later(*cleanup_task);
        $CLEANUP->{"$self"} = $self;
 }
@@ -73,6 +75,10 @@ sub new {
        _set_limiter($opts, $pi_config, 'httpbackend');
        _set_uint($opts, 'feedmax', 25);
        $opts->{nntpserver} ||= $pi_config->{'publicinbox.nntpserver'};
+       my $dir = $opts->{mainrepo};
+       if (defined $dir && -f "$dir/inbox.lock") {
+               $opts->{version} = 2;
+       }
        bless $opts, $class;
 }
 
@@ -92,7 +98,12 @@ sub mm {
        my ($self) = @_;
        $self->{mm} ||= eval {
                _cleanup_later($self);
-               PublicInbox::Msgmap->new($self->{mainrepo});
+               my $dir = $self->{mainrepo};
+               if (($self->{version} || 1) >= 2) {
+                       PublicInbox::Msgmap->new_file("$dir/msgmap.sqlite3");
+               } else {
+                       PublicInbox::Msgmap->new($dir);
+               }
        };
 }
 
@@ -100,7 +111,7 @@ sub search {
        my ($self) = @_;
        $self->{search} ||= eval {
                _cleanup_later($self);
-               PublicInbox::Search->new($self->{mainrepo}, $self->{altid});
+               PublicInbox::Search->new($self, $self->{altid});
        };
 }
 
@@ -229,13 +240,21 @@ sub msg_by_smsg ($$;$) {
        # backwards compat to fallback to msg_by_mid
        # TODO: remove if we bump SCHEMA_VERSION in Search.pm:
        defined(my $blob = $smsg->{blob}) or
-                       return msg_by_mid($self, $smsg->mid);
+                       return msg_by_path($self, mid2path($smsg->mid), $ref);
 
        my $str = git($self)->cat_file($blob, $ref);
        $$str =~ s/\A[\r\n]*From [^\r\n]*\r?\n//s if $str;
        $str;
 }
 
+sub smsg_mime {
+       my ($self, $smsg, $ref) = @_;
+       if (my $s = msg_by_smsg($self, $smsg, $ref)) {
+               $smsg->{mime} = PublicInbox::MIME->new($s);
+               return $smsg;
+       }
+}
+
 sub path_check {
        my ($self, $path) = @_;
        git($self)->check('HEAD:'.$path);
@@ -243,7 +262,13 @@ sub path_check {
 
 sub msg_by_mid ($$;$) {
        my ($self, $mid, $ref) = @_;
-       msg_by_path($self, mid2path($mid), $ref);
+       my $srch = search($self) or
+                       return msg_by_path($self, mid2path($mid), $ref);
+       my $smsg;
+       $srch->retry_reopen(sub {
+               $smsg = $srch->lookup_skeleton($mid) and $smsg->load_expand;
+       });
+       $smsg ? msg_by_smsg($self, $smsg, $ref) : undef;
 }
 
 1;