mirror of
https://github.com/retspen/webvirtcloud
synced 2024-12-26 16:15:25 +00:00
129 lines
4.1 KiB
Python
129 lines
4.1 KiB
Python
from xml.etree import ElementTree
|
|
|
|
from vrtManager.connection import wvmConnect
|
|
|
|
|
|
class wvmNWFilters(wvmConnect):
|
|
def get_nwfilter_info(self, name):
|
|
nwfilter = self.get_nwfilter(name)
|
|
xml = nwfilter.XMLDesc(0)
|
|
uuid = nwfilter.UUIDString()
|
|
return {"name": name, "uuid": uuid, "xml": xml}
|
|
|
|
def create_nwfilter(self, xml):
|
|
self.wvm.nwfilterDefineXML(xml)
|
|
|
|
def clone_nwfilter(self, name, cln_name):
|
|
nwfilter = self.get_nwfilter(name)
|
|
if nwfilter:
|
|
tree = ElementTree.fromstring(nwfilter.XMLDesc(0))
|
|
tree.set("name", cln_name)
|
|
uuid = tree.find("uuid")
|
|
tree.remove(uuid)
|
|
self.create_nwfilter(ElementTree.tostring(tree).decode())
|
|
|
|
|
|
class wvmNWFilter(wvmConnect):
|
|
def __init__(self, host, login, passwd, conn, nwfiltername):
|
|
wvmConnect.__init__(self, host, login, passwd, conn)
|
|
self.nwfilter = self.get_nwfilter(nwfiltername)
|
|
|
|
def _XMLDesc(self, flags):
|
|
return self.nwfilter.XMLDesc(flags)
|
|
|
|
def get_uuid(self):
|
|
return self.nwfilter.UUIDString()
|
|
|
|
def get_name(self):
|
|
return self.nwfilter.name()
|
|
|
|
def delete(self):
|
|
self.nwfilter.undefine()
|
|
|
|
def get_xml(self):
|
|
tree = ElementTree.fromstring(self._XMLDesc(0))
|
|
uuid = tree.find("uuid")
|
|
tree.remove(uuid)
|
|
return ElementTree.tostring(tree).decode()
|
|
|
|
def get_filter_refs(self):
|
|
tree = ElementTree.fromstring(self._XMLDesc(0))
|
|
return [ref.get("filter") for ref in tree.findall("./filterref")]
|
|
|
|
def get_rules(self):
|
|
rules = []
|
|
|
|
tree = ElementTree.fromstring(self._XMLDesc(0))
|
|
for r in tree.findall("./rule"):
|
|
rule_action = r.get("action")
|
|
rule_direction = r.get("direction")
|
|
rule_priority = r.get("priority")
|
|
rule_statematch = r.get("statematch")
|
|
|
|
rule_directives = r.find("./")
|
|
if rule_directives is not None:
|
|
rule_directives = ElementTree.tostring(rule_directives).decode()
|
|
|
|
rule_info = {
|
|
"action": rule_action,
|
|
"direction": rule_direction,
|
|
"priority": rule_priority,
|
|
"statematch": rule_statematch,
|
|
"directives": rule_directives,
|
|
}
|
|
|
|
rules.append(rule_info)
|
|
|
|
return rules
|
|
|
|
def delete_ref(self, name):
|
|
tree = ElementTree.fromstring(self._XMLDesc(0))
|
|
for ref in tree.findall("./filterref"):
|
|
if name == ref.get("filter"):
|
|
tree.remove(ref)
|
|
break
|
|
return ElementTree.tostring(tree).decode()
|
|
|
|
def delete_rule(self, action, direction, priority):
|
|
tree = ElementTree.fromstring(self._XMLDesc(0))
|
|
|
|
rule_tree = tree.findall(
|
|
"./rule[@action='%s'][@direction='%s'][@priority='%s']"
|
|
% (action, direction, priority)
|
|
)
|
|
if rule_tree:
|
|
tree.remove(rule_tree[0])
|
|
|
|
return ElementTree.tostring(tree).decode()
|
|
|
|
def add_ref(self, name):
|
|
tree = ElementTree.fromstring(self._XMLDesc(0))
|
|
element = ElementTree.Element("filterref")
|
|
element.attrib["filter"] = name
|
|
tree.append(element)
|
|
return ElementTree.tostring(tree).decode()
|
|
|
|
def add_rule(self, xml):
|
|
tree = ElementTree.fromstring(self._XMLDesc(0))
|
|
rule = ElementTree.fromstring(xml)
|
|
|
|
rule_action = rule.get("action")
|
|
rule_direction = rule.get("direction")
|
|
rule_priority = rule.get("priority")
|
|
rule_directives = rule.find("./")
|
|
rule_tree = tree.findall(
|
|
"./rule[@action='%s'][@direction='%s'][@priority='%s']"
|
|
% (rule_action, rule_direction, rule_priority)
|
|
)
|
|
|
|
if rule_tree:
|
|
rule_tree[0].append(rule_directives)
|
|
else:
|
|
element = ElementTree.Element("rule")
|
|
element.attrib["action"] = rule_action
|
|
element.attrib["direction"] = rule_direction
|
|
element.attrib["priority"] = rule_priority
|
|
element.append(rule_directives)
|
|
tree.append(element)
|
|
|
|
return ElementTree.tostring(tree).decode()
|