]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/View.pm
www_stream: fix search for new.html endpoint
[public-inbox.git] / lib / PublicInbox / View.pm
index 0b96bda81aab47d5362b8bb60d9cb1b3071b7901..140cfeedbec1ca8bee1e8ae330406183dc36d93f 100644 (file)
@@ -27,7 +27,7 @@ sub msg_html {
        my ($ctx, $mime, $footer) = @_;
        my $hdr = $mime->header_obj;
        my $tip = _msg_html_prepare($hdr, $ctx);
-       PublicInbox::WwwStream->new($ctx, sub {
+       PublicInbox::WwwStream->response($ctx, 200, sub {
                my ($nr, undef) = @_;
                if ($nr == 1) {
                        $tip . multipart_text_as_html($mime, '') .
@@ -49,25 +49,40 @@ sub msg_html {
 # /$INBOX/$MESSAGE_ID/#R
 sub msg_reply {
        my ($ctx, $hdr) = @_;
-       my $se_url = 'https://git-htmldocs.bogomips.org/git-send-email.html';
+       my $se_url =
+        'https://kernel.org/pub/software/scm/git/docs/git-send-email.html';
+       my $p_url =
+        'https://en.wikipedia.org/wiki/Posting_style#Interleaved_style';
 
        my ($arg, $link) = mailto_arg_link($hdr);
        push @$arg, '/path/to/YOUR_REPLY';
+       $arg = join(" \\\n    ", '', @$arg);
+       <<EOF
+<pre
+id=R>You may reply publically to <a
+href=#t>this message</a> via
+plain-text email using any one of the following methods:
 
-       "<pre\nid=R>".
-       "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" .
-       "  git send-email \\\n    " .
-       join(" \\\n    ", @$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 " .
-       qq(<a\nhref="$link">mailto: link</a>\n) .
-       '</pre>';
+* Save the following mbox file, import it into your mail client,
+  and reply-to-all from there: <a
+href=raw>mbox</a>
+
+  Avoid top-posting and favor interleaved quoting:
+  <a
+href="$p_url">$p_url</a>
+
+* Reply to all the recipients using the <b>--to</b>, <b>--cc</b>,
+  and <b>--in-reply-to</b> switches of git-send-email(1):
+
+  git send-email$arg
+
+  <a
+href="$se_url">$se_url</a>
+
+* If your mail client supports setting the <b>In-Reply-To</b> header
+  via mailto: links, try the <a
+href="$link">mailto: link</a></pre>
+EOF
 }
 
 sub in_reply_to {
@@ -103,36 +118,40 @@ sub index_entry {
        my $subj = $hdr->header('Subject');
 
        my $mid_raw = mid_clean(mid_mime($mime));
-       my $id = id_compress($mid_raw);
+       my $id = id_compress($mid_raw, 1);
        my $id_m = 'm'.$id;
        my $mid = PublicInbox::Hval->new_msgid($mid_raw);
 
        my $root_anchor = $ctx->{root_anchor} || '';
        my $irt = in_reply_to($hdr);
 
-       my $rv = '<b>'.ascii_html($subj).'</b>';
-       $rv = "<u\nid=u>$rv</u>" if $root_anchor eq $id_m;
-       $rv .= "\n";
+       my $rv = "<a\nhref=#e$id\nid=m$id>*</a> ";
+       $subj = '<b>'.ascii_html($subj).'</b>';
+       $subj = "<u\nid=u>$subj</u>" if $root_anchor eq $id_m;
+       $rv .= $subj . "\n";
        $rv .= _th_index_lite($mid_raw, $irt, $id, $ctx);
        my @tocc;
        foreach my $f (qw(To Cc)) {
                my $dst = _hdr_names($hdr, $f);
                push @tocc, "$f: $dst" if $dst ne '';
        }
-       my $mapping = $ctx->{mapping};
        $rv .= "From: "._hdr_names($hdr, 'From').' @ '._msg_date($hdr)." UTC";
        my $upfx = $ctx->{-upfx};
-       $rv .= qq{ (<a\nhref="$upfx$mid_raw/">permalink</a> / };
-       $rv .= qq{<a\nhref="$upfx$mid_raw/raw">raw</a>)\n};
+       my $mhref = $upfx . $mid->as_href . '/';
+       $rv .= qq{ (<a\nhref="$mhref">permalink</a> / };
+       $rv .= qq{<a\nhref="${mhref}raw">raw</a>)\n};
        $rv .= '  '.join('; +', @tocc) . "\n" if @tocc;
+
+       my $mapping = $ctx->{mapping};
        if (!$mapping && $irt) {
-               $rv .= qq(In-Reply-To: &lt;<a\nhref="$upfx$irt/">$irt</a>&gt;\n)
+               my $mirt = PublicInbox::Hval->new_msgid($irt);
+               my $href = $upfx . $mirt->as_href . '/';
+               my $html = $mirt->as_html;
+               $rv .= qq(In-Reply-To: &lt;<a\nhref="$href/">$html</a>&gt;\n)
        }
        $rv .= "\n";
 
        # scan through all parts, looking for displayable text
-       my $href = $mid->as_href;
-       my $mhref = $ctx->{-upfx}.$href.'/';
        msg_iter($mime, sub { $rv .= add_text_body($mhref, $_[0]) });
 
        # add the footer
@@ -142,7 +161,20 @@ sub index_entry {
                " / <a\nhref=\"${mhref}#R\">reply</a>";
        if (my $pct = $ctx->{pct}) { # used by SearchView.pm
                $rv .= " [relevance $pct->{$mid_raw}%]";
+       } elsif ($mapping) {
+               my $threaded = 'threaded';
+               my $flat = 'flat';
+               my $end = '';
+               if ($ctx->{flat}) {
+                       $flat = "<b>$flat</b>";
+               } else {
+                       $threaded = "<b>$threaded</b>";
+               }
+               $rv .= " / [<a\nhref=\"${mhref}T/#u\">$flat</a>";
+               $rv .= "|<a\nhref=\"${mhref}t/#u\">$threaded</a>]";
+               $rv .= " / <a\nhref=#r$id>$ctx->{s_nr}</a>";
        }
+
        $rv .= $more ? "\n\n" : "\n";
 }
 
@@ -150,7 +182,7 @@ sub pad_link ($$;$) {
        my ($mid, $level, $s) = @_;
        $s ||= '...';
        my $id = id_compress($mid, 1);
-       (' 'x19).indent_for($level).th_pfx($level)."<a\nhref=#r$id>($s)<a>\n";
+       (' 'x19).indent_for($level).th_pfx($level)."<a\nhref=#r$id>($s)</a>\n";
 }
 
 sub _th_index_lite {
@@ -186,7 +218,7 @@ sub _th_index_lite {
        my $s_c = nr_to_s($nr_c, 'reply', 'replies');
        my $this = $map->[1];
        $this =~ s!\n\z!</b>\n!s;
-       $this =~ s!<a\nhref.*a> !!s; # no point in duplicating subject
+       $this =~ s!<a\nhref.*</a> !!s; # no point in duplicating subject
        $rv .= "<b>@ $this";
        my $node = $map->[2];
        if (my $child = $node->child) {
@@ -210,7 +242,7 @@ sub _th_index_lite {
                        $rv .= $pad . $mapping->{$nn->messageid}->[1];
                }
        }
-       $rv .= "<a\nhref=#e$id\nid=m$id>_<a> <a\nhref=#r$id\n>$s_s, $s_c</a>\n";
+       $rv .= $pad ."<a\nhref=#r$id>$s_s, $s_c; $ctx->{s_nr}</a>\n";
 }
 
 sub walk_thread {
@@ -237,6 +269,50 @@ sub pre_thread  {
        skel_dump($ctx, $level, $node);
 }
 
+sub thread_index_entry {
+       my ($ctx, $level, $mime) = @_;
+       my ($beg, $end) = thread_adj_level($ctx, $level);
+       $beg . '<pre>' . index_entry($mime, $ctx, 0) . '</pre>' . $end;
+}
+
+sub stream_thread ($$) {
+       my ($th, $ctx) = @_;
+       my $inbox = $ctx->{-inbox};
+       my $mime;
+       my @q = map { (0, $_) } $th->rootset;
+       my $level;
+       while (@q) {
+               $level = shift @q;
+               my $node = shift @q or next;
+               unshift @q, $level+1, $node->child, $level, $node->next;
+               $mime = $inbox->msg_by_mid($node->messageid) and last;
+       }
+       return missing_thread($ctx) unless $mime;
+
+       $mime = Email::MIME->new($mime);
+       $ctx->{-title_html} = ascii_html($mime->header('Subject'));
+       $ctx->{-html_tip} = thread_index_entry($ctx, $level, $mime);
+       PublicInbox::WwwStream->response($ctx, 200, sub {
+               return unless $ctx;
+               while (@q) {
+                       $level = shift @q;
+                       my $node = shift @q or next;
+                       unshift @q, $level+1, $node->child, $level, $node->next;
+                       my $mid = $node->messageid;
+                       if ($mime = $inbox->msg_by_mid($mid)) {
+                               $mime = Email::MIME->new($mime);
+                               return thread_index_entry($ctx, $level, $mime);
+                       } else {
+                               return ghost_index_entry($ctx, $level, $mid);
+                       }
+               }
+               my $ret = join('', thread_adj_level($ctx, 0));
+               $ret .= ${$ctx->{dst}}; # skel
+               $ctx = undef;
+               $ret;
+       });
+}
+
 sub thread_html {
        my ($ctx) = @_;
        my $mid = $ctx->{mid};
@@ -244,34 +320,39 @@ sub thread_html {
        my $msgs = load_results($sres);
        my $nr = $sres->{total};
        return missing_thread($ctx) if $nr == 0;
-       my $skel = '</pre><hr /><pre>';
+       my $skel = '<hr /><pre>';
        $skel .= $nr == 1 ? 'only message in thread' : 'end of thread';
        $skel .= ", back to <a\nhref=\"../../\">index</a>";
        $skel .= "\n<a\nid=t>$nr+ messages in thread:</a> (download: ";
        $skel .= "<a\nhref=\"../t.mbox.gz\">mbox.gz</a>";
        $skel .= " / follow: <a\nhref=\"../t.atom\">Atom feed</a>)\n";
+       $ctx->{-upfx} = '../../';
        $ctx->{cur_level} = 0;
        $ctx->{dst} = \$skel;
-       $ctx->{mapping} = {}; # mid -> [ reply count, from@date, node ];
        $ctx->{prev_attr} = '';
        $ctx->{prev_level} = 0;
        $ctx->{root_anchor} = anchor_for($mid);
        $ctx->{seen} = {};
+       $ctx->{mapping} = {};
+       $ctx->{s_nr} = "$nr+ messages in thread";
 
-       walk_thread(thread_results($msgs), $ctx, *pre_thread);
+       my $th = thread_results($msgs);
+       walk_thread($th, $ctx, *pre_thread);
+       $skel .= '</pre>';
+       return stream_thread($th, $ctx) unless $ctx->{flat};
 
-       # lazy load the full message from mini_mime:
+       # flat display: lazy load the full message from mini_mime:
        my $inbox = $ctx->{-inbox};
        my $mime;
        while ($mime = shift @$msgs) {
                $mime = $inbox->msg_by_mid(mid_clean(mid_mime($mime))) and last;
        }
+       return missing_thread($ctx) unless $mime;
        $mime = Email::MIME->new($mime);
-       $ctx->{-upfx} = '../../';
        $ctx->{-title_html} = ascii_html($mime->header('Subject'));
        $ctx->{-html_tip} = '<pre>'.index_entry($mime, $ctx, scalar @$msgs);
        $mime = undef;
-       my $body = PublicInbox::WwwStream->new($ctx, sub {
+       PublicInbox::WwwStream->response($ctx, 200, sub {
                return unless $msgs;
                while ($mime = shift @$msgs) {
                        $mid = mid_clean(mid_mime($mime));
@@ -282,9 +363,8 @@ sub thread_html {
                        return index_entry($mime, $ctx, scalar @$msgs);
                }
                $msgs = undef;
-               $skel .= '</pre>';
+               '</pre>'.$skel;
        });
-       [ 200, ['Content-Type', 'text/html; charset=UTF-8'], $body ];
 }
 
 sub multipart_text_as_html {
@@ -434,7 +514,7 @@ sub thread_skel {
        my $mid = mid_clean($hdr->header_raw('Message-ID'));
        my $sres = $srch->get_thread($mid);
        my $nr = $sres->{total};
-       my $expand = qq(<a\nhref="${tpfx}t/#u">expand</a> ) .
+       my $expand = qq(<a\nhref="${tpfx}T/#u">expand</a> ) .
                        qq(/ <a\nhref="${tpfx}t.mbox.gz">mbox.gz</a> ) .
                        qq(/ <a\nhref="${tpfx}t.atom">Atom feed</a>);
 
@@ -805,7 +885,7 @@ sub emit_topics {
                }
 
                $subj = PublicInbox::Hval->new($subj)->as_html;
-               $cur->[1] .= "<a\nhref=\"$mid/t/#u\"><b>$subj</b></a>\n";
+               $cur->[1] .= "<a\nhref=\"$mid/T/#u\"><b>$subj</b></a>\n";
                $ts = fmt_ts($ts);
                my $attr = " $ts UTC";
 
@@ -846,4 +926,34 @@ sub emit_index_topics {
        $opts{offset};
 }
 
+sub thread_adj_level {
+       my ($ctx, $level) = @_;
+
+       my $max = $ctx->{cur_level};
+       if ($level <= 0) {
+               return ('', '') if $max == 0; # flat output
+
+               # reset existing lists
+               my $beg = $max > 1 ? ('</ul></li>' x ($max - 1)) : '';
+               $ctx->{cur_level} = 0;
+               ("$beg</ul>", '');
+       } elsif ($level == $max) { # continue existing list
+               qw(<li> </li>);
+       } elsif ($level < $max) {
+               my $beg = $max > 1 ? ('</ul></li>' x ($max - $level)) : '';
+               $ctx->{cur_level} = $level;
+               ("$beg<li>", '</li>');
+       } else { # ($level > $max) # start a new level
+               $ctx->{cur_level} = $level;
+               my $beg = ($max ? '<li>' : '') . '<ul><li>';
+               ($beg, '</li>');
+       }
+}
+
+sub ghost_index_entry {
+       my ($ctx, $level, $mid) = @_;
+       my ($beg, $end) = thread_adj_level($ctx,  $level);
+       $beg . '<pre>'. ghost_parent($ctx->{-upfx}, $mid) . '</pre>' . $end;
+}
+
 1;