Extract Git::SVN::Log from git-svn.
authorMichael G. Schwern <schwern@pobox.com>
Fri, 27 Jul 2012 00:26:01 +0000 (17:26 -0700)
committerEric Wong <normalperson@yhbt.net>
Fri, 27 Jul 2012 22:36:06 +0000 (22:36 +0000)
Straight cut & paste.

Also noticed Git::SVN::Ra wasn't in the compile test.  It is now.

Signed-off-by: Eric Wong <normalperson@yhbt.net>
git-svn.perl
perl/Git/SVN/Log.pm [new file with mode: 0644]
perl/Makefile
t/Git-SVN/00compile.t

index 48906becb745f04d8fd73f19d0f30ce8b1d0e335..15e5f3c0feda0dc362322662b8e1f042c6afa4f6 100755 (executable)
@@ -11,6 +11,7 @@ $AUTHOR = 'Eric Wong <normalperson@yhbt.net>';
 $VERSION = '@@GIT_VERSION@@';
 
 use Git::SVN;
+use Git::SVN::Log;
 use Git::SVN::Utils qw(fatal can_compress);
 
 # From which subdir have we been invoked?
@@ -2039,400 +2040,6 @@ sub gc_directory {
 }
 
 
-package Git::SVN::Log;
-use strict;
-use warnings;
-use Git::SVN::Utils qw(fatal);
-use Git qw(command command_oneline command_output_pipe command_close_pipe);
-use POSIX qw/strftime/;
-use constant commit_log_separator => ('-' x 72) . "\n";
-use vars qw/$TZ $limit $color $pager $non_recursive $verbose $oneline
-            %rusers $show_commit $incremental/;
-
-# Option set in git-svn
-our $_git_format;
-
-sub cmt_showable {
-       my ($c) = @_;
-       return 1 if defined $c->{r};
-
-       # big commit message got truncated by the 16k pretty buffer in rev-list
-       if ($c->{l} && $c->{l}->[-1] eq "...\n" &&
-                               $c->{a_raw} =~ /\@([a-f\d\-]+)>$/) {
-               @{$c->{l}} = ();
-               my @log = command(qw/cat-file commit/, $c->{c});
-
-               # shift off the headers
-               shift @log while ($log[0] ne '');
-               shift @log;
-
-               # TODO: make $c->{l} not have a trailing newline in the future
-               @{$c->{l}} = map { "$_\n" } grep !/^git-svn-id: /, @log;
-
-               (undef, $c->{r}, undef) = ::extract_metadata(
-                               (grep(/^git-svn-id: /, @log))[-1]);
-       }
-       return defined $c->{r};
-}
-
-sub log_use_color {
-       return $color || Git->repository->get_colorbool('color.diff');
-}
-
-sub git_svn_log_cmd {
-       my ($r_min, $r_max, @args) = @_;
-       my $head = 'HEAD';
-       my (@files, @log_opts);
-       foreach my $x (@args) {
-               if ($x eq '--' || @files) {
-                       push @files, $x;
-               } else {
-                       if (::verify_ref("$x^0")) {
-                               $head = $x;
-                       } else {
-                               push @log_opts, $x;
-                       }
-               }
-       }
-
-       my ($url, $rev, $uuid, $gs) = ::working_head_info($head);
-
-       require Git::SVN;
-       $gs ||= Git::SVN->_new;
-       my @cmd = (qw/log --abbrev-commit --pretty=raw --default/,
-                  $gs->refname);
-       push @cmd, '-r' unless $non_recursive;
-       push @cmd, qw/--raw --name-status/ if $verbose;
-       push @cmd, '--color' if log_use_color();
-       push @cmd, @log_opts;
-       if (defined $r_max && $r_max == $r_min) {
-               push @cmd, '--max-count=1';
-               if (my $c = $gs->rev_map_get($r_max)) {
-                       push @cmd, $c;
-               }
-       } elsif (defined $r_max) {
-               if ($r_max < $r_min) {
-                       ($r_min, $r_max) = ($r_max, $r_min);
-               }
-               my (undef, $c_max) = $gs->find_rev_before($r_max, 1, $r_min);
-               my (undef, $c_min) = $gs->find_rev_after($r_min, 1, $r_max);
-               # If there are no commits in the range, both $c_max and $c_min
-               # will be undefined.  If there is at least 1 commit in the
-               # range, both will be defined.
-               return () if !defined $c_min || !defined $c_max;
-               if ($c_min eq $c_max) {
-                       push @cmd, '--max-count=1', $c_min;
-               } else {
-                       push @cmd, '--boundary', "$c_min..$c_max";
-               }
-       }
-       return (@cmd, @files);
-}
-
-# adapted from pager.c
-sub config_pager {
-       if (! -t *STDOUT) {
-               $ENV{GIT_PAGER_IN_USE} = 'false';
-               $pager = undef;
-               return;
-       }
-       chomp($pager = command_oneline(qw(var GIT_PAGER)));
-       if ($pager eq 'cat') {
-               $pager = undef;
-       }
-       $ENV{GIT_PAGER_IN_USE} = defined($pager);
-}
-
-sub run_pager {
-       return unless defined $pager;
-       pipe my ($rfd, $wfd) or return;
-       defined(my $pid = fork) or fatal "Can't fork: $!";
-       if (!$pid) {
-               open STDOUT, '>&', $wfd or
-                                    fatal "Can't redirect to stdout: $!";
-               return;
-       }
-       open STDIN, '<&', $rfd or fatal "Can't redirect stdin: $!";
-       $ENV{LESS} ||= 'FRSX';
-       exec $pager or fatal "Can't run pager: $! ($pager)";
-}
-
-sub format_svn_date {
-       my $t = shift || time;
-       require Git::SVN;
-       my $gmoff = Git::SVN::get_tz($t);
-       return strftime("%Y-%m-%d %H:%M:%S $gmoff (%a, %d %b %Y)", localtime($t));
-}
-
-sub parse_git_date {
-       my ($t, $tz) = @_;
-       # Date::Parse isn't in the standard Perl distro :(
-       if ($tz =~ s/^\+//) {
-               $t += tz_to_s_offset($tz);
-       } elsif ($tz =~ s/^\-//) {
-               $t -= tz_to_s_offset($tz);
-       }
-       return $t;
-}
-
-sub set_local_timezone {
-       if (defined $TZ) {
-               $ENV{TZ} = $TZ;
-       } else {
-               delete $ENV{TZ};
-       }
-}
-
-sub tz_to_s_offset {
-       my ($tz) = @_;
-       $tz =~ s/(\d\d)$//;
-       return ($1 * 60) + ($tz * 3600);
-}
-
-sub get_author_info {
-       my ($dest, $author, $t, $tz) = @_;
-       $author =~ s/(?:^\s*|\s*$)//g;
-       $dest->{a_raw} = $author;
-       my $au;
-       if ($::_authors) {
-               $au = $rusers{$author} || undef;
-       }
-       if (!$au) {
-               ($au) = ($author =~ /<([^>]+)\@[^>]+>$/);
-       }
-       $dest->{t} = $t;
-       $dest->{tz} = $tz;
-       $dest->{a} = $au;
-       $dest->{t_utc} = parse_git_date($t, $tz);
-}
-
-sub process_commit {
-       my ($c, $r_min, $r_max, $defer) = @_;
-       if (defined $r_min && defined $r_max) {
-               if ($r_min == $c->{r} && $r_min == $r_max) {
-                       show_commit($c);
-                       return 0;
-               }
-               return 1 if $r_min == $r_max;
-               if ($r_min < $r_max) {
-                       # we need to reverse the print order
-                       return 0 if (defined $limit && --$limit < 0);
-                       push @$defer, $c;
-                       return 1;
-               }
-               if ($r_min != $r_max) {
-                       return 1 if ($r_min < $c->{r});
-                       return 1 if ($r_max > $c->{r});
-               }
-       }
-       return 0 if (defined $limit && --$limit < 0);
-       show_commit($c);
-       return 1;
-}
-
-my $l_fmt;
-sub show_commit {
-       my $c = shift;
-       if ($oneline) {
-               my $x = "\n";
-               if (my $l = $c->{l}) {
-                       while ($l->[0] =~ /^\s*$/) { shift @$l }
-                       $x = $l->[0];
-               }
-               $l_fmt ||= 'A' . length($c->{r});
-               print 'r',pack($l_fmt, $c->{r}),' | ';
-               print "$c->{c} | " if $show_commit;
-               print $x;
-       } else {
-               show_commit_normal($c);
-       }
-}
-
-sub show_commit_changed_paths {
-       my ($c) = @_;
-       return unless $c->{changed};
-       print "Changed paths:\n", @{$c->{changed}};
-}
-
-sub show_commit_normal {
-       my ($c) = @_;
-       print commit_log_separator, "r$c->{r} | ";
-       print "$c->{c} | " if $show_commit;
-       print "$c->{a} | ", format_svn_date($c->{t_utc}), ' | ';
-       my $nr_line = 0;
-
-       if (my $l = $c->{l}) {
-               while ($l->[$#$l] eq "\n" && $#$l > 0
-                                         && $l->[($#$l - 1)] eq "\n") {
-                       pop @$l;
-               }
-               $nr_line = scalar @$l;
-               if (!$nr_line) {
-                       print "1 line\n\n\n";
-               } else {
-                       if ($nr_line == 1) {
-                               $nr_line = '1 line';
-                       } else {
-                               $nr_line .= ' lines';
-                       }
-                       print $nr_line, "\n";
-                       show_commit_changed_paths($c);
-                       print "\n";
-                       print $_ foreach @$l;
-               }
-       } else {
-               print "1 line\n";
-               show_commit_changed_paths($c);
-               print "\n";
-
-       }
-       foreach my $x (qw/raw stat diff/) {
-               if ($c->{$x}) {
-                       print "\n";
-                       print $_ foreach @{$c->{$x}}
-               }
-       }
-}
-
-sub cmd_show_log {
-       my (@args) = @_;
-       my ($r_min, $r_max);
-       my $r_last = -1; # prevent dupes
-       set_local_timezone();
-       if (defined $::_revision) {
-               if ($::_revision =~ /^(\d+):(\d+)$/) {
-                       ($r_min, $r_max) = ($1, $2);
-               } elsif ($::_revision =~ /^\d+$/) {
-                       $r_min = $r_max = $::_revision;
-               } else {
-                       fatal "-r$::_revision is not supported, use ",
-                               "standard 'git log' arguments instead";
-               }
-       }
-
-       config_pager();
-       @args = git_svn_log_cmd($r_min, $r_max, @args);
-       if (!@args) {
-               print commit_log_separator unless $incremental || $oneline;
-               return;
-       }
-       my $log = command_output_pipe(@args);
-       run_pager();
-       my (@k, $c, $d, $stat);
-       my $esc_color = qr/(?:\033\[(?:(?:\d+;)*\d*)?m)*/;
-       while (<$log>) {
-               if (/^${esc_color}commit (?:- )?($::sha1_short)/o) {
-                       my $cmt = $1;
-                       if ($c && cmt_showable($c) && $c->{r} != $r_last) {
-                               $r_last = $c->{r};
-                               process_commit($c, $r_min, $r_max, \@k) or
-                                                               goto out;
-                       }
-                       $d = undef;
-                       $c = { c => $cmt };
-               } elsif (/^${esc_color}author (.+) (\d+) ([\-\+]?\d+)$/o) {
-                       get_author_info($c, $1, $2, $3);
-               } elsif (/^${esc_color}(?:tree|parent|committer) /o) {
-                       # ignore
-               } elsif (/^${esc_color}:\d{6} \d{6} $::sha1_short/o) {
-                       push @{$c->{raw}}, $_;
-               } elsif (/^${esc_color}[ACRMDT]\t/) {
-                       # we could add $SVN->{svn_path} here, but that requires
-                       # remote access at the moment (repo_path_split)...
-                       s#^(${esc_color})([ACRMDT])\t#$1   $2 #o;
-                       push @{$c->{changed}}, $_;
-               } elsif (/^${esc_color}diff /o) {
-                       $d = 1;
-                       push @{$c->{diff}}, $_;
-               } elsif ($d) {
-                       push @{$c->{diff}}, $_;
-               } elsif (/^\ .+\ \|\s*\d+\ $esc_color[\+\-]*
-                         $esc_color*[\+\-]*$esc_color$/x) {
-                       $stat = 1;
-                       push @{$c->{stat}}, $_;
-               } elsif ($stat && /^ \d+ files changed, \d+ insertions/) {
-                       push @{$c->{stat}}, $_;
-                       $stat = undef;
-               } elsif (/^${esc_color}    (git-svn-id:.+)$/o) {
-                       ($c->{url}, $c->{r}, undef) = ::extract_metadata($1);
-               } elsif (s/^${esc_color}    //o) {
-                       push @{$c->{l}}, $_;
-               }
-       }
-       if ($c && defined $c->{r} && $c->{r} != $r_last) {
-               $r_last = $c->{r};
-               process_commit($c, $r_min, $r_max, \@k);
-       }
-       if (@k) {
-               ($r_min, $r_max) = ($r_max, $r_min);
-               process_commit($_, $r_min, $r_max) foreach reverse @k;
-       }
-out:
-       close $log;
-       print commit_log_separator unless $incremental || $oneline;
-}
-
-sub cmd_blame {
-       my $path = pop;
-
-       config_pager();
-       run_pager();
-
-       my ($fh, $ctx, $rev);
-
-       if ($_git_format) {
-               ($fh, $ctx) = command_output_pipe('blame', @_, $path);
-               while (my $line = <$fh>) {
-                       if ($line =~ /^\^?([[:xdigit:]]+)\s/) {
-                               # Uncommitted edits show up as a rev ID of
-                               # all zeros, which we can't look up with
-                               # cmt_metadata
-                               if ($1 !~ /^0+$/) {
-                                       (undef, $rev, undef) =
-                                               ::cmt_metadata($1);
-                                       $rev = '0' if (!$rev);
-                               } else {
-                                       $rev = '0';
-                               }
-                               $rev = sprintf('%-10s', $rev);
-                               $line =~ s/^\^?[[:xdigit:]]+(\s)/$rev$1/;
-                       }
-                       print $line;
-               }
-       } else {
-               ($fh, $ctx) = command_output_pipe('blame', '-p', @_, 'HEAD',
-                                                 '--', $path);
-               my ($sha1);
-               my %authors;
-               my @buffer;
-               my %dsha; #distinct sha keys
-
-               while (my $line = <$fh>) {
-                       push @buffer, $line;
-                       if ($line =~ /^([[:xdigit:]]{40})\s\d+\s\d+/) {
-                               $dsha{$1} = 1;
-                       }
-               }
-
-               my $s2r = ::cmt_sha2rev_batch([keys %dsha]);
-
-               foreach my $line (@buffer) {
-                       if ($line =~ /^([[:xdigit:]]{40})\s\d+\s\d+/) {
-                               $rev = $s2r->{$1};
-                               $rev = '0' if (!$rev)
-                       }
-                       elsif ($line =~ /^author (.*)/) {
-                               $authors{$rev} = $1;
-                               $authors{$rev} =~ s/\s/_/g;
-                       }
-                       elsif ($line =~ /^\t(.*)$/) {
-                               printf("%6s %10s %s\n", $rev, $authors{$rev}, $1);
-                       }
-               }
-       }
-       command_close_pipe($fh, $ctx);
-}
-
 package Git::SVN::Migration;
 # these version numbers do NOT correspond to actual version numbers
 # of git nor git-svn.  They are just relative.
diff --git a/perl/Git/SVN/Log.pm b/perl/Git/SVN/Log.pm
new file mode 100644 (file)
index 0000000..3cc1c6f
--- /dev/null
@@ -0,0 +1,395 @@
+package Git::SVN::Log;
+use strict;
+use warnings;
+use Git::SVN::Utils qw(fatal);
+use Git qw(command command_oneline command_output_pipe command_close_pipe);
+use POSIX qw/strftime/;
+use constant commit_log_separator => ('-' x 72) . "\n";
+use vars qw/$TZ $limit $color $pager $non_recursive $verbose $oneline
+            %rusers $show_commit $incremental/;
+
+# Option set in git-svn
+our $_git_format;
+
+sub cmt_showable {
+       my ($c) = @_;
+       return 1 if defined $c->{r};
+
+       # big commit message got truncated by the 16k pretty buffer in rev-list
+       if ($c->{l} && $c->{l}->[-1] eq "...\n" &&
+                               $c->{a_raw} =~ /\@([a-f\d\-]+)>$/) {
+               @{$c->{l}} = ();
+               my @log = command(qw/cat-file commit/, $c->{c});
+
+               # shift off the headers
+               shift @log while ($log[0] ne '');
+               shift @log;
+
+               # TODO: make $c->{l} not have a trailing newline in the future
+               @{$c->{l}} = map { "$_\n" } grep !/^git-svn-id: /, @log;
+
+               (undef, $c->{r}, undef) = ::extract_metadata(
+                               (grep(/^git-svn-id: /, @log))[-1]);
+       }
+       return defined $c->{r};
+}
+
+sub log_use_color {
+       return $color || Git->repository->get_colorbool('color.diff');
+}
+
+sub git_svn_log_cmd {
+       my ($r_min, $r_max, @args) = @_;
+       my $head = 'HEAD';
+       my (@files, @log_opts);
+       foreach my $x (@args) {
+               if ($x eq '--' || @files) {
+                       push @files, $x;
+               } else {
+                       if (::verify_ref("$x^0")) {
+                               $head = $x;
+                       } else {
+                               push @log_opts, $x;
+                       }
+               }
+       }
+
+       my ($url, $rev, $uuid, $gs) = ::working_head_info($head);
+
+       require Git::SVN;
+       $gs ||= Git::SVN->_new;
+       my @cmd = (qw/log --abbrev-commit --pretty=raw --default/,
+                  $gs->refname);
+       push @cmd, '-r' unless $non_recursive;
+       push @cmd, qw/--raw --name-status/ if $verbose;
+       push @cmd, '--color' if log_use_color();
+       push @cmd, @log_opts;
+       if (defined $r_max && $r_max == $r_min) {
+               push @cmd, '--max-count=1';
+               if (my $c = $gs->rev_map_get($r_max)) {
+                       push @cmd, $c;
+               }
+       } elsif (defined $r_max) {
+               if ($r_max < $r_min) {
+                       ($r_min, $r_max) = ($r_max, $r_min);
+               }
+               my (undef, $c_max) = $gs->find_rev_before($r_max, 1, $r_min);
+               my (undef, $c_min) = $gs->find_rev_after($r_min, 1, $r_max);
+               # If there are no commits in the range, both $c_max and $c_min
+               # will be undefined.  If there is at least 1 commit in the
+               # range, both will be defined.
+               return () if !defined $c_min || !defined $c_max;
+               if ($c_min eq $c_max) {
+                       push @cmd, '--max-count=1', $c_min;
+               } else {
+                       push @cmd, '--boundary', "$c_min..$c_max";
+               }
+       }
+       return (@cmd, @files);
+}
+
+# adapted from pager.c
+sub config_pager {
+       if (! -t *STDOUT) {
+               $ENV{GIT_PAGER_IN_USE} = 'false';
+               $pager = undef;
+               return;
+       }
+       chomp($pager = command_oneline(qw(var GIT_PAGER)));
+       if ($pager eq 'cat') {
+               $pager = undef;
+       }
+       $ENV{GIT_PAGER_IN_USE} = defined($pager);
+}
+
+sub run_pager {
+       return unless defined $pager;
+       pipe my ($rfd, $wfd) or return;
+       defined(my $pid = fork) or fatal "Can't fork: $!";
+       if (!$pid) {
+               open STDOUT, '>&', $wfd or
+                                    fatal "Can't redirect to stdout: $!";
+               return;
+       }
+       open STDIN, '<&', $rfd or fatal "Can't redirect stdin: $!";
+       $ENV{LESS} ||= 'FRSX';
+       exec $pager or fatal "Can't run pager: $! ($pager)";
+}
+
+sub format_svn_date {
+       my $t = shift || time;
+       require Git::SVN;
+       my $gmoff = Git::SVN::get_tz($t);
+       return strftime("%Y-%m-%d %H:%M:%S $gmoff (%a, %d %b %Y)", localtime($t));
+}
+
+sub parse_git_date {
+       my ($t, $tz) = @_;
+       # Date::Parse isn't in the standard Perl distro :(
+       if ($tz =~ s/^\+//) {
+               $t += tz_to_s_offset($tz);
+       } elsif ($tz =~ s/^\-//) {
+               $t -= tz_to_s_offset($tz);
+       }
+       return $t;
+}
+
+sub set_local_timezone {
+       if (defined $TZ) {
+               $ENV{TZ} = $TZ;
+       } else {
+               delete $ENV{TZ};
+       }
+}
+
+sub tz_to_s_offset {
+       my ($tz) = @_;
+       $tz =~ s/(\d\d)$//;
+       return ($1 * 60) + ($tz * 3600);
+}
+
+sub get_author_info {
+       my ($dest, $author, $t, $tz) = @_;
+       $author =~ s/(?:^\s*|\s*$)//g;
+       $dest->{a_raw} = $author;
+       my $au;
+       if ($::_authors) {
+               $au = $rusers{$author} || undef;
+       }
+       if (!$au) {
+               ($au) = ($author =~ /<([^>]+)\@[^>]+>$/);
+       }
+       $dest->{t} = $t;
+       $dest->{tz} = $tz;
+       $dest->{a} = $au;
+       $dest->{t_utc} = parse_git_date($t, $tz);
+}
+
+sub process_commit {
+       my ($c, $r_min, $r_max, $defer) = @_;
+       if (defined $r_min && defined $r_max) {
+               if ($r_min == $c->{r} && $r_min == $r_max) {
+                       show_commit($c);
+                       return 0;
+               }
+               return 1 if $r_min == $r_max;
+               if ($r_min < $r_max) {
+                       # we need to reverse the print order
+                       return 0 if (defined $limit && --$limit < 0);
+                       push @$defer, $c;
+                       return 1;
+               }
+               if ($r_min != $r_max) {
+                       return 1 if ($r_min < $c->{r});
+                       return 1 if ($r_max > $c->{r});
+               }
+       }
+       return 0 if (defined $limit && --$limit < 0);
+       show_commit($c);
+       return 1;
+}
+
+my $l_fmt;
+sub show_commit {
+       my $c = shift;
+       if ($oneline) {
+               my $x = "\n";
+               if (my $l = $c->{l}) {
+                       while ($l->[0] =~ /^\s*$/) { shift @$l }
+                       $x = $l->[0];
+               }
+               $l_fmt ||= 'A' . length($c->{r});
+               print 'r',pack($l_fmt, $c->{r}),' | ';
+               print "$c->{c} | " if $show_commit;
+               print $x;
+       } else {
+               show_commit_normal($c);
+       }
+}
+
+sub show_commit_changed_paths {
+       my ($c) = @_;
+       return unless $c->{changed};
+       print "Changed paths:\n", @{$c->{changed}};
+}
+
+sub show_commit_normal {
+       my ($c) = @_;
+       print commit_log_separator, "r$c->{r} | ";
+       print "$c->{c} | " if $show_commit;
+       print "$c->{a} | ", format_svn_date($c->{t_utc}), ' | ';
+       my $nr_line = 0;
+
+       if (my $l = $c->{l}) {
+               while ($l->[$#$l] eq "\n" && $#$l > 0
+                                         && $l->[($#$l - 1)] eq "\n") {
+                       pop @$l;
+               }
+               $nr_line = scalar @$l;
+               if (!$nr_line) {
+                       print "1 line\n\n\n";
+               } else {
+                       if ($nr_line == 1) {
+                               $nr_line = '1 line';
+                       } else {
+                               $nr_line .= ' lines';
+                       }
+                       print $nr_line, "\n";
+                       show_commit_changed_paths($c);
+                       print "\n";
+                       print $_ foreach @$l;
+               }
+       } else {
+               print "1 line\n";
+               show_commit_changed_paths($c);
+               print "\n";
+
+       }
+       foreach my $x (qw/raw stat diff/) {
+               if ($c->{$x}) {
+                       print "\n";
+                       print $_ foreach @{$c->{$x}}
+               }
+       }
+}
+
+sub cmd_show_log {
+       my (@args) = @_;
+       my ($r_min, $r_max);
+       my $r_last = -1; # prevent dupes
+       set_local_timezone();
+       if (defined $::_revision) {
+               if ($::_revision =~ /^(\d+):(\d+)$/) {
+                       ($r_min, $r_max) = ($1, $2);
+               } elsif ($::_revision =~ /^\d+$/) {
+                       $r_min = $r_max = $::_revision;
+               } else {
+                       fatal "-r$::_revision is not supported, use ",
+                               "standard 'git log' arguments instead";
+               }
+       }
+
+       config_pager();
+       @args = git_svn_log_cmd($r_min, $r_max, @args);
+       if (!@args) {
+               print commit_log_separator unless $incremental || $oneline;
+               return;
+       }
+       my $log = command_output_pipe(@args);
+       run_pager();
+       my (@k, $c, $d, $stat);
+       my $esc_color = qr/(?:\033\[(?:(?:\d+;)*\d*)?m)*/;
+       while (<$log>) {
+               if (/^${esc_color}commit (?:- )?($::sha1_short)/o) {
+                       my $cmt = $1;
+                       if ($c && cmt_showable($c) && $c->{r} != $r_last) {
+                               $r_last = $c->{r};
+                               process_commit($c, $r_min, $r_max, \@k) or
+                                                               goto out;
+                       }
+                       $d = undef;
+                       $c = { c => $cmt };
+               } elsif (/^${esc_color}author (.+) (\d+) ([\-\+]?\d+)$/o) {
+                       get_author_info($c, $1, $2, $3);
+               } elsif (/^${esc_color}(?:tree|parent|committer) /o) {
+                       # ignore
+               } elsif (/^${esc_color}:\d{6} \d{6} $::sha1_short/o) {
+                       push @{$c->{raw}}, $_;
+               } elsif (/^${esc_color}[ACRMDT]\t/) {
+                       # we could add $SVN->{svn_path} here, but that requires
+                       # remote access at the moment (repo_path_split)...
+                       s#^(${esc_color})([ACRMDT])\t#$1   $2 #o;
+                       push @{$c->{changed}}, $_;
+               } elsif (/^${esc_color}diff /o) {
+                       $d = 1;
+                       push @{$c->{diff}}, $_;
+               } elsif ($d) {
+                       push @{$c->{diff}}, $_;
+               } elsif (/^\ .+\ \|\s*\d+\ $esc_color[\+\-]*
+                         $esc_color*[\+\-]*$esc_color$/x) {
+                       $stat = 1;
+                       push @{$c->{stat}}, $_;
+               } elsif ($stat && /^ \d+ files changed, \d+ insertions/) {
+                       push @{$c->{stat}}, $_;
+                       $stat = undef;
+               } elsif (/^${esc_color}    (git-svn-id:.+)$/o) {
+                       ($c->{url}, $c->{r}, undef) = ::extract_metadata($1);
+               } elsif (s/^${esc_color}    //o) {
+                       push @{$c->{l}}, $_;
+               }
+       }
+       if ($c && defined $c->{r} && $c->{r} != $r_last) {
+               $r_last = $c->{r};
+               process_commit($c, $r_min, $r_max, \@k);
+       }
+       if (@k) {
+               ($r_min, $r_max) = ($r_max, $r_min);
+               process_commit($_, $r_min, $r_max) foreach reverse @k;
+       }
+out:
+       close $log;
+       print commit_log_separator unless $incremental || $oneline;
+}
+
+sub cmd_blame {
+       my $path = pop;
+
+       config_pager();
+       run_pager();
+
+       my ($fh, $ctx, $rev);
+
+       if ($_git_format) {
+               ($fh, $ctx) = command_output_pipe('blame', @_, $path);
+               while (my $line = <$fh>) {
+                       if ($line =~ /^\^?([[:xdigit:]]+)\s/) {
+                               # Uncommitted edits show up as a rev ID of
+                               # all zeros, which we can't look up with
+                               # cmt_metadata
+                               if ($1 !~ /^0+$/) {
+                                       (undef, $rev, undef) =
+                                               ::cmt_metadata($1);
+                                       $rev = '0' if (!$rev);
+                               } else {
+                                       $rev = '0';
+                               }
+                               $rev = sprintf('%-10s', $rev);
+                               $line =~ s/^\^?[[:xdigit:]]+(\s)/$rev$1/;
+                       }
+                       print $line;
+               }
+       } else {
+               ($fh, $ctx) = command_output_pipe('blame', '-p', @_, 'HEAD',
+                                                 '--', $path);
+               my ($sha1);
+               my %authors;
+               my @buffer;
+               my %dsha; #distinct sha keys
+
+               while (my $line = <$fh>) {
+                       push @buffer, $line;
+                       if ($line =~ /^([[:xdigit:]]{40})\s\d+\s\d+/) {
+                               $dsha{$1} = 1;
+                       }
+               }
+
+               my $s2r = ::cmt_sha2rev_batch([keys %dsha]);
+
+               foreach my $line (@buffer) {
+                       if ($line =~ /^([[:xdigit:]]{40})\s\d+\s\d+/) {
+                               $rev = $s2r->{$1};
+                               $rev = '0' if (!$rev)
+                       }
+                       elsif ($line =~ /^author (.*)/) {
+                               $authors{$rev} = $1;
+                               $authors{$rev} =~ s/\s/_/g;
+                       }
+                       elsif ($line =~ /^\t(.*)$/) {
+                               printf("%6s %10s %s\n", $rev, $authors{$rev}, $1);
+                       }
+               }
+       }
+       command_close_pipe($fh, $ctx);
+}
+
+1;
index a628582bcae7205121725b29b5e71353204a93a5..4869a37d0ec3836925b9674905865a17e3e8033d 100644 (file)
@@ -33,6 +33,7 @@ modules += Git/SVN
 modules += Git/SVN/Memoize/YAML
 modules += Git/SVN/Fetcher
 modules += Git/SVN/Editor
+modules += Git/SVN/Log
 modules += Git/SVN/Prompt
 modules += Git/SVN/Ra
 modules += Git/SVN/Utils
index 97475d920c27933d25fb9415fec73edbadf7f2b1..37626f4284a9e326ea2716e56e1c1296d3e1ddfe 100644 (file)
@@ -3,7 +3,9 @@
 use strict;
 use warnings;
 
-use Test::More tests => 2;
+use Test::More tests => 4;
 
-require_ok 'Git::SVN::Utils';
 require_ok 'Git::SVN';
+require_ok 'Git::SVN::Utils';
+require_ok 'Git::SVN::Ra';
+require_ok 'Git::SVN::Log';