--- builds_bin/update_repos 2007/04/27 21:30:49 1.2 +++ builds_bin/update_repos 2010/05/23 19:50:15 1.57 @@ -3,241 +3,515 @@ use strict; use warnings; use RPM2; +use File::Find; +use File::Basename; +use Getopt::Std; use Data::Dumper; -sub compare($$); - -my $releases = 2; - -my $releasedir = '/releases'; -my $smerel = '7'; -my $arch = 'i386'; -my $centosrel = '4'; -my $fedorarel = '3'; -my $builds = '/builds/rpms'; -my $stagedir = '/builds'; - -my @repos = ( - "$releasedir/$smerel/smeos/$arch/CentOS/RPMS", - "$releasedir/$smerel/smeupdates/$arch/RPMS", - "$releasedir/$smerel/smeupdates-testing/$arch/RPMS", - "$releasedir/$smerel/smeextras/$arch/RPMS", - "$releasedir/$smerel/smeaddons/$arch/RPMS", - "$releasedir/$smerel/smetest/$arch/RPMS", - "$releasedir/$smerel/smedev/$arch/RPMS", - "$builds/RPMS/$arch", - "$builds/RPMS/i586", - "$builds/RPMS/i686", - "$builds/RPMS/noarch", - "$stagedir/RPMS", - ); - -my @srcrepos = ( - "/mirrors/centos/$centosrel/fasttrack/SRPMS", - "/mirrors/centos/$centosrel/updates/SRPMS", - "/mirrors/centos/$centosrel/os/SRPMS", - "/mirrors/centos/$centosrel/extras/SRPMS", - "/mirrors/rpmforge/dag/source", - "/mirrors/atrpms/src/el$centosrel-$arch/atrpms/stable", - "/mirrors/fedora/core/updates/$fedorarel/SRPMS", - "/mirrors/fedora/core/$fedorarel/source/SRPMS", - "/mirrors/fedora/extras/$fedorarel/SRPMS", - "$builds/SRPMS", - ); - -my %repohash; -my %srcrepohash; -my %changed; -my %copy; -my @remove; - -my $rpm_flags = RPM2->vsf_nodsaheader | RPM2->vsf_nodsa; - -%{$srcrepohash{$stagedir}} = map { $_ => 0 } grep { /\.rpm$/ } readdir SRPMS if ( opendir SRPMS, "$stagedir/SRPMS" ); -closedir SRPMS; - -foreach my $repo ( @repos ) { - if ( $repo =~ m{^($releasedir/$smerel/sme[^/]*)/} ) { - my $srcrepo = $1; - - %{$srcrepohash{$srcrepo}} = map { $_ => 0 } grep { /\.rpm$/ } readdir SRPMS if ( opendir SRPMS, "$srcrepo/SRPMS" ); - closedir SRPMS; - } - - opendir RPMS, $repo; - foreach my $rpm ( grep { m{\.rpm} } readdir RPMS ) { - my $header = RPM2->open_package("$repo/$rpm", $rpm_flags); - my $pkg = $header->tag("NAME").".".$header->tag("ARCH"); - if ( $repo =~ m{$stagedir/RPMS} ) { - push @{$repohash{$pkg}{$stagedir}}, $header; - } elsif ( $repo =~ m{$builds/RPMS} ) { - push @{$repohash{$pkg}{builds}}, $header; - } elsif ( $repo =~ m{^($releasedir/$smerel/sme[^/]*)/} ) { - my $pos = $1; - push @{$repohash{$pkg}{$pos}}, $header; - } - } - closedir RPMS; -} - -my %sources; -foreach my $repo ( reverse @srcrepos ) { - my %temp_repo = map { $_ => $repo } grep { /\.rpm$/ } readdir SRPMS if ( opendir SRPMS, $repo ); - closedir SRPMS; - - %sources = (%sources, %temp_repo); -} - -foreach my $pkg ( keys %repohash ) { - foreach my $repo ( @repos ) { - if ( $repo =~ m{$stagedir/RPMS} ) { - next unless $repohash{$pkg}; - if ( $repohash{$pkg}{$stagedir} ) { - my ($latest, @rest) = sort { $b cmp $a } @{$repohash{$pkg}{$stagedir}}; - delete $repohash{$pkg}{$stagedir}; - push @remove, map { $_->filename } @rest if @rest; - if ( $repohash{$pkg}{latest} ) { - if ($repohash{$pkg}{latest} ne $latest ) { - push @remove, $latest->filename; - push @{$copy{"$stagedir/RPMS"}}, $repohash{$pkg}{latest}->filename; - $repohash{$pkg}{$stagedir} = $repohash{$pkg}{latest}; - } else { - $repohash{$pkg}{$stagedir} = $latest; - } - } else { - push @remove, $latest->filename; - } - } elsif ( $repohash{$pkg}{latest} ) { - push @{$copy{"$stagedir/RPMS"}}, $repohash{$pkg}{latest}->filename; - $repohash{$pkg}{$stagedir} = $repohash{$pkg}{latest}; - } - } elsif ( $repo =~ m{^($releasedir/$smerel/sme[^/]*)/} ) { - my $pos = $1; - next unless $repohash{$pkg}{$pos}; - if ( $pos =~ m{/smedev$} ) { - next unless $repohash{$pkg}{latest}; - my @rest = grep { $_ le $repohash{$pkg}{latest} } @{$repohash{$pkg}{$pos}}; - if ( @rest ) { - push @remove, map { $_->filename } @rest; - $changed{$pos}++; - @{$repohash{$pkg}{$pos}} = grep { $_ gt $repohash{$pkg}{latest} } @{$repohash{$pkg}{$pos}}; - delete $repohash{$pkg}{$pos}; - } - } else { - my ($latest, @rest) = sort { $b cmp $a } @{$repohash{$pkg}{$pos}}; - delete $repohash{$pkg}{$pos}; - if ( $repohash{$pkg}{latest} && $repohash{$pkg}{latest} ge $latest ) { - push @rest, $latest; - } else { - $repohash{$pkg}{latest} = $latest; - $repohash{$pkg}{$pos} = $latest; - } - if ( @rest ) { - push @remove, map { $_->filename } @rest; - $changed{$pos}++; - } - } - } - } +delete $ENV{PATH}; +my $HOME=$ENV{HOME}; +umask 002; +$| = 1; + +my %opts; +getopts( 'osqtr:', \%opts ); +$opts{r} ||= ''; + +my $rpm_flags = RPM2->vsf_nosha1header | RPM2->vsf_nomd5header | RPM2->vsf_nodsaheader | RPM2->vsf_norsaheader; +$rpm_flags |= RPM2->vsf_nosha1 | RPM2->vsf_nomd5 | RPM2->vsf_nodsa | RPM2->vsf_norsa; + +my $osdir = 'SME'; +my $disttag = 'sme'; +my $repotag = 'sme'; + +my @archs = ( 'i386', 'x86_64' ); + +my $distrepo = { '7' => { active => 1, + centos => 4, + repo => '/releases/7/', + os => 'RPMS/', + builds => '/builds/smeserver-7-core/', + community => '/builds/smeserver-7-contribs/', + stage => '/stage/7/', + }, + '8' => { active => 1, + centos => 5, + repo => '/releases/testing/8/', + os => '', + builds => '/builds/smeserver-8-core/', + community => '/builds/smeserver-8-contribs/', + stage => '/stage/8/', + }, + }; + +my $repos = { "${repotag}os" => { prio => 18, inc => 1, ver => 1, rel => 1, os => 1 }, + "${repotag}updates" => { prio => 17, inc => 1, ver => 1, rel => 1 }, + "${repotag}updates-testing" => { prio => 16, inc => 1, ver => 1, rel => 3 }, + "${repotag}extras" => { prio => 15, inc => 0, ver => 1, rel => 1 }, + "${repotag}addons" => { prio => 14, inc => 0, ver => 1, rel => 1 }, + "${repotag}contribs" => { prio => 13, inc => 0, ver => 1, rel => 1 }, + "${repotag}test" => { prio => 12, inc => 0, ver => 2, rel => 3, devel => 2 }, + "${repotag}dev" => { prio => 11, inc => 0, ver => 1, rel => 1, devel => 1 }, + 'centos' => { prio => 10, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'epel' => { prio => 9, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'rpmforge' => { prio => 7, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'atrpms' => { prio => 6, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'builds' => { prio => 4, inc => 0, ver => 0, rel => 0, orig => 1 }, + 'community' => { prio => 2, inc => 0, ver => 0, rel => 0, orig => 1 }, + 'stage' => { prio => 1, inc => 0, ver => 0, rel => 0, stage => 1, os => 1 }, + }; + +my $baserepo = { "~S${repotag}os/~A/$osdir/~O" => "${repotag}os", + "~S${repotag}updates/~A/RPMS/" => "${repotag}updates", + "~S${repotag}updates-testing/~A/RPMS/" => "${repotag}updates-testing", + "~S${repotag}extras/~A/RPMS/" => "${repotag}extras", + "~S${repotag}addons/~A/RPMS/" => "${repotag}addons", + "~S${repotag}contribs/~A/RPMS/" => "${repotag}contribs", + "~S${repotag}test/~A/RPMS/" => "${repotag}test", + "~S${repotag}dev/~A/RPMS/" => "${repotag}dev", + "/stage/~s/~A/$osdir/~O" => 'stage', + '/mirrors/centos/~C/fasttrack/~A/RPMS/' => 'centos', + '/mirrors/centos/~C/updates/~A/RPMS/' => 'centos', + '/mirrors/centos/~C/os/~A/CentOS/~O' => 'centos', + '/mirrors/centos/~C/extras/~A/RPMS/' => 'centos', + '/mirrors/fedora/epel/~C/~A/' => 'epel', + '/mirrors/fedora/epel/testing/~C/~A/' => 'epel', + '/mirrors/rpmforge/dag/redhat/el~C/en/~A/dag/RPMS/' => 'rpmforge', + '/mirrors/rpmforge/dag/source/' => 'rpmforge', + '/mirrors/atrpms/el~C-~A/atrpms/stable/' => 'atrpms', + '/mirrors/atrpms/el~C-~A/atrpms/testing/' => 'atrpms', + '/mirrors/atrpms/src/el~C-~A/atrpms/stable/' => 'atrpms', + '/mirrors/atrpms/src/el~C-~A/atrpms/testing/' => 'atrpms', + }; + +if ( $opts{q} ) { + $baserepo->{'/mirrors/centos-qa/CentOS/~C/fasttrack/~A/RPMS/'} = 'centos'; + $baserepo->{'/mirrors/centos-qa/CentOS/~C/updates/~A/RPMS/'} = 'centos'; + $baserepo->{'/mirrors/centos-qa/CentOS/~C/os/~A/CentOS/~O'} = 'centos'; + $baserepo->{'/mirrors/centos-qa/CentOS/~C/extras/~A/RPMS/'} = 'centos'; } -print "\n"; -foreach my $pkg ( sort grep { $repohash{$_}{builds} } keys %repohash ) { - my %versions = (); - foreach my $ver ( sort { $b cmp $a } @{$repohash{$pkg}{builds}} ) { - next if $repohash{$pkg}{latest} && $repohash{$pkg}{latest} ge $ver; - - $versions{$ver->tag("VERSION")}++; - if ( $versions{$ver->tag("VERSION")} > $releases || (scalar keys %versions) > $releases ) { - foreach my $rpm ( grep { $ver eq $_ } @{$repohash{$pkg}{"$releasedir/$smerel/smedev"}} ) { - push @remove, $rpm->filename; - @{$repohash{$pkg}{"$releasedir/$smerel/smedev"}} = grep { $rpm ne $_ } @{$repohash{$pkg}{"$releasedir/$smerel/smedev"}}; - $changed{"$releasedir/$smerel/smedev"}++; - } +my $skippkg = { '7' => { 'centos' => { map { $_ => 1 } ( 'horde', 'imp-h3', 'ingo-h3', 'turba-h3' ) }, + 'epel' => { map { $_ => 1 } ( 'clamav', 'fping', 'ocsinventory', 'perl-Compress-Bzip2', 'perl-Compress-Raw-Zlib', 'perl-Compress-Raw-Bzip2', 'perl-Crypt-OpenSSL-Bignum', 'perl-Crypt-OpenSSL-Random', 'perl-Crypt-OpenSSL-RSA', 'perl-DateTime', 'perl-Razor-Agent', 'perl-Text-Iconv', 'proftpd' ) }, + 'rpmforge' => { map { $_ => 1 } ( 'mod_auth_tkt', 'perl-Test-Inline', 'spamassassin' ) }, + 'atrpms' => { map { $_ => 1 } ( 'check4updates', 'dovecot', 'trac', 'yum' ) }, + }, + '8' => { 'centos' => { map { $_ => 1 } ( 'horde', 'imp-h3', 'ingo-h3', 'turba-h3' ) }, + 'epel' => { map { $_ => 1 } ( 'clamav', 'horde', 'libtalloc', 'libtdb', 'perl-Compress-Bzip2', 'perl-Compress-Raw-Zlib', 'perl-Compress-Raw-Bzip2', 'perl-Crypt-OpenSSL-Bignum', 'perl-Crypt-OpenSSL-Random', 'perl-Crypt-OpenSSL-RSA', 'perl-Razor-Agent', 'proftpd', 'smolt' ) }, + 'rpmforge' => { map { $_ => 1 } ( 'mod_auth_tkt', 'perl-Test-Inline', 'spamassassin' ) }, + }, + }; + +my ($stage) = sort { $repos->{$a}->{stage} <=> $repos->{$b}->{stage} } grep { $repos->{$_}->{stage} } keys %$repos; +my ($devel1, $devel2) = sort { $repos->{$a}->{devel} <=> $repos->{$b}->{devel} } grep { $repos->{$_}->{devel} } keys %$repos; +$devel2 ||= $devel1; + +my ($rpms, %base, %latest, %sources); +foreach my $ver ( sort { $a <=> $b } keys %$distrepo ) { + next unless $distrepo->{$ver}->{active}; + my %repochg = (); + $rpms = (); + %latest = (); + %sources = (); + %base = (); + + foreach my $dir ( sort { $repos->{$baserepo->{$b}}->{prio} <=> $repos->{$baserepo->{$a}}->{prio} || $a cmp $b } keys %$baserepo ) { + my $bdir = $dir; + $bdir =~ s/~O/$distrepo->{$ver}->{os}/; + $bdir =~ s/~S/$distrepo->{$ver}->{repo}/; + $bdir =~ s/~s/$ver/; + $bdir =~ s/~C/$distrepo->{$ver}->{centos}/; + for my $arch ( @archs, 'SRPMS/' ) { + my $adir = $bdir; + if ( $arch eq 'SRPMS/' ) { + $adir =~ s/~A.*/$arch/ if $arch eq 'SRPMS/'; + } else { + $adir =~ s/~A/$arch/; + } + opendir DIR, $adir or next; + next unless -d $adir; + process_rpm("$adir$_", $ver, $baserepo->{$dir}) foreach readdir DIR; + closedir DIR; + last unless $dir =~ m{~A}; + } + } + find( { wanted => sub { process_rpm($_, $ver, 'builds'); }, no_chdir => 1, follow_fast => 1 }, $distrepo->{$ver}->{'builds'} ); + find( { wanted => sub { process_rpm($_, $ver, 'community'); }, no_chdir => 1, follow_fast => 1 }, $distrepo->{$ver}->{'community'} ) if $distrepo->{$ver}->{'community'}; + + foreach my $base ( sort keys %$rpms ) { + next unless $rpms->{$base}->{rpms}; + my %track = (); + my %seen = (); + my %counts = (); + my $acnt = (); + my $print = 0; + %latest = (); + + foreach my $pkg ( sort { $b->{rpm} cmp $a->{rpm} } @{$rpms->{$base}->{rpms}} ) { + next if $pkg->{done}; + + my $tmp = $pkg->{svr}; + SRC: { + $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{\.el\d\.at$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{\.el\d\.at$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{\.el\d(\.rf)$}{$1} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{\.el\d\.rf$}{.el5} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{(\.el\d)\.rf$}{$1} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{(\d+)\.\d+\.el\d(\.rf)$}{$1$2} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{\.el\d\.rf$}{.dag} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{(\d+)\.\d+\.el\d\.rf$}{$1.dag} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{\.el\d$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{(-\d+)\.\d+\.el\d$}{$1} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{\.centos\d$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + ($tmp = $pkg->{svr}) =~ s{\.el\d\.$disttag$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + } + if ( $rpms->{$base}->{vers}->{$tmp} ) { + foreach $tmp ( @{$rpms->{$base}->{vers}->{$tmp}} ) { + $tmp->{svr} = $pkg->{svr}; + push @{$rpms->{$base}->{rpms}}, $tmp unless $tmp->{added}; + $tmp->{added}++; + } + } + + my %orig = (); + my %pkgs = (); + my %reposrc = (); + my $srpm = undef; + foreach my $cmp ( sort { $a->{src} <=> $b->{src} || $repos->{$b->{repo}}->{prio} <=> $repos->{$a->{repo}}->{prio} } @{$rpms->{$base}->{rpms}} ) { + next unless $cmp->{svr} eq $pkg->{svr}; + + if ( ! $track{repo} || $repos->{$cmp->{repo}}->{prio} > $repos->{$track{repo}}->{prio} ) { + if ( $cmp->{src} ) { + if ( ! $track{repo} ) { + $cmp->{delete}++; + $cmp->{done}++; + next; + } + } else { + $track{repo} = $cmp->{repo}; + $track{svr} = $cmp->{svr}; + } + } + if ( $cmp->{svr} eq $track{svr} ) { + if ( $seen{$cmp->{nvra}} ) { + if ( $track{repo} ne $cmp->{repo} ) { + if ($repos->{$cmp->{repo}}->{stage} ) { + if ( $seen{$cmp->{nvra}}->{latest} ) { + $seen{$cmp->{nvra}}->{latest}++; + } else { + $cmp->{delete}++; + } + } elsif ( $repos->{$cmp->{repo}}->{orig}) { + $orig{$cmp->{nvra}}++; + unless ( $repos->{$cmp->{repo}}->{base} ) { + my $tag = sprintf '%s%s/%s-%s', $distrepo->{$ver}->{$cmp->{repo}}, $cmp->{name}, $cmp->{ver}, $cmp->{rel}; + qx(touch $tag/PUSHED) if ! $opts{t} && -d $tag && ! -f "$tag/PUSHED"; + } + } elsif ( $cmp->{src} && $reposrc{$cmp->{repo}} ) { + $reposrc{$cmp->{repo}}->{srpm} = $cmp; + } elsif ( $seen{$cmp->{nvra}}->{repo} ne $cmp->{repo} ) { + $cmp->{delete}++; + } + } + } elsif ($repos->{$cmp->{repo}}->{stage} ) { + $cmp->{delete}++; + } else { + $srpm = $cmp if ! $srpm && $cmp->{src}; + my $dest = $repos->{$track{repo}}->{prio} > $repos->{$devel2}->{prio} ? $track{repo} : $devel2; + $dest = pkgdest($cmp, $devel1, $dest, $rpms->{$base}->{rpms}); + $dest = $devel1 if verrel($cmp, $dest, \%counts); + if ( $cmp->{repo} ne $dest ) { + push @{$cmp->{repos}}, $dest; + if ( $repos->{$cmp->{repo}}->{orig} ) { + $orig{$cmp->{nvra}}++; + unless ( $repos->{$cmp->{repo}}->{base} ) { + my $tag = sprintf '%s%s/%s-%s', $distrepo->{$ver}->{$cmp->{repo}}, $cmp->{name}, $cmp->{ver}, $cmp->{rel}; + qx(touch $tag/PUSHED) if ! $opts{t} && -d $tag && ! -f "$tag/PUSHED"; + } + } elsif ( $cmp->{src} && $reposrc{$cmp->{repo}} ) { + $reposrc{$cmp->{repo}}->{srpm} = $cmp; + } else { + $cmp->{delete}++; + } + $cmp->{oldrepo} = $cmp->{repo} unless $cmp->{oldrepo}; + $cmp->{repo} = $dest; + if ( ! $cmp->{src} && $repos->{$dest}->{prio} > $repos->{$track{repo}}->{prio} ) { + $track{repo} = $dest; + $track{svr} = $cmp->{svr}; + } + } + if ( $cmp->{src} && $reposrc{$cmp->{repo}} ) { + $reposrc{$cmp->{repo}}->{srpm} = $cmp; + } + } + } else { + if ( $track{repo} eq $cmp->{repo} ) { + if ( verrel($cmp, $cmp->{repo}, \%counts) ) { + $cmp->{delete}++ unless $repos->{$cmp->{repo}}->{base}; + } elsif ( $cmp->{src} ) { + $cmp->{delete}++ unless $repos->{$cmp->{repo}}->{base}; + } else { + $track{svr} = $cmp->{svr}; + } + } elsif ( ! $repos->{$cmp->{repo}}->{base} ) { + if ( $repos->{$cmp->{repo}}->{orig} ) { + $srpm = $cmp if ! $srpm && $cmp->{src}; + my $dest = $repos->{$track{repo}}->{prio} > $repos->{$devel2}->{prio} ? $track{repo} : $devel2; + $dest = pkgdest($cmp, $devel1, $dest, $rpms->{$base}->{rpms}); + $dest = $devel1 if verrel($cmp, $dest, \%counts); + unless ( $cmp->{src} && ! $reposrc{$dest} ) { + if ( $repos->{$dest}->{prio} >= $repos->{$track{repo}}->{prio} && ! verrel($cmp, $dest, \%counts) ) { + unless ( $repos->{$cmp->{repo}}->{base} ) { + my $tag = sprintf '%s%s/%s-%s', $distrepo->{$ver}->{$cmp->{repo}}, $cmp->{name}, $cmp->{ver}, $cmp->{rel}; + qx(touch $tag/PUSHED) if ! $opts{t} && -d $tag && ! -f "$tag/PUSHED"; + } + push @{$cmp->{repos}}, $dest; + $cmp->{oldrepo} = $cmp->{repo} unless $cmp->{oldrepo}; + $cmp->{repo} = $dest; + $reposrc{$cmp->{repo}}->{srpm} = $cmp if $cmp->{src}; + $orig{$cmp->{nvra}}++; + } + } + } else { + $cmp->{delete}++; + } + } + } + unless ( $repos->{$cmp->{repo}}->{orig} || ( $cmp->{delete} && ! $cmp->{repos} ) ) { + $pkgs{$cmp->{nvra}}++; + $latest{$cmp->{base}} = $cmp->{svr} if $repos->{$cmp->{repo}}->{inc} && ! $latest{$cmp->{base}}; + $reposrc{$cmp->{repo}} = $cmp unless $reposrc{$cmp->{repo}} || $cmp->{src} || $repos->{$cmp->{repo}}->{stage}; + unless ( $seen{$cmp->{nvra}} ) { + $seen{$cmp->{nvra}} = $cmp; + $cmp->{latest}++ if $latest{$cmp->{base}} && $cmp->{svr} eq $latest{$cmp->{base}} && $repos->{$cmp->{repo}}->{inc}; + } + push @{$acnt->{$cmp->{repo}}->{$cmp->{rpm}->as_nvre}->{$cmp->{src} ? 'src' : $cmp->{rpm}->arch}}, $cmp; + } + $cmp->{done}++; + } + if ( $srpm ) { + foreach my $r ( sort { $repos->{$b}->{prio} <=> $repos->{$a}->{prio} } keys %reposrc ) { + unless ( $reposrc{$r}->{srpm} ) { + unshift @{$srpm->{repos}}, $r; + $srpm->{oldrepo} = $srpm->{repo} unless $srpm->{oldrepo}; + $srpm->{repo} = $r; + $reposrc{$r}->{srpm} = $srpm; + } + } + } elsif ( scalar keys %pkgs && $opts{s} ) { + print "\n * missing source ($disttag$ver, ", $pkg->{repo}, ", ", $pkg->{svr}, ")\n"; + } + print "\n * missing originals ($disttag$ver, ", $pkg->{repo}, ", ", $pkg->{svr}, ")\n" if $opts{o} && scalar keys %orig != scalar keys %pkgs; + } + + foreach my $r ( keys %$acnt ) { + foreach my $p ( keys %{$acnt->{$r}} ) { + foreach my $a ( keys %{$acnt->{$r}->{$p}} ) { + if ( $a eq 'noarch' ) { + my $p2 = ${$acnt->{$r}->{$p}->{$a}}[0]; + if ( ! $p2->{repos} && scalar @{$acnt->{$r}->{$p}->{$a}} != scalar @archs ) { + $p2->{oldrepo} = $p2->{repo}; + push @{$p2->{repos}}, $p2->{repo}; + } + } elsif ( scalar @{$acnt->{$r}->{$p}->{$a}} != 1 ) { + print "\n * many packages ($r, $a, $p)\n"; + } + } + } + } + + foreach my $pkg ( sort { $a->{nvra} cmp $b->{nvra} } @{$rpms->{$base}->{rpms}} ) { + if ( $pkg->{latest} && $pkg->{latest} == 1 ) { + $pkg->{oldrepo} = $pkg->{repo} unless $pkg->{oldrepo}; + $pkg->{repo} = $stage; + push @{$pkg->{repos}}, $stage; + } + if ( ! $print && ($pkg->{delete} || $pkg->{repos} || $pkg->{nosig} ) ) { + print "\n$base ($disttag$ver)\n", "=" x length("$base ($disttag$ver)"), "\n"; + $print++; + } + + my $src = $pkg->{rpm}->filename; + if ( $pkg->{nosig} ) { + print "sign package (", basename($pkg->{rpm}->filename), ")\n"; + unless ( $opts{t} ) { + qx(cat $HOME/.rpmpass | setsid rpm --addsign $src >& /dev/null); + if ($?) { + print " * failed to sign package\n"; + next; + } + } + } + + if ( $pkg->{repos} ) { + foreach my $repo ( @{$pkg->{repos}} ) { + if ( $pkg->{delete} ) { + print "move from ", $pkg->{oldrepo}, " to $repo (", basename($pkg->{rpm}->filename), ")\n"; + $pkg->{delete} = 0; + $repochg{$pkg->{oldrepo}}++ unless $repos->{$pkg->{oldrepo}}->{base} || $repos->{$pkg->{oldrepo}}->{stage}; + } elsif ( $pkg->{oldrepo} eq $repo ) { + print "distribute noarch in $repo (", basename($pkg->{rpm}->filename), ")\n"; + } else { + print "copy from ", $pkg->{oldrepo}, " to $repo (", basename($pkg->{rpm}->filename), ")\n"; + } + $repochg{$repo}++ unless $repos->{$repo}->{base} || $repos->{$repo}->{stage}; + $pkg->{oldrepo} = $repo unless $pkg->{oldrepo} eq ${$pkg->{repos}}[0]; + + my @d = (); + my $head = $distrepo->{$ver}->{repo} . $repo . '/'; + $head = $distrepo->{$ver}->{stage} if $repos->{$repo}->{stage}; + my $tail = $repos->{$repo}->{os} ? "$osdir/" . $distrepo->{$ver}->{os} : 'RPMS/'; + if ( $pkg->{src} ) { + push @d, "${head}SRPMS/" . basename($pkg->{rpm}->filename); + } elsif ( $pkg->{rpm}->arch eq 'noarch' ) { + push @d, map { "${head}$_/$tail" . basename($pkg->{rpm}->filename) } @archs; + } elsif ( $pkg->{rpm}->arch =~ m{^(i[356]86)$} ) { + push @d, "${head}i386/$tail" . basename($pkg->{rpm}->filename); + } else { + push @d, $head . $pkg->{rpm}->arch . "/$tail" . basename($pkg->{rpm}->filename); + } + foreach my $dest ( @d ) { + qx(cp --preserve=timestamps $src $dest) unless $opts{t} || -f "$dest"; + } + + } + qx(rm -f $src) if exists $pkg->{delete} && ! $opts{t}; + } elsif ( $pkg->{delete} ) { + print "delete from ", $pkg->{repo}, " (", $pkg->{arch}, ", ", basename($pkg->{rpm}->filename), ")\n"; + qx(rm -f $src) unless $opts{t}; + $repochg{$pkg->{repo}}++ unless $repos->{$pkg->{repo}}->{base} || $repos->{$pkg->{repo}}->{stage}; + if ( $repos->{$pkg->{repo}}->{orig} && ! $repos->{$pkg->{repo}}->{base} ) { + my $tag = sprintf '%s%s/%s-%s', $distrepo->{$ver}->{$pkg->{repo}}, $pkg->{name}, $pkg->{ver}, $pkg->{rel}; + qx(rm -f $tag/PUSHED) if ! $opts{t} && -d $tag && -f "$tag/PUSHED"; + } + } + } + } + + if ( %repochg ) { + print "\nrebuild repo ($disttag$ver)\n", "=" x length("rebuild repo ($disttag$ver)"), "\n"; + } + foreach my $repo ( sort { $repos->{$b}->{prio} <=> $repos->{$a}->{prio} } keys %repochg ) { + next if $repos->{$repo}->{orig} || $repos->{$repo}->{stage}; + foreach my $arch ( @archs ) { + my $dir = $distrepo->{$ver}->{repo} . "$repo/$arch"; + $dir = qx(readlink -f $dir); + chomp $dir; + print "rebuild $repo/$arch\n"; + unless ( $opts{t} ) { + if ( $dir =~ m{test} ) { + if ( -f "$dir/repodata/comps.xml" ) { + qx(createrepo --update --database --exclude *smeserver-release*.rpm --exclude *.src.rpm --exclude *-debuginfo-*.rpm --groupfile repodata/comps.xml $dir); + } else { + qx(createrepo --update --database --exclude *smeserver-release*.rpm --exclude *.src.rpm --exclude *-debuginfo-*.rpm $dir); + } } else { - print "Possible update " . $ver->filename . "\n" if $repohash{$pkg}{latest}; - if ( ! grep { $ver eq $_ } @{$repohash{$pkg}{"$releasedir/$smerel/smedev"}} ) { - push @{$copy{"$releasedir/$smerel/smedev/$arch/RPMS"}}, $ver->filename; - push @{$repohash{$pkg}{"$releasedir/$smerel/smedev"}}, $ver; - $changed{"$releasedir/$smerel/smedev"}++; - } + if ( -f "$dir/repodata/comps.xml" ) { + qx(createrepo --update --database --exclude *.src.rpm --exclude *-debuginfo-*.rpm --groupfile repodata/comps.xml $dir); + } else { + qx(createrepo --update --database --exclude *.src.rpm --exclude *-debuginfo-*.rpm $dir); + } } - } + qx(repoview $dir); + qx(rm -rf $dir/.olddata) if -d "$dir/.olddata"; + qx(rm -rf $dir/.repodata) if -d "$dir/.repodata"; + } + } + } + unless ( $opts{t} ) { + finddepth(sub{rmdir}, $distrepo->{$ver}->{builds}) if -d "$distrepo->{$ver}->{builds}"; + finddepth(sub{rmdir}, $distrepo->{$ver}->{community}) if -d "$distrepo->{$ver}->{community}"; + } } -foreach my $pkg ( grep { $repohash{$_}{"$releasedir/$smerel/smedev"} } keys %repohash ) { - foreach my $rpm ( @{$repohash{$pkg}{"$releasedir/$smerel/smedev"}} ) { - unless ( grep { $rpm eq $_ } @{$repohash{$pkg}{builds}} ) { - push @remove, $rpm->filename; - @{$repohash{$pkg}{"$releasedir/$smerel/smedev"}} = grep { $rpm ne $_ } @{$repohash{$pkg}{"$releasedir/$smerel/smedev"}}; - $changed{"$releasedir/$smerel/smedev"}++; - } - } +sub verrel { + my $pkg = shift; + my $repo = shift; + my $counts = shift; + + return 0 if $pkg->{src}; + $counts->{$repo}->{$pkg->{ver}}->{$pkg->{rel}}++; + return 1 if $repos->{$repo}->{ver} && scalar keys %{$counts->{$repo}} > $repos->{$repo}->{ver}; + return 1 if $repos->{$repo}->{rel} && scalar keys %{$counts->{$repo}->{$pkg->{ver}}} > $repos->{$repo}->{rel}; + return 0; } -print "\n"; -foreach my $repo ( sort keys %srcrepohash ) { - foreach my $pkg ( sort grep { $repohash{$_}{$repo} } keys %repohash ) { - my @rpms = ref($repohash{$pkg}{$repo}) eq "ARRAY" ? @{$repohash{$pkg}{$repo}} : ($repohash{$pkg}{$repo}); - foreach my $rpm ( sort @rpms ) { - my $src = $rpm->tag("SOURCERPM"); - - my @sources = (); - push @sources, $src; - push @sources, $src if ($src =~ s/\.\d+\.el\d+\.rf\./\.rf\./); - push @sources, $src if ($src =~ s/\.el\d\.rf\./\.rf\./); - push @sources, $src if ($src =~ s/\.el\d\.at\./\.at\./); - push @sources, $src if ($src =~ s/\.fc\d\.at\./\.at\./); - push @sources, $src if ($src =~ s/\.rf\./\.dag\./); - - my $found = 0; - foreach my $source ( @sources ) { - if ( $sources{$source} ) { - unless ( -f "$repo/SRPMS/$source" ) { - push @{$copy{"$repo/SRPMS"}}, "$sources{$source}/$source"; - $changed{$repo}++; - } - $srcrepohash{$repo}{$source}++; - $found++; - last; - } elsif ( -f "$repo/SRPMS/$source" ) { - print "Found missing source $repo/SRPMS/$source for ".$rpm->as_nvre()."\n"; - $srcrepohash{$repo}{$source}++; - $found++; - } - } - print "Can't find source for ".$rpm->as_nvre()."\n" unless $found; - } - } - - foreach my $rpm ( keys %{$srcrepohash{$repo}} ) { - unless ( $srcrepohash{$repo}{$rpm} ) { - push @remove, "$repo/SRPMS/$rpm"; - $changed{$repo}++; - } - } +sub pkgdest { + my $pkg = shift; + my $dest = shift; + my $hirepo = shift; + my $pkgs = shift; + + foreach my $cmp ( @$pkgs ) { + next if $cmp->{src} || $repos->{$cmp->{repo}}->{prio} <= $repos->{$dest}->{prio}; + next if $pkg->{name} ne ( $pkg->{src} ? $cmp->{base} : $cmp->{name} ); + if ( $repos->{$cmp->{repo}}->{prio} > $repos->{$hirepo}->{prio} ) { + $dest = $hirepo; + last; + } else { + $dest = $cmp->{repo}; + } + } + return $dest; } -print "\n"; -foreach my $repo ( sort keys %copy ) { - foreach my $rpm ( sort keys %{{ map { $_ => 1 } @{$copy{$repo}} }} ) { - print "copying $rpm to $repo/\n"; - system(qw(cp --preserve=timestamps), $rpm, "$repo/"); - } +sub process_rpm { + my $rpm = shift; + my $ver = shift; + my $repo = shift; + return unless $rpm =~ m{/([^/]*)-[^-]+-[^-]+\.\w+\.rpm$}; + my $base = $1; + return unless ! $opts{r} || $base =~ m[$opts{r}]; + return unless $latest{$base} || $sources{$base} || ! $repos->{$repo}->{base}; + + my $pkg; + eval { $pkg = RPM2->open_package($rpm, $rpm_flags); }; + if ($@) { print " * corrupt package ($rpm)\n"; return; } + eval { my $sig = $pkg->siggpg }; + my $nosig = ! $@; + + my $cmp = $latest{$pkg->name}; + if ( $repos->{$repo}->{base} && ! $pkg->is_source_package ) { + return unless $cmp; + return if $repos->{$cmp->{repo}}->{base} && $repos->{$cmp->{repo}}->{prio} > $repos->{$repo}->{prio} && $pkg ge $cmp->{rpm}; + } + my ($src, $version, $release) = ($pkg->is_source_package ? $pkg->filename : $pkg->sourcerpm) =~ m{(?:^|/)([^/]*)-([^-]+)-([^-]+)\.\w+\.rpm$}; + return if $skippkg->{$ver}->{$repo} && ( $skippkg->{$ver}->{$repo}->{$src} || $skippkg->{$ver}->{$repo}->{$pkg->name} ); + return if $repos->{$repo}->{base} && $nosig; + if ( $nosig && ! -f "$HOME/.rpmpass" ) { print " * missing signature (" .$pkg->filename . ")\n"; return; } + my $arch = 'unknown'; + $arch = 'SRPMS' if $pkg->filename =~ m{[/-](SRPMS?|src|source)/}; + $arch = 'x86_64' if $pkg->filename =~ m{[/-]x86_64/}; + $arch = 'i386' if $pkg->filename =~ m{[/-](i[356]86)/}; + $arch = 'noarch' if $pkg->filename =~ m{[/-]noarch/}; + + my $rpmhash = { base => $src, + name => $pkg->name, + repo => $repo, + nvra => $pkg->name.'-'.$pkg->version.'-'.$pkg->release.'.'.( $pkg->is_source_package ? 'src' : $pkg->tag('ARCH') ), + svr => $src.'-'.$version.'-'.$release, + src => $pkg->is_source_package, + arch => $arch, + ver => $version, + rel => $release, + rpm => $pkg, + nosig => $nosig, + }; + if ( $pkg->is_source_package ) { + push @{$rpms->{$src}->{srpms}}, $rpmhash; + push @{$rpms->{$src}->{vers}->{$rpmhash->{svr}}}, $rpmhash; + } else { + push @{$rpms->{$src}->{rpms}}, $rpmhash; + } + $sources{$src}++; + + return if $pkg->is_source_package || $repos->{$repo}->{stage}; + if ( ! $repos->{$repo}->{base} ) { + if ( ! $cmp || $pkg gt $cmp->{rpm} ) { + $latest{$pkg->name} = $rpmhash; + } + } elsif ( ( $repos->{$repo}->{prio} >= $repos->{$cmp->{repo}}->{prio} || ! $repos->{$cmp->{repo}}->{base} ) && $pkg ge $cmp->{rpm} ) { + $latest{$pkg->name} = $rpmhash; + } } - -print "\n"; -foreach my $rpm ( sort keys %{{ map { $_ => 1 } @remove }} ) { - print "removing $rpm\n"; - unlink $rpm; -} - -print "\n"; -foreach my $repo ( sort keys %changed ) { - next if $repo =~ m{^$stagedir}; - - print "rebuilding $repo/i386...\n"; - system(qw(createrepo), "$repo/i386"); - system(qw(repoview), "$repo/i386"); -} -