]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/View.pm
treewide: ditch inbox->recent method
[public-inbox.git] / lib / PublicInbox / View.pm
index 069b96806e3af4e331bcb5e70f840902ec52f8d8..466ec6cfdad1c0677211878498d0db288e170247 100644 (file)
@@ -1,4 +1,4 @@
-# Copyright (C) 2014-2021 all contributors <meta@public-inbox.org>
+# Copyright (C) all contributors <meta@public-inbox.org>
 # License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
 #
 # Used for displaying the HTML web interface.
@@ -7,6 +7,7 @@ package PublicInbox::View;
 use strict;
 use v5.10.1;
 use List::Util qw(max);
+use Text::Wrap qw(wrap); # stdlib, we need Perl 5.6+ for $huge
 use PublicInbox::MsgTime qw(msg_datestamp);
 use PublicInbox::Hval qw(ascii_html obfuscate_addrs prurl mid_href
                        ts2str fmt_ts);
@@ -63,7 +64,7 @@ sub no_over_html ($) {
        }
        delete $ctx->{obuf};
        eval { $$obuf .= html_footer($ctx, $eml) };
-       html_oneshot($ctx, 200, $obuf);
+       html_oneshot($ctx, 200, $$obuf);
 }
 
 # public functions: (unstable)
@@ -142,6 +143,9 @@ $info
   <a
 href="$se_url">$se_url</a>
 $link</pre>
+
+  Be sure your reply has a <b>Subject:</b> header at the top and a blank line
+  before the message body.
 EOF
 }
 
