package crypto; # $Id$ use diagnostics; use strict; use vars qw(%url2land %land2tzs %static_mirrors %mirrors); use common; use log; use ftp; %url2land = ( at => N("Austria"), au => N("Australia"), be => N("Belgium"), br => N("Brazil"), ca => N("Canada"), ch => N("Switzerland"), cr => N("Costa Rica"), cz => N("Czech Republic"), de => N("Germany"), dk => N("Denmark"), ee => N("Estonia"), es => N("Spain"), fi => N("Finland"), fr => N("France"), gr => N("Greece"), hu => N("Hungary"), ie => N("Ireland"), il => N("Israel"), it => N("Italy"), jp => N("Japan"), nl => N("Netherlands"), no => N("Norway"), nz => N("New Zealand"), pl => N("Poland"), pt => N("Portugal"), ru => N("Russia"), se => N("Sweden"), sk => N("Slovakia"), th => N("Thailand"), tw => N("Taiwan"), za => N("South Africa"), ); %land2tzs = ( N("Australia") => [ 'Australia/Sydney' ], N("Austria") => [ 'Europe/Vienna', 'Europe/Brussels', 'Europe/Berlin' ], N("Belgium") => [ 'Europe/Brussels', 'Europe/Paris', 'Europe/Berlin' ], N("Brazil") => [ 'Brazil/East' ], N("Canada") => [ 'Canada/Atlantic', 'Canada/Eastern' ], N("Czech Republic") => [ 'Europe/Prague', 'Europe/Berlin' ], N("Denmark") => [ 'Europe/Copenhagen', 'Europe/Berlin' ], N("Estonia") => [ 'Europe/Tallinn', 'Europe/Helsinki' ], N("Finland") => [ 'Europe/Helsinki', 'Europe/Tallinn' ], N("France") => [ 'Europe/Paris', 'Europe/Brussels', 'Europe/Berlin' ], N("Germany") => [ 'Europe/Berlin', 'Europe/Prague' ], N("Greece") => [ 'Europe/Athens', 'Europe/Prague' ], N("Hungary") => [ 'Europe/Budapest' ], N("Ireland") => [ 'Europe/Dublin', 'Europe/London' ], N("Israel") => [ 'Asia/Tel_Aviv' ], N("Italy") => [ 'Europe/Rome', 'Europe/Brussels', 'Europe/Paris' ], N("Japan") => [ 'Asia/Tokyo', 'Asia/Seoul' ], N("Netherlands") => [ 'Europe/Amsterdam', 'Europe/Brussels', 'Europe/Berlin' ], N("New Zealand") => [ 'Pacific/Auckland' ], N("Norway") => [ 'Europe/Oslo', 'Europe/Stockholm' ], N("Poland") => [ 'Europe/Warsaw' ], N("Portugal") => [ 'Europe/Lisbon', 'Europe/Madrid' ], N("Russia") => [ 'Europe/Moscow', ], N("Slovakia") => [ 'Europe/Bratislava' ], N("South Africa") => [ 'Africa/Johannesburg' ], N("Spain") => [ 'Europe/Madrid', 'Europe/Lisbon' ], N("Sweden") => [ 'Europe/Stockholm', 'Europe/Oslo' ], N("Switzerland") => [ 'Europe/Zurich', 'Europe/Berlin', 'Europe/Brussels' ], N("Taiwan") => [ 'Asia/Taipei', 'Asia/Seoul' ], N("Thailand") => [ 'Asia/Bangkok', 'Asia/Seoul' ], N("United States") => [ 'America/New_York', 'Canada/Atlantic', 'Asia/Tokyo', 'Australia/Sydney', 'Europe/Paris' ], ); %static_mirrors = ( # "ackbar" => [ "Ackbar", "/updates", "a", "a" ], ); %mirrors = (); sub mirror2text { $mirrors{$_[0]} && $mirrors{$_[0]}[0] . '|' . $_[0] } sub mirrors { my ($o_distro_type, $o_use_local_list) = @_; unless (keys %mirrors) { my $f; if ($o_use_local_list) { $f = \*DATA; } else { #- contact the following URL to retrieve the list of mirrors. require http; $f = http::getFile("http://www.mandrivalinux.com/mirrorsfull.list"); } local $SIG{ALRM} = sub { die "timeout" }; $o_use_local_list or alarm 60; my $distro_type = $o_distro_type || 'updates'; my $sub_dir = $distro_type =~ /cooker|community/ ? '' : '/' . version() . '/main_updates'; foreach (<$f>) { my ($arch, $url, $dir) = m|$distro_type([^:]*):ftp://([^/]*)(/\S*)| or next; MDK::Common::System::compat_arch($arch) or next; my $land = N("United States"); foreach (keys %url2land) { my $qu = quotemeta $_; $url =~ /\.$qu(?:\..*)?$/ and $land = $url2land{$_}; } $mirrors{$url} = [ $land, $dir . $sub_dir ]; } unless ($o_use_local_list) { http::getFile('/XXX'); #- close connection. alarm 0; } #- now add static mirror (in case of something wrong happened above). add2hash(\%mirrors, \%static_mirrors); } keys %mirrors; } sub bestMirror { my ($string, $o_distro_type) = @_; my %mirror2value; foreach my $url (mirrors($o_distro_type)) { my $value = 0; my $cvalue = mirrors($o_distro_type); $mirror2value{$url} ||= 1 + $cvalue; foreach (@{$land2tzs{$mirrors{$url}[0]} || []}) { $_ eq $string and $mirror2value{$url} > $value and $mirror2value{$url} = $value; (split '/')[0] eq (split '/', $string)[0] and $mirror2value{$url} > $cvalue and $mirror2value{$url} = $cvalue; ++$value; } } my $min_value = min(values %mirror2value); my @possible = (grep { $mirror2value{$_} == $min_value } keys %mirror2value) x 2; #- increase probability push @possible, grep { $mirror2value{$_} == 1 + $min_value } keys %mirror2value; $possible[rand @possible]; } #- hack to retrieve Mandriva Linux version... XXX figure out something more robust sub version() { require pkgs; my $pkg = pkgs::packageByName($::o->{packages}, 'mandriva-release'); my $v = $pkg && $pkg->version || '10.2'; #- safe but dangerous ;-) $v eq '2006.0' and $v = '10.2'; $v; } sub dir { $mirrors{$_[0]}[1] } sub ftp($) { ftp::new($_[0], dir($_[0])) } sub getFile { my ($file, $o_host) = @_; my $host = $o_host || $crypto::host; my $dir = dir($host); log::l("getting crypto file $file on directory $dir with login $mirrors{$host}[2]"); my ($ftp, $retr) = ftp::new($host, $dir, if_($mirrors{$host}[2], $mirrors{$host}[2]), if_($mirrors{$host}[3], $mirrors{$host}[3]) ); $$retr->close if $$retr; $$retr = $ftp->retr($file) or ftp::rewindGetFile(); $$retr ||= $ftp->retr($file); } sub getPackages { my ($packages, $mirror) = @_; $crypto::host = $mirror; #- get pubkey file first as we cannot handle 2 files opened simultaneously. my $pubkey; eval { my $fpubkey = getFile("media_info/pubkey", $mirror); $pubkey = [ $packages->parse_armored_file($fpubkey) ]; }; #- check first if there is something to get... my $fhdlist = getFile("media_info/hdlist.cz", $mirror); unless ($fhdlist) { log::l("no updates available, bailing out"); return; } #- extract hdlist of crypto, then depslist. require pkgs; my $update_medium = pkgs::psUsingHdlist('ftp', $packages, "hdlist-updates.cz", "1u", "", "Updates for Mandriva Linux " . version(), 1, $fhdlist, $pubkey); if ($update_medium) { log::l("read updates hdlist"); #- keep in mind where is the URL prefix used according to mirror (for install_any::install_urpmi). $update_medium->{prefix} = "ftp://$mirror" . dir($mirror); #- (re-)enable the medium to allow install of package, #- make it an update medium (for install_any::install_urpmi). $update_medium->select; $update_medium->{update} = 1; $install_any::global_ftp_prefix = [ $mirror, dir($mirror) ]; #- host, dir (for install_any::getFile) #- search for packages to update. $packages->{rpmdb} ||= pkgs::rpmDbOpen(); pkgs::selectPackagesToUpgrade($packages, $update_medium); } return $update_medium; } sub get { my ($mirror, $dir, @files) = @_; foreach (@files) { log::l("crypto: downloading $_"); ftp($mirror)->get($_, "$dir/$_"); } int @files; } 1; #- mirror list, hardcoded here to be used in mini-cds (ftp suppl. media) __DATA__ communityi586:ftp://ftp-linux.cc.gatech.edu/pub/linux/distributions/mandrake/devel/community/i586/media/main communityi586:ftp://ftp-stud.fht-esslingen.de/pub/Mirrors/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://ftp.gwdg.de/pub/linux/mandrakelinux/devel/community/i586/media/main communityi586:ftp://ftp.join.uni-muenster.de/pub/linux/distributions/mandrake-devel/community/i586/media/main communityi586:ftp://ftp.lip6.fr/pub/linux/distributions/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://ftp.nluug.nl/pub/os/Linux/distr/Mandrake/devel/community/i586/media/main communityi586:ftp://ftp.proxad.net/pub/Distributions_Linux/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://ftp.sunet.se/pub/Linux/distributions/mandrakelinux/devel/community/i586/media/main communityi586:ftp://ftp.surfnet.nl/pub/os/Linux/distr/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://ftp.tugraz.at/mirror/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://ftp.uninett.no/pub/unix/Linux/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://ftp.u-strasbg.fr/pub/linux/distributions/mandrakelinux/devel/community/i586/media/main communityi586:ftp://gd.tuwien.ac.at/pub/linux/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://jungle.metalab.unc.edu/pub/Linux/distributions/mandrake/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://mandrake.contactel.cz/Mandrakelinux/devel/community/i586/media/main communityi586:ftp://sunsite.informatik.rwth-aachen.de/pub/Linux/mandrake-devel/community/i586/media/main communityi586:rsync://ftp.sunet.se::Mandrakelinux/devel/community/i586/media/main communityi586:rsync://mirrors.usc.edu::mandrakelinux/devel/community/i586/media/main cookerppc:ftp://ftp-linux.cc.gatech.edu/pub/linux/distributions/mandrake/devel/cooker/ppc/media/main cookerppc:ftp://ftp-stud.fht-esslingen.de/pub/Mirrors/Mandrakelinux/devel/cooker/ppc/media/main cookerppc:ftp://ftp.club-internet.fr/pub/unix/linux/distributions/Mandrakelinux/devel/cooker/ppc/media/main cookerppc:ftp://ftp.gwdg.de/pub/linux/mandrakelinux/de