]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/ViewDiff.pm
www: switch to zadd for the majority of buffering
[public-inbox.git] / lib / PublicInbox / ViewDiff.pm
index 8c1853e625557872003af9d74cad0fc13cc3875a..95b615dc7c11a7a2084b57d9a1e1bcaac64300de 100644 (file)
@@ -10,12 +10,11 @@ package PublicInbox::ViewDiff;
 use strict;
 use v5.10.1;
 use parent qw(Exporter);
-our @EXPORT_OK = qw(flush_diff);
+our @EXPORT_OK = qw(flush_diff uri_escape_path);
 use URI::Escape qw(uri_escape_utf8);
 use PublicInbox::Hval qw(ascii_html to_attr);
 use PublicInbox::Git qw(git_unquote);
 
-my $UNSAFE = "^A-Za-z0-9\-\._~/"; # '/' + $URI::Escape::Unsafe{RFC3986}
 my $OID_NULL = '0{7,}';
 my $OID_BLOB = '[a-f0-9]{7,}';
 my $LF = qr!\n!;
@@ -41,22 +40,24 @@ our $EXTRACT_DIFFS = qr/(
                ^\+{3}\x20($FN)$LF)/msx;
 our $IS_OID = qr/\A$OID_BLOB\z/s;
 
+sub uri_escape_path {
+       # '/' + $URI::Escape::Unsafe{RFC3986}
+       uri_escape_utf8($_[0], "^A-Za-z0-9\-\._~/");
+}
+
 # link to line numbers in blobs
