1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
| | # Copyright (C) 2015-2018 all contributors <meta@public-inbox.org>
# License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
use strict;
use warnings;
use Test::More;
use File::Temp qw/tempdir/;
my $dir = tempdir('pi-git-XXXXXX', TMPDIR => 1, CLEANUP => 1);
use Cwd qw/getcwd/;
use_ok 'PublicInbox::Git';
{
is(system(qw(git init -q --bare), $dir), 0, 'created git directory');
my @cmd = ('git', "--git-dir=$dir", 'fast-import', '--quiet');
my $fi_data = getcwd().'/t/git.fast-import-data';
ok(-r $fi_data, "fast-import data readable (or run test at top level)");
my $pid = fork;
defined $pid or die "fork failed: $!\n";
if ($pid == 0) {
open STDIN, '<', $fi_data or die "open $fi_data: $!\n";
exec @cmd;
die "failed exec: ",join(' ', @cmd),": $!\n";
}
waitpid $pid, 0;
is($?, 0, 'fast-import succeeded');
}
{
my $gcf = PublicInbox::Git->new($dir);
my $f = 'HEAD:foo.txt';
my @x = $gcf->check($f);
is(scalar @x, 3, 'returned 3 element array for existing file');
like($x[0], qr/\A[a-f0-9]{40}\z/, 'returns obj ID in 1st element');
is('blob', $x[1], 'returns obj type in 2nd element');
like($x[2], qr/\A\d+\z/, 'returns obj size in 3rd element');
my $raw = $gcf->cat_file($f);
is($x[2], length($$raw), 'length matches');
{
my $size;
my $rv = $gcf->cat_file($f, sub {
my ($in, $left) = @_;
$size = $$left;
'nothing'
});
is($rv, 'nothing', 'returned from callback without reading');
is($size, $x[2], 'set size for callback correctly');
}
eval { $gcf->cat_file($f, sub { die 'OMG' }) };
like($@, qr/\bOMG\b/, 'died in callback propagated');
is(${$gcf->cat_file($f)}, $$raw, 'not broken after failures');
{
my ($buf, $r);
my $rv = $gcf->cat_file($f, sub {
my ($in, $left) = @_;
$r = read($in, $buf, 2);
$$left -= $r;
'blah'
});
is($r, 2, 'only read 2 bytes');
is($buf, '--', 'partial read succeeded');
is($rv, 'blah', 'return value propagated');
}
is(${$gcf->cat_file($f)}, $$raw, 'not broken after partial read');
}
if (1) {
use POSIX qw(dup2);
my @cmd = ('git', "--git-dir=$dir", qw(hash-object -w --stdin));
# need a big file, use the AGPL-3.0 :p
my $big_data = getcwd().'/COPYING';
ok(-r $big_data, 'COPYING readable');
my $size = -s $big_data;
ok($size > 8192, 'file is big enough');
my ($r, $w);
ok(pipe($r, $w), 'created pipe');
my $pid = fork;
defined $pid or die "fork failed: $!\n";
if ($pid == 0) {
close $r;
open STDIN, '<', $big_data or die "open $big_data: $!\n";
dup2(fileno($w), 1);
exec @cmd;
die "failed exec: ",join(' ', @cmd),": $!\n";
}
close $w;
my $n = read $r, my $buf, 41;
waitpid $pid, 0;
is(0, $?, 'hashed object successfully');
chomp $buf;
my $gcf = PublicInbox::Git->new($dir);
my $rsize;
is($gcf->cat_file($buf, sub {
$rsize = ${$_[1]};
'x';
}), 'x', 'checked input');
is($rsize, $size, 'got correct size on big file');
my $x = $gcf->cat_file($buf, \$rsize);
is($rsize, $size, 'got correct size ref on big file');
is(length($$x), $size, 'read correct number of bytes');
my $rline;
$gcf->cat_file($buf, sub {
my ($in, $left) = @_;
$rline = <$in>;
$$left -= length($rline);
});
{
open my $fh, '<', $big_data or die "open failed: $!\n";
is($rline, <$fh>, 'first line matches');
};
my $all;
$gcf->cat_file($buf, sub {
my ($in, $left) = @_;
my $x = read($in, $all, $$left);
$$left -= $x;
});
{
open my $fh, '<', $big_data or die "open failed: $!\n";
local $/;
is($all, <$fh>, 'entire read matches');
};
my $ref = $gcf->qx(qw(cat-file blob), $buf);
is($all, $ref, 'qx read giant single string');
my @ref = $gcf->qx(qw(cat-file blob), $buf);
is($all, join('', @ref), 'qx returned array when wanted');
my $nl = scalar @ref;
ok($nl > 1, "qx returned array length of $nl");
}
done_testing();
|