#!/usr/bin/env python # $Id$ # configxml.py - module to read and parse config.xml, run_state.xml ''' SYNOPSIS: parses and writes config.xml and run_state.xml USAGE: from Boinc import configxml config = configxml.ConfigFile().read() run_state = configxml.RunStateFile().read() print config.config.db_name print config.tasks[4].cmd run_state.enabled = True new_task = newConfigDict() new_task.cmd = "echo hi | mail quarl" config.tasks.append(new_task) config.write() run_state.write() ''' import sys import xml.dom.minidom import boinc_project_path def _append_new_element(parent_node, name): new_element = xml.dom.minidom.Element(name) if isinstance(parent_node,xml.dom.minidom.Document): new_element.ownerDocument = parent_node else: assert(parent_node.ownerDocument) new_element.ownerDocument = parent_node.ownerDocument parent_node.appendChild(new_element) return new_element def _get_elements(node, name): return node.getElementsByTagName(name) def _get_element(node, name, optional=True): try: return _get_elements(node,name)[0] except IndexError: if optional: return _append_new_element(node, name) raise SystemExit("ERROR: Couldn't find xml node <%s>"% name) def _None2Str(object): if object == None: return '' else: return object def _get_element_data(node): return node and _None2Str(node.firstChild and node.firstChild.data) def _get_element_int(node, default=0): try: return int(_get_element_data(node)) except: return default def _get_child_elements(node): return filter(lambda node: node.nodeType == node.ELEMENT_NODE, node.childNodes) def _set_element(node, new_data): if node.firstChild and node.firstChild.data: node.firstChild.data = str(new_data) else: new_data_node = xml.dom.minidom.Text() new_data_node.data = str(new_data) new_data_node.ownerDocument = node.ownerDocument node.appendChild(new_data_node) class ConfigDict: def __init__(self, dom_node): self._node = dom_node self._name = self._node.nodeName for node in _get_child_elements(self._node): self.__dict__[node.nodeName] = _get_element_data(node) def save(self): for key in self.__dict__: if key.startswith('_'): continue _set_element( _get_element(self._node,key,1), str(self.__dict__[key]) ) def debug_print(self): for key in self.__dict__.keys(): print key.rjust(15), '=', self.__dict__[key] class ConfigDictList(list): def __init__(self, dom_node, item_class=ConfigDict): self._node = dom_node list.__init__(self, map(item_class, _get_child_elements(self._node))) def save(self): map(ConfigDict.save, self) def make_node_and_append(self, name): '''Make a new ConfigDict and append it. Returns new ConfigDict.''' new_element = _append_new_element(self._node, name) new_cd = ConfigDict(new_element) self.append(new_cd) return new_cd class XMLConfig: '''Base class for xml config files''' def __init__(self, filename = None): # default_filename should be defined by children self.filename = filename or self.default_filename def read(self, failopen_ok=False): """Read the XML object's file source and return self.""" try: self.xml = xml.dom.minidom.parse(self.filename) except IOError, e: if not failopen_ok: # raise raise SystemExit("%s: Couldn't parse XML config\n%s: %s"%(sys.argv[0],sys.argv[0],e)) print >>sys.stderr, "Warning:", e # self.xml = xml.dom.minidom.Document() self.xml = xml.dom.minidom.parseString(self.default_xml) self._get_elements() return self def _get_elements(self): pass def write(self, output=None): """Write XML data to filename, or other stream.""" self._set_elements() if not output: output = open(self.filename,'w') self.xml.writexml(output) print >>output return self def _set_elements(self): pass class ConfigFile(XMLConfig): ''' embodies config.xml Public attributes: config - ConfigDict tasks - list of ConfigDict elements daemons - ''' default_filename = boinc_project_path.config_xml_filename def _get_elements(self): self.xml_boinc = _get_element(self.xml, 'boinc', optional=False) self.xml_config = _get_element(self.xml_boinc, 'config', optional=False) self.xml_tasks = _get_element(self.xml_boinc, 'tasks') self.xml_daemons = _get_element(self.xml_boinc, 'daemons') self.config = ConfigDict(self.xml_config) self.daemons = ConfigDictList(self.xml_daemons) self.tasks = ConfigDictList(self.xml_tasks) def _set_elements(self): self.config.save() self.daemons.save() self.tasks.save() def debug_print_all(self): '''print everything to stdout.''' print 'Debug dump of', self.filename print '-- parsed xml -------------------------------------------------------' self.xml.writexml(sys.stdout) print print '-- Config -----------------------------------------------------------' self.config.debug_print() print print '-- Daemons ------------------------------------------------------------' for daemon in self.daemons: daemon.debug_print() print print print '-- Tasks ------------------------------------------------------------' for task in self.tasks: task.debug_print() print default_xml = '' # keeps BoincCron's timestamp status file class RunStateFile(XMLConfig): ''' embodies run_state.xml Public attributes: tasks - list of ConfigDict elements enabled - boolean ''' default_filename = boinc_project_path.run_state_xml_filename def _get_elements(self): self.xml_boinc = _get_element(self.xml, 'boinc', optional=False) self.xml_tasks = _get_element(self.xml_boinc, 'tasks') self.xml_enabled = _get_element(self.xml_boinc, 'enabled') self.tasks = ConfigDictList(self.xml_tasks) self.enabled = _get_element_int(self.xml_enabled) def _set_elements(self): _set_element( self.xml_enabled, self.enabled ) self.tasks.save() default_xml = '' if __name__ == '__main__': config = ConfigFile().read() # print "setting config.enabled = True" # config.enabled = True config.debug_print_all() print " -- saving xml and rewriting -----------------------------------------------" config.write(sys.stdout)