X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FView.pm;h=27dd15541a34eed0e4b9c0bd6eaf45f5c8013274;hb=e158d56a54d3c6d4890aa6ac4caa28a834279af0;hp=326da4cb1e7efde9bc508ed7e3e6d29b72b431a3;hpb=78042ed9abb2bbe9783adcc485365a8672e4b36f;p=public-inbox.git diff --git a/lib/PublicInbox/View.pm b/lib/PublicInbox/View.pm index 326da4cb..27dd1554 100644 --- a/lib/PublicInbox/View.pm +++ b/lib/PublicInbox/View.pm @@ -8,67 +8,67 @@ use strict; use warnings; use URI::Escape qw/uri_escape_utf8/; use Date::Parse qw/str2time/; -use Encode qw/find_encoding/; 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::MID qw/mid_clean id_compress mid_mime/; use PublicInbox::MsgIter; +use PublicInbox::Address; +use PublicInbox::WwwStream; require POSIX; use constant INDENT => ' '; use constant TCHILD => '` '; sub th_pfx ($) { $_[0] == 0 ? '' : TCHILD }; -# public functions: +# public functions: (unstable) 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, '') . - '
' .
-		html_footer($hdr, 1, $ctx, 'R/') .
-		$footer .
-		'
'; + my $tip = _msg_html_prepare($hdr, $ctx); + PublicInbox::WwwStream->response($ctx, 200, sub { + my ($nr, undef) = @_; + if ($nr == 1) { + $tip . multipart_text_as_html($mime, '') . + '
' + } elsif ($nr == 2) { + # fake an EOF if generating the footer fails; + # we want to at least show the message if something + # here crashes: + eval { + '
' . html_footer($hdr, 1, $ctx) .
+				'
' . msg_reply($ctx, $hdr) + }; + } else { + undef + } + }); } -# /$INBOX/$MESSAGE_ID/R/ +# /$INBOX/$MESSAGE_ID/#R sub msg_reply { - my ($ctx, $hdr, $footer) = @_; - my $s = $hdr->header('Subject'); - $s = '(no subject)' if (!defined $s) || ($s eq ''); - my $f = $hdr->header('From'); - $f = '' unless defined $f; - my $mid = $hdr->header_raw('Message-ID'); - $mid = PublicInbox::Hval->new_msgid($mid); - my $t = ascii_html($s); + my ($ctx, $hdr) = @_; my $se_url = 'https://kernel.org/pub/software/scm/git/docs/git-send-email.html'; my ($arg, $link) = mailto_arg_link($hdr); push @$arg, '/path/to/YOUR_REPLY'; - "replying to \"$t\"
" .
-	"replying to message:\n\n" .
-	"Subject: $t\n" .
-	"From: ". ascii_html($f) .
-	"\nDate: " .  ascii_html($hdr->header('Date')) .
-	"\nMessage-ID: <" . $mid->as_html . ">\n\n" .
-	"There are multiple ways to reply:\n\n" .
+	"".
+	"You may reply publically to this message 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: mbox\n\n" .
+	"  and reply-to-all from there: mbox\n\n" .
 	"* Reply to all the recipients using the --to, --cc,\n" .
 	"  and --in-reply-to switches of git-send-email(1):\n\n" .
-	"\tgit send-email \\\n\t\t" .
-	join(" \\ \n\t\t", @$arg ). "\n\n" .
+	"  git send-email \\\n    " .
+	join(" \\\n    ", @$arg ). "\n\n" .
 	qq(  $se_url\n\n) .
 	"* If your mail client supports setting the In-Reply-To" .
 	" header\n  via mailto: links, try the " .
 	qq(mailto: link\n) .
