lib/PublicInbox/View.pm | 193 ++++++++++++++++++++++++++++++----------------------- diff --git a/lib/PublicInbox/View.pm b/lib/PublicInbox/View.pm index bd0a27aa6b454db0c296d03b2e0793b473c7bbd2..946df37f3835031b24d19c77cd35662f5203b309 100644 --- a/lib/PublicInbox/View.pm +++ b/lib/PublicInbox/View.pm @@ -31,10 +31,9 @@ $footer = "\n" . $footer; } else { $footer = ''; } - my $srch = $ctx->{srch} if $ctx; - headers_to_html_header($mime, $full_pfx, $srch) . + headers_to_html_header($mime, $full_pfx, $ctx) . multipart_text_as_html($mime, $full_pfx) . - '
' .
+		'
' . PRE_WRAP . html_footer($mime, 1, $full_pfx, $ctx) . $footer . ''; @@ -343,8 +342,8 @@ $s; } sub headers_to_html_header { - my ($mime, $full_pfx, $srch) = @_; - + my ($mime, $full_pfx, $ctx) = @_; + my $srch = $ctx->{srch} if $ctx; my $rv = ""; my @title; my $header_obj = $mime->header_obj; @@ -362,7 +361,8 @@ $title[1] = ascii_html($from[0]->name); } elsif ($h eq 'Subject') { $title[0] = $v->as_html; if ($srch) { - $rv .= "$h: "; + $rv .= "$h: "; $rv .= $v->as_html . "\n"; next; } @@ -370,10 +370,47 @@ } $rv .= "$h: " . $v->as_html . "\n"; } - $rv .= 'Message-ID: <' . $mid->as_html . '> '; my $raw_ref = $full_pfx ? 'raw' : "../../m/$mid_href/raw"; $rv .= "(raw)\n"; + if ($srch) { + $rv .= "References: [see below]\n"; + } else { + $rv .= _parent_headers_nosrch($header_obj); + } + $rv .= "\n"; + + ("". join(' - ', @title) . + '' . PRE_WRAP . $rv); +} + +sub thread_inline { + my ($dst, $ctx, $cur) = @_; + my $srch = $ctx->{srch}; + my $mid = mid_compress(mid_clean($cur->header('Message-ID'))); + my $res = $srch->get_thread($mid); + my $nr = $res->{total}; + if ($nr <= 1) { + $$dst .= "[only message in thread]\n"; + return; + } + + $$dst .= "roughly $nr messages in thread:\n"; + my $subj = $srch->subject_path($cur->header('Subject')); + my $state = { + seen => { $subj => 1 }, + srch => $srch, + cur => $mid, + }; + for (thread_results(load_results($res))->rootset) { + inline_dump($dst, $state, $_, 0); + } + $state->{next_msg}; +} + +sub _parent_headers_nosrch { + my ($header_obj) = @_; + my $rv = ''; my $irt = $header_obj->header('In-Reply-To'); if (defined $irt) { @@ -401,11 +438,7 @@ if (@refs) { $rv .= 'References: '. join(' ', @refs) . "\n"; } } - - $rv .= "\n"; - - ("". join(' - ', @title) . - '' . PRE_WRAP . $rv); + $rv; } sub html_footer { @@ -440,25 +473,11 @@ my $srch = $ctx->{srch} if $ctx; my $idx = $standalone ? " index" : ''; if ($idx && $srch) { - $mid = mid_compress(mid_clean($mid)); my $t_anchor = defined $irt ? T_ANCHOR : ''; $irt = $mime->header('In-Reply-To'); $idx = " ". - "threadlink$idx"; - my $res = $srch->get_followups($mid); - if (my $c = $res->{total}) { - my $nr = scalar @{$res->{msgs}}; - if ($nr < $c) { - $c = "$nr of $c followups"; - } else { - $c = $c == 1 ? '1 followup' : "$c followups"; - } - $idx .= "\n$c:\n"; - $res->{srch} = $srch; - thread_followups(\$idx, $mime, $res); - } else { - $idx .= "\n(no followups, yet)\n"; - } + "threadlink$idx\n\n"; + my $next = thread_inline(\$idx, $ctx, $mime); if (defined $irt) { $irt = PublicInbox::Hval->new_msgid($irt); $irt = $irt->as_href; @@ -466,6 +485,11 @@ $irt = "parent "; } else { $irt = ' ' x length('parent '); } + if ($next) { + $irt .= "next "; + } else { + $irt .= ' '; + } } else { $irt = ''; } @@ -489,61 +513,6 @@ } 'm' . $id; } -sub simple_dump { - my ($dst, $root, $node, $level) = @_; - return unless $node; - # $root = [ undef, \%seen, $srch ]; - if (my $x = $node->message) { - my $f = $x->header('X-PI-From'); - my $d = $x->header('X-PI-Date'); - if (defined $f && defined $d) { - my $mid = $x->header('Message-ID'); - my $pfx = ' ' x $level; - $$dst .= $pfx; - - # 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 = $x->header('Subject'); - my $h = $root->[2]->subject_path($s); - if ($root->[1]->{$h}) { - $s = undef; - } else { - $root->[1]->{$h} = 1; - $s = PublicInbox::Hval->new($s); - $s = $s->as_html; - } - my $m = PublicInbox::Hval->new_msgid($mid); - $f = PublicInbox::Hval->new($f); - $d = PublicInbox::Hval->new($d); - $m = '../' . $m->as_href . '/'; - $f = $f->as_html; - $d = $d->as_html . ' UTC'; - if (defined $s) { - $$dst .= "` $s\n" . - "$pfx by $f @ $d\n"; - } else { - $$dst .= "` $f @ $d\n"; - } - } - } - simple_dump($dst, $root, $node->child, $level+1); - simple_dump($dst, $root, $node->next, $level); -} - -sub thread_followups { - my ($dst, $root, $res) = @_; - $root->header_set('X-PI-TS', '0'); - my $msgs = load_results($res); - push @$msgs, $root; - my $th = thread_results($msgs); - my $srch = $res->{srch}; - my $subj = $srch->subject_path($root->header('Subject')); - my %seen = ($subj => 1); - $root = [ undef, \%seen, $srch ]; - simple_dump($dst, $root, $_, 0) for $th->rootset; -} - sub thread_html_head { my ($mime) = @_; my $s = PublicInbox::Hval->new_oneline($mime->header('Subject')); @@ -599,6 +568,64 @@ $cb->([404, ['Content-Type' => 'text/html']])->write(<$title
$title
 Return to index
