# vi: encoding=utf-8 ts=8 sts=4 sw=4 et
import sys, os, config, string, urllib, re
+from common import fileexists, noarchcachedir
errnum=0
def bailoutonerror():
print "%d error(s) encountered... aborting" % errnum
sys.exit(1)
+def pinfo(msg):
+ print msg
+
def perror(msg):
global errnum
errnum=errnum+1
print msg
def rm(file):
+ #os.remove()
print 'rm: '+file
def mv(src, dst):
- print "mv: %s %s" % (src, dst)
+ #os.rename()
+ print "mv: %s %s" % (src, dst+'/'+src.split('/')[-1])
class Build:
def __init__(self):
self.tree=tree
self.name=name
self.loaded=False
- self.marked=False
+ self.marked4removal=False
+ self.marked4moving=False
self.load()
def __repr__(self):
return self.name
- def mark(self):
- if not self.marked:
- self.tree.markedpkgs.append(self)
+ def mark4moving(self):
+ if not self.marked4moving:
+ self.tree.marked4moving.append(self)
+ self.marked4moving=True
+
+ def mark4removal(self):
+ if not self.marked4removal:
+ self.tree.marked4removal.append(self)
+ self.marked4removal=True
def load(self):
f=open(self.tree.basedir+'/SRPMS/.metadata/'+self.name+'.src.rpm.info', 'r')
f.close()
self.loaded=True
if self.info.has_key('move'):
- self.mark()
+ self.mark4moving()
def writeinfo(self):
- f=open(self.tree.basedir+'/SRPMS/.metadata/'+name+'.src.rpm.info', 'w')
+ f=open(self.tree.basedir+'/SRPMS/.metadata/'+self.name+'.src.rpm.info', 'w')
for bid in self.build.keys():
f.write("info:build:%s:requester:%s\ninfo:build:%s:requester_email:%s\n" % (bid, self.build[bid].requester, bid, self.build[bid].requester_email))
for key in self.info.keys():
for arch in self.file.keys():
for rpm in self.file[arch]:
rm(self.tree.basedir+'/'+arch+'/RPMS/'+rpm)
+ if arch=='noarch':
+ if fileexists(noarchcachedir+rpm+'.filelist'):
+ rm(noarchcachedir+rpm+'.filelist')
+ if fileexists(noarchcachedir+rpm+'.reqlist'):
+ rm(noarchcachedir+rpm+'.reqlist')
rm(self.tree.basedir+'/SRPMS/.metadata/'+self.name+'.src.rpm.info')
def move(self, dsttree):
movedany=False
for arch in self.file.keys():
if arch in dsttree[self.name].file.keys():
+ pinfo("Arch %s for %s is already present in dest tree; removing from srctree" % (arch, self.name))
for rpm in self.file[arch]:
rm(self.tree.basedir+'/'+arch+'/RPMS/'+rpm)
else:
for bid in self.build.keys():
dsttree[self.name].build[bid]=self.build[bid]
dsttree[self.name].writeinfo()
- rm(self.tree.basedir+'/SRPMS/.metadata/'+self.name+'.src.rpm.info')
+ rm(self.tree.basedir+'/SRPMS/.metadata/'+self.name+'.src.rpm.info')
else:
for arch in self.file.keys():
for rpm in self.file[arch]:
def __init__(self, tree, loadall=False):
self.basedir=config.value['ftp_dir']+'/'+tree
self.loadedpkgs={}
- self.markedpkgs=[]
- def filter_pkgs(pkg):
- if not pkg[-13:]=='.src.rpm.info':
- return None
- else:
- return pkg[:-13]
- self.pkgnames=map(filter_pkgs, os.listdir(self.basedir+'/SRPMS/.metadata/'))
+ self.marked4removal=[]
+ self.marked4moving=[]
+ self.pkgnames=[]
+ self.__loadpkgnames()
if loadall:
- for i in self.pkgnames:
- self.loadedpkgs[i]=Pkg(i, self)
+ for pkgname in self.pkgnames:
+ self.loadedpkgs[pkgname]=Pkg(pkgname, self)
+
def __getitem__(self, key):
if self.loadedpkgs.has_key(key):
return self.loadedpkgs[key]
def keys(self):
return self.pkgnames
+ def testmove(self, dsttree):
+ self.__checkbuild()
+ self.__checkarchs(dsttree)
+
def movepkgs(self, dsttree):
self.__checkbuild()
bailoutonerror()
self.__rmolderfromsrc()
self.__rmotherfromdst(dsttree)
- for pkg in self.markedpkgs:
+ for pkg in self.marked4moving:
pkg.move(dsttree)
- def markpkgs(self, wannabepkgs):
+ def removepkgs(self):
+ for pkg in self.marked4removal:
+ pkg.remove()
+
+ def mark4removal(self, wannabepkgs):
+ self.__mark4something(wannabepkgs, Pkg.mark4removal)
+
+ def mark4moving(self, wannabepkgs):
+ self.__mark4something(wannabepkgs, Pkg.mark4moving)
+
+
+ # Internal functions below
+
+ def __loadpkgnames(self):
+ def checkfiletype(name):
+ if name[-13:]=='.src.rpm.info':
+ return True
+ else:
+ return False
+ list=filter(checkfiletype, os.listdir(self.basedir+'/SRPMS/.metadata'))
+ self.pkgnames=map((lambda x: x[:-13]), list)
+
+ def __mark4something(self, wannabepkgs, markfunction):
def chopoffextension(pkg):
found=pkg.find('.src.rpm')
if found==-1:
if pkgname in self.pkgnames:
if not pkgname in self.loadedpkgs.keys():
self.loadedpkgs[pkgname]=Pkg(pkgname, self)
- self.loadedpkgs[pkgname].mark()
+ markfunction(self.loadedpkgs[pkgname])
else:
perror(pkgname+" was not found in source tree")
bailoutonerror()
+
def __checkbuild(self):
#f=urllib.urlopen('http://ep09.pld-linux.org/~builderth/queue.txt')
f=open('queue.txt')
elif i[0]=='b':
requests[id]=requests[id]+i
f.close()
- for pkg in self.markedpkgs:
+ for pkg in self.marked4moving:
for bid in pkg.build.keys():
if requests.has_key(bid) and not requests[bid].find('?') == -1:
perror("Building of package %s (buildid %s) not finished" % (pkg,bid))
def __checkarchs(self, dsttree):
- def find_other_pkgs(pkg, tree):
- ziewre=re.compile(string.join(pkg.name.split('-')[:-2], '-')+'-[^-]*-[^-]*$')
- def filter_other_pkgs(x):
- if ziewre.match(x) and not x == pkg.name:
- return x
- else:
- return None
- return filter(filter_other_pkgs, tree.pkgnames)
- self.find_other_pkgs=find_other_pkgs
- for pkg in self.markedpkgs:
- otherpkgnames=find_other_pkgs(pkg, dsttree)
+ for pkg in self.marked4moving:
+ otherpkgnames=self.__find_other_pkgs(pkg, dsttree)
curarchs=[]
missingarchs=[]
for somepkg in otherpkgnames:
if arch not in pkg.file.keys():
missingarchs.append(arch)
if missingarchs:
- perror('Moving pkg %s would remove archs: %s' % (pkg, missingarchs))
+ perror('Moving %s would remove archs: %s' % (pkg, missingarchs))
def __rmolderfromsrc(self):
- def find_older_pkgs(pkg):
- def filter_older_pkgs(x):
- ziew=x.split('-')
- cur=pkg.name.split('-')
- if ziew[-2]<cur[-2]:
- return x
- elif ziew[-2]==cur[-2]:
- if ziew[-1]<cur[-1]:
- return x
- else:
- return None
- else:
- return None
- return filter(filter_older_pkgs, self.find_other_pkgs(pkg, self))
-
- for pkg in self.markedpkgs:
- olderpkgnames=find_older_pkgs(pkg)
+ for pkg in self.marked4moving:
+ olderpkgnames=self.__find_older_pkgs(pkg)
for i in olderpkgnames:
Pkg(i, self).remove()
def __rmotherfromdst(self, dsttree):
- for pkg in self.markedpkgs:
- pkgnames=self.find_other_pkgs(pkg, dsttree)
+ for pkg in self.marked4moving:
+ pkgnames=self.__find_other_pkgs(pkg, dsttree)
for i in pkgnames:
Pkg(i, dsttree).remove()
+ # Used more than once filter functions
+
+ def __find_other_pkgs(self, pkg, tree):
+ ziewre=re.compile(string.join(pkg.name.split('-')[:-2], '-')+'-[^-]*-[^-]*$')
+ def filter_other_pkgs(x):
+ if ziewre.match(x) and not x == pkg.name:
+ return True
+ else:
+ return False
+ return filter(filter_other_pkgs, tree.pkgnames)
+
+ def __find_older_pkgs(self, pkg):
+ def filter_older_pkgs(x):
+ checking=x.split('-')
+ curpkg=pkg.name.split('-')
+ if checking[-2]<curpkg[-2]:
+ return True
+ elif checking[-2]==curpkg[-2]:
+ if checking[-1]<curpkg[-1]:
+ return True
+ else:
+ return False
+ else:
+ return False
+ return filter(filter_older_pkgs, self.__find_other_pkgs(pkg, self))
+
projects / projects / pld-ftp-admin.git / blobdiff