--- /dev/null
+#!/usr/bin/python
+
+#
+# Copyright (c) 2011, Novell Inc.
+#
+# This program is licensed under the BSD license, read LICENSE.BSD
+# for further information
+#
+
+# pysolv a little software installer demoing the sat solver library/bindings
+
+# things it does:
+# - understands globs for package names / dependencies
+# - understands .arch suffix
+# - repository data caching
+# - on demand loading of secondary repository data
+# - checksum verification
+# - deltarpm support
+# - installation of commandline packages
+#
+# things not yet ported:
+# - gpg verification
+# - file conflicts
+# - fastestmirror implementation
+#
+# things available in the library but missing from pysolv:
+# - vendor policy loading
+# - soft locks file handling
+# - multi version handling
+
+import sys
+import os
+import glob
+import solv
+import re
+import tempfile
+import time
+import subprocess
+import fnmatch
+import rpm
+from stat import *
+from solv import Pool, Repo, Dataiterator, Job, Solver, Transaction
+from iniparse import INIConfig
+from optparse import OptionParser
+
+#import gc
+#gc.set_debug(gc.DEBUG_LEAK)
+
+def calc_cookie_file(filename):
+ chksum = solv.Chksum(solv.REPOKEY_TYPE_SHA256)
+ chksum.add("1.1")
+ chksum.add_stat(filename)
+ return chksum.raw()
+
+def calc_cookie_fp(fp):
+ chksum = solv.Chksum(solv.REPOKEY_TYPE_SHA256)
+ chksum.add_fp(fp)
+ return chksum.raw()
+
+class generic_repo(dict):
+ def __init__(self, attribs):
+ for k in attribs:
+ self[k] = attribs[k]
+
+ def cachepath(self, ext = None):
+ path = re.sub(r'^\.', '_', self['alias'])
+ if ext:
+ path += "_" + ext + ".solvx"
+ else:
+ path += ".solv"
+ return "/var/cache/solv/" + re.sub(r'[/]', '_', path)
+
+ def load(self, pool):
+ self['handle'] = pool.add_repo(repo['alias'])
+ self['handle'].appdata = repo
+ self['handle'].priority = 99 - repo['priority']
+ if self['autorefresh']:
+ dorefresh = True
+ if dorefresh:
+ try:
+ st = os.stat(self.cachepath())
+ if time.time() - st[ST_MTIME] < self['metadata_expire']:
+ dorefresh = False
+ except OSError, e:
+ pass
+ self['cookie'] = ''
+ if not dorefresh and self.usecachedrepo(None):
+ print "repo: '%s': cached" % self['alias']
+ return True
+ return self.load_if_changed()
+
+ def load_ext(repodata):
+ return False
+
+ def setfromurls(self, urls):
+ if not urls:
+ return
+ url = urls[0]
+ print "[using mirror %s]" % re.sub(r'^(.*?/...*?)/.*$', r'\1', url)
+ self['baseurl'] = url
+
+ def setfrommetalink(self, metalink):
+ nf = self.download(metalink, False, None)
+ if not nf:
+ return None
+ f = os.fdopen(os.dup(solv.xfileno(nf)), 'r')
+ solv.xfclose(nf)
+ urls = []
+ chksum = None
+ for l in f.readlines():
+ l = l.strip()
+ m = re.match(r'^<hash type="sha256">([0-9a-fA-F]{64})</hash>', l)
+ if m:
+ chksum = solv.Chksum(solv.REPOKEY_TYPE_SHA256, m.group(1))
+ m = re.match(r'^<url.*>(https?://.+)repodata/repomd.xml</url>', l)
+ if m:
+ urls.append(m.group(1))
+ if not urls:
+ chksum = None # in case the metalink is about a different file
+ f.close()
+ self.setfromurls(urls)
+ return chksum
+
+ def setfrommirrorlist(self, mirrorlist):
+ nf = self.download(mirrorlist, False, None)
+ if not nf:
+ return
+ f = os.fdopen(os.dup(solv.xfileno(nf)), 'r')
+ solv.xfclose(nf)
+ urls = []
+ for l in f.readline():
+ l = l.strip()
+ if l[0:6] == 'http://' or l[0:7] == 'https://':
+ urls.append(l)
+ self.setfromurls(urls)
+ f.close()
+
+ def download(self, file, uncompress, chksum, markincomplete=False):
+ url = None
+ if 'baseurl' not in self:
+ if 'metalink' in self:
+ if file != self['metalink']:
+ metalinkchksum = self.setfrommetalink(self['metalink'])
+ if file == 'repodata/repomd.xml' and metalinkchksum and not chksum:
+ chksum = metalinkchksum
+ else:
+ url = file
+ elif 'mirrorlist' in self:
+ if file != self['mirrorlist']:
+ self.setfrommirrorlist(self['mirrorlist'])
+ else:
+ url = file
+ if not url:
+ if 'baseurl' not in self:
+ print "%s: no baseurl" % self['alias']
+ return None
+ url = re.sub(r'/$', '', self['baseurl']) + '/' + file
+ f = tempfile.TemporaryFile()
+ st = subprocess.call(['curl', '-f', '-s', '-L', url], stdout=f.fileno())
+ if os.lseek(f.fileno(), 0, os.SEEK_CUR) == 0 and (st == 0 or not chksum):
+ return None
+ os.lseek(f.fileno(), 0, os.SEEK_SET)
+ if st:
+ print "%s: download error %d" % (file, st)
+ if markincomplete:
+ self['incomplete'] = True
+ return None
+ if chksum:
+ fchksum = solv.Chksum(chksum.type)
+ if not fchksum:
+ print "%s: unknown checksum type" % file
+ if markincomplete:
+ self['incomplete'] = True
+ return None
+ fchksum.add_fd(f.fileno())
+ if not fchksum.matches(chksum):
+ print "%s: checksum mismatch" % file
+ if markincomplete:
+ self['incomplete'] = True
+ return None
+ if uncompress:
+ return solv.xfopen_fd(file, os.dup(f.fileno()))
+ return solv.xfopen_fd("", os.dup(f.fileno()))
+
+ def usecachedrepo(self, ext, mark=False):
+ if not ext:
+ cookie = self['cookie']
+ else:
+ cookie = self['extcookie']
+ handle = self['handle']
+ try:
+ repopath = self.cachepath(ext)
+ f = open(repopath, 'r')
+ f.seek(-32, os.SEEK_END)
+ fcookie = f.read(32)
+ if len(fcookie) != 32:
+ return False
+ if cookie and fcookie != cookie:
+ return False
+ if self['alias'] != '@System' and not ext:
+ f.seek(-32 * 2, os.SEEK_END)
+ fextcookie = f.read(32)
+ if len(fextcookie) != 32:
+ return False
+ f.seek(0)
+ flags = 0
+ if ext:
+ flags = Repo.REPO_USE_LOADING|Repo.REPO_EXTEND_SOLVABLES
+ if ext != 'DL':
+ flags |= Repo.REPO_LOCALPOOL
+ if not self['handle'].add_solv(f, flags):
+ return False
+ if self['alias'] != '@System' and not ext:
+ self['cookie'] = fcookie
+ self['extcookie'] = fextcookie
+ if mark:
+ # no futimes in python?
+ try:
+ os.utime(repopath, None)
+ except Exception, e:
+ pass
+ except IOError, e:
+ return False
+ return True
+
+ def genextcookie(self, f):
+ chksum = solv.Chksum(solv.REPOKEY_TYPE_SHA256)
+ chksum.add(self['cookie'])
+ if f:
+ stat = os.fstat(f.fileno())
+ chksum.add(str(stat[ST_DEV]))
+ chksum.add(str(stat[ST_INO]))
+ chksum.add(str(stat[ST_SIZE]))
+ chksum.add(str(stat[ST_MTIME]))
+ extcookie = chksum.raw()
+ # compatibility to c code
+ if ord(extcookie[0]) == 0:
+ extcookie[0] = chr(1)
+ self['extcookie'] = extcookie
+
+ def writecachedrepo(self, ext, info=None):
+ try:
+ if not os.path.isdir("/var/cache/solv"):
+ os.mkdir("/var/cache/solv", 0755)
+ (fd, tmpname) = tempfile.mkstemp(prefix='.newsolv-', dir='/var/cache/solv')
+ os.fchmod(fd, 0444)
+ f = os.fdopen(fd, 'w+')
+ if not info:
+ self['handle'].write(f)
+ elif ext:
+ info.write(f)
+ else: # rewrite_repos case
+ self['handle'].write_first_repodata(f)
+ if self['alias'] != '@System' and not ext:
+ if 'extcookie' not in self:
+ self.genextcookie(f)
+ f.write(self['extcookie'])
+ if not ext:
+ f.write(self['cookie'])
+ else:
+ f.write(self['extcookie'])
+ f.close()
+ if self['handle'].iscontiguous():
+ # switch to saved repo to activate paging and save memory
+ nf = solv.xfopen(tmpname)
+ if not ext:
+ # main repo
+ self['handle'].empty()
+ if not self['handle'].add_solv(nf, Repo.SOLV_ADD_NO_STUBS):
+ sys.exit("internal error, cannot reload solv file")
+ else:
+ # extension repodata
+ # need to extend to repo boundaries, as this is how
+ # info.write() has written the data
+ info.extend_to_repo()
+ # LOCALPOOL does not help as pool already contains all ids
+ info.read_solv_flags(nf, Repo.REPO_EXTEND_SOLVABLES)
+ solv.xfclose(nf)
+ os.rename(tmpname, self.cachepath(ext))
+ except IOError, e:
+ if tmpname:
+ os.unlink(tmpname)
+
+ def updateaddedprovides(self, addedprovides):
+ if 'incomplete' in self:
+ return
+ if 'handle' not in self:
+ return
+ if not self['handle'].nsolvables:
+ return
+ # make sure there's just one real repodata with extensions
+ repodata = self['handle'].first_repodata()
+ if not repodata:
+ return
+ oldaddedprovides = repodata.lookup_idarray(solv.SOLVID_META, solv.REPOSITORY_ADDEDFILEPROVIDES)
+ if not set(addedprovides) <= set(oldaddedprovides):
+ for id in addedprovides:
+ repodata.add_idarray(solv.SOLVID_META, solv.REPOSITORY_ADDEDFILEPROVIDES, id)
+ repodata.internalize()
+ self.writecachedrepo(None, repodata)
+
+class repomd_repo(generic_repo):
+ def load_if_changed(self):
+ print "rpmmd repo '%s':" % self['alias'],
+ sys.stdout.flush()
+ f = self.download("repodata/repomd.xml", False, None, None)
+ if not f:
+ print "no repomd.xml file, skipped"
+ self['handle'].free(True)
+ del self['handle']
+ return False
+ self['cookie'] = calc_cookie_fp(f)
+ if self.usecachedrepo(None, True):
+ print "cached"
+ solv.xfclose(f)
+ return True
+ self['handle'].add_repomdxml(f, 0)
+ solv.xfclose(f)
+ print "fetching"
+ (filename, filechksum) = self.find('primary')
+ if filename:
+ f = self.download(filename, True, filechksum, True)
+ if f:
+ self['handle'].add_rpmmd(f, None, 0)
+ solv.xfclose(f)
+ if 'incomplete' in self:
+ return False # hopeless, need good primary
+ (filename, filechksum) = self.find('updateinfo')
+ if filename:
+ f = self.download(filename, True, filechksum, True)
+ if f:
+ self['handle'].add_updateinfoxml(f, 0)
+ solv.xfclose(f)
+ self.add_exts()
+ if 'incomplete' not in self:
+ self.writecachedrepo(None)
+ # must be called after writing the repo
+ self['handle'].create_stubs()
+ return True
+
+ def find(self, what):
+ di = self['handle'].dataiterator_new(solv.SOLVID_META, solv.REPOSITORY_REPOMD_TYPE, what, Dataiterator.SEARCH_STRING)
+ di.prepend_keyname(solv.REPOSITORY_REPOMD)
+ for d in di:
+ d.setpos_parent()
+ filename = d.pool.lookup_str(solv.SOLVID_POS, solv.REPOSITORY_REPOMD_LOCATION)
+ chksum = d.pool.lookup_checksum(solv.SOLVID_POS, solv.REPOSITORY_REPOMD_CHECKSUM)
+ if filename and not chksum:
+ print "no %s file checksum!" % filename
+ filename = None
+ chksum = None
+ if filename:
+ return (filename, chksum)
+ return (None, None)
+
+ def add_ext(self, repodata, what, ext):
+ filename, chksum = self.find(what)
+ if not filename and what == 'deltainfo':
+ filename, chksum = self.find('prestodelta')
+ if not filename:
+ return
+ handle = repodata.new_handle()
+ repodata.set_poolstr(handle, solv.REPOSITORY_REPOMD_TYPE, what)
+ repodata.set_str(handle, solv.REPOSITORY_REPOMD_LOCATION, filename)
+ repodata.set_bin_checksum(handle, solv.REPOSITORY_REPOMD_CHECKSUM, chksum)
+ if what == 'deltainfo':
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOSITORY_DELTAINFO)
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOKEY_TYPE_FLEXARRAY)
+ elif what == 'filelists':
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.SOLVABLE_FILELIST)
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOKEY_TYPE_DIRSTRARRAY)
+ repodata.add_flexarray(solv.SOLVID_META, solv.REPOSITORY_EXTERNAL, handle)
+
+ def add_exts(self):
+ repodata = self['handle'].add_repodata(0)
+ self.add_ext(repodata, 'deltainfo', 'DL')
+ self.add_ext(repodata, 'filelists', 'FL')
+ repodata.internalize()
+
+ def load_ext(self, repodata):
+ repomdtype = repodata.lookup_str(solv.SOLVID_META, solv.REPOSITORY_REPOMD_TYPE)
+ if repomdtype == 'filelists':
+ ext = 'FL'
+ elif repomdtype == 'deltainfo':
+ ext = 'DL'
+ else:
+ return False
+ sys.stdout.write("[%s:%s" % (self['alias'], ext))
+ if self.usecachedrepo(ext):
+ sys.stdout.write(" cached]\n")
+ sys.stdout.flush()
+ return True
+ sys.stdout.write(" fetching]\n")
+ sys.stdout.flush()
+ filename = repodata.lookup_str(solv.SOLVID_META, solv.REPOSITORY_REPOMD_LOCATION)
+ filechksum = repodata.lookup_checksum(solv.SOLVID_META, solv.REPOSITORY_REPOMD_CHECKSUM)
+ f = self.download(filename, True, filechksum)
+ if not f:
+ return False
+ if ext == 'FL':
+ self['handle'].add_rpmmd(f, 'FL', Repo.REPO_USE_LOADING|Repo.REPO_EXTEND_SOLVABLES)
+ elif ext == 'DL':
+ self['handle'].add_deltainfoxml(f, Repo.REPO_USE_LOADING)
+ solv.xfclose(f)
+ self.writecachedrepo(ext, repodata)
+ return True
+
+class susetags_repo(generic_repo):
+ def load_if_changed(self):
+ print "susetags repo '%s':" % self['alias'],
+ sys.stdout.flush()
+ f = self.download("content", False, None, None)
+ if not f:
+ print "no content file, skipped"
+ self['handle'].free(True)
+ del self['handle']
+ return False
+ self['cookie'] = calc_cookie_fp(f)
+ if self.usecachedrepo(None, True):
+ print "cached"
+ solv.xfclose(f)
+ return True
+ self['handle'].add_content(f, 0)
+ solv.xfclose(f)
+ print "fetching"
+ defvendorid = self['handle'].lookup_id(solv.SOLVID_META, solv.SUSETAGS_DEFAULTVENDOR)
+ descrdir = self['handle'].lookup_str(solv.SOLVID_META, solv.SUSETAGS_DESCRDIR)
+ if not descrdir:
+ descrdir = "suse/setup/descr"
+ (filename, filechksum) = self.find('packages.gz')
+ if not filename:
+ (filename, filechksum) = self.find('packages')
+ if filename:
+ f = self.download(descrdir + '/' + filename, True, filechksum, True)
+ if f:
+ self['handle'].add_susetags(f, defvendorid, None, Repo.REPO_NO_INTERNALIZE|Repo.SUSETAGS_RECORD_SHARES)
+ solv.xfclose(f)
+ (filename, filechksum) = self.find('packages.en.gz')
+ if not filename:
+ (filename, filechksum) = self.find('packages.en')
+ if filename:
+ f = self.download(descrdir + '/' + filename, True, filechksum, True)
+ if f:
+ self['handle'].add_susetags(f, defvendorid, None, Repo.REPO_NO_INTERNALIZE|Repo.REPO_REUSE_REPODATA|Repo.REPO_EXTEND_SOLVABLES)
+ solv.xfclose(f)
+ self['handle'].internalize()
+ self.add_exts()
+ if 'incomplete' not in self:
+ self.writecachedrepo(None)
+ # must be called after writing the repo
+ self['handle'].create_stubs()
+ return True
+
+ def find(self, what):
+ di = self['handle'].dataiterator_new(solv.SOLVID_META, solv.SUSETAGS_FILE_NAME, what, Dataiterator.SEARCH_STRING)
+ di.prepend_keyname(solv.SUSETAGS_FILE)
+ for d in di:
+ d.setpos_parent()
+ chksum = d.pool.lookup_checksum(solv.SOLVID_POS, solv.SUSETAGS_FILE_CHECKSUM)
+ return (what, chksum)
+ return (None, None)
+
+ def add_ext(self, repodata, what, ext):
+ (filename, chksum) = self.find(what)
+ if not filename:
+ return
+ handle = repodata.new_handle()
+ repodata.set_str(handle, solv.SUSETAGS_FILE_NAME, filename)
+ if chksum:
+ repodata.set_bin_checksum(handle, solv.SUSETAGS_FILE_CHECKSUM, chksum)
+ if ext == 'DU':
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.SOLVABLE_DISKUSAGE)
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOKEY_TYPE_DIRNUMNUMARRAY)
+ elif ext == 'FL':
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.SOLVABLE_FILELIST)
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOKEY_TYPE_DIRSTRARRAY)
+ else:
+ for langtag, langtagtype in [
+ (solv.SOLVABLE_SUMMARY, solv.REPOKEY_TYPE_STR),
+ (solv.SOLVABLE_DESCRIPTION, solv.REPOKEY_TYPE_STR),
+ (solv.SOLVABLE_EULA, solv.REPOKEY_TYPE_STR),
+ (solv.SOLVABLE_MESSAGEINS, solv.REPOKEY_TYPE_STR),
+ (solv.SOLVABLE_MESSAGEDEL, solv.REPOKEY_TYPE_STR),
+ (solv.SOLVABLE_CATEGORY, solv.REPOKEY_TYPE_ID)
+ ]:
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, self['handle'].pool.id2langid(langtag, ext, 1))
+ repodata.add_idarray(handle, solv.REPOSITORY_KEYS, langtagtype)
+ repodata.add_flexarray(solv.SOLVID_META, solv.REPOSITORY_EXTERNAL, handle)
+
+ def add_exts(self):
+ repodata = self['handle'].add_repodata(0)
+ di = self['handle'].dataiterator_new(solv.SOLVID_META, solv.SUSETAGS_FILE_NAME, None, 0)
+ di.prepend_keyname(solv.SUSETAGS_FILE)
+ for d in di:
+ filename = d.match_str()
+ if not filename:
+ continue
+ if filename[0:9] != "packages.":
+ continue
+ if len(filename) == 11 and filename != "packages.gz":
+ ext = filename[9:11]
+ elif filename[11:12] == ".":
+ ext = filename[9:11]
+ else:
+ continue
+ if ext == "en":
+ continue
+ self.add_ext(repodata, filename, ext)
+ repodata.internalize()
+
+ def load_ext(self, repodata):
+ filename = repodata.lookup_str(solv.SOLVID_META, solv.SUSETAGS_FILE_NAME)
+ ext = filename[9:11]
+ sys.stdout.write("[%s:%s" % (self['alias'], ext))
+ if self.usecachedrepo(ext):
+ sys.stdout.write(" cached]\n")
+ sys.stdout.flush()
+ return True
+ sys.stdout.write(" fetching]\n")
+ sys.stdout.flush()
+ defvendorid = self['handle'].lookup_id(solv.SOLVID_META, solv.SUSETAGS_DEFAULTVENDOR)
+ descrdir = self['handle'].lookup_str(solv.SOLVID_META, solv.SUSETAGS_DESCRDIR)
+ if not descrdir:
+ descrdir = "suse/setup/descr"
+ filechksum = repodata.lookup_checksum(solv.SOLVID_META, solv.SUSETAGS_FILE_CHECKSUM)
+ f = self.download(descrdir + '/' + filename, True, filechksum)
+ if not f:
+ return False
+ self['handle'].add_susetags(f, defvendorid, None, Repo.REPO_USE_LOADING|Repo.REPO_EXTEND_SOLVABLES)
+ solv.xfclose(f)
+ self.writecachedrepo(ext, repodata)
+ return True
+
+class unknown_repo(generic_repo):
+ def load(self, pool):
+ print "unsupported repo '%s': skipped" % self['alias']
+ return False
+
+class system_repo(generic_repo):
+ def load(self, pool):
+ self['handle'] = pool.add_repo(self['alias'])
+ self['handle'].appdata = self
+ pool.installed = self['handle']
+ print "rpm database:",
+ self['cookie'] = calc_cookie_file("/var/lib/rpm/Packages")
+ if self.usecachedrepo(None):
+ print "cached"
+ return True
+ print "reading"
+ self['handle'].add_products("/etc/products.d", Repo.REPO_NO_INTERNALIZE)
+ self['handle'].add_rpmdb(None)
+ self.writecachedrepo(None)
+ return True
+
+class cmdline_repo(generic_repo):
+ def load(self, pool):
+ self['handle'] = pool.add_repo(self['alias'])
+ self['handle'].appdata = self
+ return True
+
+def validarch(pool, arch):
+ if not arch:
+ return False
+ id = pool.str2id(arch, False)
+ if not id:
+ return False
+ return pool.isknownarch(id)
+
+def limitjobs(pool, jobs, flags, evr):
+ njobs = []
+ for j in jobs:
+ how = j.how
+ sel = how & Job.SOLVER_SELECTMASK
+ what = pool.rel2id(j.what, evr, flags)
+ if flags == solv.REL_ARCH:
+ how |= Job.SOLVER_SETARCH
+ if flags == solv.REL_EQ and sel == Job.SOLVER_SOLVABLE_NAME:
+ if pool.id2str(evr).find('-') >= 0:
+ how |= Job.SOLVER_SETEVR
+ else:
+ how |= Job.SOLVER_SETEV
+ njobs.append(pool.Job(how, what))
+ return njobs
+
+def limitjobs_arch(pool, jobs, flags, evr):
+ m = re.match(r'(.+)\.(.+?)$', evr)
+ if m and validarch(pool, m.group(2)):
+ jobs = limitjobs(pool, jobs, solv.REL_ARCH, pool.str2id(m.group(2)))
+ return limitjobs(pool, jobs, flags, pool.str2id(m.group(1)))
+ else:
+ return limitjobs(pool, jobs, flags, pool.str2id(evr))
+
+def mkjobs_filelist(pool, cmd, arg):
+ if re.search(r'[[*?]', arg):
+ type = Dataiterator.SEARCH_GLOB
+ else:
+ type = Dataiterator.SEARCH_STRING
+ if cmd == 'rm' or cmd == 'erase':
+ di = pool.installed.dataiterator_new(0, solv.SOLVABLE_FILELIST, arg, type | Dataiterator.SEARCH_FILES|Dataiterator.SEARCH_COMPLETE_FILELIST)
+ else:
+ di = pool.dataiterator_new(0, solv.SOLVABLE_FILELIST, arg, type | Dataiterator.SEARCH_FILES|Dataiterator.SEARCH_COMPLETE_FILELIST)
+ matches = []
+ for d in di:
+ s = d.solvable
+ if s and s.installable():
+ matches.append(s.id)
+ di.skip_solvable() # one match is enough
+ if matches:
+ print "[using file list match for '%s']" % arg
+ if len(matches) > 1:
+ return [ pool.Job(Job.SOLVER_SOLVABLE_ONE_OF, pool.towhatprovides(matches)) ]
+ else:
+ return [ pool.Job(Job.SOLVER_SOLVABLE | Job.SOLVER_NOAUTOSET, matches[0]) ]
+ return []
+
+def mkjobs_rel(pool, cmd, name, rel, evr):
+ flags = 0
+ if rel.find('<') >= 0: flags |= solv.REL_LT
+ if rel.find('=') >= 0: flags |= solv.REL_EQ
+ if rel.find('>') >= 0: flags |= solv.REL_GT
+ jobs = depglob(pool, name, True, True)
+ if jobs:
+ return limitjobs(pool, jobs, flags, pool.str2id(evr))
+ m = re.match(r'(.+)\.(.+?)$', name)
+ if m and validarch(pool, m.group(2)):
+ jobs = depglob(pool, m.group(1), True, True)
+ if jobs:
+ jobs = limitjobs(pool, jobs, solv.REL_ARCH, pool.str2id(m.group(2)))
+ return limitjobs(pool, jobs, flags, pool.str2id(evr))
+ return []
+
+def mkjobs_nevra(pool, cmd, arg):
+ jobs = depglob(pool, arg, True, True)
+ if jobs:
+ return jobs
+ m = re.match(r'(.+)\.(.+?)$', arg)
+ if m and validarch(pool, m.group(2)):
+ jobs = depglob(pool, m.group(1), True, True)
+ if jobs:
+ return limitjobs(pool, jobs, solv.REL_ARCH, pool.str2id(m.group(2)))
+ m = re.match(r'(.+)-(.+?)$', arg)
+ if m:
+ jobs = depglob(pool, m.group(1), True, False)
+ if jobs:
+ return limitjobs_arch(pool, jobs, solv.REL_EQ, m.group(2))
+ m = re.match(r'(.+)-(.+?-.+?)$', arg)
+ if m:
+ jobs = depglob(pool, m.group(1), True, False)
+ if jobs:
+ return limitjobs_arch(pool, jobs, solv.REL_EQ, m.group(2))
+ return []
+
+def mkjobs(pool, cmd, arg):
+ if len(arg) and arg[0] == '/':
+ jobs = mkjobs_filelist(pool, cmd, arg)
+ if jobs:
+ return jobs
+ m = re.match(r'(.+?)\s*([<=>]+)\s*(.+?)$', arg)
+ if m:
+ return mkjobs_rel(pool, cmd, m.group(1), m.group(2), m.group(3))
+ else:
+ return mkjobs_nevra(pool, cmd, arg)
+
+def depglob(pool, name, globname, globdep):
+ id = pool.str2id(name, False)
+ if id:
+ match = False
+ for s in pool.providers(id):
+ if globname and s.nameid == id:
+ return [ pool.Job(Job.SOLVER_SOLVABLE_NAME, id) ]
+ match = True
+ if match:
+ if globname and globdep:
+ print "[using capability match for '%s']" % name
+ return [ pool.Job(Job.SOLVER_SOLVABLE_PROVIDES, id) ]
+ if not re.search(r'[[*?]', name):
+ return []
+ if globname:
+ # try name glob
+ idmatches = {}
+ for s in pool.solvables:
+ if s.installable() and fnmatch.fnmatch(s.name, name):
+ idmatches[s.nameid] = True
+ if idmatches:
+ return [ pool.Job(Job.SOLVER_SOLVABLE_NAME, id) for id in sorted(idmatches.keys()) ]
+ if globdep:
+ # try dependency glob
+ idmatches = {}
+ for id in pool.allprovidingids():
+ if fnmatch.fnmatch(pool.id2str(id), name):
+ idmatches[id] = True
+ if idmatches:
+ print "[using capability match for '%s']" % name
+ return [ pool.Job(Job.SOLVER_SOLVABLE_PROVIDES, id) for id in sorted(idmatches.keys()) ]
+ return []
+
+
+def load_stub(repodata):
+ repo = repodata.repo.appdata
+ if repo:
+ return repo.load_ext(repodata)
+ return False
+
+
+parser = OptionParser(usage="usage: solv.py [options] COMMAND")
+(options, args) = parser.parse_args()
+if not args:
+ parser.print_help(sys.stderr)
+ sys.exit(1)
+
+cmd = args[0]
+args = args[1:]
+if cmd == 'li':
+ cmd = 'list'
+if cmd == 'in':
+ cmd = 'install'
+if cmd == 'rm':
+ cmd = 'erase'
+if cmd == 've':
+ cmd = 'verify'
+if cmd == 'se':
+ cmd = 'search'
+
+
+pool = solv.Pool()
+pool.setarch(os.uname()[4])
+pool.set_loadcallback(load_stub)
+
+# read all repo configs
+repos = []
+for reposdir in ["/etc/zypp/repos.d"]:
+ if not os.path.isdir(reposdir):
+ continue
+ for reponame in sorted(glob.glob('%s/*.repo' % reposdir)):
+ cfg = INIConfig(open(reponame))
+ for alias in cfg:
+ repoattr = {'alias': alias, 'enabled': 0, 'priority': 99, 'autorefresh': 1, 'type': 'rpm-md', 'metadata_expire': 900}
+ for k in cfg[alias]:
+ repoattr[k] = cfg[alias][k]
+ if 'mirrorlist' in repoattr and 'metalink' not in repoattr:
+ if repoattr['mirrorlist'].find('/metalink'):
+ repoattr['metalink'] = repoattr['mirrorlist']
+ del repoattr['mirrorlist']
+ if repoattr['type'] == 'rpm-md':
+ repo = repomd_repo(repoattr)
+ elif repoattr['type'] == 'yast2':
+ repo = susetags_repo(repoattr)
+ else:
+ repo = unknown_repo(repoattr)
+ repos.append(repo)
+
+# now load all enabled repos into the pool
+sysrepo = system_repo({ 'alias': '@System', 'type': 'system' })
+sysrepo.load(pool)
+for repo in repos:
+ if int(repo['enabled']):
+ repo.load(pool)
+
+if cmd == 'search':
+ matches = {}
+ di = pool.dataiterator_new(0, solv.SOLVABLE_NAME, args[0], Dataiterator.SEARCH_SUBSTRING|Dataiterator.SEARCH_NOCASE)
+ for d in di:
+ matches[d.solvid] = True
+ for solvid in sorted(matches.keys()):
+ print " - %s [%s]: %s" % (pool.solvid2str(solvid), pool.solvables[solvid].repo.name, pool.lookup_str(solvid, solv.SOLVABLE_SUMMARY))
+ sys.exit(0)
+
+cmdlinerepo = None
+if cmd == 'list' or cmd == 'info' or cmd == 'install':
+ for arg in args:
+ if arg.endswith(".rpm") and os.access(arg, os.R_OK):
+ if not cmdlinerepo:
+ cmdlinerepo = cmdline_repo({ 'alias': '@commandline', 'type': 'commandline' })
+ cmdlinerepo.load(pool)
+ cmdlinerepo['packages'] = {}
+ cmdlinerepo['packages'][arg] = cmdlinerepo['handle'].add_rpm(arg, Repo.REPO_REUSE_REPODATA|Repo.REPO_NO_INTERNALIZE)
+ if cmdlinerepo:
+ cmdlinerepo['handle'].internalize()
+
+addedprovides = pool.addfileprovides_ids()
+if addedprovides:
+ sysrepo.updateaddedprovides(addedprovides)
+ for repo in repos:
+ repo.updateaddedprovides(addedprovides)
+
+pool.createwhatprovides()
+
+# convert arguments into jobs
+jobs = []
+for arg in args:
+ if cmdlinerepo and arg in cmdlinerepo['packages']:
+ jobs.append(pool.Job(Job.SOLVER_SOLVABLE, cmdlinerepo['packages'][arg]))
+ else:
+ jobs += mkjobs(pool, cmd, arg)
+
+if cmd == 'list' or cmd == 'info':
+ if not jobs:
+ print "no package matched."
+ sys.exit(1)
+ for job in jobs:
+ for s in pool.jobsolvables(job):
+ if cmd == 'info':
+ print "Name: %s" % s.str()
+ print "Repo: %s" % s.repo.name
+ print "Summary: %s" % s.lookup_str(solv.SOLVABLE_SUMMARY)
+ str = s.lookup_str(solv.SOLVABLE_URL)
+ if str:
+ print "Url: %s" % str
+ str = s.lookup_str(solv.SOLVABLE_LICENSE)
+ if str:
+ print "License: %s" % str
+ print "Description:\n%s" % s.lookup_str(solv.SOLVABLE_DESCRIPTION)
+ print
+ else:
+ print " - %s [%s]" % (s.str(), s.repo.name)
+ print " %s" % s.lookup_str(solv.SOLVABLE_SUMMARY)
+ sys.exit(0)
+
+if cmd == 'install' or cmd == 'erase' or cmd == 'up' or cmd == 'dup' or cmd == 'verify':
+ if not jobs:
+ if cmd == 'up' or cmd == 'verify':
+ jobs = [ pool.Job(Job.SOLVER_SOLVABLE_ALL, 0) ]
+ elif cmd == 'dup':
+ pass
+ else:
+ print "no package matched."
+ sys.exit(1)
+ for job in jobs:
+ if cmd == 'up':
+ # up magic: use install instead of update if no installed package matches
+ if job.how == Job.SOLVER_SOLVABLE_ALL or filter(lambda s: s.isinstalled(), pool.jobsolvables(job)):
+ job.how |= Job.SOLVER_UPDATE
+ else:
+ job.how |= Job.SOLVER_INSTALL
+ elif cmd == 'install':
+ job.how |= Job.SOLVER_INSTALL
+ elif cmd == 'erase':
+ job.how |= Job.SOLVER_ERASE
+ elif cmd == 'dup':
+ job.how |= Job.SOLVER_DISTUPGRADE
+ elif cmd == 'verify':
+ job.how |= Job.SOLVER_VERIFY
+
+ #pool.set_debuglevel(2)
+ solver = None
+ while True:
+ solver = pool.create_solver()
+ solver.ignorealreadyrecommended = True
+ if cmd == 'erase':
+ solver.allowuninstall = True
+ if cmd == 'dup' and not jobs:
+ solver.distupgrade = True
+ solver.updatesystem = True
+ solver.allowdowngrade = True
+ solver.allowvendorchange = True
+ solver.dosplitprovides = True
+ if cmd == 'up' and len(jobs) == 1 and jobs[0].how == (Job.SOLVER_UPDATE | Job.SOLVER_SOLVABLE_ALL):
+ solver.dosplitprovides = True
+ problems = solver.solve(jobs)
+ if not problems:
+ break
+ for problem in problems:
+ print "Problem %d:" % problem.id
+ r = problem.findproblemrule()
+ type, source, target, dep = r.info()
+ if type == Solver.SOLVER_RULE_DISTUPGRADE:
+ print "%s does not belong to a distupgrade repository" % source.str()
+ elif type == Solver.SOLVER_RULE_INFARCH:
+ print "%s has inferiour architecture" % source.str()
+ elif type == Solver.SOLVER_RULE_UPDATE:
+ print "problem with installed package %s" % source.str()
+ elif type == Solver.SOLVER_RULE_JOB:
+ print "conflicting requests"
+ elif type == Solver.SOLVER_RULE_JOB_NOTHING_PROVIDES_DEP:
+ print "nothing provides requested %s" % pool.dep2str(dep)
+ elif type == Solver.SOLVER_RULE_RPM:
+ print "some dependency problem"
+ elif type == Solver.SOLVER_RULE_RPM_NOT_INSTALLABLE:
+ print "package %s is not installable" % source.str()
+ elif type == Solver.SOLVER_RULE_RPM_NOTHING_PROVIDES_DEP:
+ print "nothing provides %s needed by %s" % (pool.dep2str(dep), source.str())
+ elif type == Solver.SOLVER_RULE_RPM_SAME_NAME:
+ print "cannot install both %s and %s" % (source.str(), target.str())
+ elif type == Solver.SOLVER_RULE_RPM_PACKAGE_CONFLICT:
+ print "package %s conflicts with %s provided by %s" % (source.str(), pool.dep2str(dep), target.str())
+ elif type == Solver.SOLVER_RULE_RPM_PACKAGE_OBSOLETES:
+ print "package %s obsoletes %s provided by %s" % (source.str(), pool.dep2str(dep), target.str())
+ elif type == Solver.SOLVER_RULE_RPM_INSTALLEDPKG_OBSOLETES:
+ print "installed package %s obsoletes %s provided by %s" % (source.str(), pool.dep2str(dep), target.str())
+ elif type == Solver.SOLVER_RULE_RPM_IMPLICIT_OBSOLETES:
+ print "package %s implicitely obsoletes %s provided by %s" % (source.str(), pool.dep2str(dep), target.str())
+ elif type == Solver.SOLVER_RULE_RPM_PACKAGE_REQUIRES:
+ print "package %s requires %s, but none of the providers can be installed" % (source.str(), pool.dep2str(dep))
+ elif type == Solver.SOLVER_RULE_RPM_SELF_CONFLICT:
+ print "package %s conflicts with %s provided by itself" % (source.str(), pool.dep2str(dep))
+ else:
+ print "bad rule type", type
+ solutions = problem.solutions()
+ for solution in solutions:
+ print " Solution %d:" % solution.id
+ elements = solution.elements()
+ for element in elements:
+ etype = element.type
+ if etype == Solver.SOLVER_SOLUTION_JOB:
+ print " - do not ask to", jobs[element.jobidx].str()
+ elif etype == Solver.SOLVER_SOLUTION_INFARCH:
+ if element.solvable.isinstalled():
+ print " - keep %s despite the inferior architecture" % element.solvable.str()
+ else:
+ print " - install %s despite the inferior architecture" % element.solvable.str()
+ elif etype == Solver.SOLVER_SOLUTION_DISTUPGRADE:
+ if element.solvable.isinstalled():
+ print " - keep obsolete %s" % element.solvable.str()
+ else:
+ print " - install %s from excluded repository" % element.solvable.str()
+ elif etype == Solver.SOLVER_SOLUTION_REPLACE:
+ illegal = element.illegalreplace()
+ if illegal & solver.POLICY_ILLEGAL_DOWNGRADE:
+ print " - allow downgrade of %s to %s" % (element.solvable.str(), element.replacement.str())
+ if illegal & solver.POLICY_ILLEGAL_ARCHCHANGE:
+ print " - allow architecture change of %s to %s" % (element.solvable.str(), element.replacement.str())
+ if illegal & solver.POLICY_ILLEGAL_VENDORCHANGE:
+ if element.replacement.vendorid:
+ print " - allow vendor change from '%s' (%s) to '%s' (%s)" % (element.solvable.vendor, element.solvable.str(), element.replacement.vendor, element.replacement.str())
+ else:
+ print " - allow vendor change from '%s' (%s) to no vendor (%s)" % (element.solvable.vendor, element.solvable.str(), element.replacement.str())
+ if illegal == 0:
+ print " - allow replacement of %s with %s" % (element.solvable.str(), element.replacement.str())
+ elif etype == Solver.SOLVER_SOLUTION_DEINSTALL:
+ print " - allow deinstallation of %s" % element.solvable.str()
+ sol = ''
+ while not (sol == 's' or sol == 'q' or (sol.isdigit() and int(sol) >= 1 and int(sol) <= len(solutions))):
+ sys.stdout.write("Please choose a solution: ")
+ sys.stdout.flush()
+ sol = sys.stdin.readline().strip()
+ if sol == 's':
+ continue # skip problem
+ if sol == 'q':
+ sys.exit(1)
+ solution = solutions[int(sol) - 1]
+ for element in solution.elements():
+ etype = element.type
+ newjob = None
+ if etype == Solver.SOLVER_SOLUTION_JOB:
+ jobs[element.jobidx] = pool.Job(Job.SOLVER_NOOP, 0)
+ elif etype == Solver.SOLVER_SOLUTION_INFARCH or etype == Solver.SOLVER_SOLUTION_DISTUPGRADE:
+ newjob = pool.Job(Job.SOLVER_INSTALL|Job.SOLVER_SOLVABLE, element.solvable.id)
+ elif etype == Solver.SOLVER_SOLUTION_REPLACE:
+ newjob = pool.Job(Job.SOLVER_INSTALL|Job.SOLVER_SOLVABLE, element.replacement.id)
+ elif etype == Solver.SOLVER_SOLUTION_DEINSTALL:
+ newjob = pool.Job(Job.SOLVER_ERASE|Job.SOLVER_SOLVABLE, element.solvable.id)
+ if newjob:
+ for job in jobs:
+ if job.how == newjob.how and job.what == newjob.what:
+ newjob = None
+ break
+ if newjob:
+ jobs.append(newjob)
+ # no problems, show transaction
+ trans = solver.transaction()
+ del solver
+ if trans.isempty():
+ print "Nothing to do."
+ sys.exit(0)
+ print
+ print "Transaction summary:"
+ print
+ for ctype, pkgs, fromid, toid in trans.classify():
+ if ctype == Transaction.SOLVER_TRANSACTION_ERASE:
+ print "%d erased packages:" % len(pkgs)
+ elif ctype == Transaction.SOLVER_TRANSACTION_INSTALL:
+ print "%d installed packages:" % len(pkgs)
+ elif ctype == Transaction.SOLVER_TRANSACTION_REINSTALLED:
+ print "%d reinstalled packages:" % len(pkgs)
+ elif ctype == Transaction.SOLVER_TRANSACTION_DOWNGRADED:
+ print "%d downgraded packages:" % len(pkgs)
+ elif ctype == Transaction.SOLVER_TRANSACTION_CHANGED:
+ print "%d changed packages:" % len(pkgs)
+ elif ctype == Transaction.SOLVER_TRANSACTION_UPGRADED:
+ print "%d upgraded packages:" % len(pkgs)
+ elif ctype == Transaction.SOLVER_TRANSACTION_VENDORCHANGE:
+ print "%d vendor changes from '%s' to '%s':" % (len(pkgs), pool.id2str(fromid), pool.id2str(toid))
+ elif ctype == Transaction.SOLVER_TRANSACTION_ARCHCHANGE:
+ print "%d arch changes from '%s' to '%s':" % (len(pkgs), pool.id2str(fromid), pool.id2str(toid))
+ else:
+ continue
+ for p in pkgs:
+ if ctype == Transaction.SOLVER_TRANSACTION_UPGRADED or ctype == Transaction.SOLVER_TRANSACTION_DOWNGRADED:
+ op = trans.othersolvable(p)
+ print " - %s -> %s" % (p.str(), op.str())
+ else:
+ print " - %s" % p.str()
+ print
+ print "install size change: %d K" % trans.calc_installsizechange()
+ print
+
+# vim: sw=4 et
+ while True:
+ sys.stdout.write("OK to continue (y/n)? ")
+ sys.stdout.flush()
+ yn = sys.stdin.readline().strip()
+ if yn == 'y': break
+ if yn == 'n': sys.exit(1)
+ newpkgs, keptpkgs = trans.installedresult()
+ newpkgsfp = {}
+ if newpkgs:
+ downloadsize = 0
+ for p in newpkgs:
+ downloadsize += p.lookup_num(solv.SOLVABLE_DOWNLOADSIZE)
+ print "Downloading %d packages, %d K" % (len(newpkgs), downloadsize)
+ for p in newpkgs:
+ repo = p.repo.appdata
+ location, medianr = p.lookup_location()
+ if not location:
+ continue
+ if repo['type'] == 'commandline':
+ f = solv.xfopen(location)
+ if not f:
+ sys.exit("\n%s: %s not found" % location)
+ newpkgsfp[p.id] = f
+ continue
+ if sysrepo['handle'].nsolvables and os.access('/usr/bin/applydeltarpm', os.X_OK):
+ pname = p.name
+ di = p.repo.dataiterator_new(solv.SOLVID_META, solv.DELTA_PACKAGE_NAME, pname, Dataiterator.SEARCH_STRING)
+ di.prepend_keyname(solv.REPOSITORY_DELTAINFO)
+ for d in di:
+ d.setpos_parent()
+ if pool.lookup_id(solv.SOLVID_POS, solv.DELTA_PACKAGE_EVR) != p.evrid or pool.lookup_id(solv.SOLVID_POS, solv.DELTA_PACKAGE_ARCH) != p.archid:
+ continue
+ baseevrid = pool.lookup_id(solv.SOLVID_POS, solv.DELTA_BASE_EVR)
+ candidate = None
+ for installedp in pool.providers(p.nameid):
+ if installedp.isinstalled() and installedp.nameid == p.nameid and installedp.archid == p.archid and installedp.evrid == baseevrid:
+ candidate = installedp
+ if not candidate:
+ continue
+ seq = pool.lookup_str(solv.SOLVID_POS, solv.DELTA_SEQ_NAME) + '-' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_SEQ_EVR) + '-' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_SEQ_NUM)
+ st = subprocess.call(['/usr/bin/applydeltarpm', '-a', p.arch, '-c', '-s', seq])
+ if st:
+ continue
+ chksum = pool.lookup_checksum(solv.SOLVID_POS, solv.DELTA_CHECKSUM)
+ if not chksum:
+ continue
+ dloc = pool.lookup_str(solv.SOLVID_POS, solv.DELTA_LOCATION_DIR) + '/' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_LOCATION_NAME) + '-' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_LOCATION_EVR) + '.' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_LOCATION_SUFFIX)
+ f = repo.download(dloc, False, chksum)
+ if not f:
+ continue
+ nf = tempfile.TemporaryFile()
+ nf = os.dup(nf.fileno())
+ st = subprocess.call(['/usr/bin/applydeltarpm', '-a', p.arch, "/dev/fd/%d" % solv.xfileno(f), "/dev/fd/%d" % nf])
+ solv.xfclose(f)
+ os.lseek(nf, 0, os.SEEK_SET)
+ newpkgsfp[p.id] = solv.xfopen_fd("", nf)
+ break
+ if p.id in newpkgsfp:
+ sys.stdout.write("d")
+ sys.stdout.flush()
+ continue
+
+ if repo['type'] == 'yast2':
+ datadir = repo['handle'].lookup_str(solv.SOLVID_META, solv.SUSETAGS_DATADIR)
+ if not datadir:
+ datadir = 'suse'
+ location = datadir + '/' + location
+ chksum = p.lookup_checksum(solv.SOLVABLE_CHECKSUM)
+ f = repo.download(location, False, chksum)
+ if not f:
+ sys.exit("\n%s: %s not found in repository" % (repo['alias'], location))
+ newpkgsfp[p.id] = f
+ sys.stdout.write(".")
+ sys.stdout.flush()
+ print
+ print "Committing transaction:"
+ print
+ ts = rpm.TransactionSet('/')
+ ts.setVSFlags(rpm._RPMVSF_NOSIGNATURES)
+ erasenamehelper = {}
+ for p in trans.steps():
+ type = trans.steptype(p, Transaction.SOLVER_TRANSACTION_RPM_ONLY)
+ if type == Transaction.SOLVER_TRANSACTION_ERASE:
+ rpmdbid = p.lookup_num(solv.RPM_RPMDBID)
+ erasenamehelper[p.name] = p
+ if not rpmdbid:
+ sys.exit("\ninternal error: installed package %s has no rpmdbid\n" % p.str())
+ ts.addErase(rpmdbid)
+ elif type == Transaction.SOLVER_TRANSACTION_INSTALL:
+ f = newpkgsfp[p.id]
+ h = ts.hdrFromFdno(solv.xfileno(f))
+ os.lseek(solv.xfileno(f), 0, os.SEEK_SET)
+ ts.addInstall(h, p, 'u')
+ elif type == Transaction.SOLVER_TRANSACTION_MULTIINSTALL:
+ f = newpkgsfp[p.id]
+ h = ts.hdrFromFdno(solv.xfileno(f))
+ os.lseek(solv.xfileno(f), 0, os.SEEK_SET)
+ ts.addInstall(h, p, 'i')
+ checkproblems = ts.check()
+ if checkproblems:
+ print checkproblems
+ sys.exit("Sorry.")
+ ts.order()
+ def runCallback(reason, amount, total, p, d):
+ if reason == rpm.RPMCALLBACK_INST_OPEN_FILE:
+ return solv.xfileno(newpkgsfp[p.id])
+ if reason == rpm.RPMCALLBACK_INST_START:
+ print "install", p.str()
+ if reason == rpm.RPMCALLBACK_UNINST_START:
+ # argh, p is just the name of the package
+ if p in erasenamehelper:
+ p = erasenamehelper[p]
+ print "erase", p.str()
+ runproblems = ts.run(runCallback, '')
+ if runproblems:
+ print runproblems
+ sys.exit(1)
+ sys.exit(0)
+
+print "unknown command", cmd
+sys.exit(1)
+++ /dev/null
-#!/usr/bin/python
-
-#
-# Copyright (c) 2011, Novell Inc.
-#
-# This program is licensed under the BSD license, read LICENSE.BSD
-# for further information
-#
-
-# pysolv a little software installer demoing the sat solver library/bindings
-
-# things it does:
-# - understands globs for package names / dependencies
-# - understands .arch suffix
-# - repository data caching
-# - on demand loading of secondary repository data
-# - checksum verification
-# - deltarpm support
-# - installation of commandline packages
-#
-# things not yet ported:
-# - gpg verification
-# - file conflicts
-# - fastestmirror implementation
-#
-# things available in the library but missing from pysolv:
-# - vendor policy loading
-# - soft locks file handling
-# - multi version handling
-
-import sys
-import os
-import glob
-import solv
-import re
-import tempfile
-import time
-import subprocess
-import fnmatch
-import rpm
-from stat import *
-from solv import Pool, Repo, Dataiterator, Job, Solver, Transaction
-from iniparse import INIConfig
-from optparse import OptionParser
-
-#import gc
-#gc.set_debug(gc.DEBUG_LEAK)
-
-def calc_cookie_stat(stat):
- chksum = solv.Chksum(solv.REPOKEY_TYPE_SHA256)
- chksum.add("1.1")
- chksum.add(str(stat[ST_DEV]))
- chksum.add(str(stat[ST_INO]))
- chksum.add(str(stat[ST_SIZE]))
- chksum.add(str(stat[ST_MTIME]))
- return chksum.raw()
-
-def calc_cookie_fp(fp):
- chksum = solv.Chksum(solv.REPOKEY_TYPE_SHA256)
- chksum.add_fp(fp)
- return chksum.raw()
-
-def calccachepath(repo, repoext = None):
- path = re.sub(r'^\.', '_', repo['alias'])
- if repoext:
- path += "_" + repoext + ".solvx"
- else:
- path += ".solv"
- return "/var/cache/solv/" + re.sub(r'[/]', '_', path)
-
-def usecachedrepo(repo, repoext, mark=False):
- if not repoext:
- cookie = repo['cookie']
- else:
- cookie = repo['extcookie']
- handle = repo['handle']
- try:
- repopath = calccachepath(repo, repoext)
- f = open(repopath, 'r')
- f.seek(-32, os.SEEK_END)
- fcookie = f.read(32)
- if len(fcookie) != 32:
- return False
- if cookie and fcookie != cookie:
- return False
- if repo['alias'] != '@System' and not repoext:
- f.seek(-32 * 2, os.SEEK_END)
- fextcookie = f.read(32)
- if len(fextcookie) != 32:
- return False
- f.seek(0)
- flags = 0
- if repoext:
- flags = Repo.REPO_USE_LOADING|Repo.REPO_EXTEND_SOLVABLES
- if repoext != 'DL':
- flags |= Repo.REPO_LOCALPOOL
- if not repo['handle'].add_solv(f, flags):
- return False
- if repo['alias'] != '@System' and not repoext:
- repo['cookie'] = fcookie
- repo['extcookie'] = fextcookie
- if mark:
- # no futimes in python?
- try:
- os.utime(repopath, None)
- except Exception, e:
- pass
- except IOError, e:
- return False
- return True
-
-def writecachedrepo(repo, repoext, info=None):
- try:
- if not os.path.isdir("/var/cache/solv"):
- os.mkdir("/var/cache/solv", 0755)
- (fd, tmpname) = tempfile.mkstemp(prefix='.newsolv-', dir='/var/cache/solv')
- os.fchmod(fd, 0444)
- f = os.fdopen(fd, 'w+')
- if not info:
- repo['handle'].write(f)
- elif repoext:
- info.write(f)
- else:
- # rewrite_repos case
- repo['handle'].write_first_repodata(f)
- if repo['alias'] != '@System' and not repoext:
- if 'extcookie' not in repo:
- # create unique id
- extcookie = calc_cookie_stat(os.fstat(f.fileno()))
- extcookie = ''.join(chr(ord(s)^ord(c)) for s,c in zip(extcookie, repo['cookie']))
- if ord(extcookie[0]) == 0:
- extcookie[0] = chr(1)
- repo['extcookie'] = extcookie
- f.write(repo['extcookie'])
- if not repoext:
- f.write(repo['cookie'])
- else:
- f.write(repo['extcookie'])
- f.close()
- if repo['handle'].iscontiguous():
- # switch to saved repo to activate paging and save memory
- nf = solv.xfopen(tmpname)
- if not repoext:
- # main repo
- repo['handle'].empty()
- if not repo['handle'].add_solv(nf, Repo.SOLV_ADD_NO_STUBS):
- sys.exit("internal error, cannot reload solv file")
- else:
- # extension repodata
- # need to extend to repo boundaries, as this is how
- # info.write() has written the data
- info.extend_to_repo()
- # LOCALPOOL does not help as pool already contains all ids
- info.read_solv_flags(nf, Repo.REPO_EXTEND_SOLVABLES)
- solv.xfclose(nf)
- os.rename(tmpname, calccachepath(repo, repoext))
- except IOError, e:
- if tmpname:
- os.unlink(tmpname)
-
-def curlfopen(repo, file, uncompress, chksum, badchecksum=None):
- baseurl = repo['baseurl']
- url = re.sub(r'/$', '', baseurl) + '/' + file
- f = tempfile.TemporaryFile()
- st = subprocess.call(['curl', '-f', '-s', '-L', url], stdout=f.fileno())
- if os.lseek(f.fileno(), 0, os.SEEK_CUR) == 0 and (st == 0 or not chksum):
- return None
- os.lseek(f.fileno(), 0, os.SEEK_SET)
- if st:
- print "%s: download error %d" % (file, st)
- if badchecksum:
- badchecksum['True'] = 'True'
- return None
- if chksum:
- fchksum = solv.Chksum(chksum.type)
- if not fchksum:
- print "%s: unknown checksum type" % file
- if badchecksum:
- badchecksum['True'] = 'True'
- return None
- fchksum.add_fd(f.fileno())
- if not fchksum.matches(chksum):
- print "%s: checksum mismatch" % file
- if badchecksum:
- badchecksum['True'] = 'True'
- return None
- if uncompress:
- return solv.xfopen_fd(file, os.dup(f.fileno()))
- return solv.xfopen_fd("", os.dup(f.fileno()))
-
-def repomd_find(repo, what):
- di = repo['handle'].dataiterator_new(solv.SOLVID_META, solv.REPOSITORY_REPOMD_TYPE, what, Dataiterator.SEARCH_STRING)
- di.prepend_keyname(solv.REPOSITORY_REPOMD)
- for d in di:
- d.setpos_parent()
- filename = d.pool.lookup_str(solv.SOLVID_POS, solv.REPOSITORY_REPOMD_LOCATION)
- chksum = d.pool.lookup_checksum(solv.SOLVID_POS, solv.REPOSITORY_REPOMD_CHECKSUM)
- if filename and not chksum:
- print "no %s file checksum!" % filename
- filename = None
- chksum = None
- if filename:
- return (filename, chksum)
- return (None, None)
-
-def repomd_add_ext(repo, repodata, what, ext):
- filename, chksum = repomd_find(repo, what)
- if not filename:
- return False
- if what == 'prestodelta':
- what = 'deltainfo'
- handle = repodata.new_handle()
- repodata.set_poolstr(handle, solv.REPOSITORY_REPOMD_TYPE, what)
- repodata.set_str(handle, solv.REPOSITORY_REPOMD_LOCATION, filename)
- repodata.set_bin_checksum(handle, solv.REPOSITORY_REPOMD_CHECKSUM, chksum)
- if what == 'deltainfo':
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOSITORY_DELTAINFO)
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOKEY_TYPE_FLEXARRAY)
- elif what == 'filelists':
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.SOLVABLE_FILELIST)
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOKEY_TYPE_DIRSTRARRAY)
- repodata.add_flexarray(solv.SOLVID_META, solv.REPOSITORY_EXTERNAL, handle)
- return True
-
-def repomd_add_exts(repo):
- repodata = repo['handle'].add_repodata(0)
- if not repomd_add_ext(repo, repodata, 'deltainfo', 'DL'):
- repomd_add_ext(repo, repodata, 'prestodelta', 'DL')
- repomd_add_ext(repo, repodata, 'filelists', 'FL')
- repodata.internalize()
-
-def repomd_load_ext(repo, repodata):
- repomdtype = repodata.lookup_str(solv.SOLVID_META, solv.REPOSITORY_REPOMD_TYPE)
- if repomdtype == 'filelists':
- ext = 'FL'
- elif repomdtype == 'deltainfo':
- ext = 'DL'
- else:
- return False
- sys.stdout.write("[%s:%s" % (repo['alias'], ext))
- if usecachedrepo(repo, ext):
- sys.stdout.write(" cached]\n")
- sys.stdout.flush()
- return True
- sys.stdout.write(" fetching]\n")
- sys.stdout.flush()
- filename = repodata.lookup_str(solv.SOLVID_META, solv.REPOSITORY_REPOMD_LOCATION)
- filechksum = repodata.lookup_checksum(solv.SOLVID_META, solv.REPOSITORY_REPOMD_CHECKSUM)
- f = curlfopen(repo, filename, True, filechksum)
- if not f:
- return False
- if ext == 'FL':
- repo['handle'].add_rpmmd(f, 'FL', Repo.REPO_USE_LOADING|Repo.REPO_EXTEND_SOLVABLES)
- elif ext == 'DL':
- repo['handle'].add_deltainfoxml(f, Repo.REPO_USE_LOADING)
- solv.xfclose(f)
- writecachedrepo(repo, ext, repodata)
- return True
-
-def susetags_find(repo, what):
- di = repo['handle'].dataiterator_new(solv.SOLVID_META, solv.SUSETAGS_FILE_NAME, what, Dataiterator.SEARCH_STRING)
- di.prepend_keyname(solv.SUSETAGS_FILE)
- for d in di:
- d.setpos_parent()
- chksum = d.pool.lookup_checksum(solv.SOLVID_POS, solv.SUSETAGS_FILE_CHECKSUM)
- return (what, chksum)
- return (None, None)
-
-def susetags_add_ext(repo, repodata, what, ext):
- (filename, chksum) = susetags_find(repo, what)
- if not filename:
- return False
- handle = repodata.new_handle()
- repodata.set_str(handle, solv.SUSETAGS_FILE_NAME, filename)
- if chksum:
- repodata.set_bin_checksum(handle, solv.SUSETAGS_FILE_CHECKSUM, chksum)
- if ext == 'DU':
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.SOLVABLE_DISKUSAGE)
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOKEY_TYPE_DIRNUMNUMARRAY)
- elif ext == 'FL':
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.SOLVABLE_FILELIST)
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, solv.REPOKEY_TYPE_DIRSTRARRAY)
- else:
- for langtag, langtagtype in [
- (solv.SOLVABLE_SUMMARY, solv.REPOKEY_TYPE_STR),
- (solv.SOLVABLE_DESCRIPTION, solv.REPOKEY_TYPE_STR),
- (solv.SOLVABLE_EULA, solv.REPOKEY_TYPE_STR),
- (solv.SOLVABLE_MESSAGEINS, solv.REPOKEY_TYPE_STR),
- (solv.SOLVABLE_MESSAGEDEL, solv.REPOKEY_TYPE_STR),
- (solv.SOLVABLE_CATEGORY, solv.REPOKEY_TYPE_ID)
- ]:
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, repo['handle'].pool.id2langid(langtag, ext, 1))
- repodata.add_idarray(handle, solv.REPOSITORY_KEYS, langtagtype)
- repodata.add_flexarray(solv.SOLVID_META, solv.REPOSITORY_EXTERNAL, handle)
- return True
-
-def susetags_add_exts(repo):
- repodata = repo['handle'].add_repodata(0)
- di = repo['handle'].dataiterator_new(solv.SOLVID_META, solv.SUSETAGS_FILE_NAME, None, 0)
- di.prepend_keyname(solv.SUSETAGS_FILE)
- for d in di:
- filename = d.match_str()
- if not filename:
- continue
- if filename[0:9] != "packages.":
- continue
- if len(filename) == 11 and filename != "packages.gz":
- ext = filename[9:11]
- elif filename[11:12] == ".":
- ext = filename[9:11]
- else:
- continue
- if ext == "en":
- continue
- susetags_add_ext(repo, repodata, filename, ext)
- repodata.internalize()
-
-def susetags_load_ext(repo, repodata):
- filename = repodata.lookup_str(solv.SOLVID_META, solv.SUSETAGS_FILE_NAME)
- ext = filename[9:11]
- sys.stdout.write("[%s:%s" % (repo['alias'], ext))
- if usecachedrepo(repo, ext):
- sys.stdout.write(" cached]\n")
- sys.stdout.flush()
- return True
- sys.stdout.write(" fetching]\n")
- sys.stdout.flush()
- defvendorid = repo['handle'].lookup_id(solv.SOLVID_META, solv.SUSETAGS_DEFAULTVENDOR)
- descrdir = repo['handle'].lookup_str(solv.SOLVID_META, solv.SUSETAGS_DESCRDIR)
- if not descrdir:
- descrdir = "suse/setup/descr"
- filechksum = repodata.lookup_checksum(solv.SOLVID_META, solv.SUSETAGS_FILE_CHECKSUM)
- f = curlfopen(repo, descrdir + '/' + filename, True, filechksum)
- if not f:
- return False
- repo['handle'].add_susetags(f, defvendorid, None, Repo.REPO_USE_LOADING|Repo.REPO_EXTEND_SOLVABLES)
- solv.xfclose(f)
- writecachedrepo(repo, ext, repodata)
- return True
-
-def validarch(pool, arch):
- if not arch:
- return False
- id = pool.str2id(arch, False)
- if not id:
- return False
- return pool.isknownarch(id)
-
-def limitjobs(pool, jobs, flags, evr):
- njobs = []
- for j in jobs:
- how = j.how
- sel = how & Job.SOLVER_SELECTMASK
- what = pool.rel2id(j.what, evr, flags)
- if flags == solv.REL_ARCH:
- how |= Job.SOLVER_SETARCH
- if flags == solv.REL_EQ and sel == Job.SOLVER_SOLVABLE_NAME:
- if pool.id2str(evr).find('-') >= 0:
- how |= Job.SOLVER_SETEVR
- else:
- how |= Job.SOLVER_SETEV
- njobs.append(pool.Job(how, what))
- return njobs
-
-def limitjobs_arch(pool, jobs, flags, evr):
- m = re.match(r'(.+)\.(.+?)$', evr)
- if m and validarch(pool, m.group(2)):
- jobs = limitjobs(pool, jobs, solv.REL_ARCH, pool.str2id(m.group(2)))
- return limitjobs(pool, jobs, flags, pool.str2id(m.group(1)))
- else:
- return limitjobs(pool, jobs, flags, pool.str2id(evr))
-
-def mkjobs(pool, cmd, arg):
- if len(arg) and arg[0] == '/':
- if re.search(r'[[*?]', arg):
- type = Dataiterator.SEARCH_GLOB
- else:
- type = Dataiterator.SEARCH_STRING
- if cmd == 'rm' or cmd == 'erase':
- di = pool.installed.dataiterator_new(0, solv.SOLVABLE_FILELIST, arg, type | Dataiterator.SEARCH_FILES|Dataiterator.SEARCH_COMPLETE_FILELIST)
- else:
- di = pool.dataiterator_new(0, solv.SOLVABLE_FILELIST, arg, type | Dataiterator.SEARCH_FILES|Dataiterator.SEARCH_COMPLETE_FILELIST)
- matches = []
- for d in di:
- s = d.solvable
- if s and s.installable():
- matches.append(s.id)
- di.skip_solvable() # one match is enough
- if len(matches):
- print "[using file list match for '%s']" % arg
- if len(matches) > 1:
- return [ pool.Job(Job.SOLVER_SOLVABLE_ONE_OF, pool.towhatprovides(matches)) ]
- else:
- return [ pool.Job(Job.SOLVER_SOLVABLE | Job.SOLVER_NOAUTOSET, matches[0]) ]
- m = re.match(r'(.+?)\s*([<=>]+)\s*(.+?)$', arg)
- if m:
- (name, rel, evr) = m.group(1, 2, 3)
- flags = 0
- if rel.find('<') >= 0: flags |= solv.REL_LT
- if rel.find('=') >= 0: flags |= solv.REL_EQ
- if rel.find('>') >= 0: flags |= solv.REL_GT
- jobs = depglob(pool, name, True, True)
- if len(jobs):
- return limitjobs(pool, jobs, flags, pool.str2id(evr))
- m = re.match(r'(.+)\.(.+?)$', name)
- if m and validarch(pool, m.group(2)):
- jobs = depglob(pool, m.group(1), True, True)
- if len(jobs):
- jobs = limitjobs(pool, jobs, solv.REL_ARCH, pool.str2id(m.group(2)))
- return limitjobs(pool, jobs, flags, pool.str2id(evr))
- else:
- jobs = depglob(pool, arg, True, True)
- if len(jobs):
- return jobs
- m = re.match(r'(.+)\.(.+?)$', arg)
- if m and validarch(pool, m.group(2)):
- jobs = depglob(pool, m.group(1), True, True)
- if len(jobs):
- return limitjobs(pool, jobs, solv.REL_ARCH, pool.str2id(m.group(2)))
- m = re.match(r'(.+)-(.+?)$', arg)
- if m:
- jobs = depglob(pool, m.group(1), True, False)
- if len(jobs):
- return limitjobs_arch(pool, jobs, solv.REL_EQ, m.group(2))
- m = re.match(r'(.+)-(.+?-.+?)$', arg)
- if m:
- jobs = depglob(pool, m.group(1), True, False)
- if len(jobs):
- return limitjobs_arch(pool, jobs, solv.REL_EQ, m.group(2))
- return []
-
-
-def depglob(pool, name, globname, globdep):
- id = pool.str2id(name, False)
- if id:
- match = False
- for s in pool.providers(id):
- if globname and s.nameid == id:
- return [ pool.Job(Job.SOLVER_SOLVABLE_NAME, id) ]
- match = True
- if match:
- if globname and globdep:
- print "[using capability match for '%s']" % name
- return [ pool.Job(Job.SOLVER_SOLVABLE_PROVIDES, id) ]
- if not re.search(r'[[*?]', name):
- return []
- if globname:
- # try name glob
- idmatches = {}
- for s in pool.solvables:
- if s.installable() and fnmatch.fnmatch(s.name, name):
- idmatches[s.nameid] = True
- if len(idmatches):
- return [ pool.Job(Job.SOLVER_SOLVABLE_NAME, id) for id in sorted(idmatches.keys()) ]
- if globdep:
- # try dependency glob
- idmatches = {}
- for id in pool.allprovidingids():
- if fnmatch.fnmatch(pool.id2str(id), name):
- idmatches[id] = True
- if len(idmatches):
- print "[using capability match for '%s']" % name
- return [ pool.Job(Job.SOLVER_SOLVABLE_PROVIDES, id) for id in sorted(idmatches.keys()) ]
- return []
-
-
-def load_stub(repodata):
- if repodata.lookup_str(solv.SOLVID_META, solv.REPOSITORY_REPOMD_TYPE):
- return repomd_load_ext(repodata.repo.appdata, repodata)
- if repodata.lookup_str(solv.SOLVID_META, solv.SUSETAGS_FILE_NAME):
- return susetags_load_ext(repodata.repo.appdata, repodata)
- return False
-
-def rewrite_repos(pool, addedprovides):
- addedprovidesset = set(addedprovides)
- for repohandle in pool.repos:
- repo = repohandle.appdata
- if 'cookie' not in repo: # ignore commandlinerepo
- continue
- if not repohandle.nsolvables:
- continue
- # make sure there's just one real repodata with extensions
- repodata = repohandle.first_repodata()
- if not repodata:
- continue
- oldaddedprovides = repodata.lookup_idarray(solv.SOLVID_META, solv.REPOSITORY_ADDEDFILEPROVIDES)
- oldaddedprovidesset = set(oldaddedprovides)
- if not addedprovidesset <= oldaddedprovidesset:
- for id in addedprovides:
- repodata.add_idarray(solv.SOLVID_META, solv.REPOSITORY_ADDEDFILEPROVIDES, id)
- repodata.internalize()
- writecachedrepo(repo, None, repodata)
-
-
-parser = OptionParser(usage="usage: solv.py [options] COMMAND")
-(options, args) = parser.parse_args()
-if not args:
- parser.print_help(sys.stderr)
- sys.exit(1)
-
-cmd = args[0]
-args = args[1:]
-
-pool = solv.Pool()
-pool.setarch(os.uname()[4])
-pool.set_loadcallback(load_stub)
-
-repos = []
-for reposdir in ["/etc/zypp/repos.d"]:
- if not os.path.isdir(reposdir):
- continue
- for reponame in sorted(glob.glob('%s/*.repo' % reposdir)):
- cfg = INIConfig(open(reponame))
- for alias in cfg:
- repo = cfg[alias]
- repo['alias'] = alias
- if 'baseurl' not in repo:
- print "repo %s has no baseurl" % alias
- continue
- if 'priority' not in repo:
- repo['priority'] = 99
- if 'autorefresh' not in repo:
- repo['autorefresh'] = 1
- if 'type' not in repo:
- repo['type'] = 'rpm-md'
- repo['metadata_expire'] = 900
- repos.append(repo)
-
-print "rpm database:",
-sysrepo = { 'alias': '@System' }
-sysrepo['handle'] = pool.add_repo(sysrepo['alias'])
-sysrepo['handle'].appdata = sysrepo
-pool.installed = sysrepo['handle']
-sysrepostat = os.stat("/var/lib/rpm/Packages")
-sysrepocookie = calc_cookie_stat(sysrepostat)
-sysrepo['cookie'] = sysrepocookie
-if usecachedrepo(sysrepo, None):
- print "cached"
-else:
- print "reading"
- sysrepo['handle'].add_products("/etc/products.d", Repo.REPO_NO_INTERNALIZE)
- sysrepo['handle'].add_rpmdb(None)
- writecachedrepo(sysrepo, None)
-
-for repo in repos:
- if not int(repo.enabled):
- continue
- repo['handle'] = pool.add_repo(repo['alias'])
- repo['handle'].appdata = repo
- repo['handle'].priority = 99 - repo['priority']
- if repo['autorefresh']:
- dorefresh = True
- if dorefresh:
- try:
- st = os.stat(calccachepath(repo))
- if time.time() - st[ST_MTIME] < repo['metadata_expire']:
- dorefresh = False
- except OSError, e:
- pass
- repo['cookie'] = None
- if not dorefresh and usecachedrepo(repo, None):
- print "repo: '%s': cached" % repo['alias']
- continue
-
- badchecksum = {}
-
- if repo['type'] == 'rpm-md':
- print "rpmmd repo '%s':" % repo['alias'],
- sys.stdout.flush()
- f = curlfopen(repo, "repodata/repomd.xml", False, None, None)
- if not f:
- print "no repomd.xml file, skipped"
- repo['handle'].free(True)
- del repo['handle']
- continue
- repo['cookie'] = calc_cookie_fp(f)
- if usecachedrepo(repo, None, True):
- print "cached"
- solv.xfclose(f)
- continue
- repo['handle'].add_repomdxml(f, 0)
- solv.xfclose(f)
- print "fetching"
- (filename, filechksum) = repomd_find(repo, 'primary')
- if filename:
- f = curlfopen(repo, filename, True, filechksum, badchecksum)
- if f:
- repo['handle'].add_rpmmd(f, None, 0)
- solv.xfclose(f)
- if badchecksum:
- continue # hopeless, need good primary
- (filename, filechksum) = repomd_find(repo, 'updateinfo')
- if filename:
- f = curlfopen(repo, filename, True, filechksum, badchecksum)
- if f:
- repo['handle'].add_updateinfoxml(f, 0)
- solv.xfclose(f)
- repomd_add_exts(repo)
- elif repo['type'] == 'yast2':
- print "susetags repo '%s':" % repo['alias'],
- sys.stdout.flush()
- f = curlfopen(repo, "content", False, None, None)
- if not f:
- print "no content file, skipped"
- repo['handle'].free(True)
- del repo['handle']
- continue
- repo['cookie'] = calc_cookie_fp(f)
- if usecachedrepo(repo, None, True):
- print "cached"
- solv.xfclose(f)
- continue
- repo['handle'].add_content(f, 0)
- solv.xfclose(f)
- print "fetching"
- defvendorid = repo['handle'].lookup_id(solv.SOLVID_META, solv.SUSETAGS_DEFAULTVENDOR)
- descrdir = repo['handle'].lookup_str(solv.SOLVID_META, solv.SUSETAGS_DESCRDIR)
- if not descrdir:
- descrdir = "suse/setup/descr"
- (filename, filechksum) = susetags_find(repo, 'packages.gz')
- if not filename:
- (filename, filechksum) = susetags_find(repo, 'packages')
- if filename:
- f = curlfopen(repo, descrdir + '/' + filename, True, filechksum, badchecksum)
- if f:
- repo['handle'].add_susetags(f, defvendorid, None, Repo.REPO_NO_INTERNALIZE|Repo.SUSETAGS_RECORD_SHARES)
- solv.xfclose(f)
- (filename, filechksum) = susetags_find(repo, 'packages.en.gz')
- if not filename:
- (filename, filechksum) = susetags_find(repo, 'packages.en')
- if filename:
- f = curlfopen(repo, descrdir + '/' + filename, True, filechksum, badchecksum)
- if f:
- repo['handle'].add_susetags(f, defvendorid, None, Repo.REPO_NO_INTERNALIZE|Repo.REPO_REUSE_REPODATA|Repo.REPO_EXTEND_SOLVABLES)
- solv.xfclose(f)
- repo['handle'].internalize()
- susetags_add_exts(repo)
- else:
- print "unsupported repo '%s': skipped" % repo['alias']
- repo['handle'].free(True)
- del repo['handle']
- continue
-
- # if the checksum was bad we work with the data we got, but don't cache it
- if 'True' not in badchecksum:
- writecachedrepo(repo, None)
- # must be called after writing the repo
- repo['handle'].create_stubs()
-
-if cmd == 'se' or cmd == 'search':
- matches = {}
- di = pool.dataiterator_new(0, solv.SOLVABLE_NAME, args[0], Dataiterator.SEARCH_SUBSTRING|Dataiterator.SEARCH_NOCASE)
- for d in di:
- matches[di.solvid] = True
- for solvid in sorted(matches.keys()):
- print " - %s [%s]: %s" % (pool.solvid2str(solvid), pool.solvables[solvid].repo.name, pool.lookup_str(solvid, solv.SOLVABLE_SUMMARY))
- sys.exit(0)
-
-cmdlinerepo = None
-cmdlinepkgs = {}
-if cmd == 'li' or cmd == 'list' or cmd == 'info' or cmd == 'in' or cmd == 'install':
- for arg in args:
- if arg.endswith(".rpm") and os.access(arg, os.R_OK):
- if not cmdlinerepo:
- cmdlinerepo = { 'alias': '@commandline' }
- cmdlinerepo['handle'] = pool.add_repo(cmdlinerepo['alias'])
- cmdlinerepo['handle'].appdata = cmdlinerepo
- cmdlinepkgs[arg] = cmdlinerepo['handle'].add_rpm(arg, Repo.REPO_REUSE_REPODATA|Repo.REPO_NO_INTERNALIZE)
- if cmdlinerepo:
- cmdlinerepo['handle'].internalize()
-
-addedprovides = pool.addfileprovides_ids()
-if addedprovides:
- rewrite_repos(pool, addedprovides)
-pool.createwhatprovides()
-
-jobs = []
-for arg in args:
- if cmdlinerepo and arg in cmdlinepkgs:
- jobs.append(pool.Job(Job.SOLVER_SOLVABLE, cmdlinepkgs[arg]))
- continue
- argjob = mkjobs(pool, cmd, arg)
- jobs += argjob
-
-if cmd == 'li' or cmd == 'list' or cmd == 'info':
- if not jobs:
- print "no package matched."
- sys.exit(1)
- for job in jobs:
- for s in pool.jobsolvables(job):
- if cmd == 'info':
- print "Name: %s" % s.str()
- print "Repo: %s" % s.repo.name
- print "Summary: %s" % s.lookup_str(solv.SOLVABLE_SUMMARY)
- str = s.lookup_str(solv.SOLVABLE_URL)
- if str:
- print "Url: %s" % str
- str = s.lookup_str(solv.SOLVABLE_LICENSE)
- if str:
- print "License: %s" % str
- print "Description:\n%s" % s.lookup_str(solv.SOLVABLE_DESCRIPTION)
- print
- else:
- print " - %s [%s]" % (s.str(), s.repo.name)
- print " %s" % s.lookup_str(solv.SOLVABLE_SUMMARY)
- sys.exit(0)
-
-if cmd == 'in' or cmd == 'install' or cmd == 'rm' or cmd == 'erase' or cmd == 'up':
- if cmd == 'up' and not jobs:
- jobs = [ pool.Job(Job.SOLVER_SOLVABLE_ALL, 0) ]
- if not jobs:
- print "no package matched."
- sys.exit(1)
- for job in jobs:
- if cmd == 'up':
- if job.how == Job.SOLVER_SOLVABLE_ALL or filter(lambda s: s.isinstalled(), pool.jobsolvables(job)):
- job.how |= Job.SOLVER_UPDATE
- else:
- job.how |= Job.SOLVER_INSTALL
- if cmd == 'in' or cmd == 'install':
- job.how |= Job.SOLVER_INSTALL
- elif cmd == 'rm' or cmd == 'erase':
- job.how |= Job.SOLVER_ERASE
-
- #pool.set_debuglevel(2)
- solver = None
- while True:
- solver = pool.create_solver()
- solver.ignorealreadyrecommended = True
- if cmd == 'rm' or cmd == 'erase':
- solver.allowuninstall = True
- problems = solver.solve(jobs)
- if not problems:
- break
- for problem in problems:
- print "Problem %d:" % problem.id
- r = problem.findproblemrule()
- type, source, target, dep = r.info()
- if type == Solver.SOLVER_RULE_DISTUPGRADE:
- print "%s does not belong to a distupgrade repository" % source.str()
- elif type == Solver.SOLVER_RULE_INFARCH:
- print "%s has inferiour architecture" % source.str()
- elif type == Solver.SOLVER_RULE_UPDATE:
- print "problem with installed package %s" % source.str()
- elif type == Solver.SOLVER_RULE_JOB:
- print "conflicting requests"
- elif type == Solver.SOLVER_RULE_JOB_NOTHING_PROVIDES_DEP:
- print "nothing provides requested %s" % pool.dep2str(dep)
- elif type == Solver.SOLVER_RULE_RPM:
- print "some dependency problem"
- elif type == Solver.SOLVER_RULE_RPM_NOT_INSTALLABLE:
- print "package %s is not installable" % source.str()
- elif type == Solver.SOLVER_RULE_RPM_NOTHING_PROVIDES_DEP:
- print "nothing provides %s needed by %s" % (pool.dep2str(dep), source.str())
- elif type == Solver.SOLVER_RULE_RPM_SAME_NAME:
- print "cannot install both %s and %s" % (source.str(), target.str())
- elif type == Solver.SOLVER_RULE_RPM_PACKAGE_CONFLICT:
- print "package %s conflicts with %s provided by %s" % (source.str(), pool.dep2str(dep), target.str())
- elif type == Solver.SOLVER_RULE_RPM_PACKAGE_OBSOLETES:
- print "package %s obsoletes %s provided by %s" % (source.str(), pool.dep2str(dep), target.str())
- elif type == Solver.SOLVER_RULE_RPM_INSTALLEDPKG_OBSOLETES:
- print "installed package %s obsoletes %s provided by %s" % (source.str(), pool.dep2str(dep), target.str())
- elif type == Solver.SOLVER_RULE_RPM_IMPLICIT_OBSOLETES:
- print "package %s implicitely obsoletes %s provided by %s" % (source.str(), pool.dep2str(dep), target.str())
- elif type == Solver.SOLVER_RULE_RPM_PACKAGE_REQUIRES:
- print "package %s requires %s, but none of the providers can be installed" % (source.str(), pool.dep2str(dep))
- elif type == Solver.SOLVER_RULE_RPM_SELF_CONFLICT:
- print "package %s conflicts with %s provided by itself" % (source.str(), pool.dep2str(dep))
- else:
- print "bad rule type", type
- solutions = problem.solutions()
- for solution in solutions:
- print " Solution %d:" % solution.id
- elements = solution.elements()
- for element in elements:
- etype = element.type
- if etype == Solver.SOLVER_SOLUTION_JOB:
- print " - remove job %d" % element.jobidx
- elif etype == Solver.SOLVER_SOLUTION_INFARCH:
- if element.solvable.isinstalled():
- print " - keep %s despite the inferior architecture" % element.solvable.str()
- else:
- print " - install %s despite the inferior architecture" % element.solvable.str()
- elif etype == Solver.SOLVER_SOLUTION_DISTUPGRADE:
- if element.solvable.isinstalled():
- print " - keep obsolete %s" % element.solvable.str()
- else:
- print " - install %s from excluded repository" % element.solvable.str()
- elif etype == Solver.SOLVER_SOLUTION_REPLACE:
- print " - allow replacement of %s with %s" % (element.solvable.str(), element.replacement.str())
- elif etype == Solver.SOLVER_SOLUTION_DEINSTALL:
- print " - allow deinstallation of %s" % element.solvable.str()
- sol = ''
- while not (sol == 's' or sol == 'q' or (sol.isdigit() and int(sol) >= 1 and int(sol) <= len(solutions))):
- sys.stdout.write("Please choose a solution: ")
- sys.stdout.flush()
- sol = sys.stdin.readline().strip()
- if sol == 's':
- continue # skip problem
- if sol == 'q':
- sys.exit(1)
- solution = solutions[int(sol) - 1]
- for element in solution.elements():
- etype = element.type
- newjob = None
- if etype == Solver.SOLVER_SOLUTION_JOB:
- jobs[element.jobidx] = pool.Job(Job.SOLVER_NOOP, 0)
- elif etype == Solver.SOLVER_SOLUTION_INFARCH or etype == Solver.SOLVER_SOLUTION_DISTUPGRADE:
- newjob = pool.Job(Job.SOLVER_INSTALL|Job.SOLVER_SOLVABLE, element.solvable.id)
- elif etype == Solver.SOLVER_SOLUTION_REPLACE:
- newjob = pool.Job(Job.SOLVER_INSTALL|Job.SOLVER_SOLVABLE, element.replacement.id)
- elif etype == Solver.SOLVER_SOLUTION_DEINSTALL:
- newjob = pool.Job(Job.SOLVER_ERASE|Job.SOLVER_SOLVABLE, element.solvable.id)
- if newjob:
- for job in jobs:
- if job.how == newjob.how and job.what == newjob.what:
- newjob = None
- break
- if newjob:
- jobs.append(newjob)
- # no problems, show transaction
- trans = solver.transaction()
- del solver
- if trans.isempty():
- print "Nothing to do."
- sys.exit(0)
- print
- print "Transaction summary:"
- print
- for ctype, pkgs, fromid, toid in trans.classify():
- if ctype == Transaction.SOLVER_TRANSACTION_ERASE:
- print "%d erased packages:" % len(pkgs)
- elif ctype == Transaction.SOLVER_TRANSACTION_INSTALL:
- print "%d installed packages:" % len(pkgs)
- elif ctype == Transaction.SOLVER_TRANSACTION_REINSTALLED:
- print "%d reinstalled packages:" % len(pkgs)
- elif ctype == Transaction.SOLVER_TRANSACTION_DOWNGRADED:
- print "%d downgraded packages:" % len(pkgs)
- elif ctype == Transaction.SOLVER_TRANSACTION_CHANGED:
- print "%d changed packages:" % len(pkgs)
- elif ctype == Transaction.SOLVER_TRANSACTION_UPGRADED:
- print "%d upgraded packages:" % len(pkgs)
- elif ctype == Transaction.SOLVER_TRANSACTION_VENDORCHANGE:
- print "%d vendor changes from '%s' to '%s':" % (len(pkgs), pool.id2str(fromid), pool.id2str(toid))
- elif ctype == Transaction.SOLVER_TRANSACTION_ARCHCHANGE:
- print "%d arch changes from '%s' to '%s':" % (len(pkgs), pool.id2str(fromid), pool.id2str(toid))
- else:
- continue
- for p in pkgs:
- if ctype == Transaction.SOLVER_TRANSACTION_UPGRADED or ctype == Transaction.SOLVER_TRANSACTION_DOWNGRADED:
- op = trans.othersolvable(p)
- print " - %s -> %s" % (p.str(), op.str())
- else:
- print " - %s" % p.str()
- print
- print "install size change: %d K" % trans.calc_installsizechange()
- print
-
-# vim: sw=4 et
- while True:
- sys.stdout.write("OK to continue (y/n)? ")
- sys.stdout.flush()
- yn = sys.stdin.readline().strip()
- if yn == 'y': break
- if yn == 'n': sys.exit(1)
- newpkgs, keptpkgs = trans.installedresult()
- newpkgsfp = {}
- if newpkgs:
- downloadsize = 0
- for p in newpkgs:
- downloadsize += p.lookup_num(solv.SOLVABLE_DOWNLOADSIZE)
- print "Downloading %d packages, %d K" % (len(newpkgs), downloadsize)
- for p in newpkgs:
- repo = p.repo.appdata
- location, medianr = p.lookup_location()
- if not location:
- continue
- if repo == cmdlinerepo:
- f = solv.xfopen(location)
- if not f:
- sys.exit("\n%s: %s not found" % location)
- newpkgsfp[p.id] = f
- continue
- if sysrepo['handle'].nsolvables and os.access('/usr/bin/applydeltarpm', os.X_OK):
- pname = p.name
- di = p.repo.dataiterator_new(solv.SOLVID_META, solv.DELTA_PACKAGE_NAME, pname, Dataiterator.SEARCH_STRING)
- di.prepend_keyname(solv.REPOSITORY_DELTAINFO)
- for d in di:
- d.setpos_parent()
- if pool.lookup_id(solv.SOLVID_POS, solv.DELTA_PACKAGE_EVR) != p.evrid or pool.lookup_id(solv.SOLVID_POS, solv.DELTA_PACKAGE_ARCH) != p.archid:
- continue
- baseevrid = pool.lookup_id(solv.SOLVID_POS, solv.DELTA_BASE_EVR)
- candidate = None
- for installedp in pool.providers(p.nameid):
- if installedp.isinstalled() and installedp.nameid == p.nameid and installedp.archid == p.archid and installedp.evrid == baseevrid:
- candidate = installedp
- if not candidate:
- continue
- seq = pool.lookup_str(solv.SOLVID_POS, solv.DELTA_SEQ_NAME) + '-' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_SEQ_EVR) + '-' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_SEQ_NUM)
- st = subprocess.call(['/usr/bin/applydeltarpm', '-a', p.arch, '-c', '-s', seq])
- if st:
- continue
- chksum = pool.lookup_checksum(solv.SOLVID_POS, solv.DELTA_CHECKSUM)
- if not chksum:
- continue
- dloc = pool.lookup_str(solv.SOLVID_POS, solv.DELTA_LOCATION_DIR) + '/' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_LOCATION_NAME) + '-' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_LOCATION_EVR) + '.' + pool.lookup_str(solv.SOLVID_POS, solv.DELTA_LOCATION_SUFFIX)
- f = curlfopen(repo, dloc, False, chksum)
- if not f:
- continue
- nf = tempfile.TemporaryFile()
- nf = os.dup(nf.fileno())
- st = subprocess.call(['/usr/bin/applydeltarpm', '-a', p.arch, "/dev/fd/%d" % solv.xfileno(f), "/dev/fd/%d" % nf])
- solv.xfclose(f)
- os.lseek(nf, 0, os.SEEK_SET)
- newpkgsfp[p.id] = solv.xfopen_fd("", nf)
- break
- if p.id in newpkgsfp:
- sys.stdout.write("d")
- sys.stdout.flush()
- continue
-
- if repo['type'] == 'yast2':
- datadir = repo['handle'].lookup_str(solv.SOLVID_META, solv.SUSETAGS_DATADIR)
- if not datadir:
- datadir = 'suse'
- location = datadir + '/' + location
- chksum = p.lookup_checksum(solv.SOLVABLE_CHECKSUM)
- f = curlfopen(repo, location, False, chksum)
- if not f:
- sys.exit("\n%s: %s not found in repository" % (repo['alias'], location))
- newpkgsfp[p.id] = f
- sys.stdout.write(".")
- sys.stdout.flush()
- print
- print "Committing transaction:"
- print
- ts = rpm.TransactionSet('/')
- ts.setVSFlags(rpm._RPMVSF_NOSIGNATURES)
- erasenamehelper = {}
- for p in trans.steps():
- type = trans.steptype(p, Transaction.SOLVER_TRANSACTION_RPM_ONLY)
- if type == Transaction.SOLVER_TRANSACTION_ERASE:
- rpmdbid = p.lookup_num(solv.RPM_RPMDBID)
- erasenamehelper[p.name] = p
- if not rpmdbid:
- sys.exit("\ninternal error: installed package %s has no rpmdbid\n" % p.str())
- ts.addErase(rpmdbid)
- elif type == Transaction.SOLVER_TRANSACTION_INSTALL:
- f = newpkgsfp[p.id]
- h = ts.hdrFromFdno(solv.xfileno(f))
- os.lseek(solv.xfileno(f), 0, os.SEEK_SET)
- ts.addInstall(h, p, 'u')
- elif type == Transaction.SOLVER_TRANSACTION_MULTIINSTALL:
- f = newpkgsfp[p.id]
- h = ts.hdrFromFdno(solv.xfileno(f))
- os.lseek(solv.xfileno(f), 0, os.SEEK_SET)
- ts.addInstall(h, p, 'i')
- checkproblems = ts.check()
- if checkproblems:
- print checkproblems
- sys.exit("Sorry.")
- ts.order()
- def runCallback(reason, amount, total, p, d):
- if reason == rpm.RPMCALLBACK_INST_OPEN_FILE:
- return solv.xfileno(newpkgsfp[p.id])
- if reason == rpm.RPMCALLBACK_INST_START:
- print "install", p.str()
- if reason == rpm.RPMCALLBACK_UNINST_START:
- # argh, p is just the name of the package
- if p in erasenamehelper:
- p = erasenamehelper[p]
- print "erase", p.str()
- runproblems = ts.run(runCallback, '')
- if runproblems:
- print runproblems
- sys.exit(1)
bp++;
if (chksumtypep && !*chksumtypep && !strncmp(bp, "<hash type=\"sha256\">", 20))
{
- int i;
-
bp += 20;
- memset(chksump, 0, 32);
- for (i = 0; i < 64; i++)
- {
- int c = *bp++;
- if (c >= '0' && c <= '9')
- chksump[i / 2] = chksump[i / 2] * 16 + (c - '0');
- else if (c >= 'a' && c <= 'f')
- chksump[i / 2] = chksump[i / 2] * 16 + (c - ('a' - 10));
- else if (c >= 'A' && c <= 'F')
- chksump[i / 2] = chksump[i / 2] * 16 + (c - ('A' - 10));
- else
- break;
- }
- if (i == 64)
+ if (sat_hex2bin((const char **)&bp, chksump, 32) == 32)
*chksumtypep = REPOKEY_TYPE_SHA256;
continue;
}
return 0;
}
+static inline int
+iscompressed(const char *name)
+{
+ int l = strlen(name);
+ return l > 3 && !strcmp(name + l - 3, ".gz") ? 1 : 0;
+}
+
FILE *
curlfopen(struct repoinfo *cinfo, const char *file, int uncompress, const unsigned char *chksum, Id chksumtype, int *badchecksump)
{
char *q, *p = pool_tmpjoin(repo->pool, SOLVCACHE_PATH, "/", repo->name);
if (repoext)
{
- p = pool_tmpjoin(repo->pool, p, "_", repoext);
- p = pool_tmpjoin(repo->pool, p, ".solvx", 0);
+ p = pool_tmpappend(repo->pool, p, "_", repoext);
+ p = pool_tmpappend(repo->pool, p, ".solvx", 0);
}
else
- p = pool_tmpjoin(repo->pool, p, ".solv", 0);
+ p = pool_tmpappend(repo->pool, p, ".solv", 0);
q = p + strlen(SOLVCACHE_PATH) + 1;
if (*q == '.')
*q = '_';
cinfo = repo->appdata;
mkdir(SOLVCACHE_PATH, 0755);
+ /* use dupjoin instead of tmpjoin because tmpl must survive repo_write */
tmpl = sat_dupjoin(SOLVCACHE_PATH, "/", ".newsolv-XXXXXX");
fd = mkstemp(tmpl);
if (fd < 0)
return 1;
}
+int
+repomd_load_ext(Repo *repo, Repodata *data)
+{
+ const char *filename, *repomdtype;
+ char ext[3];
+ FILE *fp;
+ struct repoinfo *cinfo;
+ const unsigned char *filechksum;
+ Id filechksumtype;
+
+ cinfo = repo->appdata;
+ repomdtype = repodata_lookup_str(data, SOLVID_META, REPOSITORY_REPOMD_TYPE);
+ if (!repomdtype)
+ return 0;
+ if (!strcmp(repomdtype, "filelists"))
+ strcpy(ext, "FL");
+ else if (!strcmp(repomdtype, "deltainfo"))
+ strcpy(ext, "DL");
+ else
+ return 0;
+#if 1
+ printf("[%s:%s", repo->name, ext);
+#endif
+ if (usecachedrepo(repo, ext, cinfo->extcookie, 0))
+ {
+ printf(" cached]\n");fflush(stdout);
+ return 1;
+ }
+ printf(" fetching]\n"); fflush(stdout);
+ filename = repodata_lookup_str(data, SOLVID_META, REPOSITORY_REPOMD_LOCATION);
+ filechksumtype = 0;
+ filechksum = repodata_lookup_bin_checksum(data, SOLVID_META, REPOSITORY_REPOMD_CHECKSUM, &filechksumtype);
+ if ((fp = curlfopen(cinfo, filename, iscompressed(filename), filechksum, filechksumtype, 0)) == 0)
+ return 0;
+ if (!strcmp(ext, "FL"))
+ repo_add_rpmmd(repo, fp, ext, REPO_USE_LOADING|REPO_EXTEND_SOLVABLES);
+ else if (!strcmp(ext, "DL"))
+ repo_add_deltainfoxml(repo, fp, REPO_USE_LOADING);
+ fclose(fp);
+ writecachedrepo(repo, data, ext, cinfo->extcookie);
+ return 1;
+}
+
/* susetags helpers */
dataiterator_free(&di);
}
-
-static inline int
-iscompressed(const char *name)
-{
- int l = strlen(name);
- return l > 3 && !strcmp(name + l - 3, ".gz") ? 1 : 0;
-}
-
-
-/* load callback */
-
int
-load_stub(Pool *pool, Repodata *data, void *dp)
+susetags_load_ext(Repo *repo, Repodata *data)
{
- const char *filename, *descrdir, *repomdtype;
- const unsigned char *filechksum;
- Id filechksumtype;
- struct repoinfo *cinfo;
- FILE *fp;
+ const char *filename, *descrdir;
Id defvendor;
char ext[3];
+ FILE *fp;
+ struct repoinfo *cinfo;
+ const unsigned char *filechksum;
+ Id filechksumtype;
- cinfo = data->repo->appdata;
-
+ cinfo = repo->appdata;
filename = repodata_lookup_str(data, SOLVID_META, SUSETAGS_FILE_NAME);
- if (filename)
- {
- /* susetags load */
- ext[0] = filename[9];
- ext[1] = filename[10];
- ext[2] = 0;
-#if 1
- printf("[%s:%s", data->repo->name, ext);
-#endif
- if (usecachedrepo(data->repo, ext, cinfo->extcookie, 0))
- {
- printf(" cached]\n"); fflush(stdout);
- return 1;
- }
+ if (!filename)
+ return 0;
+ /* susetags load */
+ ext[0] = filename[9];
+ ext[1] = filename[10];
+ ext[2] = 0;
#if 1
- printf(" fetching]\n"); fflush(stdout);
+ printf("[%s:%s", repo->name, ext);
#endif
- defvendor = repo_lookup_id(data->repo, SOLVID_META, SUSETAGS_DEFAULTVENDOR);
- descrdir = repo_lookup_str(data->repo, SOLVID_META, SUSETAGS_DESCRDIR);
- if (!descrdir)
- descrdir = "suse/setup/descr";
- filechksumtype = 0;
- filechksum = repodata_lookup_bin_checksum(data, SOLVID_META, SUSETAGS_FILE_CHECKSUM, &filechksumtype);
- if ((fp = curlfopen(cinfo, pool_tmpjoin(pool, descrdir, "/", filename), iscompressed(filename), filechksum, filechksumtype, 0)) == 0)
- return 0;
- repo_add_susetags(data->repo, fp, defvendor, ext, REPO_USE_LOADING|REPO_EXTEND_SOLVABLES);
- fclose(fp);
- writecachedrepo(data->repo, data, ext, cinfo->extcookie);
+ if (usecachedrepo(repo, ext, cinfo->extcookie, 0))
+ {
+ printf(" cached]\n"); fflush(stdout);
return 1;
}
-
- repomdtype = repodata_lookup_str(data, SOLVID_META, REPOSITORY_REPOMD_TYPE);
- if (repomdtype)
- {
- if (!strcmp(repomdtype, "filelists"))
- strcpy(ext, "FL");
- else if (!strcmp(repomdtype, "deltainfo"))
- strcpy(ext, "DL");
- else
- return 0;
#if 1
- printf("[%s:%s", data->repo->name, ext);
+ printf(" fetching]\n"); fflush(stdout);
#endif
- if (usecachedrepo(data->repo, ext, cinfo->extcookie, 0))
- {
- printf(" cached]\n");fflush(stdout);
- return 1;
- }
- printf(" fetching]\n"); fflush(stdout);
- filename = repodata_lookup_str(data, SOLVID_META, REPOSITORY_REPOMD_LOCATION);
- filechksumtype = 0;
- filechksum = repodata_lookup_bin_checksum(data, SOLVID_META, REPOSITORY_REPOMD_CHECKSUM, &filechksumtype);
- if ((fp = curlfopen(cinfo, filename, iscompressed(filename), filechksum, filechksumtype, 0)) == 0)
- return 0;
- if (!strcmp(ext, "FL"))
- repo_add_rpmmd(data->repo, fp, ext, REPO_USE_LOADING|REPO_EXTEND_SOLVABLES);
- else if (!strcmp(ext, "DL"))
- repo_add_deltainfoxml(data->repo, fp, REPO_USE_LOADING);
- fclose(fp);
- writecachedrepo(data->repo, data, ext, cinfo->extcookie);
- return 1;
- }
+ defvendor = repo_lookup_id(repo, SOLVID_META, SUSETAGS_DEFAULTVENDOR);
+ descrdir = repo_lookup_str(repo, SOLVID_META, SUSETAGS_DESCRDIR);
+ if (!descrdir)
+ descrdir = "suse/setup/descr";
+ filechksumtype = 0;
+ filechksum = repodata_lookup_bin_checksum(data, SOLVID_META, SUSETAGS_FILE_CHECKSUM, &filechksumtype);
+ if ((fp = curlfopen(cinfo, pool_tmpjoin(repo->pool, descrdir, "/", filename), iscompressed(filename), filechksum, filechksumtype, 0)) == 0)
+ return 0;
+ repo_add_susetags(repo, fp, defvendor, ext, REPO_USE_LOADING|REPO_EXTEND_SOLVABLES);
+ fclose(fp);
+ writecachedrepo(repo, data, ext, cinfo->extcookie);
+ return 1;
+}
+
+
+/* load callback */
+
+int
+load_stub(Pool *pool, Repodata *data, void *dp)
+{
+ struct repoinfo *cinfo = data->repo->appdata;
+ if (cinfo->type == TYPE_SUSETAGS)
+ return susetags_load_ext(data->repo, data);
+ if (cinfo->type == TYPE_RPMMD)
+ return repomd_load_ext(data->repo, data);
return 0;
}
fclose(fp);
}
-static int
-hexstr2bytes(unsigned char *buf, const char *str, int buflen)
-{
- int i;
- for (i = 0; i < buflen; i++)
- {
-#define c2h(c) (((c)>='0' && (c)<='9') ? ((c)-'0') \
- : ((c)>='a' && (c)<='f') ? ((c)-('a'-10)) \
- : ((c)>='A' && (c)<='F') ? ((c)-('A'-10)) \
- : -1)
- int v = c2h(*str);
- str++;
- if (v < 0)
- return 0;
- buf[i] = v;
- v = c2h(*str);
- str++;
- if (v < 0)
- return 0;
- buf[i] = (buf[i] << 4) | v;
-#undef c2h
- }
- return buflen;
-}
-
const char *
debian_find_component(struct repoinfo *cinfo, FILE *fp, char *comp, const unsigned char **chksump, Id *chksumtypep)
{
bp += lbinarydir;
if (!strcmp(bp, "Packages") || !strcmp(bp, "Packages.gz"))
{
+ unsigned char curchksum[32];
+ int curl;
if (filename && !strcmp(bp, "Packages"))
continue;
- if (chksumtype && sat_chksum_len(chksumtype) > sat_chksum_len(curchksumtype))
+ curl = sat_chksum_len(curchksumtype);
+ if (!curl || (chksumtype && sat_chksum_len(chksumtype) > curl))
continue;
- if (!hexstr2bytes(chksum, ch, sat_chksum_len(curchksumtype)))
+ if (sat_hex2bin(&ch, curchksum, sizeof(curchksum)) != curl)
continue;
sat_free(filename);
filename = strdup(fn);
chksumtype = curchksumtype;
+ memcpy(chksum, curchksum, curl);
}
}
free(binarydir);
seqevr = pool_lookup_str(pool, SOLVID_POS, DELTA_SEQ_EVR);
seqnum = pool_lookup_str(pool, SOLVID_POS, DELTA_SEQ_NUM);
seq = pool_tmpjoin(pool, seqname, "-", seqevr);
- seq = pool_tmpjoin(pool, seq, "-", seqnum);
+ seq = pool_tmpappend(pool, seq, "-", seqnum);
#ifdef FEDORA
sprintf(cmd, "/usr/bin/applydeltarpm -a %s -c -s ", id2str(pool, s->arch));
#else
if (!chksumtype)
continue; /* no way! */
dloc = pool_lookup_str(pool, SOLVID_POS, DELTA_LOCATION_DIR);
- dloc = pool_tmpjoin(pool, dloc, "/", pool_lookup_str(pool, SOLVID_POS, DELTA_LOCATION_NAME));
- dloc = pool_tmpjoin(pool, dloc, "-", pool_lookup_str(pool, SOLVID_POS, DELTA_LOCATION_EVR));
- dloc = pool_tmpjoin(pool, dloc, ".", pool_lookup_str(pool, SOLVID_POS, DELTA_LOCATION_SUFFIX));
+ dloc = pool_tmpappend(pool, dloc, "/", pool_lookup_str(pool, SOLVID_POS, DELTA_LOCATION_NAME));
+ dloc = pool_tmpappend(pool, dloc, "-", pool_lookup_str(pool, SOLVID_POS, DELTA_LOCATION_EVR));
+ dloc = pool_tmpappend(pool, dloc, ".", pool_lookup_str(pool, SOLVID_POS, DELTA_LOCATION_SUFFIX));
if ((fp = curlfopen(cinfo, dloc, 0, chksum, chksumtype, 0)) == 0)
continue;
/* got it, now reconstruct */
if (evrp > evr && evrp[0] == ':' && evrp[1])
evr = evrp + 1;
nvra = pool_tmpjoin(pool, id2str(pool, s->name), "-", evr);
- nvra = pool_tmpjoin(pool, nvra, ".", id2str(pool, s->arch));
+ nvra = pool_tmpappend(pool, nvra, ".", id2str(pool, s->arch));
runrpm("-e", nvra, -1); /* too bad that --querybynumber doesn't work */
#else
rundpkg("--remove", id2str(pool, s->name), 0);
#include "stdio.h"
#include "pool.h"
#include "solver.h"
+#include "policy.h"
+#include "solverdebug.h"
#include "repo_solv.h"
#include "chksum.h"
job->what = what;
return job;
}
+
+ const char *str() {
+ Pool *pool = $self->pool;
+ Id select = $self->how & SOLVER_SELECTMASK;
+ char *strstart = 0, *strend = 0;
+ switch ($self->how & SOLVER_JOBMASK) {
+ case SOLVER_INSTALL:
+ if (select == SOLVER_SOLVABLE && pool->installed && pool->solvables[$self->what].repo == pool->installed)
+ strstart = "keep ", strend = "installed";
+ else if (select == SOLVER_SOLVABLE_PROVIDES)
+ strstart = "install a solvable ";
+ else
+ strstart = "install ";
+ break;
+ case SOLVER_ERASE:
+ if (select == SOLVER_SOLVABLE && !(pool->installed && pool->solvables[$self->what].repo == pool->installed))
+ strstart = "keep ", strend = "uninstalled";
+ else if (select == SOLVER_SOLVABLE_PROVIDES)
+ strstart = "deinstall all solvables ";
+ else
+ strstart = "deinstall ";
+ break;
+ case SOLVER_UPDATE:
+ strstart = "install the most recent version of ";
+ break;
+ case SOLVER_LOCK:
+ strstart = "lock ";
+ break;
+ default:
+ return "unknwon job";
+ }
+ return pool_tmpjoin(pool, strstart, solver_select2str(pool, select, $self->what), strend);
+ }
}
%extend Chksum {
Chksum(Id type) {
return (Chksum *)sat_chksum_create(type);
}
+ Chksum(Id type, const char *hex) {
+ unsigned char buf[64];
+ int l = sat_chksum_len(type);
+ if (!l)
+ return 0;
+ if (sat_hex2bin(&hex, buf, sizeof(buf)) != l || hex[0])
+ return 0;
+ return (Chksum *)sat_chksum_create_from_bin(type, buf);
+ }
~Chksum() {
sat_chksum_free($self, 0);
}
sat_chksum_add($self, buf, l);
lseek(fd, 0, 0); /* convenience */
}
+ void add_stat(const char *filename) {
+ struct stat stb;
+ if (stat(filename, &stb))
+ memset(&stb, 0, sizeof(stb));
+ sat_chksum_add($self, &stb.st_dev, sizeof(stb.st_dev));
+ sat_chksum_add($self, &stb.st_ino, sizeof(stb.st_ino));
+ sat_chksum_add($self, &stb.st_size, sizeof(stb.st_size));
+ sat_chksum_add($self, &stb.st_mtime, sizeof(stb.st_mtime));
+ }
bool matches(Chksum *othersum) {
int l;
const unsigned char *b, *bo;
}
%newobject hex;
char *hex() {
- int i, l, c;
+ int l;
const unsigned char *b;
char *ret, *rp;
b = sat_chksum_get($self, &l);
- ret = rp = sat_malloc(2 * l + 1);
- for (i = 0; i < l; i++)
- {
- c = b[i] >> 4;
- *rp++ = c < 10 ? c + '0' : c + ('a' - 10);
- c = b[i] & 15;
- *rp++ = c < 10 ? c + '0' : c + ('a' - 10);
- }
- *rp++ = 0;
+ ret = sat_malloc(2 * l + 1);
+ sat_bin2hex(b, l, ret);
return ret;
}
}
return 1;
}
Id add_rpm(const char *name, int flags = 0) {
- int oldend = $self->end;
- repo_add_rpms($self, &name, 1, flags);
- if (oldend == $self->end)
- return 0;
- return $self->end - 1;
+ return repo_add_rpm($self, name, flags);
}
bool add_susetags(FILE *fp, Id defvendor, const char *language, int flags = 0) {
repo_add_susetags($self, fp, defvendor, language, flags);
return xs->pool->solvables[xs->id].arch;
}
%}
+ const char * const vendor;
+ %{
+ SWIGINTERN const char *XSolvable_vendor_get(XSolvable *xs) {
+ Pool *pool = xs->pool;
+ return id2str(pool, pool->solvables[xs->id].vendor);
+ }
+ %}
+ Id const vendorid;
+ %{
+ SWIGINTERN Id XSolvable_vendorid_get(XSolvable *xs) {
+ return xs->pool->solvables[xs->id].vendor;
+ }
+ %}
Repo * const repo;
%{
SWIGINTERN Repo *XSolvable_repo_get(XSolvable *xs) {
}
return e;
}
+ int illegalreplace() {
+ if ($self->type != SOLVER_SOLUTION_REPLACE || $self->p <= 0 || $self->rp <= 0)
+ return 0;
+ return policy_is_illegal($self->solv, $self->solv->pool->solvables + $self->p, $self->solv->pool->solvables + $self->rp, 0);
+ }
%newobject solvable;
XSolvable * const solvable;
%newobject replacement;
static const int SOLVER_SOLUTION_DEINSTALL = SOLVER_SOLUTION_DEINSTALL;
static const int SOLVER_SOLUTION_REPLACE = SOLVER_SOLUTION_REPLACE;
+ static const int POLICY_ILLEGAL_DOWNGRADE = POLICY_ILLEGAL_DOWNGRADE;
+ static const int POLICY_ILLEGAL_ARCHCHANGE = POLICY_ILLEGAL_ARCHCHANGE;
+ static const int POLICY_ILLEGAL_VENDORCHANGE = POLICY_ILLEGAL_VENDORCHANGE;
+
~Solver() {
solver_free($self);
}
projects / platform / upstream / libsolv.git / commitdiff