]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/View.pm
view: introduce WwwStream interface
[public-inbox.git] / lib / PublicInbox / View.pm
index 0ba78fe2d9e103bcbe201dbbb47d1cf32a56fa40..e7e387d3069f0f5f04daf1873b6bd09ec40fa7c0 100644 (file)
@@ -9,11 +9,13 @@ use warnings;
 use URI::Escape qw/uri_escape_utf8/;
 use Date::Parse qw/str2time/;
 use Encode::MIME::Header;
+use Plack::Util;
 use PublicInbox::Hval qw/ascii_html/;
 use PublicInbox::Linkify;
 use PublicInbox::MID qw/mid_clean id_compress mid2path mid_mime/;
 use PublicInbox::MsgIter;
 use PublicInbox::Address;
+use PublicInbox::WwwStream;
 require POSIX;
 
 use constant INDENT => '  ';
@@ -21,17 +23,22 @@ use constant TCHILD => '` ';
 sub th_pfx ($) { $_[0] == 0 ? '' : TCHILD };
 
 # public functions: (unstable)
-# TODO: stream this, since threading is expensive but also oh-so-important
 sub msg_html {
        my ($ctx, $mime, $footer) = @_;
-       $footer = defined($footer) ? "\n$footer" : '';
        my $hdr = $mime->header_obj;
-       headers_to_html_header($hdr, $ctx) .
-               multipart_text_as_html($mime, '') .
-               '</pre><hr /><pre>' .
-               html_footer($hdr, 1, $ctx) .
-               '</pre>' . msg_reply($ctx, $hdr) .
-               '<hr /><pre>'.  $footer . '</pre></body></html>';
+       my $tip = _msg_html_prepare($hdr, $ctx);
+       PublicInbox::WwwStream->new($ctx, sub {
+               my ($nr, undef) = @_;
+               if ($nr == 1) {
+                       $tip . multipart_text_as_html($mime, '') .
+                               '</pre><hr />'
+               } elsif ($nr == 2) {
+                       '<pre>' . html_footer($hdr, 1, $ctx) .
+                       '</pre>' . msg_reply($ctx, $hdr) . '<hr />'
+               } else {
+                       undef
+               }
+       });
 }
 
 # /$INBOX/$MESSAGE_ID/#R
@@ -44,14 +51,14 @@ sub msg_reply {
        push @$arg, '/path/to/YOUR_REPLY';
 
        "<hr /><pre\nid=R>".
-       "You may reply publically to <a\nhref=#t>this message</a> via email\n".
-       "using any one of the following methods:\n\n" .
+       "You may reply publically to <a\nhref=#t>this message</a> via\n".
+       "plain-text email using any one of the following methods:\n\n" .
        "* Save the following mbox file, import it into your mail client,\n" .
        "  and reply-to-all from there: <a\nhref=raw>mbox</a>\n\n" .
        "* Reply to all the recipients using the <b>--to</b>, <b>--cc</b>,\n" .
        "  and <b>--in-reply-to</b> switches of git-send-email(1):\n\n" .
        "\tgit send-email \\\n\t\t" .
-       join(" \\ \n\t\t", @$arg ). "\n\n" .
+       join(" \\\n\t\t", @$arg ). "\n\n" .
        qq(  <a\nhref="$se_url">$se_url</a>\n\n) .
        "* If your mail client supports setting the <b>In-Reply-To</b>" .
        " header\n  via mailto: links, try the " .
@@ -303,18 +310,15 @@ sub add_text_body {
        $s;
 }
 
-sub headers_to_html_header {
+sub _msg_html_prepare {
        my ($hdr, $ctx) = @_;
        my $srch = $ctx->{srch} if $ctx;
        my $atom = '';
-       my $rv = '';
-       my $upfx = '';
+       my $rv = "<pre\nid=b>"; # anchor for body start
 
        if ($srch) {
-               $atom = qq{<link\nrel=alternate\ntitle="Atom feed"\n} .
-                       qq!href="${upfx}t.atom"\ntype="application/atom+xml"/>!;
+               $ctx->{-upfx} = '../';
        }
-
        my @title;
        my $mid = $hdr->header_raw('Message-ID');
        $mid = PublicInbox::Hval->new_msgid($mid);
@@ -337,15 +341,11 @@ sub headers_to_html_header {
                $rv .= "$h: " . $v->as_html . "\n";
 
        }
+       $ctx->{-title_html} = join(' - ', @title);
        $rv .= 'Message-ID: &lt;' . $mid->as_html . '&gt; ';
-       $rv .= "(<a\nhref=\"${upfx}raw\">raw</a>)\n";
+       $rv .= "(<a\nhref=\"raw\">raw</a>)\n";
        $rv .= _parent_headers($hdr, $srch);
        $rv .= "\n";
-
-       ("<html><head><title>".  join(' - ', @title) . "</title>$atom".
-        PublicInbox::Hval::STYLE .
-        "</head><body><pre\nid=b>" . # anchor for body start
-        $rv);
 }
 
 sub thread_skel {