X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfatables%2Fcommands%2FAdd.py;h=da02e869258646c75e1cdd2fac8ca19a15dffe47;hb=87121ca63d2b95bb155ea2adc5fd7c61d5cddcbe;hp=d8bd9a769e317df3df1765a482e4e621d136ee81;hpb=ca033bfcc5afa7b9633f9caba9e9b1691222cbf2;p=sfa.git diff --git a/sfatables/commands/Add.py b/sfatables/commands/Add.py index d8bd9a76..da02e869 100644 --- a/sfatables/commands/Add.py +++ b/sfatables/commands/Add.py @@ -1,5 +1,7 @@ import os, time +import libxml2 from sfatables.command import Command +from sfatables.globals import * class Add(Command): options = [('-A','--add')] @@ -10,7 +12,60 @@ class Add(Command): def __init__(self): return - def call(self, command_options, match_options, target_options): - # Override this function + def getnextfilename(self,type,chain): + dir = sfatables_config + "/"+chain; + last_rule_number = 0 + + for (root, dirs, files) in os.walk(dir): + for file in files: + if (file.startswith('sfatables-') and file.endswith(type)): + number_str = file.split('-')[1] + number = int(number_str) + if (number>last_rule_number): + last_rule_number = number + + return "sfatables-%d-%s"%(last_rule_number+1,type) + + def call_gen(self, chain, type, dir, options): + filename = os.path.join(dir, options.name+".xml") + xmldoc = libxml2.parseFile(filename) + + p = xmldoc.xpathNewContext() + + supplied_arguments = options.arguments + if (hasattr(options,'element') and options.element): + element = options.element + else: + element='*' + + for option in supplied_arguments: + option_name = option['name'] + option_value = getattr(options,option_name) + + if (hasattr(options,option_name)): + context = p.xpathEval("//rule[@element='%s' or @element='*']/argument[name='%s']"%(element, option_name)) + if (not context): + raise Exception('Unknown option %s for match %s and element %s'%(option,option['name'], element)) + else: + # Add the value of option + valueNode = libxml2.newNode('value') + valueNode.addContent(option_value) + context[0].addChild(valueNode) + + filename = self.getnextfilename(type,chain) + file_path = os.path.join(sfatables_config, chain, filename) + if not os.path.isdir(os.path.dirname(file_path)): + os.makedirs(os.path.dirname(file_path)) + xmldoc.saveFile(file_path) + p.xpathFreeContext() + xmldoc.freeDoc() + return True + def call(self, command_options, match_options, target_options): + chain = command_options.args[0] + ret = self.call_gen(chain, 'match',match_dir, match_options) + if (ret): + ret = self.call_gen(chain, 'target',target_dir, target_options) + + return ret