]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/Mbox.pm
.txt links return an mbox instead
[public-inbox.git] / lib / PublicInbox / Mbox.pm
index cb9d65d1a9fb069b498ee4fe2161824aebb6fe51..bc4d639ebad0809f3591cc38ecea7bb736039cb0 100644 (file)
@@ -4,14 +4,24 @@
 package PublicInbox::Mbox;
 use strict;
 use warnings;
-use PublicInbox::MID qw/mid_clean mid_compressed mid2path/;
-use Fcntl qw(SEEK_SET);
+use PublicInbox::MID qw/mid_compressed mid2path/;
+require Email::Simple;
 
 sub thread_mbox {
-       my ($ctx, $srch) = @_;
+       my ($ctx, $srch, $sfx) = @_;
        sub {
                my ($response) = @_; # Plack callback
-               emit_mbox($response, $ctx, $srch);
+               emit_mbox($response, $ctx, $srch, $sfx);
+       }
+}
+
+sub emit1 {
+       my $simple = Email::Simple->new(pop);
+       sub {
+               my ($response) = @_;
+               # single message should be easily renderable in browsers
+               my $fh = $response->([200, ['Content-Type'=>'text/plain']]);
+               emit_msg($fh, $simple);
        }
 }
 
@@ -39,17 +49,20 @@ sub emit_msg {
 }
 
 sub emit_mbox {
-       my ($response, $ctx, $srch) = @_;
-       eval { require IO::Compress::Gzip };
-       return need_gzip($response) if $@;
+       my ($response, $ctx, $srch, $sfx) = @_;
+       my $type = 'mbox';
+       if ($sfx) {
+               eval { require IO::Compress::Gzip };
+               return need_gzip($response) if $@;
+               $type = 'gzip';
+       }
 
        # http://www.iana.org/assignments/media-types/application/gzip
        # http://www.iana.org/assignments/media-types/application/mbox
-       my $fh = $response->([200, ['Content-Type' => 'application/gzip']]);
-       $fh = PublicInbox::MboxGz->new($fh);
+       my $fh = $response->([200, ['Content-Type' => "application/$type"]]);
+       $fh = PublicInbox::MboxGz->new($fh) if $sfx;
 
        require PublicInbox::GitCatFile;
-       require Email::Simple;
        my $mid = mid_compressed($ctx->{mid});
        my $git = PublicInbox::GitCatFile->new($ctx->{git_dir});
        my %opts = (offset => 0);
@@ -81,6 +94,7 @@ The administrator needs to install the IO::Compress::Gzip Perl module
 to support gzipped mboxes.
 <a href="../">Return to index</a></pre></body></html>
 EOF
+       $fh->close;
 }
 
 1;
@@ -119,7 +133,7 @@ sub close {
        my ($self) = @_;
        $self->{gz}->close;
        _flush_buf($self);
-       # do not actually close $fh
+       $self->{fh}->close;
 }
 
 1;