aboutsummaryrefslogtreecommitdiffstats
path: root/lib/Youri/Submit/Action
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Youri/Submit/Action')
-rw-r--r--lib/Youri/Submit/Action/CleanRpmsrate.pm53
-rw-r--r--lib/Youri/Submit/Action/Gendistrib.pm66
-rw-r--r--lib/Youri/Submit/Action/Genhdlist2.pm74
-rw-r--r--lib/Youri/Submit/Action/Rsync.pm87
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;