721c764951
To quote the function's comment: Awful hack to handle timeouts in SQLite: just retry the transaction. DBD::SQLite *has* a 30 second retry window, but apparently it doesn't work. Since SQLite is now dropped entirely, this wrapper can be removed completely.
80 lines
2.3 KiB
Perl
80 lines
2.3 KiB
Perl
package Hydra::Plugin::BazaarInput;
|
|
|
|
use strict;
|
|
use parent 'Hydra::Plugin';
|
|
use Digest::SHA qw(sha256_hex);
|
|
use File::Path;
|
|
use Hydra::Helper::Nix;
|
|
use Nix::Store;
|
|
|
|
sub supportedInputTypes {
|
|
my ($self, $inputTypes) = @_;
|
|
$inputTypes->{'bzr'} = 'Bazaar export';
|
|
$inputTypes->{'bzr-checkout'} = 'Bazaar checkout';
|
|
}
|
|
|
|
sub fetchInput {
|
|
my ($self, $type, $name, $value) = @_;
|
|
|
|
return undef if $type ne "bzr" && $type ne "bzr-checkout";
|
|
|
|
my $uri = $value;
|
|
|
|
my $sha256;
|
|
my $storePath;
|
|
|
|
my $stdout; my $stderr;
|
|
|
|
# First figure out the last-modified revision of the URI.
|
|
my @cmd = (["bzr", "revno", $uri], "|", ["sed", 's/^ *\([0-9]*\).*/\1/']);
|
|
|
|
IPC::Run::run(@cmd, \$stdout, \$stderr);
|
|
die "cannot get head revision of Bazaar branch at `$uri':\n$stderr" if $?;
|
|
my $revision = $stdout; chomp $revision;
|
|
die unless $revision =~ /^\d+$/;
|
|
|
|
(my $cachedInput) = $self->{db}->resultset('CachedBazaarInputs')->search(
|
|
{uri => $uri, revision => $revision});
|
|
|
|
addTempRoot($cachedInput->storepath) if defined $cachedInput;
|
|
|
|
if (defined $cachedInput && isValidPath($cachedInput->storepath)) {
|
|
$storePath = $cachedInput->storepath;
|
|
$sha256 = $cachedInput->sha256hash;
|
|
} else {
|
|
|
|
# Then download this revision into the store.
|
|
print STDERR "checking out Bazaar input ", $name, " from $uri revision $revision\n";
|
|
$ENV{"NIX_HASH_ALGO"} = "sha256";
|
|
$ENV{"PRINT_PATH"} = "1";
|
|
$ENV{"NIX_PREFETCH_BZR_LEAVE_DOT_BZR"} = $type eq "bzr-checkout" ? "1" : "0";
|
|
|
|
(my $res, $stdout, $stderr) = captureStdoutStderr(1200,
|
|
"nix-prefetch-bzr", $uri, $revision);
|
|
die "cannot check out Bazaar branch `$uri':\n$stderr" if $res;
|
|
|
|
($sha256, $storePath) = split ' ', $stdout;
|
|
|
|
# FIXME: time window between nix-prefetch-bzr and addTempRoot.
|
|
addTempRoot($storePath);
|
|
|
|
$self->{db}->txn_do(sub {
|
|
$self->{db}->resultset('CachedBazaarInputs')->create(
|
|
{ uri => $uri
|
|
, revision => $revision
|
|
, sha256hash => $sha256
|
|
, storepath => $storePath
|
|
});
|
|
});
|
|
}
|
|
|
|
return
|
|
{ uri => $uri
|
|
, storePath => $storePath
|
|
, sha256hash => $sha256
|
|
, revision => $revision
|
|
};
|
|
}
|
|
|
|
1;
|