-	"\nFor context, the original message or " .
-	qq(thread) .
-	'
' . $footer .  '
'; + ''; } sub in_reply_to { @@ -84,140 +84,273 @@ sub in_reply_to { undef; } +sub _hdr_names ($$) { + my ($hdr, $field) = @_; + my $val = $hdr->header($field) or return ''; + ascii_html(join(', ', PublicInbox::Address::names($val))); +} + +sub nr_to_s ($$$) { + my ($nr, $singular, $plural) = @_; + return "0 $plural" if $nr == 0; + $nr == 1 ? "$nr $singular" : "$nr $plural"; +} + # this is already inside a 
 sub index_entry {
-	my ($mime, $level, $state) = @_;
-	my $midx = $state->{anchor_idx}++;
-	my $ctx = $state->{ctx};
+	my ($mime, $ctx, $more) = @_;
 	my $srch = $ctx->{srch};
 	my $hdr = $mime->header_obj;
 	my $subj = $hdr->header('Subject');
 
 	my $mid_raw = mid_clean(mid_mime($mime));
-	my $id = anchor_for($mid_raw);
-	my $seen = $state->{seen};
-	$seen->{$id} = "#$id"; # save the anchor for children, later
-
+	my $id = id_compress($mid_raw, 1);
+	my $id_m = 'm'.$id;
 	my $mid = PublicInbox::Hval->new_msgid($mid_raw);
-	my $from = $hdr->header('From');
-	my @from = Email::Address->parse($from);
-	$from = $from[0]->name;
 
-	my $root_anchor = $state->{root_anchor} || '';
-	my $path = $root_anchor ? '../../' : '';
-	my $href = $mid->as_href;
+	my $root_anchor = $ctx->{root_anchor} || '';
 	my $irt = in_reply_to($hdr);
-	my $parent_anchor = $seen->{anchor_for($irt)} if defined $irt;
-
-	$from = ascii_html($from);
-	$subj = ascii_html($subj);
-	$subj = "$subj";
-	$subj = "$subj" if $root_anchor eq $id;
 
-	my $ts = _msg_date($hdr);
-	my $rv = "";
-	$rv .= "$subj\n";
-	my $txt = "${path}$href/raw";
-	my $fh = $state->{fh};
-	$fh->write($rv .= "- $from @ $ts UTC (raw)\n\n");
-
-	my $mhref = "${path}$href/";
+	my $rv = ''.ascii_html($subj).'';
+	$rv = "$rv" if $root_anchor eq $id_m;
+	$rv .= "\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 '';
+	}
+	$rv .= "From: "._hdr_names($hdr, 'From').' @ '._msg_date($hdr)." UTC";
+	my $upfx = $ctx->{-upfx};
+	my $mhref = $upfx . $mid->as_href . '/';
+	$rv .= qq{ (permalink / };
+	$rv .= qq{raw)\n};
+	$rv .= '  '.join('; +', @tocc) . "\n" if @tocc;
+
+	my $mapping = $ctx->{mapping};
+	if (!$mapping && $irt) {
+		my $mirt = PublicInbox::Hval->new_msgid($irt);
+		my $href = $upfx . $mirt->as_href . '/';
+		my $html = $mirt->as_html;
+		$rv .= qq(In-Reply-To: <$html>\n)
+	}
+	$rv .= "\n";
 
 	# scan through all parts, looking for displayable text
