clone|--mirror: support --epoch=RANGE for partial clones

[public-inbox.git] / t / v2mirror.t

diff --git a/t/v2mirror.t b/t/v2mirror.t
index 8bcffc29265a81cde1037e59f211b3b760726dc0..20a8daaa32d33fb9d657ae87caa35db84cb8c214 100644 (file)
--- a/t/v2mirror.t
+++ b/t/v2mirror.t
@@ -3,7 +3,7 @@
 use strict;
 use v5.10.1;
 use PublicInbox::TestCommon;
-use File::Path qw(remove_tree);
+use File::Path qw(remove_tree make_path);
 use Cwd qw(abs_path);
 require_git(2.6);
 require_cmd('curl');
@@ -98,8 +98,9 @@ $ibx->cleanup;
 my @new_epochs;
 my $fetch_each_epoch = sub {
        my %before = map { $_ => 1 } glob("$tmpdir/m/git/*");
-       run_script([qw(-fetch -q)], undef, {-C => "$tmpdir/m"}) or
+       run_script([qw(-fetch --exit-code -q)], undef, {-C => "$tmpdir/m"}) or
                xbail '-fetch fail';
+       is($?, 0, '--exit-code 0 after fetch updated');
        my @after = grep { !$before{$_} } glob("$tmpdir/m/git/*");
        push @new_epochs, @after;
 };
@@ -228,10 +229,66 @@ EOF
        is(scalar($mset->items), 0, 'large message not re-indexed');
 }
 ok(scalar(@new_epochs), 'new epochs were created and fetched');
+for my $d (@new_epochs) {
+       is(xqx(['git', "--git-dir=$d", 'config', qw(include.path)]),
+               "../../all.git/config\n",
+               'include.path set');
+}
+
+if ('test read-only epoch dirs') {
+       my @git = ('git', "--git-dir=$new_epochs[0]");
+       my $get_objs = [@git,
+               qw(cat-file --buffer --batch-check --batch-all-objects)];
+       my $before = [sort xqx($get_objs)];
+
+       remove_tree(map { "$new_epochs[0]/$_" } qw(objects refs/heads));
+       chmod(0555, $new_epochs[0]) or xbail "chmod: $!";
+
+       # force a refetch
+       unlink("$tmpdir/m/manifest.js.gz") or xbail "unlink: $!";
+
+       run_script([qw(-fetch -q)], undef, {-C => "$tmpdir/m"}) or
+               xbail '-fetch failed';
+
+       ok(!-d "$new_epochs[0]/objects", 'no objects after fetch to R/O dir');
+
+       chmod(0755, $new_epochs[0]) or xbail "chmod: $!";
+       mkdir("$new_epochs[0]/objects") or xbail "mkdir: $!";
+       mkdir("$new_epochs[0]/refs/heads") or xbail "mkdir: $!";
+
+       my $err = '';
+       run_script([qw(-fetch -q)], undef, {-C => "$tmpdir/m", 2 => \$err}) or
+               xbail '-fetch failed '.$err;
+       is_deeply([ sort xqx($get_objs) ], $before,
+               'fetch restored objects once GIT_DIR became writable');
+}
+
+{
+       my $dst = "$tmpdir/partial";
+       run_script([qw(-clone -q --epoch=~0), "http://$host:$port/v2/", $dst]);
+       is($?, 0, 'no error from partial clone');
+       my @g = glob("$dst/git/*.git");
+       my @w = grep { -w $_ } @g;
+       my @r = grep { ! -w $_ } @g;
+       is(scalar(@w), 1, 'one writable directory');
+       my ($w) = ($w[0] =~ m!/([0-9]+)\.git\z!);
+       is((grep {
+               m!/([0-9]+)\.git\z! or xbail "no digit in $_";
+               $w > ($1 + 0)
+       } @r), scalar(@r), 'writable epoch # exceeds read-only ones');
+       run_script([qw(-fetch -q)], undef, { -C => $dst });
+       is($?, 0, 'no error from partial fetch');
+       remove_tree($dst);
+
+       run_script([qw(-clone -q --epoch=~1..),
+                       "http://$host:$port/v2/", $dst]);
+       my @g2 = glob("$dst/git/*.git") ;
+       is_deeply(\@g2, \@g, 'cloned again');
+       is(scalar(grep { -w $_ } @g2), scalar(@w) + 1,
+               'got one more cloned epoch');
+}
 
 ok($td->kill, 'killed httpd');
 $td->join;
 
-done_testing();
-
-1;
+done_testing;