1 files changed, 87 insertions, 0 deletions
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;