diff --git a/changelogs/fragments/71-refactor-interface-test.yaml b/changelogs/fragments/71-refactor-interface-test.yaml new file mode 100644 index 0000000..55c4e57 --- /dev/null +++ b/changelogs/fragments/71-refactor-interface-test.yaml @@ -0,0 +1,3 @@ +--- +minor_changes: + - Moved intent testcases from integration suite to unit tests. diff --git a/plugins/modules/vyos_interface.py b/plugins/modules/vyos_interface.py index 839e559..21b0dc2 100644 --- a/plugins/modules/vyos_interface.py +++ b/plugins/modules/vyos_interface.py @@ -1,546 +1,555 @@ #!/usr/bin/python # -*- coding: utf-8 -*- # (c) 2017, Ansible by Red Hat, inc # # This file is part of Ansible by Red Hat # # Ansible is free software: you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation, either version 3 of the License, or # (at your option) any later version. # # Ansible is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with Ansible. If not, see . # from __future__ import absolute_import, division, print_function __metaclass__ = type DOCUMENTATION = """ module: vyos_interface author: Ganesh Nalawade (@ganeshrn) short_description: (deprecated, removed after 2022-06-01) Manage Interface on VyOS network devices description: - This module provides declarative management of Interfaces on VyOS network devices. version_added: 1.0.0 deprecated: alternative: vyos_interfaces why: Updated modules released with more functionality. removed_at_date: '2022-06-01' notes: - Tested against VYOS 1.1.7 options: name: description: - Name of the Interface. type: str description: description: - Description of Interface. type: str enabled: description: - Interface link status. type: bool default: True speed: description: - Interface link speed. type: str mtu: description: - Maximum size of transmit packet. type: int duplex: description: - Interface link status. type: str choices: - full - half - auto delay: description: - Time in seconds to wait before checking for the operational state on remote device. This wait is applicable for operational state argument which are I(state) with values C(up)/C(down) and I(neighbors). default: 10 type: int neighbors: description: - Check the operational state of given interface C(name) for LLDP neighbor. - The following suboptions are available. type: list elements: dict suboptions: host: description: - LLDP neighbor host for given interface C(name). type: str port: description: - LLDP neighbor port to which given interface C(name) is connected. type: str aggregate: description: List of Interfaces definitions. type: list elements: dict suboptions: name: description: - Name of the Interface. required: true type: str description: description: - Description of Interface. type: str enabled: description: - Interface link status. type: bool speed: description: - Interface link speed. type: str mtu: description: - Maximum size of transmit packet. type: int duplex: description: - Interface link status. type: str choices: - full - half - auto delay: description: - Time in seconds to wait before checking for the operational state on remote device. This wait is applicable for operational state argument which are I(state) with values C(up)/C(down) and I(neighbors). type: int neighbors: description: - Check the operational state of given interface C(name) for LLDP neighbor. - The following suboptions are available. type: list elements: dict suboptions: host: description: - LLDP neighbor host for given interface C(name). type: str port: description: - LLDP neighbor port to which given interface C(name) is connected. type: str state: description: - State of the Interface configuration, C(up) means present and operationally up and C(down) means present and operationally C(down) type: str choices: - present - absent - up - down state: description: - State of the Interface configuration, C(up) means present and operationally up and C(down) means present and operationally C(down) default: present type: str choices: - present - absent - up - down extends_documentation_fragment: - vyos.vyos.vyos """ EXAMPLES = """ - name: configure interface vyos.vyos.vyos_interface: name: eth0 description: test-interface - name: remove interface vyos.vyos.vyos_interface: name: eth0 state: absent - name: make interface down vyos.vyos.vyos_interface: name: eth0 enabled: false - name: make interface up vyos.vyos.vyos_interface: name: eth0 enabled: true - name: Configure interface speed, mtu, duplex vyos.vyos.vyos_interface: name: eth5 state: present speed: 100 mtu: 256 duplex: full - name: Set interface using aggregate vyos.vyos.vyos_interface: aggregate: - {name: eth1, description: test-interface-1, speed: 100, duplex: half, mtu: 512} - {name: eth2, description: test-interface-2, speed: 1000, duplex: full, mtu: 256} - name: Disable interface on aggregate net_interface: aggregate: - name: eth1 - name: eth2 enabled: false - name: Delete interface using aggregate net_interface: aggregate: - name: eth1 - name: eth2 state: absent - name: Check lldp neighbors intent arguments vyos.vyos.vyos_interface: name: eth0 neighbors: - port: eth0 host: netdev - name: Config + intent vyos.vyos.vyos_interface: name: eth1 enabled: false state: down """ RETURN = """ commands: description: The list of configuration mode commands to send to the device returned: always, except for the platforms that use Netconf transport to manage the device. type: list sample: - set interfaces ethernet eth0 description "test-interface" - set interfaces ethernet eth0 speed 100 - set interfaces ethernet eth0 mtu 256 - set interfaces ethernet eth0 duplex full """ import re from copy import deepcopy from time import sleep from ansible.module_utils._text import to_text from ansible.module_utils.basic import AnsibleModule from ansible.module_utils.connection import exec_command from ansible_collections.ansible.netcommon.plugins.module_utils.network.common.utils import ( conditional, remove_default_spec, ) from ansible_collections.vyos.vyos.plugins.module_utils.network.vyos.vyos import ( load_config, get_config, ) from ansible_collections.vyos.vyos.plugins.module_utils.network.vyos.vyos import ( vyos_argument_spec, ) def search_obj_in_list(name, lst): for o in lst: if o["name"] == name: return o return None def map_obj_to_commands(updates): commands = list() want, have = updates - params = ("speed", "description", "duplex", "mtu") for w in want: name = w["name"] disable = w["disable"] state = w["state"] obj_in_have = search_obj_in_list(name, have) set_interface = "set interfaces ethernet " + name delete_interface = "delete interfaces ethernet " + name if state == "absent" and obj_in_have: commands.append(delete_interface) elif state in ("present", "up", "down"): if obj_in_have: for item in params: value = w.get(item) if value and value != obj_in_have.get(item): if item == "description": value = "'" + str(value) + "'" commands.append( set_interface + " " + item + " " + str(value) ) if disable and not obj_in_have.get("disable", False): commands.append(set_interface + " disable") elif not disable and obj_in_have.get("disable", False): commands.append(delete_interface + " disable") else: commands.append(set_interface) for item in params: value = w.get(item) if value: if item == "description": value = "'" + str(value) + "'" commands.append( set_interface + " " + item + " " + str(value) ) if disable: commands.append(set_interface + " disable") return commands def map_config_to_obj(module): data = get_config(module, flags=["| grep interface"]) obj = [] for line in data.split("\n"): if line.startswith("set interfaces ethernet"): match = re.search(r"set interfaces ethernet (\S+)", line, re.M) name = match.group(1) if name: interface = {} for item in obj: if item["name"] == name: interface = item break if not interface: interface = {"name": name} obj.append(interface) match = re.search(r"%s (\S+)" % name, line, re.M) if match: param = match.group(1) if param == "description": match = re.search(r"description (.+)", line, re.M) description = match.group(1).strip("'") interface["description"] = description elif param == "speed": match = re.search(r"speed (\S+)", line, re.M) speed = match.group(1).strip("'") interface["speed"] = speed elif param == "mtu": match = re.search(r"mtu (\S+)", line, re.M) mtu = match.group(1).strip("'") interface["mtu"] = int(mtu) elif param == "duplex": match = re.search(r"duplex (\S+)", line, re.M) duplex = match.group(1).strip("'") interface["duplex"] = duplex elif param.strip("'") == "disable": interface["disable"] = True return obj def map_params_to_obj(module): obj = [] aggregate = module.params.get("aggregate") if aggregate: for item in aggregate: for key in item: if item.get(key) is None: item[key] = module.params[key] d = item.copy() if d["enabled"]: d["disable"] = False else: d["disable"] = True obj.append(d) else: params = { "name": module.params["name"], "description": module.params["description"], "speed": module.params["speed"], "mtu": module.params["mtu"], "duplex": module.params["duplex"], "delay": module.params["delay"], "state": module.params["state"], "neighbors": module.params["neighbors"], } if module.params["enabled"]: params.update({"disable": False}) else: params.update({"disable": True}) obj.append(params) return obj +def get_interfaces_data(module, name): + command = "show interfaces ethernet %s" % name + rc, out, err = exec_command(module, command) + return [rc, out, err] + + +def get_lldp_neighbor(module): + command = "show lldp neighbors detail" + rc, out, err = exec_command(module, command) + return [rc, out, err] + + def check_declarative_intent_params(module, want, result): failed_conditions = [] have_neighbors = None for w in want: want_state = w.get("state") want_neighbors = w.get("neighbors") if want_state not in ("up", "down") and not want_neighbors: continue if result["changed"]: sleep(w["delay"]) command = "show interfaces ethernet %s" % w["name"] - rc, out, err = exec_command(module, command) + rc, out, err = get_interfaces_data(w["name"], module) if rc != 0: module.fail_json( msg=to_text(err, errors="surrogate_then_replace"), command=command, rc=rc, ) if want_state in ("up", "down"): match = re.search(r"%s (\w+)" % "state", out, re.M) have_state = None if match: have_state = match.group(1) if have_state is None or not conditional( want_state, have_state.strip().lower() ): failed_conditions.append("state " + "eq(%s)" % want_state) if want_neighbors: have_host = [] have_port = [] if have_neighbors is None: - rc, have_neighbors, err = exec_command( - module, "show lldp neighbors detail" - ) + rc, have_neighbors, err = get_lldp_neighbor(module) if rc != 0: module.fail_json( msg=to_text(err, errors="surrogate_then_replace"), command=command, rc=rc, ) if have_neighbors: lines = have_neighbors.strip().split("Interface: ") for line in lines: field = line.split("\n") if field[0].split(",")[0].strip() == w["name"]: for item in field: if item.strip().startswith("SysName:"): have_host.append(item.split(":")[1].strip()) if item.strip().startswith("PortDescr:"): have_port.append(item.split(":")[1].strip()) for item in want_neighbors: host = item.get("host") port = item.get("port") if host and host not in have_host: failed_conditions.append("host " + host) if port and port not in have_port: failed_conditions.append("port " + port) return failed_conditions def main(): """ main entry point for module execution """ neighbors_spec = dict(host=dict(), port=dict()) element_spec = dict( name=dict(), description=dict(), speed=dict(), mtu=dict(type="int"), duplex=dict(choices=["full", "half", "auto"]), enabled=dict(default=True, type="bool"), neighbors=dict(type="list", elements="dict", options=neighbors_spec), delay=dict(default=10, type="int"), state=dict( default="present", choices=["present", "absent", "up", "down"] ), ) aggregate_spec = deepcopy(element_spec) aggregate_spec["name"] = dict(required=True) # remove default in aggregate spec, to handle common arguments remove_default_spec(aggregate_spec) argument_spec = dict( aggregate=dict(type="list", elements="dict", options=aggregate_spec), ) argument_spec.update(element_spec) argument_spec.update(vyos_argument_spec) required_one_of = [["name", "aggregate"]] mutually_exclusive = [["name", "aggregate"]] required_together = [["speed", "duplex"]] module = AnsibleModule( argument_spec=argument_spec, required_one_of=required_one_of, mutually_exclusive=mutually_exclusive, required_together=required_together, supports_check_mode=True, ) warnings = list() result = {"changed": False} if warnings: result["warnings"] = warnings want = map_params_to_obj(module) have = map_config_to_obj(module) commands = map_obj_to_commands((want, have)) result["commands"] = commands if commands: commit = not module.check_mode diff = load_config(module, commands, commit=commit) if diff: if module._diff: result["diff"] = {"prepared": diff} result["changed"] = True failed_conditions = check_declarative_intent_params(module, want, result) if failed_conditions: msg = "One or more conditional statements have not been satisfied" module.fail_json(msg=msg, failed_conditions=failed_conditions) module.exit_json(**result) if __name__ == "__main__": main() diff --git a/tests/integration/targets/vyos_interface/tests/cli/intent.yaml b/tests/integration/targets/vyos_interface/tests/cli/intent.yaml deleted file mode 100644 index e3245d3..0000000 --- a/tests/integration/targets/vyos_interface/tests/cli/intent.yaml +++ /dev/null @@ -1,162 +0,0 @@ ---- -- debug: msg="START cli/intent.yaml on connection={{ ansible_connection }}" - -- name: Detect if we have existing lldp neighbors configured - register: neighbors_out - vyos.vyos.vyos_command: - commands: - - show lldp neighbors detail - - -# setting a variable dynamically using set_fact isn't working in devel. -# - name: Should we run lldp tests? -# set_fact: -# run_lldp_tests: "'PortDescr: eth0' in neighbors_out.stdout[0]" - -- name: Enable LLDP service - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - vyos.vyos.vyos_lldp: - state: present - -- name: Create LLDP configuration - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - vyos.vyos.vyos_lldp_interface: - name: eth1 - state: present - -- name: Setup (interface is up) - register: result - vyos.vyos.vyos_interface: - name: eth1 - enabled: true - state: present - -- name: Check intent arguments - register: result - vyos.vyos.vyos_interface: - name: eth1 - state: up - -- assert: - that: - - result.failed == false - -- name: Check lldp neighbors intent arguments - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - register: result - vyos.vyos.vyos_interface: - name: eth0 - neighbors: - - - port: eth0 - -- assert: - that: - - result.failed == false - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - -- name: Check intent arguments (failed condition) - ignore_errors: true - register: result - vyos.vyos.vyos_interface: - name: eth1 - state: down - -- assert: - that: - - result.failed == true - - "'state eq(down)' in result.failed_conditions" - -- name: Check lldp neighbors intent arguments (failed) - ignore_errors: true - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - register: result - vyos.vyos.vyos_interface: - name: eth0 - neighbors: - - - port: dummy_port - host: dummy_host - -- assert: - that: - - result.failed == true - - "'host dummy_host' in result.failed_conditions" - - "'port dummy_port' in result.failed_conditions" - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - -- name: Config + intent - register: result - vyos.vyos.vyos_interface: - name: eth1 - enabled: false - state: down - -- assert: - that: - - result.failed == false - -- name: Config + intent (fail) - ignore_errors: true - register: result - vyos.vyos.vyos_interface: - name: eth1 - enabled: false - state: up - -- assert: - that: - - result.failed == true - - "'state eq(up)' in result.failed_conditions" - -- name: Aggregate config + intent (pass) - ignore_errors: true - register: result - vyos.vyos.vyos_interface: - aggregate: - - - name: eth1 - enabled: true - state: up - -- assert: - that: - - result.failed == false - -- name: Check lldp neighbors intent aggregate arguments - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - register: result - vyos.vyos.vyos_interface: - aggregate: - - - name: eth0 - neighbors: - - - port: eth0 - -- assert: - that: - - result.failed == false - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - -- name: Check lldp neighbors intent aggregate arguments (failed) - ignore_errors: true - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" - register: result - vyos.vyos.vyos_interface: - aggregate: - - - name: eth0 - neighbors: - - - port: eth0 - - - port: dummy_port - host: dummy_host - -- assert: - that: - - result.failed == true - - "'host dummy_host' in result.failed_conditions" - - "'port dummy_port' in result.failed_conditions" - when: "'PortDescr: eth0' in neighbors_out.stdout[0]" diff --git a/tests/unit/modules/network/vyos/fixtures/vyos_interface_config.cfg b/tests/unit/modules/network/vyos/fixtures/vyos_interface_config.cfg new file mode 100644 index 0000000..0876916 --- /dev/null +++ b/tests/unit/modules/network/vyos/fixtures/vyos_interface_config.cfg @@ -0,0 +1,6 @@ +set interfaces ethernet eth0 address 'dhcp' +set interfaces ethernet eth0 hw-id '08:00:27:7c:85:05' +set interfaces ethernet eth1 description 'test-interface' +set interfaces ethernet eth2 hw-id '08:00:27:04:85:99' +set interfaces ethernet eth3 hw-id '08:00:27:1c:82:d1' +set interfaces loopback 'lo' diff --git a/tests/unit/modules/network/vyos/fixtures/vyos_lldp_neighbor_config.cfg b/tests/unit/modules/network/vyos/fixtures/vyos_lldp_neighbor_config.cfg new file mode 100644 index 0000000..267958c --- /dev/null +++ b/tests/unit/modules/network/vyos/fixtures/vyos_lldp_neighbor_config.cfg @@ -0,0 +1,68 @@ +------------------------------------------------------------------------------- +LLDP neighbors: +------------------------------------------------------------------------------- +Interface: eth1, via: LLDP, RID: 1, Time: 0 day, 00:30:34 + Chassis: + ChassisID: mac 08:00:27:7c:85:05 + SysName: vyos + SysDescr: Vyatta Router running on VyOS 1.1.8 (helium) + MgmtIP: 192.168.56.101 + Capability: Bridge, off + Capability: Router, on + Capability: Wlan, off + Port: + PortID: mac 08:00:27:04:85:99 + PortDescr: eth0 + PMD autoneg: supported: yes, enabled: yes + Adv: 10Base-T, HD: yes, FD: yes + Adv: 100Base-T, HD: yes, FD: yes + Adv: 1000Base-T, HD: no, FD: yes + MAU oper type: 1000BaseTFD - Four-pair Category 5 UTP, full duplex mode + LLDP-MED: + Device Type: Network Connectivity Device + Capability: Capabilities + Capability: Policy + Capability: Location + Capability: MDI/PSE + Capability: MDI/PD + Capability: Inventory + Inventory: + Hardware Revision: 1.2 + Software Revision: 3.13.11-1-586-vyos + Firmware Revision: VirtualBox + Serial Number: 0 + Manufacturer: innotek GmbH + Model: VirtualBox +------------------------------------------------------------------------------- +Interface: eth0, via: LLDP, RID: 1, Time: 0 day, 00:32:50 + Chassis: + ChassisID: mac 08:00:27:7c:85:05 + SysName: vyos + SysDescr: Vyatta Router running on VyOS 1.1.8 (helium) + MgmtIP: 192.168.56.101 + Capability: Bridge, off + Capability: Router, on + Capability: Wlan, off + Port: + PortID: mac 08:00:27:18:e6:f2 + PortDescr: eth1 + PMD autoneg: supported: yes, enabled: yes + Adv: 10Base-T, HD: yes, FD: yes + Adv: 100Base-T, HD: yes, FD: yes + Adv: 1000Base-T, HD: no, FD: yes + MAU oper type: 1000BaseTFD - Four-pair Category 5 UTP, full duplex mode + LLDP-MED: + Device Type: Network Connectivity Device + Capability: Capabilities + Capability: Policy + Capability: Location + Capability: MDI/PSE + Capability: MDI/PD + Capability: Inventory + Inventory: + Hardware Revision: 1.2 + Software Revision: 3.13.11-1-586-vyos + Firmware Revision: VirtualBox + Serial Number: 0 + Manufacturer: innotek GmbH + Model: VirtualBox diff --git a/tests/unit/modules/network/vyos/test_vyos_interface.py b/tests/unit/modules/network/vyos/test_vyos_interface.py new file mode 100644 index 0000000..96bc9f6 --- /dev/null +++ b/tests/unit/modules/network/vyos/test_vyos_interface.py @@ -0,0 +1,231 @@ +# (c) 2016 Red Hat Inc. +# +# This file is part of Ansible +# +# Ansible is free software: you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# Ansible is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with Ansible. If not, see . + +# Make coding more python3-ish +from __future__ import absolute_import, division, print_function + +__metaclass__ = type + +from ansible_collections.vyos.vyos.tests.unit.compat.mock import patch +from ansible_collections.vyos.vyos.plugins.modules import vyos_interface +from ansible_collections.vyos.vyos.tests.unit.modules.utils import ( + set_module_args, +) +from .vyos_module import TestVyosModule, load_fixture + + +class TestVyosInterfaceModule(TestVyosModule): + + module = vyos_interface + + def setUp(self): + super(TestVyosInterfaceModule, self).setUp() + self.mock_get_config = patch( + "ansible_collections.vyos.vyos.plugins.modules.vyos_interface.get_config" + ) + self.get_config = self.mock_get_config.start() + + self.mock_load_config = patch( + "ansible_collections.vyos.vyos.plugins.modules.vyos_interface.load_config" + ) + self.load_config = self.mock_load_config.start() + + self.mock_execute_interfaces_command = patch( + "ansible_collections.vyos.vyos.plugins.modules.vyos_interface.get_interfaces_data" + ) + self.execute_interfaces_command = ( + self.mock_execute_interfaces_command.start() + ) + self.mock_execute_lldp_command = patch( + "ansible_collections.vyos.vyos.plugins.modules.vyos_interface.get_lldp_neighbor" + ) + self.execute_lldp_command = self.mock_execute_lldp_command.start() + + # self.mock_get_config = patch( + # "ansible_collections.ansible.netcommon.plugins.module_utils.network.common.network.Config.get_config" + # ) + # self.get_config = self.mock_get_config.start() + + # self.mock_load_config = patch( + # "ansible_collections.ansible.netcommon.plugins.module_utils.network.common.network.Config.load_config" + # ) + # self.load_config = self.mock_load_config.start() + + # self.mock_get_resource_connection_config = patch( + # "ansible_collections.ansible.netcommon.plugins.module_utils.network.common.cfg.base.get_resource_connection" + # ) + # self.get_resource_connection_config = ( + # self.mock_get_resource_connection_config.start() + # ) + + # self.mock_get_resource_connection_facts = patch( + # "ansible_collections.ansible.netcommon.plugins.module_utils.network.common.facts.facts.get_resource_connection" + # ) + # self.get_resource_connection_facts = ( + # self.mock_get_resource_connection_facts.start() + # ) + + def tearDown(self): + super(TestVyosInterfaceModule, self).tearDown() + self.mock_get_config.stop() + self.mock_load_config.stop() + self.mock_execute_lldp_command.stop() + self.mock_execute_interfaces_command.stop() + + def load_fixtures(self, commands=None, transport="cli"): + self.get_config.return_value = load_fixture( + "vyos_interface_config.cfg" + ) + self.execute_interfaces_command.return_value = [ + 0, + load_fixture("vyos_interface_config.cfg"), + None, + ] + self.execute_lldp_command.return_value = [ + 0, + load_fixture("vyos_lldp_neighbor_config.cfg"), + None, + ] + self.load_config.return_value = dict(diff=None, session="session") + + def test_vyos_setup_int(self): + set_module_args( + dict( + name="eth1", + enabled=True, + state="present", + speed="100", + duplex="half", + ) + ) + commands = [ + "set interfaces ethernet eth1 speed 100", + "set interfaces ethernet eth1 duplex half", + ] + self.execute_module(changed=True, commands=commands) + + def test_vyos_setup_required_params(self): + set_module_args( + dict(name="eth1", enabled=True, state="present", speed="100",) + ) + result = self.execute_module(failed=True) + self.assertIn( + "parameters are required together: speed, duplex", result["msg"] + ) + + def test_vyos_setup_int_idempotent(self): + set_module_args(dict(name="eth1", enabled=True, state="present",)) + self.execute_module(changed=False, commands=[]) + + def test_vyos_disable_int(self): + set_module_args(dict(name="eth1", state="absent",)) + commands = ["delete interfaces ethernet eth1"] + self.execute_module(changed=True, commands=commands) + + def test_vyos_setup_int_aggregate(self): + set_module_args( + dict( + aggregate=[ + dict( + name="eth1", + enabled=True, + state="present", + mtu="512", + duplex="half", + speed="100", + ), + dict( + name="eth2", + enabled=True, + state="present", + speed="1000", + duplex="full", + mtu="256", + ), + ] + ) + ) + commands = [ + "set interfaces ethernet eth1 speed 100", + "set interfaces ethernet eth1 duplex half", + "set interfaces ethernet eth1 mtu 512", + "set interfaces ethernet eth2 speed 1000", + "set interfaces ethernet eth2 duplex full", + "set interfaces ethernet eth2 mtu 256", + ] + self.execute_module(changed=True, commands=commands) + + def test_vyos_delete_int_aggregate(self): + set_module_args( + dict( + aggregate=[ + dict(name="eth1", state="absent",), + dict(name="eth2", state="absent",), + ] + ) + ) + commands = [ + "delete interfaces ethernet eth1", + "delete interfaces ethernet eth2", + ] + self.execute_module(changed=True, commands=commands) + + def test_vyos_disable_int_aggregate(self): + set_module_args( + dict( + aggregate=[ + dict(name="eth1", enabled=False,), + dict(name="eth2", enabled=False,), + ] + ) + ) + commands = [ + "set interfaces ethernet eth1 disable", + "set interfaces ethernet eth2 disable", + ] + self.execute_module(changed=True, commands=commands) + + def test_vyos_intent_wrongport(self): + set_module_args( + dict( + name="eth0", + neighbors=[dict(port="dummy_port", host="dummy_host")], + ) + ) + result = self.execute_module(failed=True) + self.assertIn( + "One or more conditional statements have not been satisfied", + result["msg"], + ) + + def test_vyos_intent_neighbor_fail(self): + set_module_args(dict(name="eth0", neighbors=[dict(port="eth0",)])) + result = self.execute_module(failed=True) + self.assertIn( + "One or more conditional statements have not been satisfied", + result["msg"], + ) + + def test_vyos_intent_neighbor(self): + set_module_args(dict(name="eth1", neighbors=[dict(port="eth0",)])) + self.execute_module(failed=False) + + def test_vyos_intent_neighbor_aggregate(self): + set_module_args( + dict(aggregate=[dict(name="eth1", neighbors=[dict(port="eth0",)])]) + ) + self.execute_module(failed=False)