@@ -243,6 +247,7 @@ sub eml_entry {
 
        # scan through all parts, looking for displayable text
        $ctx->{mhref} = $mhref;
+       $ctx->{end_id} = "e$id";
        $ctx->{obuf} = \$rv;
        $eml->each_part(\&add_text_body, $ctx, 1);
        delete $ctx->{obuf};
@@ -253,6 +258,9 @@ sub eml_entry {
                " <a\nhref=\"${mhref}raw\">raw</a>" .
                " <a\nhref=\"${mhref}#R\">reply</a>";
 
+       delete($ctx->{-qry}) and
+               $rv .= qq[ <a\nhref="${mhref}#related">related</a>];
+
        my $hr;
        if (defined(my $pct = $smsg->{pct})) { # used by SearchView.pm
                $rv .= "\t[relevance $pct%]";
@@ -260,7 +268,6 @@ sub eml_entry {
        } elsif ($mapping) {
                my $nested = 'nested';
                my $flat = 'flat';
-               my $end = '';
                if ($ctx->{flat}) {
                        $hr = 1;
                        $flat = "<b>$flat</b>";
@@ -427,7 +434,7 @@ sub stream_thread_i { # PublicInbox::WwwStream::getline callback
 
 sub stream_thread ($$) {
        my ($rootset, $ctx) = @_;
-       $ctx->{-queue} = [ map { (0, $_) } @$rootset ];
+       @{$ctx->{-queue}} = map { (0, $_) } @$rootset;
        PublicInbox::WwwStream::aresponse($ctx, 200, \&stream_thread_i);
 }
 
@@ -533,6 +540,7 @@ sub attach_link ($$$$;$) {
 
        my $nl = $idx eq '1' ? '' : "\n"; # like join("\n", ...)
        my $size = length($part->body);
+       delete $part->{bdy}; # save memory
 
        # hide attributes normally, unless we want to aid users in
        # spotting MUA problems:
@@ -585,7 +593,7 @@ sub add_text_body { # callback for each_part
 
        # makes no difference to browsers, and don't screw up filename
        # link generation in diffs with the extra '%0D'
-       $s =~ s/\r\n/\n/sg;
+       $s =~ s/\r+\n/\n/sg;
 
        # will be escaped to `&#8226;' in HTML
        obfuscate_addrs($ibx, $s, "\x{2022}") if $ibx->{obfuscate};
@@ -624,9 +632,6 @@ sub add_text_body { # callback for each_part
                $ctx->{-spfx} = $spfx;
        };
 
-       # some editors don't put trailing newlines at the end:
-       $s .= "\n" unless $s =~ /\n\z/s;
-
        # split off quoted and unquoted blocks:
        my @sections = PublicInbox::MsgIter::split_quotes($s);
        undef $s; # free memory
@@ -635,6 +640,7 @@ sub add_text_body { # callback for each_part
                attach_link($ctx, $ct, $p, $fn, $err);
                $$rv .= "\n";
        }
+       delete $part->{bdy}; # save memory
        foreach my $cur (@sections) {
                if ($cur =~ /\A>/) {
                        # we use a <span> here to allow users to specify
@@ -819,15 +825,39 @@ sub _parent_headers {
 # returns a string buffer
 sub html_footer {
        my ($ctx, $hdr) = @_;
-       my $ibx = $ctx->{ibx};
        my $upfx = '../';
        my $skel;
        my $rv = '<pre>';
-       if ($ibx->over) {
+       my $related;
+       my $qry = delete $ctx->{-qry};
+       if ($qry && $ctx->{ibx}->isrch) {
+               my $q = ''; # search for either ancestor or descendent patches
+               for (@{$qry->{dfpre}}, @{$qry->{dfpost}}) {
+                       chop if length > 7; # include 1 abbrev "older" patches
+                       $q .= "dfblob:$_ ";
+               }
+               chop $q; # omit trailing SP
+               local $Text::Wrap::columns = COLS;
+               local $Text::Wrap::huge = 'overflow';
+               $q = wrap('', '', $q);
+               my $rows = ($q =~ tr/\n/\n/) + 1;
+               $q = ascii_html($q);
+               $related = <<EOM;
+<form id=related
+action=$upfx
+><pre>find likely ancestor, descendant, or conflicting patches for <a
+href=#t>this message</a>:
+<textarea name=q cols=${\COLS} rows=$rows>$q</textarea>
+<input type=submit value=search
+/>\t(<a href=${upfx}_/text/help/>help</a>)</pre></form>
+EOM
+       }
+       if ($ctx->{ibx}->over) {
                my $t = ts2str($ctx->{-t_max});
                my $t_fmt = fmt_ts($ctx->{-t_max});
-               $skel .= <<EOF;
-       other threads:[<a
+               my $fallback = $related ? "\t" : "<a id=related>\t</a>";
+               $skel = <<EOF;
+${fallback}other threads:[<a
 href="$upfx?t=$t">~$t_fmt UTC</a>|<a
 href="$upfx">newest</a>]
 EOF
@@ -868,6 +898,7 @@ EOF
        $rv .= qq(<a\nhref="#R">reply</a>);
        $rv .= $skel;
        $rv .= '</pre>';
+       $rv .= $related // '';
        $rv .= msg_reply($ctx, $hdr);
 }
 
@@ -979,7 +1010,7 @@ sub skel_dump { # walk_thread callback
                $$skel .= delete($ctx->{sl_note}) || '';
        }
 
-       my $f = ascii_html($smsg->{from_name});
+       my $f = ascii_html(delete $smsg->{from_name});
        my $obfs_ibx = $ctx->{-obfs_ibx};
        obfuscate_addrs($obfs_ibx, $f) if $obfs_ibx;
 
@@ -1074,10 +1105,10 @@ sub _skel_ghost {
 }
 
 sub sort_ds {
-       [ sort {
+       @{$_[0]} = sort {
                (eval { $a->topmost->{ds} } || 0) <=>
                (eval { $b->topmost->{ds} } || 0)
-       } @{$_[0]} ];
+       } @{$_[0]};
 }
 
 # accumulate recent topics if search is supported
@@ -1157,9 +1188,9 @@ sub dump_topics {
 
                my $s = "<a\nhref=\"$href/T/$anchor\">$top_subj</a>\n" .
                        " $ds UTC $n\n";
-               for (my $i = 0; $i < scalar(@extra); $i += 2) {
-                       my $level = $extra[$i];
-                       my $subj = $extra[$i + 1]; # already normalized
+               while (@extra) {
+                       my $level = shift @extra;
+                       my $subj = shift @extra; # already normalized
                        $mid = delete $seen->{$subj};
                        my @subj = split(/ /, $subj);
                        my @next_prev = @subj; # full copy
@@ -1191,7 +1222,7 @@ sub pagination_footer ($$) {
                $next = $next ? "$next | " : '             | ';
                $prev .= qq[ | <a\nhref="$latest">latest</a>];
        }
-       "<hr><pre>page: $next$prev</pre>";
+       ($next || $prev) ? "<hr><pre>page: $next$prev</pre>" : '';
 }
 
 sub paginate_recent ($$) {
@@ -1206,12 +1237,11 @@ sub paginate_recent ($$) {
        $t =~ s/\A([0-9]{8,14})-// and $after = str2ts($1);
        $t =~ /\A([0-9]{8,14})\z/ and $before = str2ts($1);
 
-       my $ibx = $ctx->{ibx};
-       my $msgs = $ibx->recent($opts, $after, $before);
+       my $msgs = $ctx->{ibx}->over->recent($opts, $after, $before);
        my $nr = scalar @$msgs;
        if ($nr < $lim && defined($after)) {
                $after = $before = undef;
-               $msgs = $ibx->recent($opts);
+               $msgs = $ctx->{ibx}->over->recent($opts);
                $nr = scalar @$msgs;
        }
        my $more = $nr == $lim;
@@ -1242,11 +1272,8 @@ sub paginate_recent ($$) {
 sub index_topics {
        my ($ctx) = @_;
        my $msgs = paginate_recent($ctx, 200); # 200 is our window
-       if (@$msgs) {
-               walk_thread(thread_results($ctx, $msgs), $ctx, \&acc_topic);
-       }
-       html_oneshot($ctx, dump_topics($ctx), \pagination_footer($ctx, '.'));
-
+       walk_thread(thread_results($ctx, $msgs), $ctx, \&acc_topic) if @$msgs;
+       html_oneshot($ctx, dump_topics($ctx), pagination_footer($ctx, '.'));
 }
 
 sub thread_adj_level {