blob: 270f0a5f20c6ccba98737ae525c37562c171b7ca (
plain)
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
|
"""Bcfg2 Support for Encap Packages"""
import glob
import re
import Bcfg2.Client.Tools
class Encap(Bcfg2.Client.Tools.PkgTool):
"""Support for Encap packages."""
name = 'Encap'
__execs__ = ['/usr/local/bin/epkg']
__handles__ = [('Package', 'encap')]
__req__ = {'Package': ['version', 'url']}
pkgtype = 'encap'
pkgtool = ("/usr/local/bin/epkg -l -f -q %s", ("%s", ["url"]))
splitter = re.compile(r'.*/(?P<name>[\w-]+)\-(?P<version>[\w\.+-]+)')
def RefreshPackages(self):
"""Try to find encap packages."""
self.installed = {}
for pkg in glob.glob("/usr/local/encap/*"):
match = self.splitter.match(pkg)
if match:
self.installed[match.group('name')] = match.group('version')
else:
print("Failed to split name %s" % pkg)
self.logger.debug("Encap: RefreshPackages: self.installed.keys() are:")
self.logger.debug("%s" % list(self.installed.keys()))
def VerifyPackage(self, entry, _):
"""Verify Package status for entry."""
if not entry.get('version'):
self.logger.info("Insufficient information of Package %s; "
"cannot Verify" % entry.get('name'))
return False
success = self.cmd.run("/usr/local/bin/epkg -q -S -k %s-%s" %
(entry.get('name'),
entry.get('version'))).success
if not success:
self.logger.debug("Package %s version incorrect" %
entry.get('name'))
return success
def Remove(self, packages):
"""Deal with extra configuration detected."""
names = " ".join([pkg.get('name') for pkg in packages])
self.logger.info("Removing packages: %s" % (names))
self.cmd.run("/usr/local/bin/epkg -l -q -r %s" % (names))
self.RefreshPackages()
self.extra = self.FindExtra()
|
