From c35347887bb3d452d6104b13308d853b3da44b68 Mon Sep 17 00:00:00 2001 From: "Chris St. Pierre" Date: Tue, 8 May 2012 15:09:54 -0400 Subject: modularized Cfg --- src/lib/Bcfg2/Server/Plugins/Cfg/CfgDiffFilter.py | 27 +++++++++++++++++++++++ 1 file changed, 27 insertions(+) create mode 100644 src/lib/Bcfg2/Server/Plugins/Cfg/CfgDiffFilter.py (limited to 'src/lib/Bcfg2/Server/Plugins/Cfg/CfgDiffFilter.py') diff --git a/src/lib/Bcfg2/Server/Plugins/Cfg/CfgDiffFilter.py b/src/lib/Bcfg2/Server/Plugins/Cfg/CfgDiffFilter.py new file mode 100644 index 000000000..b408e1b55 --- /dev/null +++ b/src/lib/Bcfg2/Server/Plugins/Cfg/CfgDiffFilter.py @@ -0,0 +1,27 @@ +import os +import logging +import tempfile +import Bcfg2.Server.Plugin +from subprocess import Popen, PIPE +from Bcfg2.Server.Plugins.Cfg import CfgFilter + +logger = logging.getLogger(__name__) + +class CfgDiffFilter(CfgFilter): + __extensions__ = ['diff'] + + def modify_data(self, entry, metadata, data): + basehandle, basename = tempfile.mkstemp() + open(basename, 'w').write(data) + os.close(basehandle) + + cmd = ["patch", "-u", "-f", basefile.name] + patch = Popen(cmd, stdin=PIPE, stdout=PIPE, stderr=PIPE) + stderr = patch.communicate(input=self.data)[1] + ret = patch.wait() + output = open(basefile.name, 'r').read() + os.unlink(basefile.name) + if ret >> 8 != 0: + logger.error("Error applying diff %s: %s" % (delta.name, stderr)) + raise Bcfg2.Server.Plugin.PluginExecutionError('delta', delta) + return output -- cgit v1.2.3-1-g7c22