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
|
'''This module implements a templating generator based on Genshi'''
__revision__ = '$Revision$'
import Bcfg2.Server.Plugin
import lxml.etree, logging
logger = logging.getLogger('Bcfg2.Plugins.SGenshi')
try:
import genshi.template, genshi.core, genshi.template.base
except:
logger.error("Failed to load Genshi; disabling SGenshi")
raise
def removecomment(stream):
"""A genshi filter that removes comments from the stream."""
for kind, data, pos in stream:
if kind is genshi.core.COMMENT:
continue
yield kind, data, pos
class TemplateFile(Bcfg2.Server.Plugin.FileBacked):
'''Genshi template file object'''
loader = genshi.template.TemplateLoader(auto_reload=True,
max_cache_size=64)
def HandleEvent(self, _=None):
'''Process FAM/GAMIN event'''
try:
self.template = self.loader.load(self.name,
cls=genshi.template.MarkupTemplate)
except genshi.template.base.TemplateSyntaxError, e:
logger.error("SGenshi: Parse failure due to %s" % (e))
def GetValue(self, metadata):
'''Build actual structure contents'''
if not hasattr(self, 'template'):
logger.error("Template data for %s could not be loaded" % self.name)
raise Bcfg2.Server.Plugin.PluginExecutionError
stream = self.template.generate(metadata=metadata).filter(removecomment)
data = stream.render('xml')
return lxml.etree.XML(data)
class SGenshi(Bcfg2.Server.Plugin.Plugin,
Bcfg2.Server.Plugin.XMLDirectoryBacked):
'''SGenshi is a structure plugin that provides direct plugin access to templated structures'''
__child__ = TemplateFile
__name__ = 'SGenshi'
__version__ = '$Id$'
def __init__(self, core, datastore):
Bcfg2.Server.Plugin.Plugin.__init__(self, core, datastore)
try:
Bcfg2.Server.Plugin.XMLDirectoryBacked.__init__(self,
self.data,
self.core.fam)
except:
logger.error("Failed to load SGenshi repository; disabling SGenshi")
raise Bcfg2.Server.Plugin.PluginInitError
def BuildStructures(self, metadata):
'''Build SGenshi structures'''
ret = []
for entry in self.entries.values():
try:
ret.append(entry.GetValue(metadata))
except Bcfg2.Server.Plugin.PluginExecutionError:
logger.error("SGenshi: Failed to template file %s" % entry.name)
return ret
|
