--- builds_bin/update_repos 2007/06/04 16:39:15 1.13 +++ builds_bin/update_repos 2020/11/26 18:37:39 1.93 @@ -3,221 +3,694 @@ 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 $centosrel = '4'; -my $fedorarel = '3'; -my $builds = '/builds/rpms'; -my $stagedir = '/builds'; -my $arch = `uname -i`; -chomp $arch; - -my @repos = ( - "$releasedir/$smerel/smeos/$arch/CentOS/RPMS", - "$releasedir/$smerel/smeos/$arch/SME/RPMS", - "$releasedir/$smerel/smeos/$arch/RPMS", - "$releasedir/$smerel/smeos/$arch/SME", - "$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/atrpms/src/el$centosrel-$arch/atrpms/testing", - "/mirrors/fedora/epel/$centosrel/SRPMS", - "/mirrors/fedora/core/updates/$fedorarel/SRPMS", - "/mirrors/fedora/core/$fedorarel/source/SRPMS", - "/mirrors/fedora/extras/$fedorarel/SRPMS", - "$builds/SRPMS", - ); - -my $rpm_flags = RPM2->vsf_nodsaheader | RPM2->vsf_nodsa; - -my @rpms; -my %srpms; -my %sources; -my %changed; -my %copy; - -foreach my $repo ( @repos ) { - my $r = $repo; - if ( $repo =~ m{$stagedir/RPMS} ) { - $r = $stagedir; - } elsif ( $repo =~ m{$builds/RPMS} ) { - $r = 'builds'; - } elsif ( $repo =~ m{^($releasedir/$smerel/sme[^/]*)/} ) { - $r = $1; - } - - if ( $r ne 'builds' ) { - opendir SRPMS, "$r/SRPMS" or next; - foreach my $srpm ( grep { /\.rpm$/ } readdir SRPMS ) { - $srpms{$r}{$srpm} = 0; - $sources{$srpm} = "$r/SRPMS"; - } - closedir SRPMS; - } - - opendir RPMS, $repo or next; - foreach my $pkg ( reverse sort map { RPM2->open_package("$repo/$_", $rpm_flags); } grep { /\.rpm$/ } readdir RPMS ) { - my $rpm = { name => $pkg->tag("NAME"), - filename => join("-", map { $pkg->tag($_) } qw/name version release/) . "." . $pkg->tag("ARCH"), - version => $pkg->tag("VERSION"), - release => $pkg->tag("RELEASE"), - repo => $r, - rpm => $pkg, - }; - my $source = $pkg->tag("SOURCERPM"); - $source =~ s#-$rpm->{version}-$rpm->{release}.*##; - $rpm->{source} = $source; - - if ( $rpm->{repo} =~ m{^$releasedir/$smerel/} && $rpm->{repo} !~ m{/smedev$} ) { - $rpm->{repo} = 'deleted' if grep { $_->{repo} ne $rpm->{repo} && $_->{name} eq $rpm->{name} && $_->{rpm} ge $rpm->{rpm} } @rpms; - $rpm->{repo} = 'deleted' if grep { $_->{repo} eq $rpm->{repo} && $_->{name} eq $rpm->{name} && $_->{rpm} gt $rpm->{rpm} } @rpms; - $changed{$r}++ if $rpm->{repo} eq 'deleted'; - } - - push @rpms, $rpm; - } - closedir RPMS; -} - -foreach my $repo ( reverse @srcrepos ) { - my %temp_repo = map { $_ => $repo } grep { /\.rpm$/ } readdir SRPMS if ( opendir SRPMS, $repo ); - closedir SRPMS; - - %sources = (%sources, %temp_repo); -} - -my @latest; -foreach my $rpm ( reverse grep { $_->{repo} =~ m{^$releasedir/$smerel/} && $_->{repo} !~ m{/smedev$} } @rpms ) { - unless ( grep { $_->{name} eq $rpm->{name} && $_->{rpm} gt $rpm->{rpm} } @latest ) { - push @latest, $rpm; - unless ( grep { $_->{repo} eq $stagedir && $_->{filename} eq $rpm->{filename} } @rpms ) { - push @{$copy{"$stagedir/RPMS"}}, $rpm->{rpm}->filename; - push @rpms, { name => $rpm->{name}, - filename => $rpm->{filename}, - version => $rpm->{version}, - release => $rpm->{release}, - repo => $stagedir, - rpm => $rpm->{rpm}, - source => $rpm->{source} - }; - } - } -} - -foreach my $rpm ( grep { $_->{repo} eq $stagedir } @rpms ) { - $rpm->{repo} = 'deleted' unless grep { $_->{filename} eq $rpm->{filename} } @latest; -} - -my @devel; -my %versions; -foreach my $rpm ( grep { $_->{repo} eq 'builds' } @rpms ) { - next if grep { $_->{name} eq $rpm->{name} && $_->{rpm} ge $rpm->{rpm} } @latest; - - $versions{$rpm->{name}}{$rpm->{version}}++ unless grep { $_->{name} eq $rpm->{name} && $_->{rpm} eq $rpm->{rpm} } @devel; - next if $versions{$rpm->{name}}{$rpm->{version}} > $releases || scalar keys %{$versions{$rpm->{name}}} > $releases; - print "Possible update " . $rpm->{rpm}->filename . "\n" if grep { $_->{name} eq $rpm->{name} } @latest; - - push @devel, $rpm; - unless ( grep { $_->{repo} =~ m{/smedev$} && $_->{filename} eq $rpm->{filename} } @rpms ) { - push @{$copy{"$releasedir/$smerel/smedev/$arch/RPMS"}}, $rpm->{rpm}->filename; - $changed{"$releasedir/$smerel/smedev"}++; - push @rpms, { name => $rpm->{name}, - filename => $rpm->{filename}, - version => $rpm->{version}, - release => $rpm->{release}, - repo => "$releasedir/$smerel/smedev", - rpm => $rpm->{rpm}, - source => $rpm->{source} - }; - } -} +delete $ENV{PATH}; +my $HOME=$ENV{HOME}; +umask 002; +$| = 1; + +my %opts; +getopts( 'ostr:', \%opts ); +$opts{r} ||= ''; +#available options +#-o = verify we have originals of the packages in repos (not really used anymore) +#-s = verify every package has a source package (so we can rebuild if necessary) +#-t = test run (don't do anything just print out what would be done) +#-r {regex} = regex of packages to run the script against + +my $rpm_flags = RPM2->vsf_nodsaheader | RPM2->vsf_norsaheader | RPM2->vsf_nodsa | RPM2->vsf_norsa; + +my $osdir = 'Packages'; +my $disttag = 'sme'; +my $repotag = 'sme'; + +my $distrepo = { '8' => { active => 0, + centos => 5, + archs => [ 'i386', 'x86_64' ], + repo => '/build/smeserver/repo/8/', + builds => ['/build/builds/smeserver-8-core/'], + community => '/build/builds/smeserver-8-contribs/', + stage => '/build/smeserver/stage/8/', + sign => 1, + keyname => 'SME Server 7 signing key ', + checksum => 'sha', + }, + '9' => { active => 1, + centos => 6, + archs => [ 'i386', 'x86_64' ], + repo => '/build/smeserver/repo/9/', + builds => ['/build/builds/smeserver-9-core/'], + community => '/build/builds/smeserver-9-contribs/', + stage => '/build/smeserver/stage/9/', + sign => 1, + keyname => 'SME Server 7 signing key ', + checksum => 'sha256', + }, + '10' => { active => 1, + centos => 7, + archs => [ 'x86_64' ], + repo => '/build/smeserver/repo/testing/10/', + builds => ['/build/builds/smeserver-10-core/'], + community => '/build/builds/smeserver-10-contribs/', + stage => '/build/smeserver/stage/10/', + sign => 1, + keyname => 'Koozali SME Server signing key (10) ', + checksum => 'sha256', + }, + }; + +# list here repo and priority +# prio: highest priority will hide lowest priority +# inc: include for iso ? +# ver: +# rel: +# orig: +# base, os, stage: +my $repos = { "${repotag}os" => { prio => 29, inc => 1, ver => 1, rel => 1, os => 1 }, + "${repotag}updates" => { prio => 28, inc => 1, ver => 1, rel => 1 }, + "${repotag}updates-testing" => { prio => 27, inc => 1, ver => 1, rel => 3 }, + "${repotag}extras" => { prio => 26, inc => 0, ver => 1, rel => 1 }, + "${repotag}addons" => { prio => 25, inc => 0, ver => 1, rel => 1 }, + "${repotag}contribs" => { prio => 24, inc => 0, ver => 1, rel => 1 }, + "${repotag}test" => { prio => 23, inc => 0, ver => 2, rel => 3, devel => 2 }, + "${repotag}dev" => { prio => 22, inc => 0, ver => 1, rel => 1, devel => 1 }, + 'centos' => { prio => 21, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'remisafe' => { prio => 12, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'remi' => { prio => 11, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'epel' => { prio => 10, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'epeltesting' => { prio => 9, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'rpmfusion' => { prio => 8, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'openfusion' => { prio => 7, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'rpmforge' => { prio => 6, inc => 0, ver => 0, rel => 0, orig => 1, base => 1 }, + 'atrpms' => { prio => 5, 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 }, + }; + +# list here the path on our local mirror to each upstream and our mirrors +# ~A will be expanded to architecture +# ~C will be expanded to Centos main version number, i.e. 7 for SME 10. +# ~s will be expanded to SME version +# ~S expanded to repo root +my $baserepo = { "~S${repotag}os/~A/" => "${repotag}os", + "~S${repotag}updates/~A/" => "${repotag}updates", + "~S${repotag}updates-testing/~A/" => "${repotag}updates-testing", + "~S${repotag}extras/~A/" => "${repotag}extras", + "~S${repotag}addons/~A/" => "${repotag}addons", + "~S${repotag}contribs/~A/" => "${repotag}contribs", + "~S${repotag}test/~A/" => "${repotag}test", + "~S${repotag}dev/~A/" => "${repotag}dev", + "/build/smeserver/stage/~s/~A/" => 'stage', + '/mirrors/centos/~C/fasttrack/~A/' => 'centos', + '/mirrors/centos/~C/updates/~A/' => 'centos', + '/mirrors/centos/~C/os/~A/' => 'centos', + '/mirrors/centos/~C/extras/~A/' => 'centos', + '/mirrors/centos-vault/~C/fasttrack/~A/' => 'centos', + '/mirrors/centos-vault/~C/updates/~A/' => 'centos', + '/mirrors/centos-vault/~C/os/~A/' => 'centos', + '/mirrors/centos-vault/~C/extras/~A/' => 'centos', + '/mirrors/fedora/epel/~C/~A/' => 'epel', + '/mirrors/fedora/epel/testing/~C/~A/' => 'epeltesting', + '/mirrors/remi/enterprise/~C/remi/~A/' => 'remi', + '/mirrors/remi/SRPMS/' => 'remi', + '/mirrors/remi/enterprise/~C/safe/~A/' => 'remisafe', + '/mirrors/rpmfusion/updates/~C/~A/' => 'rpmfusion', + '/mirrors/rpmforge/redhat/el~C/en/~A/dag/' => 'rpmforge', + '/mirrors/rpmforge/redhat/el~C/en/~A/extras/' => 'rpmforge', + '/mirrors/rpmforge/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', + '/mirrors/openfusion/centos~C-~A/' => 'openfusion', + '/mirrors/openfusion/srpms-el~C/' => 'openfusion', + }; + +# add here packages to exclude +# for each version, if a repo is listed and rpm are listed they will be ignored fromt his repo +my $skippkg = { '8' => { 'atrpms' => { map { $_ => 1 } ( 'clamav', 'gnupg' ) }, + 'centos' => { map { $_ => 1 } ( 'horde', 'imp-h3', 'ingo-h3', 'turba-h3' ) }, + 'epel' => { map { $_ => 1 } ( 'clamav', 'cppunit', 'fping', 'html2ps', 'horde', 'libtalloc', 'libtdb', 'oidentd', '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', 'smolt' ) }, + 'epeltesting' => { map { $_ => 1 } ( 'clamav', 'cppunit', 'fping', 'html2ps', 'horde', 'libtalloc', 'libtdb', 'oidentd', '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', 'smolt' ) }, + 'rpmforge' => { map { $_ => 1 } ( 'dovecot', 'libtalloc', 'mod_auth_tkt', 'perl-Test-Inline', 'spamassassin', 'lzo', 'perl-Convert-TNEF', 'perl-Mail-SPF', 'proftpd', 'erlang', 'perl-DateTime-Format-Mail', 'perl-DateTime-Format-W3CDTF', 'perl-Email-Abstract', 'perl-Email-MIME-Attachment-Stripper', 'perl-Email-Reply', 'perl-Font-AFM', 'perl-IPC-Run', 'rkhunter') }, + }, + '9' => { 'atrpms' => { map { $_ => 1 } ( 'clamav', 'perl-Pod-Escapes', 'perl-Pod-Simple','libvorbis' , 'libogg','iksemel' ) }, + 'epel' => { map { $_ => 1 } ( 'clamav', 'oidentd', 'perl-Razor-Agent' ) }, + 'epeltesting' => { map { $_ => 1 } ( 'clamav', 'oidentd', 'perl-Razor-Agent' ) }, + 'rpmforge' => { map { $_ => 1 } ( 'perl-CGI', 'perl-Compress-Raw-Zlib', 'perl-ExtUtils-ParseXS', 'perl-Pod-Escapes', 'perl-Pod-Simple', 'perl-Time-HiRes', 'perl-version', 'spamassassin', 'portreserve', 'perl-libwww-perl' , 'lzo', 'perl-BSD-Resource', 'perl-Convert-ASN1', 'perl-DBD-SQLite', 'perl-Devel-StackTrace', 'perl-Digest-SHA1', 'perl-JSON', 'perl-MIME-tools', 'perl-MailTools', 'perl-PPI', 'perl-URI', 'perl-XML-NamespaceSupport', 'perl-XML-Parser', 'perl-XML-SAX-Writer', 'perl-YAML-Syck', 'proftpd', 'syslinux') }, + }, + '10' => { + 'epel' => { map { $_ => 1 } ( 'clamav') }, + 'epeltesting' => { map { $_ => 1 } ( 'clamav', 'tidy') }, + 'openfusion' => { map { $_ => 1 } ( 'daemontools-encore') }, + }, + }; + +# add here include only conditions +# for each version if a repo is listed here, only listed rpm will be considered +my $onlypkg = { '8' => { + 'openfusion' => { }, + 'remi' => { }, + 'remisafe' => { }, + }, + '9' => { + 'openfusion' => { map { $_ => 1 } ( 'perl-Carp', 'perl-Scalar-List-Utils', 'perl-Class-Method-Modifiers', 'perl-B-Hooks-OP-Check', 'perl-Sub-Exporter-Progressive', 'perl-Devel-GlobalDestruction', 'perl-Socket', 'perl-Data-Validate-IP', 'perl-Eval-Closure', 'perl-Params-Classify', 'perl-Module-Runtime', 'perl-Module-Implementation', 'perl-Class-Load-XS', 'perl-MooX-Types-MooseLike', 'perl-Hash-FieldHash', 'perl-Algorithm-C3', 'perl-Class-C3', 'perl-MRO-Compat', 'perl-Class-XSAccessor', 'perl-ExtUtils-Manifest', 'perl-IPC-Cmd', 'perl-Module-Build', 'perl-ExtUtils-CBuilder', 'perl-Perl-OSType', 'perl-ExtUtils-Install', 'perl-Params-Validate', 'perl-Sub-Name', 'perl-Sub-Quote', 'perl-Sub-Identify', 'perl-Role-Tiny', 'perl-File-HomeDir', 'perl-Data-Dumper-Concise', 'perl-multidimensional', 'perl-Test-Warnings', 'perl-Term-ANSIColor', 'perl-Task-Weaken', 'perl-Clone-PP', 'perl-Data-IEEE754', 'perl-DateTime-TimeZone', 'perl-Exporter-Tiny', 'perl-List-AllUtils', 'perl-Dist-CheckConflicts', 'perl-Moose', 'perl-DateTime-Locale', 'perl-DateTime', 'perl-Variable-Magic', 'perl-B-Hooks-EndOfScope', 'perl-namespace-clean', 'perl-namespace-autoclean', 'perl-Lexical-SealRequireHints', 'perl-bareword-filehandles', 'perl-indirect', 'perl-strictures', 'perl-Moo', 'perl-MooX-StrictConstructor', 'perl-Throwable', 'perl-Math-Int64', 'perl-Math-Int128', 'perl-MaxMind-DB-Common', 'perl-Net-Works', 'perl-Sort-Naturally', 'perl-Data-Printer', 'perl-MaxMind-DB-Reader', 'perl-GeoIP2', 'perl-Data-OptList','perl-Class-Load', 'perl-App-cpanminus' )}, # not for moment : perl-Devel-StackTrace perl-parent perl-ExtUtils-MakeMaker perl-List-MoreUtils + 'remi' => { }, + }, + '10' => { + 'openfusion' => {map { $_ => 1 } ( 'perl-Carp', 'perl-Scalar-List-Utils', 'perl-Class-Method-Modifiers', 'perl-B-Hooks-OP-Check', 'perl-Sub-Exporter-Progressive', 'perl-Devel-GlobalDestruction', 'perl-Socket', 'perl-Data-Validate-IP', 'perl-Eval-Closure', 'perl-Params-Classify', 'perl-Module-Runtime', 'perl-Module-Implementation', 'perl-Class-Load-XS', 'perl-MooX-Types-MooseLike', 'perl-Hash-FieldHash', 'perl-Algorithm-C3', 'perl-Class-C3', 'perl-MRO-Compat', 'perl-Class-XSAccessor', 'perl-ExtUtils-Manifest', 'perl-IPC-Cmd', 'perl-Module-Build', 'perl-ExtUtils-CBuilder', 'perl-Perl-OSType', 'perl-ExtUtils-Install', 'perl-Params-Validate', 'perl-Sub-Name', 'perl-Sub-Quote', 'perl-Sub-Identify', 'perl-Role-Tiny', 'perl-File-HomeDir', 'perl-Data-Dumper-Concise', 'perl-multidimensional', 'perl-Test-Warnings', 'perl-Term-ANSIColor', 'perl-Task-Weaken', 'perl-Clone-PP', 'perl-Data-IEEE754', 'perl-DateTime-TimeZone', 'perl-Exporter-Tiny', 'perl-List-AllUtils', 'perl-Dist-CheckConflicts', 'perl-Moose', 'perl-DateTime-Locale', 'perl-DateTime', 'perl-Variable-Magic', 'perl-B-Hooks-EndOfScope', 'perl-namespace-clean', 'perl-namespace-autoclean', 'perl-Lexical-SealRequireHints', 'perl-bareword-filehandles', 'perl-indirect', 'perl-strictures', 'perl-Moo', 'perl-MooX-StrictConstructor', 'perl-Throwable', 'perl-Math-Int64', 'perl-Math-Int128', 'perl-MaxMind-DB-Common', 'perl-Net-Works', 'perl-Sort-Naturally', 'perl-Data-Printer', 'perl-MaxMind-DB-Reader', 'perl-GeoIP2', 'perl-Data-OptList','perl-Class-Load', 'perl-App-cpanminus', 'perl-Array-Compare', 'perl-Unicode-IMAPUtf7', 'perl-Filesys-DiskFree') }, + 'remi' => { map { $_ => 1 } ( 'php-pear' )}, + }, +}; + +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 = (); + + @{$distrepo->{$ver}->{all_archs}} = ('noarch', @{$distrepo->{$ver}->{'archs'}}); + if ( grep $_ eq 'i386', @{$distrepo->{$ver}->{'archs'}} ) { + push @{$distrepo->{$ver}->{all_archs}}, ('i586', 'i686'); + } + + foreach my $dir ( sort { $repos->{$baserepo->{$b}}->{prio} <=> $repos->{$baserepo->{$a}}->{prio} || $a cmp $b } keys %$baserepo ) { + my $bdir = $dir; + $bdir =~ s/~S/$distrepo->{$ver}->{repo}/; + $bdir =~ s/~s/$ver/; + $bdir =~ s/~C/$distrepo->{$ver}->{centos}/; + for my $arch ( @{$distrepo->{$ver}->{'archs'}}, 'SRPMS/' ) { + my $adir = $bdir; + if ( $arch eq 'SRPMS/' ) { + $adir =~ s/~A.*//; + if ( -d "${adir}SRPMS" ) { + $adir .= "SRPMS/"; + } elsif ( -d "${adir}Source/SPackages" ) { + $adir .= "Source/SPackages/"; + } + } else { + $adir =~ s/~A/$arch/; + if ( -d "${adir}RPMS" ) { + $adir .= "RPMS/"; + } elsif ( -d "${adir}Packages" ) { + $adir .= "Packages/"; + } elsif ( -d "${adir}CentOS" ) { + $adir .= "CentOS/"; + } elsif ( -d "${adir}$osdir" ) { + $adir .= "$osdir/"; + } + } + next unless -d $adir; + opendir DIR, $adir or next; + my @txt = grep { /\.rpm$/ && -f "$adir/$_" } readdir DIR; + closedir DIR; + if (scalar(@txt)) { + opendir DIR, $adir or next; + process_rpm("$adir$_", $ver, $baserepo->{$dir}) foreach readdir DIR; + closedir DIR; + } elsif ($baserepo->{$dir} eq 'epel') { + # EPEL 7 uses a structure with subfolders of first letter of package + find( { wanted => sub { process_rpm($_, $ver, $baserepo->{$dir}) if ($_ =~ m/\.rpm$/);}, no_chdir => 1, follow_fast => 1 }, $adir ); + } + last unless $dir =~ m{~A}; + } + } + find( { wanted => sub { process_rpm($_, $ver, 'builds'); }, no_chdir => 1, follow_fast => 1 }, "$_" ) foreach @{$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}; + # srpm transformations to match up binary and source rpms + SRC: { + # Try to find the name the binary wants (no changes) + $rpms->{$base}->{vers}->{$tmp} && last SRC; + + # rpmforge (.el4.rf to .rf, with rf,rfb,rft,rfx endings) + ($tmp = $pkg->{svr}) =~ s{\.el\d(\.rf[btx]?)$}{$1} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + # rpmforge (.el4.rfx to .rf, rfb,rft,rfx switched to rf) + ($tmp = $pkg->{svr}) =~ s{\.el\d(\.rf)[btx]$}{$1} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + # rpmforge (.el4.rf to .rfx, rf,rfb,rft,rfx switched to rfx) + ($tmp = $pkg->{svr}) =~ s{\.el\d(\.rf)[btx]?$}{$1x} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + # rpmforge (.el4.rf to .el5) TODO: remove when no longer needed + ($tmp = $pkg->{svr}) =~ s{\.el\d\.rf$}{.el5} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + # rpmforge (.2.el4.rf to .rf, minor modification not pushed to source?) TODO: remove when no longer needed + ($tmp = $pkg->{svr}) =~ s{\.2\.el\d(\.rf)$}{$1} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + + # atrpms (remove .at) + ($tmp = $pkg->{svr}) =~ s{\.at$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + # atrpms (remove .el4.at) + ($tmp = $pkg->{svr}) =~ s{\.el\d\.at$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + # atrpms (remove .el4) + ($tmp = $pkg->{svr}) =~ s{\.el\d$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + # atrpms (remove .0.el5, minor modification not pushed to source?) TODO: remove when no longer needed + ($tmp = $pkg->{svr}) =~ s{\.0\.el\d$}{} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + + # Transformations that we hopefully won't have to use anymore TODO: remove if no issues + #($tmp = $pkg->{svr}) =~ s{(\.el\d)\.rf$}{$1} && $rpms->{$base}->{vers}->{$tmp} && last SRC; + #($tmp = $pkg->{svr}) =~ s{(\d+)\.\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{\.at$}{} && $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}++; + delete $cmp->{delete} if $cmp->{delete}; + } else { + $cmp->{delete}++; + } + } elsif ( $repos->{$cmp->{repo}}->{orig} ) { + $orig{$cmp->{nvra}}++; + unless ( $repos->{$cmp->{repo}}->{base} ) { + my $tag = dirname(dirname($cmp->{rpm}->{filename})); + qx(touch $tag/PUSHED) if ! $opts{t} && -d $tag && ! -f "$tag/PUSHED"; + } + } elsif ( $cmp->{src} ) { + if ( $cmp->{delete} && $cmp->{oldrepo} && $reposrc{$cmp->{oldrepo}}) { + $cmp->{repo} = $cmp->{oldrepo}; + delete $cmp->{delete}; + } + if ( $reposrc{$cmp->{repo}} ) { + $reposrc{$cmp->{repo}}->{srpm} = $cmp; + $srpm = $cmp if ! $srpm; + } elsif ( $seen{$cmp->{nvra}}->{repo} ne $cmp->{repo} && ! $cmp->{done} ) { + $cmp->{delete}++; + } + } elsif ( $seen{$cmp->{nvra}}->{repo} ne $cmp->{repo} ) { + $cmp->{delete}++; + } + } elsif ( $cmp->{src} ) { + if ( $reposrc{$cmp->{repo}} && $reposrc{$cmp->{repo}}->{srpm} && $reposrc{$cmp->{repo}}->{srpm}->{oldrepo} ne $cmp->{repo} ) { + $acnt->{$cmp->{repo}}->{$cmp->{rpm}->as_nvre}->{src} = [ + grep { $_ ne $reposrc{$cmp->{repo}}->{srpm} } @{$acnt->{$cmp->{repo}}->{$cmp->{rpm}->as_nvre}->{src}} + ]; + + if ( @{$reposrc{$cmp->{repo}}->{srpm}->{repos}} == 1 ) { + $reposrc{$cmp->{repo}}->{srpm}->{repo} = $reposrc{$cmp->{repo}}->{srpm}->{oldrepo}; + delete $reposrc{$cmp->{repo}}->{srpm}->{oldrepo}; + delete $reposrc{$cmp->{repo}}->{srpm}->{delete}; + delete $reposrc{$cmp->{repo}}->{srpm}->{repos}; + delete $reposrc{$cmp->{repo}}->{srpm}->{done}; + $seen{$cmp->{nvra}} = $cmp if $seen{$cmp->{nvra}} eq $reposrc{$cmp->{repo}}->{srpm}; + } else { + warn "How did I get here??"; + } + } else { + $seen{$cmp->{nvra}} = $cmp if $seen{$cmp->{nvra}}->{repo} ne $cmp->{repo}; + } + $srpm = $cmp if ! $srpm && $cmp->{src}; + $reposrc{$cmp->{repo}}->{srpm} = $cmp if $reposrc{$cmp->{repo}}; + } + } elsif ( $repos->{$cmp->{repo}}->{stage} ) { + $cmp->{delete}++; + } elsif ( $cmp->{src} || grep $_ eq $cmp->{rpm}->arch, @{$distrepo->{$ver}->{all_archs}} ) { + $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 = dirname(dirname($cmp->{rpm}->{filename})); + 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 = dirname(dirname($cmp->{rpm}->{filename})); + 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}; + if ( $latest{$cmp->{base}} && $cmp->{svr} eq $latest{$cmp->{base}} && $repos->{$cmp->{repo}}->{inc} ) { + $cmp->{latest}++ if ! $seen{$cmp->{nvra}} || $cmp->{src}; + } + $seen{$cmp->{nvra}} = $cmp unless $seen{$cmp->{nvra}}; + push @{$acnt->{$cmp->{repo}}->{$cmp->{rpm}->as_nvre}->{$cmp->{src} ? 'src' : $cmp->{rpm}->arch}}, $cmp unless $cmp->{done}; + } + $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 $rpm ( grep { $_->{repo} =~ m{/smedev$} } @rpms ) { - $rpm->{repo} = 'deleted' unless grep { $_->{filename} eq $rpm->{filename} } @devel; -} + 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 @{$distrepo->{$ver}->{'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" unless ( ($p =~ m{^syslinux-nonlinux-[0-9]}) || ($p =~ m{^lib(mcrypt|webp)-[0-9]}) ) ; + } + } + } + } -print "\n"; -foreach my $rpm ( grep { $_->{repo} !~ m{^(builds|deleted)$} } @rpms ) { - my $src; - my $srpm = $rpm->{rpm}->tag("SOURCERPM"); - - my @sources = (); - push @sources, ($src = $srpm); - push @sources, $src if (($src = $srpm) =~ s/\.el\d\.rf\./\.rf\./); - push @sources, $src if (($src = $srpm) =~ s/\.[0-3]\.el\d+\.rf\./\.rf\./); - push @sources, $src if (($src = $srpm) =~ s/\.(el|fc)\d\.at//); - push @sources, $src if (($src = $srpm) =~ s/\.at//); - push @sources, $src if (($src = $srpm) =~ s/\.(el|fc)\d//); - push @sources, $src if (($src = $srpm) =~ s/\.\d+\.(el|fc)\d//); - - my $found = 0; - my $repo = $rpm->{repo}; - foreach my $source ( @sources ) { - if ( $sources{$source} ) { - unless ( -f "$repo/SRPMS/$source" ) { - push @{$copy{"$repo/SRPMS"}}, "$sources{$source}/$source"; - $changed{$repo}++ unless $repo eq $stagedir; - } - $srpms{$repo}{$source}++; - $found++; - last; - } - } - print "Can't find source for ".$rpm->{rpm}->filename."\n" unless $found; -} + foreach my $pkg ( sort { $a->{nvra} cmp $b->{nvra} } @{$rpms->{$base}->{rpms}} ) { + if ( $pkg->{latest} && $pkg->{latest} == 1 ) { + unless ( grep { $_->{nvra} eq $pkg->{nvra} && $_->{repo} eq $stage } @{$rpms->{$base}->{rpms}} ) { + $pkg->{oldrepo} = $pkg->{repo} unless $pkg->{oldrepo}; + $pkg->{repo} = $stage; + push @{$pkg->{repos}}, $stage; + } + } + + if ( ! $print && ($pkg->{delete} || $pkg->{repos} || ( ! $repos->{$pkg->{repo}}->{base} && $pkg->{nosig} && $distrepo->{$ver}->{sign} ) ) ) { + print "\n$base ($disttag$ver)\n", "=" x length("$base ($disttag$ver)"), "\n"; + $print++; + } + + my $src = $pkg->{rpm}->filename; + if ( ! $repos->{$pkg->{repo}}->{base} && $pkg->{nosig} && $distrepo->{$ver}->{sign} ) { + print "sign package (", basename($pkg->{rpm}->filename), ")\n"; + unless ( $opts{t} ) { + qx(cat $HOME/.rpmpass | setsid rpm -D '_gpg_name $distrepo->{$ver}->{keyname}' --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/" : '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) } @{$distrepo->{$ver}->{'archs'}}; + } elsif ($ver>=10 && $pkg->{rpm}->arch =~ m{^(i[356]86)$} && $pkg->{arch} =~ m{^(x86_64)$} ) { + #add copy of i686 packages in x86_64 folder for SME>=10 + push @d, map { "${head}$_/$tail" . basename($pkg->{rpm}->filename) } @{$distrepo->{$ver}->{'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 = dirname(dirname($pkg->{rpm}->{filename})); + qx(rm -f $tag/PUSHED) if ! $opts{t} && -d $tag && -f "$tag/PUSHED"; + } + } + } -my @remove; -foreach my $repo ( keys %srpms ) { - foreach my $rpm ( keys %{$srpms{$repo}} ) { - unless ( $srpms{$repo}{$rpm} ) { - push @remove, "$repo/SRPMS/$rpm"; - $changed{$repo}++ unless $repo eq $stagedir; - } - } -} + if ( $rpms->{$base}->{srpms} ) { + foreach my $pkg ( sort { $b->{rpm} cmp $a->{rpm} } @{$rpms->{$base}->{srpms}} ) { + next if $pkg->{done} || $repos->{$pkg->{repo}}->{orig} || $repos->{$pkg->{repo}}->{base}; + $pkg->{delete}++; + my $src = $pkg->{rpm}->filename; + if ( ! $print && ($pkg->{delete} || $pkg->{repos} || ( $pkg->{nosig} && $distrepo->{$ver}->{sign} ) ) ) { + print "\n$base ($disttag$ver)\n", "=" x length("$base ($disttag$ver)"), "\n"; + $print++; + } + 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}; + } + } + } -print "\n"; -foreach my $repo ( sort keys %copy ) { - foreach my $rpm ( keys %{{ map { $_ => 1 } @{$copy{$repo}} }} ) { - print "copying $rpm to $repo/\n"; - system(qw(cp --preserve=timestamps), $rpm, "$repo/"); + 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 ( @{$distrepo->{$ver}->{'archs'}} ) { + my $dir = $distrepo->{$ver}->{repo} . "$repo/$arch"; + $dir = qx(readlink -f $dir); + if ( $dir ) { + chomp $dir; + } else { + $dir = $distrepo->{$ver}->{repo} . "$repo/$arch"; + } + print "rebuild $repo/$arch\n"; + unless ( $opts{t} ) { + my $checksum = "--checksum $distrepo->{$ver}->{checksum}"; + + my $exclude = ""; + $exclude .= " --exclude ${osdir}/*" if ( -d "$dir/Packages" && ${osdir} ne "Packages" ); + $exclude .= " --exclude *smeserver-release*.rpm" if $dir =~ m{test/|-testing/}; + + my $groupfile = ""; + $groupfile = "--simple-md-filenames --groupfile repodata/comps.xml" if -f "$dir/repodata/comps.xml"; + + qx(createrepo --update --database --exclude *.src.rpm --exclude *-debuginfo-*.rpm $checksum $exclude $groupfile $dir); + qx(repoview $dir); + + qx(rm -rf $dir/.olddata) if -d "$dir/.olddata"; + qx(rm -rf $dir/.repodata) if -d "$dir/.repodata"; + qx(rm -rf $dir/repodata/index.html) if -f "$dir/repodata/index.html"; + qx(rm -rf $dir/repodata/update-info) if -d "$dir/repodata/update-info"; + qx(rm -rf $dir/repodata/repoview) if -d "$dir/repodata/repoview"; + } + } + } + unless ( $opts{t} ) { + foreach (@{$distrepo->{$ver}->{'builds'}}) + { + finddepth(sub{rmdir}, "$_") if -d "$_"; } + finddepth(sub{rmdir}, $distrepo->{$ver}->{'community'}) if -d "$distrepo->{$ver}->{'community'}"; + } } -print "\n"; -foreach my $rpm ( keys %{{ map { $_ => 1 } (@remove, map { $_->{rpm}->filename } grep { $_->{repo} eq 'deleted' } @rpms) }} ) { - print "removing $rpm\n"; - unlink $rpm; +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; +} + +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 %changed ) { - my $dir=`readlink -f $repo/$arch`; - chomp $dir; - print "rebuilding $dir...\n"; - system(qw(createrepo), "$dir"); - system(qw(repoview), "$dir"); +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 = 1; + eval { my $sig = $pkg->dsaheader }; $nosig &= ! $@; + eval { my $sig = $pkg->rsaheader }; $nosig &= ! $@; + eval { my $sig = $pkg->siggpg }; $nosig &= ! $@; + eval { my $sig = $pkg->sigpgp }; $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 $onlypkg->{$ver}->{$repo} && !( $onlypkg->{$ver}->{$repo}->{$src} || $onlypkg->{$ver}->{$repo}->{$pkg->name} ); + return if $repos->{$repo}->{base} && $nosig && $baserepo->{$ver}->{sign}; + 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; + } }