diff options
Diffstat (limited to 'test/unittests/test_parse.py')
| -rw-r--r-- | test/unittests/test_parse.py | 749 |
1 files changed, 749 insertions, 0 deletions
diff --git a/test/unittests/test_parse.py b/test/unittests/test_parse.py new file mode 100644 index 0000000..27b26b9 --- /dev/null +++ b/test/unittests/test_parse.py @@ -0,0 +1,749 @@ +from __future__ import print_function +from __future__ import unicode_literals +# Copyright (C) 2013 Kristoffer Gronlund <kgronlund@suse.com> +# See COPYING for license information. +# +# unit tests for parse.py +try: + from unittest import mock +except ImportError: + import mock + +from builtins import zip +from crmsh import parse +import unittest +import shlex +from crmsh.utils import lines2cli +from crmsh.xmlutil import xml_tostring +from lxml import etree + + +def test_score_to_kind(): + assert parse.score_to_kind("0") == "Optional" + assert parse.score_to_kind("INFINITY") == "Mandatory" + assert parse.score_to_kind("200") == "Mandatory" + + +class MockValidation(parse.Validation): + def resource_roles(self): + return ['Master', 'Slave', 'Started'] + + def resource_actions(self): + return ['start', 'stop', 'promote', 'demote'] + + def date_ops(self): + return ['lt', 'gt', 'in_range', 'date_spec'] + + def expression_types(self): + return ['normal', 'string', 'number'] + + def rsc_order_kinds(self): + return ['Mandatory', 'Optional', 'Serialize'] + + def op_attributes(self): + return ['id', 'name', 'interval', 'timeout', 'description', + 'start-delay', 'interval-origin', 'timeout', 'enabled', + 'record-pending', 'role', 'requires', 'on-fail'] + + def acl_2_0(self): + return True + + +class TestBaseParser(unittest.TestCase): + def setUp(self): + self.base = parse.BaseParser() + + def _reset(self, cmd): + self.base._cmd = shlex.split(cmd) + self.base._currtok = 0 + + @mock.patch('logging.Logger.error') + def test_err(self, mock_err): + self._reset('a:b:c:d') + + def runner(): + self.base.match_split() + self.assertRaises(parse.ParseError, runner) + + @mock.patch('logging.Logger.error') + def test_idspec(self, mock_error): + self._reset('$id=foo') + self.base.match_idspec() + self.assertEqual(self.base.matched(1), '$id') + self.assertEqual(self.base.matched(2), 'foo') + + self._reset('$id-ref=foo') + self.base.match_idspec() + self.assertEqual(self.base.matched(1), '$id-ref') + self.assertEqual(self.base.matched(2), 'foo') + + def runner(): + self._reset('id=foo') + self.base.match_idspec() + self.assertRaises(parse.ParseError, runner) + + def test_match_split(self): + self._reset('resource:role') + a, b = self.base.match_split() + self.assertEqual(a, 'resource') + self.assertEqual(b, 'role') + + self._reset('role') + a, b = self.base.match_split() + self.assertEqual(a, 'role') + self.assertEqual(b, None) + + def test_description(self): + self._reset('description="this is a description"') + self.assertEqual(self.base.try_match_description(), 'this is a description') + + def test_nvpairs(self): + self._reset('foo=bar wiz="fizz buzz" bug= bug2=') + ret = self.base.match_nvpairs() + self.assertEqual(len(ret), 4) + retdict = dict([(r.get('name'), r.get('value')) for r in ret]) + self.assertEqual(retdict['foo'], 'bar') + self.assertEqual(retdict['bug'], '') + self.assertEqual(retdict['wiz'], 'fizz buzz') + + +class TestCliParser(unittest.TestCase): + def setUp(self): + parse.validator = MockValidation() + self.comments = [] + + def _parse(self, s): + return parse.parse(s, comments=self.comments) + + @mock.patch('logging.Logger.error') + def test_node(self, mock_error): + out = self._parse('node node-1') + self.assertEqual(out.get('uname'), 'node-1') + + out = self._parse('node $id=testid node-1') + self.assertEqual(out.get('id'), 'testid') + self.assertEqual(out.get('uname'), 'node-1') + + out = self._parse('node 1: node-1') + self.assertEqual(out.get('id'), '1') + self.assertEqual(out.get('uname'), 'node-1') + + out = self._parse('node testid: node-1') + self.assertEqual(out.get('id'), 'testid') + self.assertEqual(out.get('uname'), 'node-1') + + out = self._parse('node $id=testid node-1:ping') + self.assertEqual(out.get('id'), 'testid') + self.assertEqual(out.get('uname'), 'node-1') + self.assertEqual(out.get('type'), 'ping') + + out = self._parse('node node-1:unknown') + self.assertFalse(out) + + out = self._parse('node node-1 description="foo bar" attributes foo=bar') + self.assertEqual(out.get('description'), 'foo bar') + self.assertEqual(['bar'], out.xpath('instance_attributes/nvpair[@name="foo"]/@value')) + + out = self._parse('node node-1 attributes foo=bar utilization wiz=bang') + self.assertEqual(['bar'], out.xpath('instance_attributes/nvpair[@name="foo"]/@value')) + self.assertEqual(['bang'], out.xpath('utilization/nvpair[@name="wiz"]/@value')) + + @mock.patch('logging.Logger.error') + def test_resources(self, mock_error): + out = self._parse('primitive www ocf:heartbeat:apache op monitor timeout=10s') + self.assertEqual(out.get('id'), 'www') + self.assertEqual(out.get('class'), 'ocf') + self.assertEqual(['monitor'], out.xpath('//op/@name')) + + out = self._parse('rsc_template public_vm ocf:heartbeat:Xen op start timeout=300s op stop timeout=300s op monitor interval=30s timeout=60s op migrate_from timeout=600s op migrate_to timeout=600s') + self.assertEqual(out.get('id'), 'public_vm') + self.assertEqual(out.get('class'), 'ocf') + #print out + + out = self._parse('primitive st stonith:ssh params hostlist=node1 meta target-role=Started requires=nothing op start timeout=60s op monitor interval=60m timeout=60s') + self.assertEqual(out.get('id'), 'st') + + out2 = self._parse('primitive st stonith:ssh hostlist=node1 meta target-role=Started requires=nothing op start timeout=60s op monitor interval=60m timeout=60s') + self.assertEqual(out2.get('id'), 'st') + + self.assertEqual(xml_tostring(out), xml_tostring(out2)) + + out = self._parse('primitive st stonith:ssh params hostlist= meta') + self.assertEqual(out.get('id'), 'st') + + out = self._parse('primitive st stonith:null params hostlist=node1 meta requires=nothing description="some description here" op start op monitor interval=60m') + self.assertEqual(out.get('id'), 'st') + + out = self._parse('ms m0 resource params a=b') + self.assertEqual(out.get('id'), 'm0') + print(xml_tostring(out)) + self.assertEqual(['resource'], out.xpath('./crmsh-ref/@id')) + self.assertEqual(['b'], out.xpath('instance_attributes/nvpair[@name="a"]/@value')) + + out2 = self._parse('ms m0 resource a=b') + self.assertEqual(out.get('id'), 'm0') + self.assertEqual(xml_tostring(out), xml_tostring(out2)) + + out = self._parse('master ma resource meta a=b') + self.assertEqual(out.get('id'), 'ma') + self.assertEqual(['resource'], out.xpath('./crmsh-ref/@id')) + self.assertEqual(['b'], out.xpath('meta_attributes/nvpair[@name="a"]/@value')) + + out = self._parse('clone clone-1 resource meta a=b') + self.assertEqual(out.get('id'), 'clone-1') + self.assertEqual(['resource'], out.xpath('./crmsh-ref/@id')) + self.assertEqual(['b'], out.xpath('meta_attributes/nvpair[@name="a"]/@value')) + + out = self._parse('group group-1 a') + self.assertEqual(out.get('id'), 'group-1') + self.assertEqual(len(out), 1) + + out = self._parse('group group-1 a b c') + self.assertEqual(len(out), 3) + + out = self._parse('group group-1') + self.assertFalse(out) + + out = self._parse('group group-1 params a=b') + self.assertEqual(len(out), 1) + self.assertEqual(['b'], out.xpath('/group/instance_attributes/nvpair[@name="a"]/@value')) + + def test_heartbeat_class(self): + out = self._parse('primitive p_node-activate heartbeat:node-activate') + self.assertEqual(out.get('id'), 'p_node-activate') + self.assertEqual(out.get('class'), 'heartbeat') + self.assertEqual(out.get('provider'), None) + self.assertEqual(out.get('type'), 'node-activate') + + + def test_nvpair_ref(self): + out = self._parse('primitive dummy-0 Dummy params @foo') + self.assertEqual(out.get('id'), 'dummy-0') + self.assertEqual(out.get('class'), 'ocf') + self.assertEqual(['foo'], out.xpath('.//nvpair/@id-ref')) + + out = self._parse('primitive dummy-0 Dummy params @fiz:buz') + self.assertEqual(out.get('id'), 'dummy-0') + self.assertEqual(out.get('class'), 'ocf') + self.assertEqual(['fiz'], out.xpath('.//nvpair/@id-ref')) + self.assertEqual(['buz'], out.xpath('.//nvpair/@name')) + + @mock.patch('logging.Logger.error') + def test_location(self, mock_error): + out = self._parse('location loc-1 resource inf: foo') + self.assertEqual(out.get('id'), 'loc-1') + self.assertEqual(out.get('rsc'), 'resource') + self.assertEqual(out.get('score'), 'INFINITY') + self.assertEqual(out.get('node'), 'foo') + + out = self._parse('location loc-1 /foo.*/ inf: bar') + self.assertEqual(out.get('id'), 'loc-1') + self.assertEqual(out.get('rsc-pattern'), 'foo.*') + self.assertEqual(out.get('score'), 'INFINITY') + self.assertEqual(out.get('node'), 'bar') + #print out + + out = self._parse('location loc-1 // inf: bar') + self.assertFalse(out) + + out = self._parse('location loc-1 { one ( two three ) four } inf: bar') + self.assertEqual(out.get('id'), 'loc-1') + self.assertEqual(['one', 'two', 'three', 'four'], out.xpath('//resource_ref/@id')) + self.assertEqual(out.get('score'), 'INFINITY') + self.assertEqual(out.get('node'), 'bar') + #print out + + out = self._parse('location loc-1 thing rule role=slave -inf: #uname eq madrid') + self.assertEqual(out.get('id'), 'loc-1') + self.assertEqual(out.get('rsc'), 'thing') + self.assertEqual(out.get('score'), None) + + out = self._parse('location l { a:foo b:bar }') + self.assertFalse(out) + + @mock.patch('logging.Logger.error') + def test_colocation(self, mock_error): + out = self._parse('colocation col-1 inf: foo:master ( bar wiz sequential=yes )') + self.assertEqual(out.get('id'), 'col-1') + self.assertEqual(['foo', 'bar', 'wiz'], out.xpath('//resource_ref/@id')) + self.assertEqual([], out.xpath('//resource_set[@name="sequential"]/@value')) + + out = self._parse( + 'colocation col-1 -20: foo:Master ( bar wiz ) ( zip zoo ) node-attribute="fiz"') + self.assertEqual(out.get('id'), 'col-1') + self.assertEqual(out.get('score'), '-20') + self.assertEqual(['foo', 'bar', 'wiz', 'zip', 'zoo'], out.xpath('//resource_ref/@id')) + self.assertEqual(['fiz'], out.xpath('//@node-attribute')) + + out = self._parse('colocation col-1 0: a:master b') + self.assertEqual(out.get('id'), 'col-1') + + out = self._parse('colocation col-1 10: ) bar wiz') + self.assertFalse(out) + + out = self._parse('colocation col-1 10: ( bar wiz') + self.assertFalse(out) + + out = self._parse('colocation col-1 10: ( bar wiz ]') + self.assertFalse(out) + + def test_order(self): + out = self._parse('order o1 Mandatory: [ A B sequential=true ] C') + print(xml_tostring(out)) + self.assertEqual(['Mandatory'], out.xpath('/rsc_order/@kind')) + self.assertEqual(2, len(out.xpath('/rsc_order/resource_set'))) + self.assertEqual(['false'], out.xpath('/rsc_order/resource_set/@require-all')) + self.assertEqual(['A', 'B', 'C'], out.xpath('//resource_ref/@id')) + + out = self._parse('order o1 Mandatory: [ A B sequential=false ] C') + self.assertEqual(2, len(out.xpath('/rsc_order/resource_set'))) + #self.assertTrue(['require-all', 'false'] in out.resources[0][1]) + #self.assertTrue(['sequential', 'false'] in out.resources[0][1]) + self.assertEqual(out.get('id'), 'o1') + + out = self._parse('order o1 Mandatory: A B C sequential=false') + self.assertEqual(1, len(out.xpath('/rsc_order/resource_set'))) + #self.assertTrue(['sequential', 'false'] in out.resources[0][1]) + self.assertEqual(out.get('id'), 'o1') + + out = self._parse('order o1 Mandatory: A B C sequential=true') + self.assertEqual(1, len(out.xpath('/rsc_order/resource_set'))) + #self.assertTrue(['sequential', 'true'] not in out.resources[0][1]) + self.assertEqual(out.get('id'), 'o1') + + out = self._parse('order c_apache_1 Mandatory: apache:start ip_1') + self.assertEqual(out.get('id'), 'c_apache_1') + + out = self._parse('order c_apache_2 Mandatory: apache:start ip_1 ip_2 ip_3') + self.assertEqual(2, len(out.xpath('/rsc_order/resource_set'))) + self.assertEqual(out.get('id'), 'c_apache_2') + + out = self._parse('order o1 Serialize: A ( B C )') + self.assertEqual(2, len(out.xpath('/rsc_order/resource_set'))) + self.assertEqual(out.get('id'), 'o1') + + out = self._parse('order o1 Serialize: A ( B C ) symmetrical=false') + self.assertEqual(2, len(out.xpath('/rsc_order/resource_set'))) + self.assertEqual(out.get('id'), 'o1') + self.assertEqual(['false'], out.xpath('//@symmetrical')) + + out = self._parse('order o1 Serialize: A ( B C ) symmetrical=true') + self.assertEqual(2, len(out.xpath('/rsc_order/resource_set'))) + self.assertEqual(out.get('id'), 'o1') + self.assertEqual(['true'], out.xpath('//@symmetrical')) + + inp = 'colocation rsc_colocation-master INFINITY: [ vip-master vip-rep sequential=true ] [ msPostgresql:Master sequential=true ]' + out = self._parse(inp) + self.assertEqual(2, len(out.xpath('/rsc_colocation/resource_set'))) + self.assertEqual(out.get('id'), 'rsc_colocation-master') + + out = self._parse('order order_2 Mandatory: [ A B ] C') + self.assertEqual(2, len(out.xpath('/rsc_order/resource_set'))) + self.assertEqual(out.get('id'), 'order_2') + self.assertEqual(['Mandatory'], out.xpath('/rsc_order/@kind')) + self.assertEqual(['false'], out.xpath('//resource_set/@sequential')) + + out = self._parse('order order-1 Optional: group1:stop group2:start') + self.assertEqual(out.get('id'), 'order-1') + self.assertEqual(['Optional'], out.xpath('/rsc_order/@kind')) + self.assertEqual(['group1'], out.xpath('/rsc_order/@first')) + self.assertEqual(['stop'], out.xpath('/rsc_order/@first-action')) + self.assertEqual(['group2'], out.xpath('/rsc_order/@then')) + self.assertEqual(['start'], out.xpath('/rsc_order/@then-action')) + + def test_ticket(self): + out = self._parse('rsc_ticket ticket-A_public-ip ticket-A: public-ip') + self.assertEqual(out.get('id'), 'ticket-A_public-ip') + + out = self._parse('rsc_ticket ticket-A_bigdb ticket-A: bigdb loss-policy=fence') + self.assertEqual(out.get('id'), 'ticket-A_bigdb') + + out = self._parse( + 'rsc_ticket ticket-B_storage ticket-B: drbd-a:Master drbd-b:Master') + self.assertEqual(out.get('id'), 'ticket-B_storage') + + @mock.patch('logging.Logger.error') + def test_bundle(self, mock_error): + out = self._parse('bundle httpd docker image=pcmk:httpd replicas=3 network ip-range-start=10.10.10.123 host-netmask=24 port-mapping port=80 storage storage-mapping target-dir=/var/www/html source-dir=/srv/www options=rw primitive httpd-apache') + self.assertEqual(out.get('id'), 'httpd') + self.assertEqual(['pcmk:httpd'], out.xpath('/bundle/docker/@image')) + self.assertEqual(['httpd-apache'], out.xpath('/bundle/crmsh-ref/@id')) + + out = self._parse('bundle httpd docker image=pcmk:httpd primitive httpd-apache apache') + self.assertFalse(out) + + @mock.patch('logging.Logger.error') + def test_op(self, mock_error): + out = self._parse('monitor apache:Master 10s:20s') + self.assertEqual(out.get('rsc'), 'apache') + self.assertEqual(out.get('role'), 'Master') + self.assertEqual(out.get('interval'), '10s') + self.assertEqual(out.get('timeout'), '20s') + + out = self._parse('monitor apache 60m') + self.assertEqual(out.get('rsc'), 'apache') + self.assertEqual(out.get('role'), None) + self.assertEqual(out.get('interval'), '60m') + + out = self._parse('primitive rsc_dummy1 Dummy op monitor interval=10 OCF_CHECK_LEVEL=10 timeout=60') + # incorrect ordering of attributes + self.assertFalse(out) + + @mock.patch('logging.Logger.error') + def test_acl(self, mock_error): + out = self._parse('role user-1 error') + self.assertFalse(out) + out = self._parse('user user-1 role:user-1') + self.assertNotEqual(out, False) + + out = self._parse("role bigdb_admin " + + "write meta:bigdb:target-role " + + "write meta:bigdb:is-managed " + + "write location:bigdb " + + "read ref:bigdb") + self.assertEqual(4, len(out)) + + # new type of acls + + out = self._parse("acl_target foo a") + self.assertEqual('acl_target', out.tag) + self.assertEqual('foo', out.get('id')) + self.assertEqual(['a'], out.xpath('./role/@id')) + + out = self._parse("acl_target foo a b") + self.assertEqual('acl_target', out.tag) + self.assertEqual('foo', out.get('id')) + self.assertEqual(['a', 'b'], out.xpath('./role/@id')) + + out = self._parse("acl_target foo a b c") + self.assertEqual('acl_target', out.tag) + self.assertEqual('foo', out.get('id')) + self.assertEqual(['a', 'b', 'c'], out.xpath('./role/@id')) + out = self._parse("acl_group fee a b c") + self.assertEqual('acl_group', out.tag) + self.assertEqual('fee', out.get('id')) + self.assertEqual(['a', 'b', 'c'], out.xpath('./role/@id')) + out = self._parse('role fum description="test" read a: description="test2" xpath:*[@name=\\"karl\\"]') + self.assertEqual(['*[@name="karl"]'], out.xpath('/acl_role/acl_permission/@xpath')) + + def test_xml(self): + out = self._parse('xml <node uname="foo-1"/>') + self.assertEqual('node', out.tag) + self.assertEqual('foo-1', out.get('uname')) + + @mock.patch('logging.Logger.error') + def test_property(self, mock_error): + out = self._parse('property stonith-enabled=true') + self.assertEqual(['true'], out.xpath('//nvpair[@name="stonith-enabled"]/@value')) + + # missing score + out = self._parse('property rule #uname eq node1 stonith-enabled=no') + self.assertEqual(['INFINITY'], out.xpath('//@score')) + + out = self._parse('property rule 10: #uname eq node1 stonith-enabled=no') + self.assertEqual(['no'], out.xpath('//nvpair[@name="stonith-enabled"]/@value')) + self.assertEqual(['node1'], out.xpath('//expression[@attribute="#uname"]/@value')) + + out = self._parse('property rule +inf: date spec years=2014 stonith-enabled=no') + self.assertEqual(['no'], out.xpath('//nvpair[@name="stonith-enabled"]/@value')) + self.assertEqual(['2014'], out.xpath('//date_spec/@years')) + + out = self._parse('rsc_defaults failure-timeout=3m') + self.assertEqual(['3m'], out.xpath('//nvpair[@name="failure-timeout"]/@value')) + + out = self._parse('rsc_defaults foo: failure-timeout=3m') + self.assertEqual('foo', out[0].get('id')) + self.assertEqual(['3m'], out.xpath('//nvpair[@name="failure-timeout"]/@value')) + + out = self._parse('rsc_defaults failure-timeout=3m foo:') + self.assertEqual(False, out) + + def test_empty_property_sets(self): + out = self._parse('rsc_defaults defaults:') + self.assertEqual('<rsc_defaults><meta_attributes id="defaults"/></rsc_defaults>', + xml_tostring(out)) + + out = self._parse('op_defaults defaults:') + self.assertEqual('<op_defaults><meta_attributes id="defaults"/></op_defaults>', + xml_tostring(out)) + + def test_fencing(self): + # num test nodes are 3 + + out = self._parse('fencing_topology') + expect = '<fencing-topology/>' + self.assertEqual(expect, xml_tostring(out)) + + out = self._parse('fencing_topology poison-pill power') + expect = '<fencing-topology><fencing-level target="ha-one" index="1" devices="poison-pill"/><fencing-level target="ha-one" index="2" devices="power"/><fencing-level target="ha-three" index="1" devices="poison-pill"/><fencing-level target="ha-three" index="2" devices="power"/><fencing-level target="ha-two" index="1" devices="poison-pill"/><fencing-level target="ha-two" index="2" devices="power"/></fencing-topology>' + self.assertEqual(expect, xml_tostring(out)) + + out = self._parse('fencing_topology node-a: poison-pill power node-b: ipmi serial') + self.assertEqual(4, len(out)) + + devs = ['stonith-vbox3-1-off', 'stonith-vbox3-2-off', + 'stonith-vbox3-1-on', 'stonith-vbox3-2-on'] + out = self._parse('fencing_topology vbox4: %s' % ','.join(devs)) + print(xml_tostring(out)) + self.assertEqual(1, len(out)) + + def test_fencing_1114(self): + """ + Test node attribute fence target assignment + """ + out = self._parse('fencing_topology attr:rack=1 poison-pill power') + expect = """<fencing-topology><fencing-level index="1" devices="poison-pill" target-attribute="rack" target-value="1"/><fencing-level index="2" devices="power" target-attribute="rack" target-value="1"/></fencing-topology>""" + self.assertEqual(expect, xml_tostring(out)) + + out = self._parse('fencing_topology attr:rack=1 poison-pill,power') + expect = '<fencing-topology><fencing-level index="1" devices="poison-pill,power" target-attribute="rack" target-value="1"/></fencing-topology>' + self.assertEqual(expect, xml_tostring(out)) + + @mock.patch('logging.Logger.error') + def test_tag(self, mock_error): + out = self._parse('tag tag1: one two three') + self.assertEqual(out.get('id'), 'tag1') + self.assertEqual(['one', 'two', 'three'], out.xpath('/tag/obj_ref/@id')) + + out = self._parse('tag tag1:') + self.assertFalse(out) + + out = self._parse('tag tag1:: foo') + self.assertFalse(out) + + out = self._parse('tag tag1 foo bar') + self.assertEqual(out.get('id'), 'tag1') + self.assertEqual(['foo', 'bar'], out.xpath('/tag/obj_ref/@id')) + + def test_alerts(self): + "Test alerts (1.1.15+)" + out = self._parse('alert alert1 /tmp/foo.sh to /tmp/bar.log') + self.assertEqual(out.get('id'), 'alert1') + self.assertEqual(['/tmp/foo.sh'], + out.xpath('/alert/@path')) + self.assertEqual(['/tmp/bar.log'], + out.xpath('/alert/recipient/@value')) + + def test_alerts_brackets(self): + "Test alerts w/ brackets (1.1.15+)" + out = self._parse('alert alert2 /tmp/foo.sh to { /tmp/bar.log meta timeout=10s }') + self.assertEqual(out.get('id'), 'alert2') + self.assertEqual(['/tmp/foo.sh'], + out.xpath('/alert/@path')) + self.assertEqual(['/tmp/bar.log'], + out.xpath('/alert/recipient/@value')) + self.assertEqual(['10s'], + out.xpath('/alert/recipient/meta_attributes/nvpair[@name="timeout"]/@value')) + + def test_alerts_selectors(self): + "Test alerts w/ selectors (1.1.17+)" + out = self._parse('alert alert3 /tmp/foo.sh select nodes fencing attributes { standby shutdown } to { /tmp/bar.log meta timeout=10s }') + self.assertEqual(out.get('id'), 'alert3') + self.assertEqual(1, len(out.xpath('/alert/select/select_nodes'))) + self.assertEqual(1, len(out.xpath('/alert/select/select_fencing'))) + self.assertEqual(['standby', 'shutdown'], + out.xpath('/alert/select/select_attributes/attribute/@name')) + + + def _parse_lines(self, lines): + out = [] + for line in lines2cli(lines): + if line is not None: + tmp = self._parse(line.strip()) + self.assertNotEqual(tmp, False) + if tmp is not None: + out.append(tmp) + return out + + def test_comments(self): + outp = self._parse_lines(''' + # comment + node n1 + ''') + self.assertNotEqual(-1, xml_tostring(outp[0]).find('# comment')) + + def test_uppercase(self): + outp = self._parse_lines(''' + PRIMITIVE rsc_dummy ocf:heartbeat:Dummy + MONITOR rsc_dummy 30 + ''') + #print outp + self.assertEqual('primitive', outp[0].tag) + self.assertEqual('op', outp[1].tag) + + outp = self._parse_lines(''' + PRIMITIVE testfs ocf:heartbeat:Filesystem \ + PARAMS directory="/mnt" fstype="ocfs2" device="/dev/sda1" + CLONE testfs-clone testfs \ + META ordered="true" interleave="true" + ''') + #print outp + self.assertEqual('primitive', outp[0].tag) + self.assertEqual('clone', outp[1].tag) + + out = self._parse('LOCATION loc-1 resource INF: foo') + self.assertEqual(out.get('id'), 'loc-1') + self.assertEqual(out.get('rsc'), 'resource') + self.assertEqual(out.get('score'), 'INFINITY') + self.assertEqual(out.get('node'), 'foo') + + out = self._parse('NODE node-1 ATTRIBUTES foo=bar UTILIZATION wiz=bang') + self.assertEqual('node-1', out.get('uname')) + self.assertEqual(['bar'], out.xpath('/node/instance_attributes/nvpair[@name="foo"]/@value')) + self.assertEqual(['bang'], out.xpath('/node/utilization/nvpair[@name="wiz"]/@value')) + + out = self._parse('PRIMITIVE virtual-ip ocf:heartbeat:IPaddr2 PARAMS ip=192.168.122.13 lvs_support=false OP start timeout=20 interval=0 OP stop timeout=20 interval=0 OP monitor interval=10 timeout=20') + self.assertEqual(['192.168.122.13'], out.xpath('//instance_attributes/nvpair[@name="ip"]/@value')) + + out = self._parse('GROUP web-server virtual-ip apache META target-role=Started') + self.assertEqual(out.get('id'), 'web-server') + + def test_nvpair_novalue(self): + inp = """primitive stonith_ipmi-karl stonith:fence_ipmilan \ + params pcmk_host_list=karl verbose action=reboot \ + ipaddr=10.43.242.221 login=root passwd=dummy method=onoff \ + op start interval=0 timeout=60 \ + op stop interval=0 timeout=60 \ + op monitor interval=600 timeout=60 \ + meta target-role=Started""" + + outp = self._parse_lines(inp) + self.assertEqual(len(outp), 1) + self.assertEqual('primitive', outp[0].tag) + # print xml_tostring(outp[0]) + verbose = outp[0].xpath('//nvpair[@name="verbose"]') + self.assertEqual(len(verbose), 1) + self.assertTrue('value' not in verbose[0].attrib) + + @mock.patch('logging.Logger.error') + def test_configs(self, mock_error): + outp = self._parse_lines(''' + primitive rsc_dummy ocf:heartbeat:Dummy + monitor rsc_dummy 30 + ''') + #print outp + self.assertEqual(2, len(outp)) + + outp = self._parse_lines(''' + primitive testfs ocf:heartbeat:Filesystem \ + params directory="/mnt" fstype="ocfs2" device="/dev/sda1" + clone testfs-clone testfs \ + meta ordered="true" interleave="true" + ''') + #print outp + self.assertEqual(2, len(outp)) + + inp = [ + """node node1 attributes mem=16G""", + """node node2 utilization cpu=4""", + """primitive st stonith:ssh \ + params hostlist='node1 node2' \ + meta target-role="Started" requires="nothing" \ + op start timeout=60s \ + op monitor interval=60m timeout=60s""", + """primitive st2 stonith:ssh \ + params hostlist='node1 node2'""", + """primitive d1 ocf:pacemaker:Dummy \ + operations $id=d1-ops \ + op monitor interval=60m \ + op monitor interval=120m OCF_CHECK_LEVEL=10""", + """monitor d1 60s:30s""", + """primitive d2 ocf:heartbeat:Delay \ + params mondelay=60 \ + op start timeout=60s \ + op stop timeout=60s""", + """monitor d2:Started 60s:30s""", + """group g1 d1 d2""", + """primitive d3 ocf:pacemaker:Dummy""", + """clone c d3 \ + meta clone-max=1""", + """primitive d4 ocf:pacemaker:Dummy""", + """ms m d4""", + """primitive s5 ocf:pacemaker:Stateful \ + operations $id-ref=d1-ops""", + """primitive s6 ocf:pacemaker:Stateful \ + operations $id-ref=d1""", + """ms m5 s5""", + """ms m6 s6""", + """location l1 g1 100: node1""", + """location l2 c \ + rule $id=l2-rule1 100: #uname eq node1""", + """location l3 m5 \ + rule inf: #uname eq node1 and pingd gt 0""", + """location l4 m5 \ + rule -inf: not_defined pingd or pingd lte 0""", + """location l5 m5 \ + rule -inf: not_defined pingd or pingd lte 0 \ + rule inf: #uname eq node1 and pingd gt 0 \ + rule inf: date lt "2009-05-26" and \ + date in start="2009-05-26" end="2009-07-26" and \ + date in start="2009-05-26" years="2009" and \ + date date_spec years="2009" hours=09-17""", + """location l6 m5 \ + rule $id-ref=l2-rule1""", + """location l7 m5 \ + rule $id-ref=l2""", + """collocation c1 inf: m6 m5""", + """collocation c2 inf: m5:Master d1:Started""", + """order o1 Mandatory: m5 m6""", + """order o2 Optional: d1:start m5:promote""", + """order o3 Serialize: m5 m6""", + """order o4 inf: m5 m6""", + """rsc_ticket ticket-A_m6 ticket-A: m6""", + """rsc_ticket ticket-B_m6_m5 ticket-B: m6 m5 loss-policy=fence""", + """rsc_ticket ticket-C_master ticket-C: m6 m5:Master loss-policy=fence""", + """fencing_topology st st2""", + """property stonith-enabled=true""", + """property $id=cpset2 maintenance-mode=true""", + """rsc_defaults failure-timeout=10m""", + """op_defaults $id=opsdef2 record-pending=true"""] + + outp = self._parse_lines('\n'.join(inp)) + a = [xml_tostring(x) for x in outp] + b = [ + '<node uname="node1"><instance_attributes><nvpair name="mem" value="16G"/></instance_attributes></node>', + '<node uname="node2"><utilization><nvpair name="cpu" value="4"/></utilization></node>', + '<primitive id="st" class="stonith" type="ssh"><instance_attributes><nvpair name="hostlist" value="node1 node2"/></instance_attributes><meta_attributes><nvpair name="target-role" value="Started"/><nvpair name="requires" value="nothing"/></meta_attributes><operations><op name="start" timeout="60s" interval="0s"/><op name="monitor" interval="60m" timeout="60s"/></operations></primitive>', + '<primitive id="st2" class="stonith" type="ssh"><instance_attributes><nvpair name="hostlist" value="node1 node2"/></instance_attributes></primitive>', + '<primitive id="d1" class="ocf" provider="pacemaker" type="Dummy"><operations id="d1-ops"><op name="monitor" interval="60m"/><op name="monitor" interval="120m"><instance_attributes><nvpair name="OCF_CHECK_LEVEL" value="10"/></instance_attributes></op></operations></primitive>', + '<op name="monitor" rsc="d1" interval="60s" timeout="30s"/>', + '<primitive id="d2" class="ocf" provider="heartbeat" type="Delay"><instance_attributes><nvpair name="mondelay" value="60"/></instance_attributes><operations><op name="start" timeout="60s" interval="0s"/><op name="stop" timeout="60s" interval="0s"/></operations></primitive>', + '<op name="monitor" role="Started" rsc="d2" interval="60s" timeout="30s"/>', + '<group id="g1"><crmsh-ref id="d1"/><crmsh-ref id="d2"/></group>', + '<primitive id="d3" class="ocf" provider="pacemaker" type="Dummy"/>', + '<clone id="c"><meta_attributes><nvpair name="clone-max" value="1"/></meta_attributes><crmsh-ref id="d3"/></clone>', + '<primitive id="d4" class="ocf" provider="pacemaker" type="Dummy"/>', + '<master id="m"><crmsh-ref id="d4"/></master>', + '<primitive id="s5" class="ocf" provider="pacemaker" type="Stateful"><operations id-ref="d1-ops"/></primitive>', + '<primitive id="s6" class="ocf" provider="pacemaker" type="Stateful"><operations id-ref="d1"/></primitive>', + '<master id="m5"><crmsh-ref id="s5"/></master>', + '<master id="m6"><crmsh-ref id="s6"/></master>', + '<rsc_location id="l1" rsc="g1" score="100" node="node1"/>', + '<rsc_location id="l2" rsc="c"><rule id="l2-rule1" score="100"><expression operation="eq" attribute="#uname" value="node1"/></rule></rsc_location>', + '<rsc_location id="l3" rsc="m5"><rule score="INFINITY"><expression operation="eq" attribute="#uname" value="node1"/><expression operation="gt" attribute="pingd" value="0"/></rule></rsc_location>', + '<rsc_location id="l4" rsc="m5"><rule score="-INFINITY" boolean-op="or"><expression operation="not_defined" attribute="pingd"/><expression operation="lte" attribute="pingd" value="0"/></rule></rsc_location>', + '<rsc_location id="l5" rsc="m5"><rule score="-INFINITY" boolean-op="or"><expression operation="not_defined" attribute="pingd"/><expression operation="lte" attribute="pingd" value="0"/></rule><rule score="INFINITY"><expression operation="eq" attribute="#uname" value="node1"/><expression operation="gt" attribute="pingd" value="0"/></rule><rule score="INFINITY"><date_expression operation="lt" end="2009-05-26"/><date_expression operation="in_range" start="2009-05-26" end="2009-07-26"/><date_expression operation="in_range" start="2009-05-26"><duration years="2009"/></date_expression><date_expression operation="date_spec"><date_spec years="2009" hours="09-17"/></date_expression></rule></rsc_location>', + '<rsc_location id="l6" rsc="m5"><rule id-ref="l2-rule1"/></rsc_location>', + '<rsc_location id="l7" rsc="m5"><rule id-ref="l2"/></rsc_location>', + '<rsc_colocation id="c1" score="INFINITY" rsc="m6" with-rsc="m5"/>', + '<rsc_colocation id="c2" score="INFINITY" rsc="m5" rsc-role="Master" with-rsc="d1" with-rsc-role="Started"/>', + '<rsc_order id="o1" kind="Mandatory" first="m5" then="m6"/>', + '<rsc_order id="o2" kind="Optional" first="d1" first-action="start" then="m5" then-action="promote"/>', + '<rsc_order id="o3" kind="Serialize" first="m5" then="m6"/>', + '<rsc_order id="o4" kind="Mandatory" first="m5" then="m6"/>', + '<rsc_ticket id="ticket-A_m6" ticket="ticket-A" rsc="m6"/>', + '<rsc_ticket id="ticket-B_m6_m5" ticket="ticket-B" loss-policy="fence"><resource_set><resource_ref id="m6"/><resource_ref id="m5"/></resource_set></rsc_ticket>', + '<rsc_ticket id="ticket-C_master" ticket="ticket-C" loss-policy="fence"><resource_set><resource_ref id="m6"/></resource_set><resource_set role="Master"><resource_ref id="m5"/></resource_set></rsc_ticket>', + '<fencing-topology><fencing-level target="ha-one" index="1" devices="st"/><fencing-level target="ha-one" index="2" devices="st2"/><fencing-level target="ha-three" index="1" devices="st"/><fencing-level target="ha-three" index="2" devices="st2"/><fencing-level target="ha-two" index="1" devices="st"/><fencing-level target="ha-two" index="2" devices="st2"/></fencing-topology>', + '<cluster_property_set><nvpair name="stonith-enabled" value="true"/></cluster_property_set>', + '<cluster_property_set id="cpset2"><nvpair name="maintenance-mode" value="true"/></cluster_property_set>', + '<rsc_defaults><meta_attributes><nvpair name="failure-timeout" value="10m"/></meta_attributes></rsc_defaults>', + '<op_defaults><meta_attributes id="opsdef2"><nvpair name="record-pending" value="true"/></meta_attributes></op_defaults>', + ] + + for result, expected in zip(a, b): + self.maxDiff = None + self.assertEqual(expected, result) + +if __name__ == '__main__': + unittest.main() |