1package Git::SVN::Log;
2use strict;
3use warnings;
4use Git::SVN::Utils qw(fatal);
5use Git qw(command
6 command_oneline
7 command_output_pipe
8 command_close_pipe
9 get_tz_offset);
10use POSIX qw/strftime/;
11use constant commit_log_separator => ('-' x 72) . "\n";
12use vars qw/$TZ $limit $color $pager $non_recursive $verbose $oneline
13 %rusers $show_commit $incremental/;
14# Option set in git-svn
16our $_git_format;
17sub cmt_showable {
19 my ($c) = @_;
20 return 1 if defined $c->{r};
21 # big commit message got truncated by the 16k pretty buffer in rev-list
23 if ($c->{l} && $c->{l}->[-1] eq "...\n" &&
24 $c->{a_raw} =~ /\@([a-f\d\-]+)>$/) {
25 @{$c->{l}} = ();
26 my @log = command(qw/cat-file commit/, $c->{c});
27 # shift off the headers
29 shift @log while ($log[0] ne '');
30 shift @log;
31 # TODO: make $c->{l} not have a trailing newline in the future
33 @{$c->{l}} = map { "$_\n" } grep !/^git-svn-id: /, @log;
34 (undef, $c->{r}, undef) = ::extract_metadata(
36 (grep(/^git-svn-id: /, @log))[-1]);
37 }
38 return defined $c->{r};
39}
40sub log_use_color {
42 return $color || Git->repository->get_colorbool('color.diff');
43}
44sub git_svn_log_cmd {
46 my ($r_min, $r_max, @args) = @_;
47 my $head = 'HEAD';
48 my (@files, @log_opts);
49 foreach my $x (@args) {
50 if ($x eq '--' || @files) {
51 push @files, $x;
52 } else {
53 if (::verify_ref("$x^0")) {
54 $head = $x;
55 } else {
56 push @log_opts, $x;
57 }
58 }
59 }
60 my ($url, $rev, $uuid, $gs) = ::working_head_info($head);
62 require Git::SVN;
64 $gs ||= Git::SVN->_new;
65 my @cmd = (qw/log --abbrev-commit --pretty=raw --default/,
66 $gs->refname);
67 push @cmd, '-r' unless $non_recursive;
68 push @cmd, qw/--raw --name-status/ if $verbose;
69 push @cmd, '--color' if log_use_color();
70 push @cmd, @log_opts;
71 if (defined $r_max && $r_max == $r_min) {
72 push @cmd, '--max-count=1';
73 if (my $c = $gs->rev_map_get($r_max)) {
74 push @cmd, $c;
75 }
76 } elsif (defined $r_max) {
77 if ($r_max < $r_min) {
78 ($r_min, $r_max) = ($r_max, $r_min);
79 }
80 my (undef, $c_max) = $gs->find_rev_before($r_max, 1, $r_min);
81 my (undef, $c_min) = $gs->find_rev_after($r_min, 1, $r_max);
82 # If there are no commits in the range, both $c_max and $c_min
83 # will be undefined. If there is at least 1 commit in the
84 # range, both will be defined.
85 return () if !defined $c_min || !defined $c_max;
86 if ($c_min eq $c_max) {
87 push @cmd, '--max-count=1', $c_min;
88 } else {
89 push @cmd, '--boundary', "$c_min..$c_max";
90 }
91 }
92 return (@cmd, @files);
93}
94# adapted from pager.c
96sub config_pager {
97 if (! -t *STDOUT) {
98 $ENV{GIT_PAGER_IN_USE} = 'false';
99 $pager = undef;
100 return;
101 }
102 chomp($pager = command_oneline(qw(var GIT_PAGER)));
103 if ($pager eq 'cat') {
104 $pager = undef;
105 }
106 $ENV{GIT_PAGER_IN_USE} = defined($pager);
107}
108sub run_pager {
110 return unless defined $pager;
111 pipe my ($rfd, $wfd) or return;
112 defined(my $pid = fork) or fatal "Can't fork: $!";
113 if (!$pid) {
114 open STDOUT, '>&', $wfd or
115 fatal "Can't redirect to stdout: $!";
116 return;
117 }
118 open STDIN, '<&', $rfd or fatal "Can't redirect stdin: $!";
119 $ENV{LESS} ||= 'FRX';
120 $ENV{LV} ||= '-c';
121 exec $pager or fatal "Can't run pager: $! ($pager)";
122}
123sub format_svn_date {
125 my $t = shift || time;
126 require Git::SVN;
127 my $gmoff = get_tz_offset($t);
128 return strftime("%Y-%m-%d %H:%M:%S $gmoff (%a, %d %b %Y)", localtime($t));
129}
130sub parse_git_date {
132 my ($t, $tz) = @_;
133 # Date::Parse isn't in the standard Perl distro :(
134 if ($tz =~ s/^\+//) {
135 $t += tz_to_s_offset($tz);
136 } elsif ($tz =~ s/^\-//) {
137 $t -= tz_to_s_offset($tz);
138 }
139 return $t;
140}
141sub set_local_timezone {
143 if (defined $TZ) {
144 $ENV{TZ} = $TZ;
145 } else {
146 delete $ENV{TZ};
147 }
148}
149sub tz_to_s_offset {
151 my ($tz) = @_;
152 $tz =~ s/(\d\d)$//;
153 return ($1 * 60) + ($tz * 3600);
154}
155sub get_author_info {
157 my ($dest, $author, $t, $tz) = @_;
158 $author =~ s/(?:^\s*|\s*$)//g;
159 $dest->{a_raw} = $author;
160 my $au;
161 if ($::_authors) {
162 $au = $rusers{$author} || undef;
163 }
164 if (!$au) {
165 ($au) = ($author =~ /<([^>]+)\@[^>]+>$/);
166 }
167 $dest->{t} = $t;
168 $dest->{tz} = $tz;
169 $dest->{a} = $au;
170 $dest->{t_utc} = parse_git_date($t, $tz);
171}
172sub process_commit {
174 my ($c, $r_min, $r_max, $defer) = @_;
175 if (defined $r_min && defined $r_max) {
176 if ($r_min == $c->{r} && $r_min == $r_max) {
177 show_commit($c);
178 return 0;
179 }
180 return 1 if $r_min == $r_max;
181 if ($r_min < $r_max) {
182 # we need to reverse the print order
183 return 0 if (defined $limit && --$limit < 0);
184 push @$defer, $c;
185 return 1;
186 }
187 if ($r_min != $r_max) {
188 return 1 if ($r_min < $c->{r});
189 return 1 if ($r_max > $c->{r});
190 }
191 }
192 return 0 if (defined $limit && --$limit < 0);
193 show_commit($c);
194 return 1;
195}
196my $l_fmt;
198sub show_commit {
199 my $c = shift;
200 if ($oneline) {
201 my $x = "\n";
202 if (my $l = $c->{l}) {
203 while ($l->[0] =~ /^\s*$/) { shift @$l }
204 $x = $l->[0];
205 }
206 $l_fmt ||= 'A' . length($c->{r});
207 print 'r',pack($l_fmt, $c->{r}),' | ';
208 print "$c->{c} | " if $show_commit;
209 print $x;
210 } else {
211 show_commit_normal($c);
212 }
213}
214sub show_commit_changed_paths {
216 my ($c) = @_;
217 return unless $c->{changed};
218 print "Changed paths:\n", @{$c->{changed}};
219}
220sub show_commit_normal {
222 my ($c) = @_;
223 print commit_log_separator, "r$c->{r} | ";
224 print "$c->{c} | " if $show_commit;
225 print "$c->{a} | ", format_svn_date($c->{t_utc}), ' | ';
226 my $nr_line = 0;
227 if (my $l = $c->{l}) {
229 while ($l->[$#$l] eq "\n" && $#$l > 0
230 && $l->[($#$l - 1)] eq "\n") {
231 pop @$l;
232 }
233 $nr_line = scalar @$l;
234 if (!$nr_line) {
235 print "1 line\n\n\n";
236 } else {
237 if ($nr_line == 1) {
238 $nr_line = '1 line';
239 } else {
240 $nr_line .= ' lines';
241 }
242 print $nr_line, "\n";
243 show_commit_changed_paths($c);
244 print "\n";
245 print $_ foreach @$l;
246 }
247 } else {
248 print "1 line\n";
249 show_commit_changed_paths($c);
250 print "\n";
251 }
253 foreach my $x (qw/raw stat diff/) {
254 if ($c->{$x}) {
255 print "\n";
256 print $_ foreach @{$c->{$x}}
257 }
258 }
259}
260sub cmd_show_log {
262 my (@args) = @_;
263 my ($r_min, $r_max);
264 my $r_last = -1; # prevent dupes
265 set_local_timezone();
266 if (defined $::_revision) {
267 if ($::_revision =~ /^(\d+):(\d+)$/) {
268 ($r_min, $r_max) = ($1, $2);
269 } elsif ($::_revision =~ /^\d+$/) {
270 $r_min = $r_max = $::_revision;
271 } else {
272 fatal "-r$::_revision is not supported, use ",
273 "standard 'git log' arguments instead";
274 }
275 }
276 config_pager();
278 @args = git_svn_log_cmd($r_min, $r_max, @args);
279 if (!@args) {
280 print commit_log_separator unless $incremental || $oneline;
281 return;
282 }
283 my $log = command_output_pipe(@args);
284 run_pager();
285 my (@k, $c, $d, $stat);
286 my $esc_color = qr/(?:\033\[(?:(?:\d+;)*\d*)?m)*/;
287 while (<$log>) {
288 if (/^${esc_color}commit (?:- )?($::sha1_short)/o) {
289 my $cmt = $1;
290 if ($c && cmt_showable($c) && $c->{r} != $r_last) {
291 $r_last = $c->{r};
292 process_commit($c, $r_min, $r_max, \@k) or
293 goto out;
294 }
295 $d = undef;
296 $c = { c => $cmt };
297 } elsif (/^${esc_color}author (.+) (\d+) ([\-\+]?\d+)$/o) {
298 get_author_info($c, $1, $2, $3);
299 } elsif (/^${esc_color}(?:tree|parent|committer) /o) {
300 # ignore
301 } elsif (/^${esc_color}:\d{6} \d{6} $::sha1_short/o) {
302 push @{$c->{raw}}, $_;
303 } elsif (/^${esc_color}[ACRMDT]\t/) {
304 # we could add $SVN->{svn_path} here, but that requires
305 # remote access at the moment (repo_path_split)...
306 s#^(${esc_color})([ACRMDT])\t#$1 $2 #o;
307 push @{$c->{changed}}, $_;
308 } elsif (/^${esc_color}diff /o) {
309 $d = 1;
310 push @{$c->{diff}}, $_;
311 } elsif ($d) {
312 push @{$c->{diff}}, $_;
313 } elsif (/^\ .+\ \|\s*\d+\ $esc_color[\+\-]*
314 $esc_color*[\+\-]*$esc_color$/x) {
315 $stat = 1;
316 push @{$c->{stat}}, $_;
317 } elsif ($stat && /^ \d+ files changed, \d+ insertions/) {
318 push @{$c->{stat}}, $_;
319 $stat = undef;
320 } elsif (/^${esc_color} (git-svn-id:.+)$/o) {
321 ($c->{url}, $c->{r}, undef) = ::extract_metadata($1);
322 } elsif (s/^${esc_color} //o) {
323 push @{$c->{l}}, $_;
324 }
325 }
326 if ($c && defined $c->{r} && $c->{r} != $r_last) {
327 $r_last = $c->{r};
328 process_commit($c, $r_min, $r_max, \@k);
329 }
330 if (@k) {
331 ($r_min, $r_max) = ($r_max, $r_min);
332 process_commit($_, $r_min, $r_max) foreach reverse @k;
333 }
334out:
335 close $log;
336 print commit_log_separator unless $incremental || $oneline;
337}
338sub cmd_blame {
340 my $path = pop;
341 config_pager();
343 run_pager();
344 my ($fh, $ctx, $rev);
346 if ($_git_format) {
348 ($fh, $ctx) = command_output_pipe('blame', @_, $path);
349 while (my $line = <$fh>) {
350 if ($line =~ /^\^?([[:xdigit:]]+)\s/) {
351 # Uncommitted edits show up as a rev ID of
352 # all zeros, which we can't look up with
353 # cmt_metadata
354 if ($1 !~ /^0+$/) {
355 (undef, $rev, undef) =
356 ::cmt_metadata($1);
357 $rev = '0' if (!$rev);
358 } else {
359 $rev = '0';
360 }
361 $rev = sprintf('%-10s', $rev);
362 $line =~ s/^\^?[[:xdigit:]]+(\s)/$rev$1/;
363 }
364 print $line;
365 }
366 } else {
367 ($fh, $ctx) = command_output_pipe('blame', '-p', @_, 'HEAD',
368 '--', $path);
369 my ($sha1);
370 my %authors;
371 my @buffer;
372 my %dsha; #distinct sha keys
373 while (my $line = <$fh>) {
375 push @buffer, $line;
376 if ($line =~ /^([[:xdigit:]]{40})\s\d+\s\d+/) {
377 $dsha{$1} = 1;
378 }
379 }
380 my $s2r = ::cmt_sha2rev_batch([keys %dsha]);
382 foreach my $line (@buffer) {
384 if ($line =~ /^([[:xdigit:]]{40})\s\d+\s\d+/) {
385 $rev = $s2r->{$1};
386 $rev = '0' if (!$rev)
387 }
388 elsif ($line =~ /^author (.*)/) {
389 $authors{$rev} = $1;
390 $authors{$rev} =~ s/\s/_/g;
391 }
392 elsif ($line =~ /^\t(.*)$/) {
393 printf("%6s %10s %s\n", $rev, $authors{$rev}, $1);
394 }
395 }
396 }
397 command_close_pipe($fh, $ctx);
398}
3991;