diff options
Diffstat (limited to 'lib/Youri/Submit/Action')
| -rw-r--r-- | lib/Youri/Submit/Action/CleanRpmsrate.pm | 53 | ||||
| -rw-r--r-- | lib/Youri/Submit/Action/Gendistrib.pm | 66 | ||||
| -rw-r--r-- | lib/Youri/Submit/Action/Genhdlist2.pm | 74 | ||||
| -rw-r--r-- | lib/Youri/Submit/Action/Rsync.pm | 87 |
4 files changed, 280 insertions, 0 deletions
diff --git a/lib/Youri/Submit/Action/CleanRpmsrate.pm b/lib/Youri/Submit/Action/CleanRpmsrate.pm new file mode 100644 index 0000000..977e2a0 --- /dev/null +++ b/lib/Youri/Submit/Action/CleanRpmsrate.pm @@ -0,0 +1,53 @@ +# $Id: CleanRpmsrate.pm 115367 2007-01-30 09:47:04Z pixel $ +package Youri::Submit::Post::CleanRpmsrate; + +=head1 NAME + +Youri::Submit::Post::CleanRpmsrate - calls clean-rpmsrate + +=head1 DESCRIPTION + +Calls clean-rpmsrate + +=cut + +use warnings; +use strict; +use Carp; +use base qw/Youri::Submit::Post/; + +#- inlined from MDK::Common::DataStructure +sub uniq { my %l; $l{$_} = 1 foreach @_; grep { delete $l{$_} } @_ } + +sub _init { +} + +sub run { + my ($self, $repository, $target, $define) = @_; + croak "Not a class method" unless ref $self; + my $root = $repository->get_install_root(); + my @changed = @{$repository->get_arch_changed($target)}; + if (grep { $_ eq 'i586' } @changed) { + # x86_64 uses i586 pkgs, so rpmsrate need to be rebuild + @changed = uniq(@changed, 'x86_64'); + } + foreach my $arch (@changed) { + my $rpmsrate = "$root/$target/$arch/media/media_info/rpmsrate"; + my @media = "$root/$target/$arch/media/main/release"; + system("cp", "$rpmsrate-raw", "$rpmsrate-new"); + system("clean-rpmsrate", "$rpmsrate-new", @media); + system("mv", "-f", "$rpmsrate-new", $rpmsrate); + } + return +} + +=head1 COPYRIGHT AND LICENSE + +Copyright (C) 2007, Mandriva <blino@mandriva.com> + +This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself. + +=cut + +1; + diff --git a/lib/Youri/Submit/Action/Gendistrib.pm b/lib/Youri/Submit/Action/Gendistrib.pm new file mode 100644 index 0000000..98205c7 --- /dev/null +++ b/lib/Youri/Submit/Action/Gendistrib.pm @@ -0,0 +1,66 @@ +# $Id: Gendistrib.pm 115367 2007-01-30 09:47:04Z pixel $ +package Youri::Submit::Post::Gendistrib; + +=head1 NAME + +Youri::Submit::Post::Gendistrib - calls gendistrib + +=head1 DESCRIPTION + +Calls gendistrib + +=cut + +use warnings; +use strict; +use Carp; +use base qw/Youri::Submit::Post/; + +sub _init { + my $self = shift; + my %options = ( + user => '', + host => '', + source => '', + destination => '', + @_ + ); + + foreach my $var ('tmpdir', 'command') { + $self->{"_$var"} = $options{$var}; + } +} + +sub run { + my ($self, $repository, $target, $define) = @_; + croak "Not a class method" unless ref $self; + my $root = $repository->get_install_root(); + (undef, undef, my $hour) = gmtime(time); + # during the night, use complete hdlist rebuild + my $fast = '--fast'; + $fast = ''; # blino: don't use fast for now, it might be broken + if ($hour > 22 && $hour < 5) { + if ($hour < 4) { + $fast = '--blind' + } else { + $fast = '' + } + } + foreach my $arch (@{$repository->get_arch_changed($target)}) { + my $cmd = "TMPDIR=$self->{_tmpdir}/$target/$arch time $self->{_command} --nochkdep --nobadrpm $fast --noclean $root/$target/$arch"; + print "$cmd\n"; + system($cmd); + } + return +} + +=head1 COPYRIGHT AND LICENSE + +Copyright (C) 2002-2006, Mandriva <warly@mandriva.com> + +This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself. + +=cut + +1; + diff --git a/lib/Youri/Submit/Action/Genhdlist2.pm b/lib/Youri/Submit/Action/Genhdlist2.pm new file mode 100644 index 0000000..e9c3e24 --- /dev/null +++ b/lib/Youri/Submit/Action/Genhdlist2.pm @@ -0,0 +1,74 @@ +# $Id: Gendistrib.pm 115367 2007-01-30 09:47:04Z pixel $ +package Youri::Submit::Post::Genhdlist2; + +=head1 NAME + +Youri::Submit::Post::Genhdlist2 - calls genhdlist2 + +=head1 DESCRIPTION + +Calls genhdlist2 + +=cut + +use warnings; +use strict; +use Carp; +use base qw/Youri::Submit::Post/; + +sub _init { + my $self = shift; + my %options = ( + user => '', + host => '', + source => '', + destination => '', + @_ + ); + + foreach my $var ('command') { + $self->{"_$var"} = $options{$var}; + } +} + +sub run { + my ($self, $repository, $target, $define) = @_; + croak "Not a class method" unless ref $self; + my $root = $repository->get_install_root(); + (undef, undef, my $hour) = gmtime(time); + my @changed = @{$repository->get_install_dir_changed($target)}; + if (!@changed) { + print "nothing to do\n"; + return; + } + foreach my $dir (@changed) { + my $file_deps = "$dir/../../media_info/file-deps"; + my $file_deps_option = -e $file_deps ? "--file-deps $file_deps" : ''; + my $cmd = "time $self->{_command} -v --allow-empty-media $file_deps_option $dir"; + print "$cmd\n"; + system($cmd) == 0 or print "ERROR: $cmd failed\n"; + } + + # need to redo global MD5SUM. This MD5SUM is mostly obsolete, but is still needed up to 2007.1 + # (and even on cooker for existing urpmi.cfg) + foreach my $arch (@{$repository->get_arch_changed($target)}) { + my $dir = "$root/$target/$arch/media/media_info"; + my $cmd = "cd $dir ; time md5sum hdlist_* synthesis.*"; + print "$cmd\n"; + my $m = `$cmd`; + open my $f, '>', "$dir/MD5SUM" or die "Can't write $dir/MD5SUM: $!\n"; + print $f $m; + } + return; +} + +=head1 COPYRIGHT AND LICENSE + +Copyright (C) 2002-2006, Mandriva <warly@mandriva.com> + +This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself. + +=cut + +1; + diff --git a/lib/Youri/Submit/Action/Rsync.pm b/lib/Youri/Submit/Action/Rsync.pm new file mode 100644 index 0000000..036612c --- /dev/null +++ b/lib/Youri/Submit/Action/Rsync.pm @@ -0,0 +1,87 @@ +# $Id$ +package Youri::Submit::Pre::Rsync; + +=head1 NAME + +Youri::Submit::Pre::Rsync - Old revisions archiving + +=head1 DESCRIPTION + +This action plugin ensures archiving of old package revisions. + +=cut + +use warnings; +use strict; +use Carp; +use base qw/Youri::Submit::Pre/; + +sub _init { + my $self = shift; + my %options = ( + user => '', + host => '', + source => '', + destination => '', + @_ + ); + + foreach my $var ('user', 'host', 'source', 'destination') { + $self->{"_$var"} = $options{$var}; + } +} + +sub run { + my ($self, $pre_packages, $repository, $target, $define) = @_; + croak "Not a class method" unless ref $self; + + if (system("rsync --remove-sent-files -avlPHe 'ssh -xc arcfour' $self->{_user}\@$self->{_host}:$self->{_source}/$target/ $self->{_destination}/$target/")) { + $self->{_error} = "Rsync command failed ($!)"; + return + } + my $queue = "$self->{_destination}/$target"; + $self->{_error} = "Reading queue directory failed"; + # now get the packages downloaded + my %packages; + opendir my $queuedh, "$self->{_destination}/$target/" or return "Could not open $self->{_destination}/$target"; + opendir my $targetdh, $queue or return "Could not open $queue"; + my $idx; + foreach my $media (readdir $targetdh) { + $media =~ /^\.{1,2}$/ and next; + print "$target - $media\n"; + if (-d "$queue/$media") { + opendir my $submediadh, "$queue/$media" or return "Could not open $queue/$media"; + foreach my $submedia (readdir $submediadh) { + $submedia =~ /^\.{1,2}$/ and next; + print "$target - $media - $submedia\n"; + opendir my $rpmdh, "$queue/$media/$submedia" or return "Could not open $queue/$media/$submedia"; + foreach my $rpm (readdir $rpmdh) { + $rpm =~ /^\.{1,2}$/ and next; + print "$target - $media - $submedia : $rpm\n"; + my $file = "$queue/$media/$submedia/$rpm"; + $file =~ s/\/+/\//g; + if ($rpm =~ /^(\d{14}\.\w+\.\w+\.\d+)_.*\.rpm$/) { + push @{$packages{$1}{rpms}}, { section => "$media/$submedia", file => $file }; + } elsif ($rpm =~ /\.rpm$/) { + $idx++; + push @{$packages{"independant_$idx"}{rpms}}, { section => "$media/$submedia", file => $file } + } + } + } + } + } + foreach my $key (keys %packages) { + push @$pre_packages, $packages{$key}{rpms} + } + return +} + +=head1 COPYRIGHT AND LICENSE + +Copyright (C) 2002-2006, Mandriva <warly@mandriva.com> + +This program is free software; you can redistribute it and/or modify it under the same terms as Perl itself. + +=cut + +1; |