lei_mail_sync: rely on flock(2), avoid IPC

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

diff --git a/lib/PublicInbox/LeiInspect.pm b/lib/PublicInbox/LeiInspect.pm
index 2ade17aff089cc006f7a114fd0f7d32654e8219f..f06cea613e600c266190d33ef2e496cfa05d8987 100644 (file)
--- a/lib/PublicInbox/LeiInspect.pm
+++ b/lib/PublicInbox/LeiInspect.pm
@@ -9,6 +9,7 @@ package PublicInbox::LeiInspect;
 use strict;
 use v5.10.1;
 use PublicInbox::Config;
+use PublicInbox::MID qw(mids);
 
 sub inspect_blob ($$) {
        my ($lei, $oidhex) = @_;
@@ -17,7 +18,7 @@ sub inspect_blob ($$) {
                my $oidbin = pack('H*', $oidhex);
                my @docids = $lse ? $lse->over->oidbin_exists($oidbin) : ();
                $ent->{'lei/store'} = \@docids if @docids;
-               my $lms = $lse->lms;
+               my $lms = $lei->lms;
                if (my $loc = $lms ? $lms->locations_for($oidbin) : undef) {
                        $ent->{'mail-sync'} = $loc;
                }
@@ -28,8 +29,7 @@ sub inspect_blob ($$) {
 sub inspect_imap_uid ($$) {
        my ($lei, $uid_uri) = @_;
        my $ent = {};
-       my $lse = $lei->{lse} or return $ent;
-       my $lms = $lse->lms or return $ent;
+       my $lms = $lei->lms or return $ent;
        my $oidhex = $lms->imap_oid($lei, $uid_uri);
        if (ref(my $err = $oidhex)) { # art2folder error
                $lei->qerr(@{$err->{qerr}}) if $err->{qerr};
@@ -184,6 +184,33 @@ sub inspect1 ($$$) {
        1;
 }
 
+sub _inspect_argv ($$) {
+       my ($lei, $argv) = @_;
+       my $multi = scalar(@$argv) > 1;
+       $lei->out('[') if $multi;
+       while (defined(my $x = shift @$argv)) {
+               inspect1($lei, $x, scalar(@$argv)) or return;
+       }
+       $lei->out(']') if $multi;
+}
+
+sub ins_add { # InputPipe->consume callback
+       my ($lei) = @_; # $_[1] = $rbuf
+       if (defined $_[1]) {
+               $_[1] eq '' and return eval {
+                       my $str = delete $lei->{istr};
+                       $str =~ s/\A[\r\n]*From [^\r\n]*\r?\n//s;
+                       my $eml = PublicInbox::Eml->new(\$str);
+                       _inspect_argv($lei, [
+                               'blob:'.$lei->git_oid($eml)->hexdigest,
+                               map { "mid:$_" } @{mids($eml)} ]);
+               };
+               $lei->{istr} .= $_[1];
+       } else {
+               $lei->fail("error reading stdin: $!");
+       }
+}
+
 sub lei_inspect {
        my ($lei, @argv) = @_;
        $lei->{json} = ref(PublicInbox::Config::json())->new->utf8->canonical;
@@ -196,12 +223,15 @@ sub lei_inspect {
        }
        $lei->start_pager if -t $lei->{1};
        $lei->{1}->autoflush(0);
-       my $multi = scalar(@argv) > 1;
-       $lei->out('[') if $multi;
-       while (defined(my $x = shift @argv)) {
-               inspect1($lei, $x, scalar(@argv)) or return;
+       if ($lei->{opt}->{stdin}) {
+               return $lei->fail(<<'') if @argv;
+no args allowed on command-line with --stdin
+
+               require PublicInbox::InputPipe;
+               PublicInbox::InputPipe::consume($lei->{0}, \&ins_add, $lei);
+               return;
        }
-       $lei->out(']') if $multi;
+       _inspect_argv($lei, \@argv);
 }
 
 sub _complete_inspect {