-	msg_iter($mime, sub { index_walk($fh, $mhref, $_[0]) });
-	$rv = "\n" . html_footer($hdr, 0, $ctx, "$path$href/R/");
-
-	if (defined $irt) {
-		unless (defined $parent_anchor) {
-			my $v = PublicInbox::Hval->new_msgid($irt, 1);
-			$v = $v->as_href;
-			$parent_anchor = "${path}$v/";
-		}
-		$rv .= " parent";
-	}
-	if (my $pct = $state->{pct}) { # used by SearchView.pm
+	msg_iter($mime, sub { $rv .= add_text_body($mhref, $_[0]) });
+
+	# add the footer
+	$rv .= "\n^ ".
+		"permalink" .
+		" / raw" .
+		" / reply";
+	if (my $pct = $ctx->{pct}) { # used by SearchView.pm
 		$rv .= " [relevance $pct->{$mid_raw}%]";
-	} elsif ($srch) {
+	} elsif ($mapping) {
 		my $threaded = 'threaded';
 		my $flat = 'flat';
 		my $end = '';
 		if ($ctx->{flat}) {
 			$flat = "$flat";
-			$end = "\n"; # for lynx
 		} else {
 			$threaded = "$threaded";
 		}
-		$rv .= " [$threaded";
-		$rv .= "|$flat]$end";
+		$rv .= " / [$flat";
+		$rv .= "|$threaded]";
+		$rv .= " / $ctx->{s_nr}";
 	}
-	$fh->write($rv .= '
'); -} -sub thread_html { - my ($ctx, $foot, $srch) = @_; - # $_[0] in sub is the Plack callback - sub { emit_thread_html($_[0], $ctx, $foot, $srch) } + $rv .= $more ? "\n\n" : "\n"; } -# only private functions below. +sub pad_link ($$;$) { + my ($mid, $level, $s) = @_; + $s ||= '...'; + my $id = id_compress($mid, 1); + (' 'x19).indent_for($level).th_pfx($level)."($s)\n"; +} -sub emit_thread_html { - my ($res, $ctx, $foot, $srch) = @_; - my $mid = $ctx->{mid}; - my $flat = $ctx->{flat}; - my $msgs = load_results($srch->get_thread($mid, { asc => $flat })); - my $nr = scalar @$msgs; - return missing_thread($res, $ctx) if $nr == 0; - my $seen = {}; - my $state = { - res => $res, - ctx => $ctx, - seen => $seen, - root_anchor => anchor_for($mid), - anchor_idx => 0, - cur_level => 0, - }; - - require PublicInbox::Git; - $ctx->{git} ||= PublicInbox::Git->new($ctx->{git_dir}); - if ($flat) { - pre_anchor_entry($seen, $_) for (@$msgs); - __thread_entry($state, $_, 0) for (@$msgs); - } else { - my $th = thread_results($msgs); - thread_entry($state, $_, 0) for $th->rootset; - if (my $max = $state->{cur_level}) { - $state->{fh}->write( - ('' x ($max - 1)) . ''); +sub _th_index_lite { + my ($mid_raw, $irt, $id, $ctx) = @_; + my $rv = ''; + my $mapping = $ctx->{mapping} or return $rv; + my $pad = ' '; + # map = [children, attr, node, idx, level] + my $map = $mapping->{$mid_raw}; + my $nr_c = scalar @{$map->[0]}; + my $nr_s = 0; + my $level = $map->[4]; + my $idx = $map->[3]; + if (defined $irt) { + my $irt_map = $mapping->{$irt}; + my $siblings = $irt_map->[0]; + $nr_s = scalar(@$siblings) - 1; + $rv .= $pad . $irt_map->[1]; + if ($idx > 0) { + my $prev = $siblings->[$idx - 1]; + my $pmid = $prev->messageid; + if ($idx > 2) { + my $s = ($idx - 1). ' preceding siblings ...'; + $rv .= pad_link($pmid, $level, $s); + } elsif ($idx == 2) { + my $ppmid = $siblings->[0]->messageid; + $rv .= $pad . $mapping->{$ppmid}->[1]; + } + $rv .= $pad . $mapping->{$pmid}->[1]; } } - Email::Address->purge_cache; - - # there could be a race due to a message being deleted in git - # but still being in the Xapian index: - my $fh = delete $state->{fh} or return missing_thread($res, $ctx); - - my $final_anchor = $state->{anchor_idx}; - my $next = ""; - $next .= $final_anchor == 1 ? 'only message in' : 'end of'; - $next .= " thread, back to index"; - $next .= "\ndownload thread: "; - $next .= "mbox.gz"; - $next .= " / follow: Atom feed"; - $fh->write('
' . $next . "\n\n".
-			$foot .  '
'); - $fh->close; + my $s_s = nr_to_s($nr_s, 'sibling', 'siblings'); + my $s_c = nr_to_s($nr_c, 'reply', 'replies'); + my $this = $map->[1]; + $this =~ s!\n\z!\n!s; + $this =~ s! !!s; # no point in duplicating subject + $rv .= "@ $this"; + my $node = $map->[2]; + if (my $child = $node->child) { + my $cmid = $child->messageid; + $rv .= $pad . $mapping->{$cmid}->[1]; + if ($nr_c > 2) { + my $s = ($nr_c - 1). ' more replies'; + $rv .= pad_link($cmid, $level + 1, $s); + } elsif (my $cn = $child->next) { + $rv .= $pad . $mapping->{$cn->messageid}->[1]; + } + } + if (my $next = $node->next) { + my $nmid = $next->messageid; + $rv .= $pad . $mapping->{$nmid}->[1]; + my $nnext = $nr_s - $idx; + if ($nnext > 2) { + my $s = ($nnext - 1).' subsequent siblings'; + $rv .= pad_link($nmid, $level, $s); + } elsif (my $nn = $next->next) { + $rv .= $pad . $mapping->{$nn->messageid}->[1]; + } + } + $rv .= "_ "; + $rv .= "$s_s, $s_c; $ctx->{s_nr}\n"; +} + +sub walk_thread { + my ($th, $ctx, $cb) = @_; + my @q = map { (0, $_) } $th->rootset; + while (@q) { + my $level = shift @q; + my $node = shift @q or next; + $cb->($ctx, $level, $node); + unshift @q, $level+1, $node->child, $level, $node->next; + } } -sub index_walk { - my ($fh, $upfx, $p) = @_; - my $s = add_text_body($upfx, $p); - - return if $s eq ''; - - $s .= "\n"; # ensure there's a trailing newline +sub pre_thread { + my ($ctx, $level, $node) = @_; + my $mapping = $ctx->{mapping}; + my $idx = -1; + if (my $parent = $node->parent) { + my $m = $mapping->{$parent->messageid}->[0]; + $idx = scalar @$m; + push @$m, $node; + } + $mapping->{$node->messageid} = [ [], '', $node, $idx, $level ]; + skel_dump($ctx, $level, $node); +} + +sub thread_index_entry { + my ($ctx, $level, $mime) = @_; + my ($beg, $end) = thread_adj_level($ctx, $level); + $beg . '
' . index_entry($mime, $ctx, 0) . '
' . $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; + }); +} - $fh->write($s); +sub thread_html { + my ($ctx) = @_; + my $mid = $ctx->{mid}; + my $sres = $ctx->{srch}->get_thread($mid, { asc => 1 }); + my $msgs = load_results($sres); + my $nr = $sres->{total}; + return missing_thread($ctx) if $nr == 0; + my $skel = '
';
+	$skel .= $nr == 1 ? 'only message in thread' : 'end of thread';
+	$skel .= ", back to index";
+	$skel .= "\n$nr+ messages in thread: (download: ";
+	$skel .= "mbox.gz";
+	$skel .= " / follow: Atom feed)\n";
+	$ctx->{-upfx} = '../../';
+	$ctx->{cur_level} = 0;
+	$ctx->{dst} = \$skel;
+	$ctx->{prev_attr} = '';
+	$ctx->{prev_level} = 0;
+	$ctx->{root_anchor} = anchor_for($mid);
+	$ctx->{seen} = {};
+	$ctx->{mapping} = {};
+	$ctx->{s_nr} = "$nr+ messages in thread";
+
+	my $th = thread_results($msgs);
+	walk_thread($th, $ctx, *pre_thread);
+	$skel .= '
'; + return stream_thread($th, $ctx) unless $ctx->{flat}; + + # 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->{-title_html} = ascii_html($mime->header('Subject')); + $ctx->{-html_tip} = '
'.index_entry($mime, $ctx, scalar @$msgs);
+	$mime = undef;
+	PublicInbox::WwwStream->response($ctx, 200, sub {
+		return unless $msgs;
+		while ($mime = shift @$msgs) {
+			$mid = mid_clean(mid_mime($mime));
+			$mime = $inbox->msg_by_mid($mid) and last;
+		}
+		if ($mime) {
+			$mime = Email::MIME->new($mime);
+			return index_entry($mime, $ctx, scalar @$msgs);
+		}
+		$msgs = undef;
+		'
'.$skel; + }); } sub multipart_text_as_html { @@ -227,9 +360,7 @@ sub multipart_text_as_html { # scan through all parts, looking for displayable text msg_iter($mime, sub { my ($p) = @_; - $p = add_text_body($upfx, $p); - $rv .= $p; - $rv .= "\n" if $p ne ''; + $rv .= add_text_body($upfx, $p); }); $rv; } @@ -242,7 +373,7 @@ sub flush_quote { my $rv = $l->linkify_1(join('', @$quot)); @$quot = (); - # we use a
here to allow users to specify their own + # we use a here to allow users to specify their own # color for quoted text $rv = $l->linkify_2(ascii_html($rv)); $$s .= qq() . $rv . '' @@ -260,17 +391,18 @@ sub attach_link ($$$$) { my $desc = $part->header('Content-Description'); $desc = $fn unless defined $desc; $desc = '' unless defined $desc; - $desc = ': '.$desc if $desc; my $sfn; - if (defined $fn && $fn =~ /\A[\w-]+\.[a-z0-9]+\z/) { + if (defined $fn && $fn =~ /\A[[:alnum:]][\w\.-]+[[:alnum:]]\z/) { $sfn = $fn; } elsif ($ct eq 'text/plain') { $sfn = 'a.txt'; } else { $sfn = 'a.bin'; } - qq($nl[-- Attachment #$idx$desc --]\n) . - "[-- Type: $ct, Size: $size bytes --]" + my @ret = qq($nl[-- Attachment #$idx: ); + my $ts = "Type: $ct, Size: $size bytes"; + push(@ret, ($desc eq '') ? "$ts --]" : "$desc --]\n[-- $ts --]"); + join('', @ret, "\n"); } sub add_text_body { @@ -292,7 +424,7 @@ sub add_text_body { $s = ''; if (defined($fn) || $depth > 0) { $s .= attach_link($upfx, $ct, $p, $fn); - $s .= "\n\n"; + $s .= "\n"; } my @quot; my $l = PublicInbox::Linkify->new; @@ -310,25 +442,26 @@ sub add_text_body { } } - flush_quote(\$s, $l, \@quot) if @quot; + my $end = "\n"; + if (@quot) { + $end = ''; + flush_quote(\$s, $l, \@quot); + } $s =~ s/[ \t]+$//sgm; # kill per-line trailing whitespace $s =~ s/\A\n+//s; # kill leading blank lines - $s =~ s/\s+\z//s; # kill all trailing spaces (final "\n" added if ne '') - $s; + $s =~ s/\s+\z//s; # kill all trailing spaces + $s .= $end; } -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 = ""; # anchor for body start if ($srch) { - $atom = qq{!; + $ctx->{-upfx} = '../'; } - my @title; my $mid = $hdr->header_raw('Message-ID'); $mid = PublicInbox::Hval->new_msgid($mid); @@ -338,8 +471,8 @@ sub headers_to_html_header { $v = PublicInbox::Hval->new($v); if ($h eq 'From') { - my @from = Email::Address->parse($v->raw); - $title[1] = ascii_html($from[0]->name); + my @n = PublicInbox::Address::names($v->raw); + $title[1] = ascii_html(join(', ', @n)); } elsif ($h eq 'Subject') { $title[0] = $v->as_html; if ($srch) { @@ -348,18 +481,17 @@ sub headers_to_html_header { next; } } - $rv .= "$h: " . $v->as_html . "\n"; + $v = $v->as_html; + $v =~ s/(\@[^,]+,) /$1\n\t/g if ($h eq 'Cc' || $h eq 'To'); + $rv .= "$h: $v\n"; } + $title[0] ||= '(no subject)'; + $ctx->{-title_html} = join(' - ', @title); $rv .= 'Message-ID: <' . $mid->as_html . '> '; - $rv .= "(raw)\n"; + $rv .= "(raw)\n"; $rv .= _parent_headers($hdr, $srch); $rv .= "\n"; - - ("". join(' - ', @title) . "$atom". - PublicInbox::Hval::STYLE . - "" . # anchor for body start - $rv); } sub thread_skel { @@ -368,7 +500,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(expand ) . + my $expand = qq(expand ) . qq(/ mbox.gz ) . qq(/ Atom feed); @@ -389,17 +521,12 @@ sub thread_skel { $$dst .= qq! / [top])\n!; my $subj = $srch->subject_path($hdr->header('Subject')); - my $state = { - seen => { $subj => 1 }, - srch => $srch, - cur => $mid, - prev_attr => '', - prev_level => 0, - }; - for (thread_results(load_results($sres))->rootset) { - skel_dump($dst, $state, $tpfx, $_, 0); - } - $ctx->{next_msg} = $state->{next_msg}; + $ctx->{seen} = { $subj => 1 }; + $ctx->{cur} = $mid; + $ctx->{prev_attr} = ''; + $ctx->{prev_level} = 0; + $ctx->{dst} = $dst; + walk_thread(thread_results(load_results($sres)), $ctx, *skel_dump); $ctx->{parent_msg} = $parent; } @@ -434,12 +561,21 @@ sub _parent_headers { } if (@refs) { - $rv .= 'References: '. join(' ', @refs) . "\n"; + $rv .= 'References: '. join("\n\t", @refs) . "\n"; } } $rv; } +sub squote_maybe ($) { + my ($val) = @_; + if ($val =~ m{([^\w@\./,\%\+\-])}) { + $val =~ s/(['!])/'\\$1'/g; # '!' for csh + return "'$val'"; + } + $val; +} + sub mailto_arg_link { my ($hdr) = @_; my %cc; # everyone else @@ -448,21 +584,19 @@ sub mailto_arg_link { foreach my $h (qw(From To Cc)) { my $v = $hdr->header($h); defined($v) && ($v ne '') or next; - my @addrs = Email::Address->parse($v); - foreach my $recip (@addrs) { - my $address = $recip->address; + my @addrs = PublicInbox::Address::emails($v); + foreach my $address (@addrs) { my $dst = lc($address); $cc{$dst} ||= $address; $to ||= $dst; } } - Email::Address->purge_cache; my @arg; my $subj = $hdr->header('Subject') || ''; $subj = "Re: $subj" unless $subj =~ /\bRe:/i; my $mid = $hdr->header_raw('Message-ID'); - push @arg, "--in-reply-to='" . ascii_html($mid) . "'"; + push @arg, '--in-reply-to='.ascii_html(squote_maybe(mid_clean($mid))); my $irt = uri_escape_utf8($mid); delete $cc{$to}; push @arg, '--to=' . ascii_html($to); @@ -474,7 +608,7 @@ sub mailto_arg_link { my $href = "mailto:$to?In-Reply-To=$irt&Cc=${cc}&Subject=$subj"; $href =~ s/%20/+/g; - (\@arg, $href); + (\@arg, ascii_html($href)); } sub html_footer { @@ -493,7 +627,7 @@ sub html_footer { if ($p) { $p = PublicInbox::Hval->new_msgid($p); $p = $p->as_href; - $irt = "parent "; + $irt = "parent "; } else { $irt = ' ' x length('parent '); } @@ -506,8 +640,9 @@ sub html_footer { } else { $irt = ''; } - - $irt . qq(reply) . $idx; + $rhref ||= '#R'; + $irt .= qq(reply); + $irt .= $idx; } sub linkify_ref_nosrch { @@ -519,31 +654,7 @@ sub linkify_ref_nosrch { sub anchor_for { my ($msgid) = @_; - my $id = $msgid; - if ($id !~ /\A[a-f0-9]{40}\z/) { - $id = id_compress(mid_clean($id), 1); - } - 'm' . $id; -} - -sub thread_html_head { - my ($hdr, $state) = @_; - my $res = delete $state->{res} or die "BUG: no Plack callback in {res}"; - my $fh = $res->([200, ['Content-Type'=> 'text/html; charset=UTF-8']]); - $state->{fh} = $fh; - - my $s = ascii_html($hdr->header('Subject')); - $fh->write("$s". - qq{! . - PublicInbox::Hval::STYLE . - ""); -} - -sub pre_anchor_entry { - my ($seen, $mime) = @_; - my $id = anchor_for(mid_mime($mime)); - $seen->{$id} = "#$id"; # save the anchor for children, later + 'm' . id_compress($msgid, 1); } sub ghost_parent { @@ -557,87 +668,11 @@ sub ghost_parent { qq{[parent not found: <$html>]}; } -sub thread_adj_level { - my ($state, $level) = @_; - - my $max = $state->{cur_level}; - if ($level <= 0) { - return '' if $max == 0; # flat output - - # reset existing lists - my $x = $max > 1 ? ('' x ($max - 1)) : ''; - $state->{fh}->write($x . ''); - $state->{cur_level} = 0; - return ''; - } - if ($level == $max) { # continue existing list - $state->{fh}->write('
  • '); - } elsif ($level < $max) { - my $x = $max > 1 ? ('
    • ' x ($max - $level)) : ''; - $state->{fh}->write($x .= '
  • '); - $state->{cur_level} = $level; - } else { # ($level > $max) # start a new level - $state->{cur_level} = $level; - $state->{fh}->write(($max ? '
  • ' : '') . '
    • '); - } - '
      • '; -} - -sub ghost_flush { - my ($state, $upfx, $mid, $level) = @_; - my $end = '
      '. ghost_parent($upfx, $mid) . '
      '; - $state->{fh}->write($end .= thread_adj_level($state, $level)); -} - -sub __thread_entry { - my ($state, $mime, $level) = @_; - - # lazy load the full message from mini_mime: - $mime = eval { - my $path = mid2path(mid_clean(mid_mime($mime))); - Email::MIME->new($state->{ctx}->{git}->cat_file('HEAD:'.$path)); - } or return; - - thread_html_head($mime, $state) if $state->{anchor_idx} == 0; - if (my $ghost = delete $state->{ghost}) { - # n.b. ghost messages may only be parents, not children - foreach my $g (@$ghost) { - ghost_flush($state, '../../', @$g); - } - } - my $end = thread_adj_level($state, $level); - index_entry($mime, $level, $state); - $state->{fh}->write($end) if $end; - - 1; -} - sub indent_for { my ($level) = @_; INDENT x ($level - 1); } -sub __ghost_prepare { - my ($state, $node, $level) = @_; - my $ghost = $state->{ghost} ||= []; - push @$ghost, [ $node->messageid, $level ]; -} - -sub thread_entry { - my ($state, $node, $level) = @_; - return unless $node; - if (my $mime = $node->message) { - unless (__thread_entry($state, $mime, $level)) { - __ghost_prepare($state, $node, $level); - } - } else { - __ghost_prepare($state, $node, $level); - } - - thread_entry($state, $node->child, $level + 1); - thread_entry($state, $node->next, $level); -} - sub load_results { my ($sres) = @_; @@ -660,10 +695,9 @@ sub thread_results { } sub missing_thread { - my ($res, $ctx) = @_; + my ($ctx) = @_; require PublicInbox::ExtMsg; - - $res->(PublicInbox::ExtMsg::ext_msg($ctx)) + PublicInbox::ExtMsg::ext_msg($ctx); } sub _msg_date { @@ -675,75 +709,95 @@ sub _msg_date { sub fmt_ts { POSIX::strftime('%Y-%m-%d %k:%M', gmtime($_[0])) } sub _skel_header { - my ($dst, $state, $upfx, $hdr, $level) = @_; + my ($ctx, $hdr, $level) = @_; - my $cur = $state->{cur}; + my $dst = $ctx->{dst}; + my $cur = $ctx->{cur}; my $mid = mid_clean($hdr->header_raw('Message-ID')); my $f = ascii_html($hdr->header('X-PI-From')); - my $d = _msg_date($hdr); - my $pfx = "$d " . indent_for($level) . th_pfx($level); + my $d = _msg_date($hdr) . ' ' . indent_for($level) . th_pfx($level); my $attr = $f; - $state->{first_level} ||= $level; + $ctx->{first_level} ||= $level; - if ($attr ne $state->{prev_attr} || $state->{prev_level} > $level) { - $state->{prev_attr} = $attr; + if ($attr ne $ctx->{prev_attr} || $ctx->{prev_level} > $level) { + $ctx->{prev_attr} = $attr; } else { $attr = ''; } - $state->{prev_level} = $level; + $ctx->{prev_level} = $level; if ($cur) { if ($cur eq $mid) { - delete $state->{cur}; - $$dst .= "$pfx". + delete $ctx->{cur}; + $$dst .= $d; + $$dst .= "". "$attr [this message]\n"; - return; } } else { - $state->{next_msg} ||= $mid; + $ctx->{next_msg} ||= $mid; } # Subject is never undef, this mail was loaded from # our Xapian which would've resulted in '' if it were # really missing (and Filter rejects empty subjects) my $s = $hdr->header('Subject'); - my $h = $state->{srch}->subject_path($s); - if ($state->{seen}->{$h}) { + my $h = $ctx->{srch}->subject_path($s); + if ($ctx->{seen}->{$h}) { $s = undef; } else { - $state->{seen}->{$h} = 1; + $ctx->{seen}->{$h} = 1; $s = PublicInbox::Hval->new($s); $s = $s->as_html; } my $m = PublicInbox::Hval->new_msgid($mid); - $m = $upfx . '../' . $m->as_href . '/'; - $$dst .= "$pfx"; - $$dst .= defined($s) ? "$s $f\n" : "$f\n"; + my $id = ''; + my $mapping = $ctx->{mapping}; + my $end = defined($s) ? "$s $f\n" : "$f\n"; + if ($mapping) { + my $map = $mapping->{$mid}; + $id = id_compress($mid, 1); + $m = '#m'.$id; + $map->[1] = "$d$end"; + $id = "\nid=r".$id; + } else { + $m = $ctx->{-upfx}.$m->as_href.'/'; + } + $$dst .= $d . "" . $end; } sub skel_dump { - my ($dst, $state, $upfx, $node, $level) = @_; - return unless $node; + my ($ctx, $level, $node) = @_; if (my $mime = $node->message) { - my $hdr = $mime->header_obj; - my $mid = mid_clean($hdr->header_raw('Message-ID')); - _skel_header($dst, $state, $upfx, $hdr, $level); + _skel_header($ctx, $mime->header_obj, $level); } else { my $mid = $node->messageid; + my $dst = $ctx->{dst}; + my $mapping = $ctx->{mapping}; + my $map = $mapping->{$mid} if $mapping; if ($mid eq 'subject dummy') { - $$dst .= "\t[no common parent]\n"; + my $ncp = "\t[no common parent]\n"; + $map->[1] = $ncp if $map; + $$dst .= $ncp; + return; + } + my $d = $ctx->{pct} ? ' [irrelevant] ' # search result + : ' [not found] '; + $d .= indent_for($level) . th_pfx($level); + my $upfx = $ctx->{-upfx}; + my $m = PublicInbox::Hval->new_msgid($mid); + my $href = $upfx . $m->as_href . '/'; + my $html = $m->as_html; + + if ($map) { + my $id = id_compress($mid, 1); + $map->[1] = $d . qq{<$html>\n}; + $d .= qq{<$html>\n}; } else { - $$dst .= ' [not found] '; - $$dst .= indent_for($level) . th_pfx($level); - $mid = PublicInbox::Hval->new_msgid($mid); - my $href = "$upfx../" . $mid->as_href . '/'; - my $html = $mid->as_html; - $$dst .= qq{<$html>\n}; + $d .= qq{<$html>\n}; } + $$dst .= $d; } - skel_dump($dst, $state, $upfx, $node->child, $level+1); - skel_dump($dst, $state, $upfx, $node->next, $level); } sub sort_ts { @@ -753,46 +807,44 @@ sub sort_ts { } @_; } +sub _tryload_ghost ($$) { + my ($srch, $mid) = @_; + my $smsg = $srch->lookup_mail($mid) or return; + $smsg->mini_mime; +} + # accumulate recent topics if search is supported # returns 1 if done, undef if not sub add_topic { - my ($state, $node, $level) = @_; - return unless $node; - my $child_adjust = 1; - - if (my $x = $node->message) { + my ($ctx, $level, $node) = @_; + my $srch = $ctx->{srch}; + my $mid = $node->messageid; + my $x = $node->message || _tryload_ghost($srch, $mid); + my ($subj, $ts); + if ($x) { $x = $x->header_obj; - my $subj; - $subj = $x->header('Subject'); - $subj = $state->{srch}->subject_normalized($subj); - - if (++$state->{subjs}->{$subj} == 1) { - push @{$state->{order}}, [ $level, $subj ]; - } - - my $mid = mid_clean($x->header_raw('Message-ID')); - - my $ts = $x->header('X-PI-TS'); - my $exist = $state->{latest}->{$subj}; - if (!$exist || $exist->[1] < $ts) { - $state->{latest}->{$subj} = [ $mid, $ts ]; - } - } else { - # ghost message, do not bump level - $child_adjust = 0; + $subj = $srch->subject_normalized($subj); + $ts = $x->header('X-PI-TS'); + } else { # ghost message, do not bump level + $ts = -666; + $subj = "<$mid>"; + } + if (++$ctx->{subjs}->{$subj} == 1) { + push @{$ctx->{order}}, [ $level, $subj ]; + } + my $exist = $ctx->{latest}->{$subj}; + if (!$exist || $exist->[1] < $ts) { + $ctx->{latest}->{$subj} = [ $mid, $ts ]; } - - add_topic($state, $node->child, $level + $child_adjust); - add_topic($state, $node->next, $level); } sub emit_topics { - my ($state) = @_; - my $order = $state->{order}; - my $subjs = $state->{subjs}; - my $latest = $state->{latest}; - my $fh = $state->{fh}; + my ($ctx) = @_; + my $order = $ctx->{order}; + my $subjs = $ctx->{subjs}; + my $latest = $ctx->{latest}; + my $fh = $ctx->{fh}; return $fh->write("\n[No topics in range]") unless scalar @$order; my $pfx; my $prev = 0; @@ -804,7 +856,6 @@ sub emit_topics { my $n = delete $subjs->{$subj}; my ($mid, $ts) = @{delete $latest->{$subj}}; $mid = PublicInbox::Hval->new_msgid($mid)->as_href; - $subj = PublicInbox::Hval->new($subj)->as_html; $pfx = indent_for($level); my $nl = $level == $prev ? "\n" : ''; if ($nl && $cur) { @@ -813,10 +864,14 @@ sub emit_topics { } $cur ||= [ $ts, '' ]; $cur->[0] = $ts if $ts > $cur->[0]; - $cur->[1] .= $nl . $pfx . th_pfx($level) . - "" . - $subj . "\n"; + $cur->[1] .= $nl . $pfx . th_pfx($level); + if ($ts == -666) { # ghost + $cur->[1] .= ghost_parent('', $mid) . "\n"; + next; # child will have mbox / atom link + } + $subj = PublicInbox::Hval->new($subj)->as_html; + $cur->[1] .= "$subj\n"; $ts = fmt_ts($ts); my $attr = " $ts UTC"; @@ -838,26 +893,53 @@ sub emit_topics { } sub emit_index_topics { - my ($state) = @_; - my $off = $state->{ctx}->{cgi}->param('o'); - $off = 0 unless defined $off; - $state->{order} = []; - $state->{subjs} = {}; - $state->{latest} = {}; + my ($ctx) = @_; + my ($off) = (($ctx->{cgi}->param('o') || '0') =~ /(\d+)/); + $ctx->{order} = []; + $ctx->{subjs} = {}; + $ctx->{latest} = {}; my $max = 25; - my %opts = ( offset => int $off, limit => $max * 4 ); - while (scalar @{$state->{order}} < $max) { - my $sres = $state->{srch}->query('', \%opts); + my %opts = ( offset => $off, limit => $max * 4 ); + while (scalar @{$ctx->{order}} < $max) { + my $sres = $ctx->{srch}->query('', \%opts); my $nr = scalar @{$sres->{msgs}} or last; - - for (thread_results(load_results($sres))->rootset) { - add_topic($state, $_, 0); - } + $sres = load_results($sres); + walk_thread(thread_results($sres), $ctx, *add_topic); $opts{offset} += $nr; } - emit_topics($state); + emit_topics($ctx); $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 ? ('
    • ' x ($max - 1)) : ''; + $ctx->{cur_level} = 0; + ("$beg", ''); + } elsif ($level == $max) { # continue existing list + qw(
    • ); + } elsif ($level < $max) { + my $beg = $max > 1 ? ('' x ($max - $level)) : ''; + $ctx->{cur_level} = $level; + ("$beg
  • ", '
    • '); + } else { # ($level > $max) # start a new level + $ctx->{cur_level} = $level; + my $beg = ($max ? '
  • ' : '') . '
    • '; + ($beg, '
      • '); + } +} + +sub ghost_index_entry { + my ($ctx, $level, $mid) = @_; + my ($beg, $end) = thread_adj_level($ctx, $level); + $beg . '
      '. ghost_parent($ctx->{-upfx}, $mid) . '
      ' . $end; +} + 1;