EOF +} + +sub _inline_header { + my ($dst, $state, $mime, $level) = @_; + my $pfx = ' ' x $level; + + my $cur = $state->{cur}; + my $mid = $mime->header('Message-ID'); + my $f = $mime->header('X-PI-From'); + my $d = $mime->header('X-PI-Date'); + $f = PublicInbox::Hval->new($f); + $d = PublicInbox::Hval->new($d); + $f = $f->as_html; + $d = $d->as_html . ' UTC'; + my $midc = mid_compress(mid_clean($mid)); + if ($cur) { + if ($cur eq $midc) { + delete $state->{cur}; + $$dst .= "$pfx` ". + "[this message] by $f @ $d\n"; + + return; + } + } else { + $state->{next_msg} ||= $midc; + } + + # 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 = $mime->header('Subject'); + my $h = $state->{srch}->subject_path($s); + if ($state->{seen}->{$h}) { + $s = undef; + } else { + $state->{seen}->{$h} = 1; + $s = PublicInbox::Hval->new($s); + $s = $s->as_html; + } + my $m = PublicInbox::Hval->new_msgid($mid); + $m = '../' . $m->as_href . '/'; + if (defined $s) { + $$dst .= "$pfx` $s\n" . + "$pfx $f @ $d\n"; + } else { + $$dst .= "$pfx` $f @ $d\n"; + } +} + +sub inline_dump { + my ($dst, $state, $node, $level) = @_; + return unless $node; + return if $state->{stopped}; + if (my $mime = $node->message) { + _inline_header($dst, $state, $mime, $level); + } + inline_dump($dst, $state, $node->child, $level+1); + inline_dump($dst, $state, $node->next, $level); } 1;