1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
'''Bcfg2 Support for RPMS'''
__revision__ = '$Revision$'
import Bcfg2.Client.Tools, time
class RPM(Bcfg2.Client.Tools.PkgTool):
'''Support for RPM packages'''
name = 'RPM'
__execs__ = ['/bin/rpm', '/var/lib/rpm']
__handles__ = [('Package', 'rpm')]
__req__ = {'Package': ['name', 'version']}
__ireq__ = {'Package': ['name', 'version', 'url']}
pkgtype = 'rpm'
pkgtool = ("rpm --oldpackage --replacepkgs --quiet -U %s", ("%s", ["url"]))
def RefreshPackages(self, level=0):
'''Cache package states'''
self.installed = {}
if level > 5:
return
for line in self.cmd.run("rpm -qa --qf '%{NAME} %{VERSION}-%{RELEASE}\n'")[1]:
try:
(name, version) = line.split()
self.installed[name] = version
except ValueError:
if line == '':
continue
self.logger.error("Failed to access RPM db; retrying after 30s")
time.sleep(30)
return self.RefreshPackages(level + 1)
def VerifyPackage(self, entry, modlist):
'''Verify Package status for entry'''
if not entry.get('version'):
self.logger.error("Can't install package %s, not enough data." % (entry.get('name')))
return False
rpm_options = []
if entry.get('verify', 'false') == 'nomtime':
self.logger.debug("Skipping mtime verification for package %s" % \
(entry.get('name')))
rpm_options.append("--nomtime")
if entry.get('name') in self.installed:
if entry.get('version') == self.installed[entry.get('name')]:
if entry.get('multiarch'):
archs = entry.get('multiarch').split()
info = self.cmd.run(
'rpm -q %s --qf "%%{NAME} %%{VERSION}-%%{RELEASE} %%{ARCH}\n"' \
% (entry.get('name')))[1]
while info:
arch = info.pop().split()[2]
if arch in archs:
archs.remove(arch)
else:
self.logger.error("Got pkg install for Package %s: arch %s" % \
(entry.get('name'), arch))
return False
if archs:
self.logger.error("Package %s not installed for arch: %s" % \
(entry.get('name'), archs))
return False
if (self.setup['quick'] or (entry.get('verify', 'true') == 'false')) \
or entry.get('multiarch'):
if entry.get('verify', 'true') == 'false':
self.logger.debug("Skipping checksum verification for package %s" % \
(entry.get('name')))
return True
else:
self.logger.debug("Package %s: wrong version installed. want %s have %s" %
(entry.get('name'), entry.get('version'),
self.installed[entry.get('name')]))
entry.set('current_version', self.installed[entry.get('name')])
entry.set('qtext', 'Upgrade/downgrade Package %s (%s -> %s)? (y/N) ' % \
(entry.get('name'), entry.get('current_version'),
entry.get('version')))
return False
else:
self.logger.debug("Package %s: not installed" % (entry.get('name')))
entry.set('current_exists', 'false')
entry.set('qtext', "Install Package %s-%s? (y/N) " % \
(entry.get('name'), entry.get('version')))
return False
(vstat, output) = self.cmd.run("rpm --verify %s %s-%s" % \
(" ".join(rpm_options),
entry.get('name'),
entry.get('version')))
if vstat != 0:
if [name for name in output if name.split()[-1] not in modlist]:
self.logger.debug("Package %s content verification failed" % \
entry.get('name'))
return False
return True
def RemovePackages(self, packages):
'''Remove specified entries'''
pkgnames = [pkg.get('name') for pkg in packages]
if len(pkgnames) > 0:
self.logger.info("Removing packages: %s" % pkgnames)
if self.cmd.run("rpm --quiet -e --allmatches %s" % " ".join(pkgnames))[0] == 0:
self.modified += packages
else:
for pkg in packages:
if self.cmd.run("rpm --quiet -e --allmatches %s" % \
pkg.get('name'))[0] == 0:
self.modified += pkg
self.RefreshPackages()
self.extra = self.FindExtraPackages()
|
