X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FViewVCS.pm;h=eecc51e673b2aad8ad8fbfbca21326ed895be7b6;hb=ce4fe8f5144f7555ddd42b6a94ec602e042c6e43;hp=fa76086a466a4bc1fa25a514d7386266e452e8a3;hpb=fffbc9ec32b78731acd30539f6e3f2778d2d1fb2;p=public-inbox.git diff --git a/lib/PublicInbox/ViewVCS.pm b/lib/PublicInbox/ViewVCS.pm index fa76086a..eecc51e6 100644 --- a/lib/PublicInbox/ViewVCS.pm +++ b/lib/PublicInbox/ViewVCS.pm @@ -20,10 +20,21 @@ use Encode qw(find_encoding); use PublicInbox::SolverGit; use PublicInbox::WwwStream; use PublicInbox::Linkify; -use PublicInbox::Hval qw(ascii_html to_filename); +use PublicInbox::Hval qw(ascii_html to_filename src_escape); +my $hl = eval { + require PublicInbox::HlMod; + PublicInbox::HlMod->new; +}; + +# we need to trigger highlight::CodeGenerator::deleteInstance +# in HlMod::DESTROY before the rest of Perl shuts down to avoid +# a segfault at shutdown +END { $hl = undef }; + my %QP_MAP = ( A => 'oid_a', B => 'oid_b', a => 'path_a', b => 'path_b' ); my $max_size = 1024 * 1024; # TODO: configurable my $enc_utf8 = find_encoding('UTF-8'); +my $BIN_DETECT = 8000; # same as git sub html_page ($$$) { my ($ctx, $code, $strref) = @_; @@ -33,7 +44,33 @@ sub html_page ($$$) { my ($nr, undef) = @_; $nr == 1 ? $$strref : undef; }); - $wcb->($res); + $wcb ? $wcb->($res) : $res; +} + +sub stream_large_blob ($$$$) { + my ($ctx, $res, $logref, $fn) = @_; + my ($git, $oid, $type, $size, $di) = @$res; + my $cmd = ['git', "--git-dir=$git->{git_dir}", 'cat-file', $type, $oid]; + my $qsp = PublicInbox::Qspawn->new($cmd); + my @cl = ('Content-Length', $size); + my $env = $ctx->{env}; + $env->{'qspawn.wcb'} = delete $ctx->{-wcb}; + $qsp->psgi_return($env, undef, sub { + my ($r, $bref) = @_; + if (!defined $r) { # error + html_page($ctx, 500, $logref); + } elsif (index($$bref, "\0") >= 0) { + my $ct = 'application/octet-stream'; + [200, ['Content-Type', $ct, @cl ] ]; + } else { + my $n = bytes::length($$bref); + if ($n >= $BIN_DETECT || $n == $size) { + my $ct = 'text/plain; charset=UTF-8'; + return [200, ['Content-Type', $ct, @cl] ]; + } + undef; # bref keeps growing + } + }); } sub solve_result { @@ -46,7 +83,6 @@ sub solve_result { $log = do { local $/; <$log> }; my $ref = ref($res); - $log .= $res unless $ref; my $l = PublicInbox::Linkify->new; $l->linkify_1($log); $log = '
debug log:

' .
@@ -56,9 +92,12 @@ sub solve_result {
 	$ref eq 'ARRAY' or return html_page($ctx, 500, \$log);
 
 	my ($git, $oid, $type, $size, $di) = @$res;
+	my $path = to_filename($di->{path_b} || $hints->{path_b} || 'blob');
+	my $raw_link = "(raw)";
 	if ($size > $max_size) {
-		# TODO: stream the raw file if it's gigantic, at least
-		$log = '
Too big to show
' . $log; + return stream_large_blob($ctx, $res, \$log, $fn) if defined $fn; + $log = "
Too big to show, download available\n" .
+			"$oid $type $size bytes $raw_link
" . $log; return html_page($ctx, 500, \$log); } @@ -77,8 +116,6 @@ sub solve_result { return delete($ctx->{-wcb})->([200, $h, [ $$blob ]]); } - my $path = to_filename($di->{path_b} || $hints->{path_b} || 'blob'); - my $raw_link = "(raw)"; if ($binary) { $log = "
$oid $type $size bytes (binary)" .
 			" $raw_link
" . $log; @@ -89,6 +126,16 @@ sub solve_result { my $nl = ($$blob =~ tr/\n/\n/); my $pad = length($nl); + $l->linkify_1($$blob); + my $ok = $hl->do_hl($blob, $path) if $hl; + if ($ok) { + $$ok = $enc_utf8->decode($$ok); + src_escape($$ok); + $blob = $ok; + } else { + $$blob = ascii_html($$blob); + } + # using some of the same CSS class names and ids as cgit $log = "
$oid $type $size bytes $raw_link
" . "
". @@ -97,7 +144,7 @@ sub solve_result { } (1..$nl)) . '
' . '
 
'. # pad for non-CSS users "" . - ascii_html($$blob) . + $l->linkify_2($$blob) . '' . $log; html_page($ctx, 200, \$log);