-sub diff_hunk ($$$$) {
-       my ($dst, $dctx, $ca, $cb) = @_;
+sub diff_hunk ($$$) {
+       my ($dctx, $ca, $cb) = @_;
        my ($oid_a, $oid_b, $spfx) = @$dctx{qw(oid_a oid_b spfx)};
 
        if (defined($spfx) && defined($oid_a) && defined($oid_b)) {
-               my ($n) = ($ca =~ /^-([0-9]+)/);
-               $n = defined($n) ? "#n$n" : '';
-
-               $$dst .= qq(@@ <a\nhref="$spfx$oid_a/s/$dctx->{Q}$n">$ca</a>);
+               my $n = ($ca =~ /^-([0-9]+)/) ? "#n$1" : '';
+               my $x = qq(@@ <a\nhref="$spfx$oid_a/s/$dctx->{Q}$n">$ca</a>);
 
-               ($n) = ($cb =~ /^\+([0-9]+)/);
-               $n = defined($n) ? "#n$n" : '';
-               $$dst .= qq( <a\nhref="$spfx$oid_b/s/$dctx->{Q}$n">$cb</a> @@);
+               $n = ($cb =~ /^\+([0-9]+)/) ? "#n$1" : '';
+               $x .= qq( <a\nhref="$spfx$oid_b/s/$dctx->{Q}$n">$cb</a> @@);
        } else {
-               $$dst .= "@@ $ca $cb @@";
+               "@@ $ca $cb @@";
        }
 }
 
@@ -123,14 +124,14 @@ sub diff_header ($$$) {
        $pa = (split(m'/', git_unquote($pa), 2))[1] if $pa ne '/dev/null';
        $pb = (split(m'/', git_unquote($pb), 2))[1] if $pb ne '/dev/null';
        if ($pa eq $pb && $pb ne '/dev/null') {
-               $dctx->{Q} = "?b=".uri_escape_utf8($pb, $UNSAFE);
+               $dctx->{Q} = '?b='.uri_escape_path($pb);
        } else {
                my @q;
                if ($pb ne '/dev/null') {
-                       push @q, 'b='.uri_escape_utf8($pb, $UNSAFE);
+                       push @q, 'b='.uri_escape_path($pb);
                }
                if ($pa ne '/dev/null') {
-                       push @q, 'a='.uri_escape_utf8($pa, $UNSAFE);
+                       push @q, 'a='.uri_escape_path($pa);
                }
                $dctx->{Q} = '?'.join('&amp;', @q);
        }
@@ -155,37 +156,33 @@ sub diff_header ($$$) {
                warn "BUG? <$$x> had no ^index line";
        }
        $$x =~ s!^diff --git!anchor1($ctx, $pb) // 'diff --git'!ems;
-       my $dst = $ctx->{obuf};
-       $$dst .= qq(<span\nclass="head">);
-       $$dst .= $$x;
-       $$dst .= '</span>';
+       $ctx->zadd(qq(<span\nclass="head">$$x</span>));
        $dctx;
 }
 
 sub diff_before_or_after ($$) {
        my ($ctx, $x) = @_;
-       my $linkify = $ctx->{-linkify};
-       my $dst = $ctx->{obuf};
        if (exists $ctx->{-anchors} && $$x =~ /\A(.*?) # likely "---\n"
                        # diffstat lines:
                        ((?:^\x20(?:[^\n]+?)(?:\x20+\|\x20[^\n]*\n))+)
                        (\x20[0-9]+\x20files?\x20)changed,([^\n]+\n)
                        (.*?)\z/msx) { # notes, commit message, etc
-               undef $$x;
                my @x = ($5, $4, $3, $2, $1);
-               $$dst .= $linkify->to_html(pop @x); # uninteresting prefix
+               my $lnk = $ctx->{-linkify};
+               $$x = $lnk->to_html(pop @x); # uninteresting prefix
                for my $l (split(/^/m, pop(@x))) { # per-file diffstat lines
                        $l =~ /^ (.+)( +\| .*\z)/s and
-                               anchor0($dst, $ctx, $1, $2) and next;
-                       $$dst .= $linkify->to_html($l);
+                               anchor0($x, $ctx, $1, $2) and next;
+                       $$x .= $lnk->to_html($l);
                }
-               $$dst .= $x[2]; # $3 /^ \d+ files? /
+               $$x .= pop @x; # $3 /^ \d+ files? /
                my $ch = $ctx->{changed_href} // '#related';
-               $$dst .= qq(<a href="$ch">changed</a>,);
-               $$dst .= ascii_html($x[1]); # $4: insertions/deletions
-               $$dst .= $linkify->to_html($x[0]); # notes, commit message, etc
+               $$x .= qq(<a href="$ch">changed</a>,);
+               $$x .= ascii_html(pop @x); # $4: insertions/deletions
+               # notes, commit message, etc
+               $ctx->zadd($$x .= $lnk->to_html(pop @x));
        } else {
-               $$dst .= $linkify->to_html($$x);
+               $ctx->zadd($ctx->{-linkify}->to_html($$x));
        }
 }
 
@@ -196,8 +193,7 @@ sub flush_diff ($$) {
        my @top = split($EXTRACT_DIFFS, $$cur);
        undef $$cur; # free memory
 
-       my $linkify = $ctx->{-linkify};
-       my $dst = $ctx->{obuf};
+       my $lnk = $ctx->{-linkify};
        my $dctx; # {}, keys: Q, oid_a, oid_b
 
        while (defined(my $x = shift @top)) {
@@ -224,26 +220,26 @@ sub flush_diff ($$) {
                                if (!defined($dctx)) {
                                        $after .= $s;
                                } elsif ($s =~ s/\A@@ (\S+) (\S+) @@//) {
-                                       $$dst .= qq(<span\nclass="hunk">);
-                                       diff_hunk($dst, $dctx, $1, $2);
-                                       $$dst .= $linkify->to_html($s);
-                                       $$dst .= '</span>';
-                               } elsif ($s =~ /\A\+/) {
-                                       $$dst .= qq(<span\nclass="add">);
-                                       $$dst .= $linkify->to_html($s);
-                                       $$dst .= '</span>';
+                                       $ctx->zadd(qq(<span\nclass="hunk">) .
+                                               diff_hunk($dctx, $1, $2) .
+                                               $lnk->to_html($s) .
+                                               '</span>');
+                               } elsif ($s =~ /\A\+/) { # $s may be huge
+                                       $ctx->zadd(qq(<span\nclass="add">),
+                                                       $lnk->to_html($s),
+                                                       '</span>');
                                } elsif ($s =~ /\A-- $/sm) { # email sig starts
                                        $dctx = undef;
                                        $after .= $s;
-                               } elsif ($s =~ /\A-/) {
-                                       $$dst .= qq(<span\nclass="del">);
-                                       $$dst .= $linkify->to_html($s);
-                                       $$dst .= '</span>';
-                               } else {
-                                       $$dst .= $linkify->to_html($s);
+                               } elsif ($s =~ /\A-/) { # $s may be huge
+                                       $ctx->zadd(qq(<span\nclass="del">),
+                                               $lnk->to_html($s),
+                                               '</span>');
+                               } else { # $s may be huge
+                                       $ctx->zadd($lnk->to_html($s));
                                }
                        }
-                       diff_before_or_after($ctx, \$after) unless $dctx;
+                       diff_before_or_after($ctx, \$after) if !$dctx;
                } else {
                        diff_before_or_after($ctx, \$x);
                }