Add a new module ce_lldp to manage Link Layer Discovery Protocol(LLDP) (#63395)
* new module ce_lldp * update for shippable * update for shippable * update for shipabble * update * merge confilcts * add integration test. * update for shippable. * update for bad-whitespace * update for shippable * update for shippable * update for shippable * update license. * update for typo.
This commit is contained in:
parent
5ea72934bd
commit
39c92310b4
14 changed files with 1185 additions and 0 deletions
788
lib/ansible/modules/network/cloudengine/ce_lldp.py
Normal file
788
lib/ansible/modules/network/cloudengine/ce_lldp.py
Normal file
|
@ -0,0 +1,788 @@
|
||||||
|
#!/usr/bin/python
|
||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Copyright 2019 Red Hat
|
||||||
|
# GNU General Public License v3.0+
|
||||||
|
# (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
|
||||||
|
#
|
||||||
|
|
||||||
|
from __future__ import (absolute_import, division, print_function)
|
||||||
|
__metaclass__ = type
|
||||||
|
|
||||||
|
|
||||||
|
ANSIBLE_METADATA = {'metadata_version': '1.1',
|
||||||
|
'status': ['preview'],
|
||||||
|
'supported_by': 'community'}
|
||||||
|
|
||||||
|
DOCUMENTATION = '''
|
||||||
|
---
|
||||||
|
|
||||||
|
module: ce_lldp
|
||||||
|
version_added: "2.10"
|
||||||
|
short_description: Manages LLDP configuration on HUAWEI CloudEngine switches.
|
||||||
|
description:
|
||||||
|
- Manages LLDP configuration on HUAWEI CloudEngine switches.
|
||||||
|
author:
|
||||||
|
- xuxiaowei0512 (@CloudEngine-Ansible)
|
||||||
|
options:
|
||||||
|
lldpenable:
|
||||||
|
description:
|
||||||
|
- Set global LLDP enable state.
|
||||||
|
required: false
|
||||||
|
choices: ['enabled', 'disabled']
|
||||||
|
type: str
|
||||||
|
mdnstatus:
|
||||||
|
description:
|
||||||
|
- Set global MDN enable state.
|
||||||
|
required: false
|
||||||
|
choices: ['rxOnly', 'disabled']
|
||||||
|
type: str
|
||||||
|
interval:
|
||||||
|
description:
|
||||||
|
- Frequency at which LLDP advertisements are sent (in seconds).
|
||||||
|
required: false
|
||||||
|
type: int
|
||||||
|
hold_multiplier:
|
||||||
|
description:
|
||||||
|
- Time multiplier for device information in neighbor devices.
|
||||||
|
required: false
|
||||||
|
type: int
|
||||||
|
restart_delay:
|
||||||
|
description:
|
||||||
|
- Specifies the delay time of the interface LLDP module from disabled state to re enable.
|
||||||
|
required: false
|
||||||
|
type: int
|
||||||
|
transmit_delay:
|
||||||
|
description:
|
||||||
|
- Delay time for sending LLDP messages.
|
||||||
|
required: false
|
||||||
|
type: int
|
||||||
|
notification_interval:
|
||||||
|
description:
|
||||||
|
- Suppression time for sending LLDP alarm.
|
||||||
|
required: false
|
||||||
|
type: int
|
||||||
|
fast_count:
|
||||||
|
description:
|
||||||
|
- The number of LLDP messages sent to the neighbor nodes by the specified device.
|
||||||
|
required: false
|
||||||
|
type: int
|
||||||
|
mdn_notification_interval:
|
||||||
|
description:
|
||||||
|
- Delay time for sending MDN neighbor information change alarm.
|
||||||
|
required: false
|
||||||
|
type: int
|
||||||
|
management_address:
|
||||||
|
description:
|
||||||
|
- The management IP address of LLDP.
|
||||||
|
required: false
|
||||||
|
default: null
|
||||||
|
type: str
|
||||||
|
bind_name:
|
||||||
|
description:
|
||||||
|
- Binding interface name.
|
||||||
|
required: false
|
||||||
|
default: null
|
||||||
|
type: str
|
||||||
|
state:
|
||||||
|
description:
|
||||||
|
- Manage the state of the resource.
|
||||||
|
required: false
|
||||||
|
default: present
|
||||||
|
type: str
|
||||||
|
choices: ['present','absent']
|
||||||
|
'''
|
||||||
|
|
||||||
|
EXAMPLES = '''
|
||||||
|
- name: "Configure global LLDP enable state"
|
||||||
|
ce_lldp:
|
||||||
|
lldpenable: enabled
|
||||||
|
|
||||||
|
- name: "Configure global MDN enable state"
|
||||||
|
ce_lldp:
|
||||||
|
mdnstatus: rxOnly
|
||||||
|
|
||||||
|
- name: "Configure LLDP transmit interval and ensure global LLDP state is already enabled"
|
||||||
|
ce_lldp:
|
||||||
|
enable: enable
|
||||||
|
interval: 32
|
||||||
|
|
||||||
|
- name: "Configure LLDP transmit multiplier hold and ensure global LLDP state is already enabled"
|
||||||
|
ce_lldp:
|
||||||
|
enable: enable
|
||||||
|
hold_multiplier: 5
|
||||||
|
|
||||||
|
- name: "Configure the delay time of the interface LLDP module from disabled state to re enable"
|
||||||
|
ce_lldp:
|
||||||
|
enable: enable
|
||||||
|
restart_delay: 3
|
||||||
|
|
||||||
|
- name: "Reset the delay time for sending LLDP messages"
|
||||||
|
ce_lldp:
|
||||||
|
enable: enable
|
||||||
|
transmit_delay: 4
|
||||||
|
|
||||||
|
- name: "Configure device to send neighbor device information change alarm delay time"
|
||||||
|
ce_lldp:
|
||||||
|
lldpenable: enabled
|
||||||
|
notification_interval: 6
|
||||||
|
|
||||||
|
- name: "Configure the number of LLDP messages sent to the neighbor nodes by the specified device"
|
||||||
|
ce_lldp:
|
||||||
|
enable: enable
|
||||||
|
fast_count: 5
|
||||||
|
|
||||||
|
- name: "Configure the delay time for sending MDN neighbor information change alarm"
|
||||||
|
ce_lldp:
|
||||||
|
enable: enable
|
||||||
|
mdn_notification_interval: 6
|
||||||
|
- name: "Configuring the management IP address of LLDP"
|
||||||
|
ce_lldp:
|
||||||
|
enable: enable
|
||||||
|
management_address: 10.1.0.1
|
||||||
|
|
||||||
|
- name: "Configuring LLDP to manage the binding relationship between IP addresses and interfaces"
|
||||||
|
ce_lldp:
|
||||||
|
enable: enable
|
||||||
|
bind_name: LoopBack2
|
||||||
|
'''
|
||||||
|
|
||||||
|
RETURN = '''
|
||||||
|
proposed:
|
||||||
|
description: k/v pairs of parameters passed into module
|
||||||
|
returned: always
|
||||||
|
type: dict
|
||||||
|
sample: {
|
||||||
|
"lldpenable": "enabled",
|
||||||
|
"mdnstatus": "rxOnly",
|
||||||
|
"interval": "32",
|
||||||
|
"hold_multiplier": "5",
|
||||||
|
"restart_delay": "3",
|
||||||
|
"transmit_delay": "4",
|
||||||
|
"notification_interval": "6",
|
||||||
|
"fast_count": "5",
|
||||||
|
"mdn_notification_interval": "6",
|
||||||
|
"management_address": "10.1.0.1",
|
||||||
|
"bind_name": "LoopBack2",
|
||||||
|
"state": "present"
|
||||||
|
}
|
||||||
|
existing:
|
||||||
|
description: k/v pairs of existing global LLDP configuration.
|
||||||
|
returned: always
|
||||||
|
type: dict
|
||||||
|
sample: {
|
||||||
|
"lldpenable": "disabled",
|
||||||
|
"mdnstatus": "disabled"
|
||||||
|
}
|
||||||
|
end_state:
|
||||||
|
description: k/v pairs of global LLDP configuration after module execution.
|
||||||
|
returned: always
|
||||||
|
type: dict
|
||||||
|
sample: {
|
||||||
|
"lldpenable": "enabled",
|
||||||
|
"mdnstatus": "rxOnly",
|
||||||
|
"interval": "32",
|
||||||
|
"hold_multiplier": "5",
|
||||||
|
"restart_delay": "3",
|
||||||
|
"transmit_delay": "4",
|
||||||
|
"notification_interval": "6",
|
||||||
|
"fast_count": "5",
|
||||||
|
"mdn_notification_interval": "6",
|
||||||
|
"management_address": "10.1.0.1",
|
||||||
|
"bind_name": "LoopBack2"
|
||||||
|
}
|
||||||
|
updates:
|
||||||
|
description: command sent to the device
|
||||||
|
returned: always
|
||||||
|
type: list
|
||||||
|
sample: [
|
||||||
|
"lldp enable",
|
||||||
|
"lldp mdn enable",
|
||||||
|
"lldp transmit interval 32",
|
||||||
|
"lldp transmit multiplier 5",
|
||||||
|
"lldp restart 3",
|
||||||
|
"lldp transmit delay 4",
|
||||||
|
"lldp trap-interval 6",
|
||||||
|
"lldp fast-count 5",
|
||||||
|
"lldp mdn trap-interval 6",
|
||||||
|
"lldp management-address 10.1.0.1",
|
||||||
|
"lldp management-address bind interface LoopBack 2"
|
||||||
|
]
|
||||||
|
changed:
|
||||||
|
description: check to see if a change was made on the device
|
||||||
|
returned: always
|
||||||
|
type: bool
|
||||||
|
sample: true
|
||||||
|
'''
|
||||||
|
|
||||||
|
import copy
|
||||||
|
import re
|
||||||
|
from xml.etree import ElementTree
|
||||||
|
from ansible.module_utils.basic import AnsibleModule
|
||||||
|
from ansible.module_utils.network.cloudengine.ce import set_nc_config, get_nc_config, execute_nc_action
|
||||||
|
|
||||||
|
CE_NC_GET_GLOBAL_LLDPENABLE_CONFIG = """
|
||||||
|
<filter type="subtree">
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys>
|
||||||
|
<lldpEnable></lldpEnable>
|
||||||
|
<mdnStatus></mdnStatus>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</filter>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBA_LLDPENABLE_CONFIG = """
|
||||||
|
<config>
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys operation="merge">
|
||||||
|
<lldpEnable>%s</lldpEnable>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</config>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBA_MDNENABLE_CONFIG = """
|
||||||
|
<config>
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys operation="merge">
|
||||||
|
<mdnStatus>%s</mdnStatus>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</config>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_GET_GLOBAL_LLDP_CONFIG = """
|
||||||
|
<filter type="subtree">
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys>
|
||||||
|
<lldpSysParameter>
|
||||||
|
<messageTxInterval></messageTxInterval>
|
||||||
|
<messageTxHoldMultiplier></messageTxHoldMultiplier>
|
||||||
|
<reinitDelay></reinitDelay>
|
||||||
|
<txDelay></txDelay>
|
||||||
|
<notificationInterval></notificationInterval>
|
||||||
|
<notificationEnable></notificationEnable>
|
||||||
|
<fastMessageCount></fastMessageCount>
|
||||||
|
<mdnNotificationInterval></mdnNotificationInterval>
|
||||||
|
<mdnNotificationEnable></mdnNotificationEnable>
|
||||||
|
<configManAddr></configManAddr>
|
||||||
|
<bindifName></bindifName>
|
||||||
|
</lldpSysParameter>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</filter>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER = """
|
||||||
|
<config>
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys>
|
||||||
|
<lldpSysParameter operation="merge">
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_INTERVAL = """
|
||||||
|
<messageTxInterval>%s</messageTxInterval>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HOLD_MULTIPLIER = """
|
||||||
|
<messageTxHoldMultiplier>%s</messageTxHoldMultiplier>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_RESTART_DELAY = """
|
||||||
|
<reinitDelay>%s</reinitDelay>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TRANSMIT_DELAY = """
|
||||||
|
<txDelay>%s</txDelay>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_NOTIFICATION_INTERVAL = """
|
||||||
|
<notificationInterval>%s</notificationInterval>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_FAST_COUNT = """
|
||||||
|
<fastMessageCount>%s</fastMessageCount>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_MDN_NOTIFICATION_INTERVAL = """
|
||||||
|
<mdnNotificationInterval>%s</mdnNotificationInterval>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_MANAGEMENT_ADDRESS = """
|
||||||
|
<configManAddr>%s</configManAddr>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_BIND_NAME = """
|
||||||
|
<bindifName>%s</bindifName>
|
||||||
|
"""
|
||||||
|
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL = """
|
||||||
|
</lldpSysParameter>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</config>
|
||||||
|
"""
|
||||||
|
|
||||||
|
|
||||||
|
class Lldp(object):
|
||||||
|
"""Manage global lldp enable configuration"""
|
||||||
|
|
||||||
|
def __init__(self, argument_spec):
|
||||||
|
self.spec = argument_spec
|
||||||
|
self.module = None
|
||||||
|
self.init_module()
|
||||||
|
self.lldpenable = self.module.params['lldpenable'] or None
|
||||||
|
self.interval = self.module.params['interval'] or None
|
||||||
|
self.mdnstatus = self.module.params['mdnstatus'] or None
|
||||||
|
self.hold_multiplier = self.module.params['hold_multiplier'] or None
|
||||||
|
self.restart_delay = self.module.params['restart_delay'] or None
|
||||||
|
self.transmit_delay = self.module.params['transmit_delay'] or None
|
||||||
|
self.notification_interval = self.module.params['notification_interval'] or None
|
||||||
|
self.fast_count = self.module.params['fast_count'] or None
|
||||||
|
self.mdn_notification_interval = self.module.params['mdn_notification_interval'] or None
|
||||||
|
self.management_address = self.module.params['management_address']
|
||||||
|
self.bind_name = self.module.params['bind_name']
|
||||||
|
self.state = self.module.params['state']
|
||||||
|
self.lldp_conf = dict()
|
||||||
|
self.conf_exsit = False
|
||||||
|
self.conf_exsit_lldp = False
|
||||||
|
self.enable_flag = 0
|
||||||
|
self.check_params()
|
||||||
|
self.existing_state_value = dict()
|
||||||
|
self.existing_end_state_value = dict()
|
||||||
|
self.changed = False
|
||||||
|
self.proposed_changed = dict()
|
||||||
|
self.updates_cmd = list()
|
||||||
|
self.results = dict()
|
||||||
|
self.proposed = dict()
|
||||||
|
self.existing = dict()
|
||||||
|
self.end_state = dict()
|
||||||
|
|
||||||
|
def is_valid_v4addr(self):
|
||||||
|
"""check if ipv4 addr is valid"""
|
||||||
|
if self.management_address.find('.') != -1:
|
||||||
|
addr_list = self.management_address.split('.')
|
||||||
|
if self.management_address == "0.0.0.0":
|
||||||
|
self.module.fail_json(msg='Error: The management address is 0.0.0.0 .')
|
||||||
|
if len(addr_list) != 4:
|
||||||
|
self.module.fail_json(msg='Error: Invalid IPV4 address.')
|
||||||
|
for each_num in addr_list:
|
||||||
|
each_num_tmp = str(each_num)
|
||||||
|
if not each_num_tmp.isdigit():
|
||||||
|
self.module.fail_json(msg='Error: The ip address is not digit.')
|
||||||
|
if (int(each_num) > 255) or (int(each_num) < 0):
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: The value of ip address is out of [0 - 255].')
|
||||||
|
else:
|
||||||
|
self.module.fail_json(msg='Error: Invalid IP address.')
|
||||||
|
|
||||||
|
def check_params(self):
|
||||||
|
"""Check all input params"""
|
||||||
|
|
||||||
|
if self.interval:
|
||||||
|
if int(self.interval) < 5 or int(self.interval) > 32768:
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: The value of interval is out of [5 - 32768].')
|
||||||
|
|
||||||
|
if self.hold_multiplier:
|
||||||
|
if int(self.hold_multiplier) < 2 or int(self.hold_multiplier) > 10:
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: The value of hold_multiplier is out of [2 - 10].')
|
||||||
|
|
||||||
|
if self.restart_delay:
|
||||||
|
if int(self.restart_delay) < 1 or int(self.restart_delay) > 10:
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: The value of restart_delay is out of [1 - 10].')
|
||||||
|
|
||||||
|
if self.transmit_delay:
|
||||||
|
if int(self.transmit_delay) < 1 or int(self.transmit_delay) > 8192:
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: The value of transmit_delay is out of [1 - 8192].')
|
||||||
|
|
||||||
|
if self.notification_interval:
|
||||||
|
if int(self.notification_interval) < 5 or int(self.notification_interval) > 3600:
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: The value of notification_interval is out of [5 - 3600].')
|
||||||
|
|
||||||
|
if self.fast_count:
|
||||||
|
if int(self.fast_count) < 1 or int(self.fast_count) > 8:
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: The value of fast_count is out of [1 - 8].')
|
||||||
|
|
||||||
|
if self.mdn_notification_interval:
|
||||||
|
if int(self.mdn_notification_interval) < 5 or int(self.mdn_notification_interval) > 3600:
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: The value of mdn_notification_interval is out of [5 - 3600].')
|
||||||
|
|
||||||
|
if self.management_address:
|
||||||
|
self.is_valid_v4addr()
|
||||||
|
|
||||||
|
if self.bind_name:
|
||||||
|
if (len(self.bind_name) < 1) or (len(self.bind_name) > 63):
|
||||||
|
self.module.fail_json(
|
||||||
|
msg='Error: Bind_name length is between 1 and 63.')
|
||||||
|
|
||||||
|
def init_module(self):
|
||||||
|
"""Init module object"""
|
||||||
|
|
||||||
|
self.module = AnsibleModule(
|
||||||
|
argument_spec=self.spec, supports_check_mode=True)
|
||||||
|
|
||||||
|
def check_response(self, xml_str, xml_name):
|
||||||
|
"""Check if response message is already succeed"""
|
||||||
|
|
||||||
|
if "<ok/>" not in xml_str:
|
||||||
|
self.module.fail_json(msg='Error: %s failed.' % xml_name)
|
||||||
|
|
||||||
|
def config_lldp(self):
|
||||||
|
"""Configure lldp enabled and mdn enabled parameters"""
|
||||||
|
|
||||||
|
if self.state == 'present':
|
||||||
|
if (self.enable_flag == 1 and self.lldpenable == 'enabled') and not self.conf_exsit:
|
||||||
|
if self.mdnstatus:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBA_MDNENABLE_CONFIG % self.mdnstatus
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "MDN_ENABLE_CONFIG")
|
||||||
|
|
||||||
|
if self.lldpenable == 'enabled' and not self.conf_exsit:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBA_LLDPENABLE_CONFIG % self.lldpenable
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_ENABLE_CONFIG")
|
||||||
|
|
||||||
|
if self.mdnstatus:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBA_MDNENABLE_CONFIG % self.mdnstatus
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "MDN_ENABLE_CONFIG")
|
||||||
|
|
||||||
|
if (self.enable_flag == 1) and not self.conf_exsit:
|
||||||
|
if self.mdnstatus:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBA_MDNENABLE_CONFIG % self.mdnstatus
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "MDN_ENABLE_CONFIG")
|
||||||
|
|
||||||
|
if (self.lldpenable == 'enabled' or self.enable_flag == 1) and not self.conf_exsit_lldp:
|
||||||
|
if self.hold_multiplier:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HOLD_MULTIPLIER % self.hold_multiplier) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.interval:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_INTERVAL % self.interval) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.restart_delay:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_RESTART_DELAY % self.restart_delay) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.transmit_delay:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TRANSMIT_DELAY % self.transmit_delay) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.notification_interval:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_NOTIFICATION_INTERVAL % self.notification_interval) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.fast_count:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_FAST_COUNT % self.fast_count) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.mdn_notification_interval:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_MDN_NOTIFICATION_INTERVAL % self.mdn_notification_interval) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.management_address:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_MANAGEMENT_ADDRESS % self.management_address) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.bind_name:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBAL_LLDP_CONFIG_HEADER + \
|
||||||
|
(CE_NC_MERGE_GLOBAL_LLDP_CONFIG_BIND_NAME % self.bind_name) + \
|
||||||
|
CE_NC_MERGE_GLOBAL_LLDP_CONFIG_TAIL
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_CONFIG_INTERVAL")
|
||||||
|
|
||||||
|
if self.lldpenable == 'disabled' and not self.conf_exsit:
|
||||||
|
xml_str = CE_NC_MERGE_GLOBA_LLDPENABLE_CONFIG % self.lldpenable
|
||||||
|
ret_xml = set_nc_config(self.module, xml_str)
|
||||||
|
self.check_response(ret_xml, "LLDP_DISABLE_CONFIG")
|
||||||
|
|
||||||
|
def show_result(self):
|
||||||
|
"""Show result"""
|
||||||
|
|
||||||
|
self.results['changed'] = self.changed
|
||||||
|
self.results['proposed'] = self.proposed
|
||||||
|
self.results['existing'] = self.existing
|
||||||
|
self.results['end_state'] = self.end_state
|
||||||
|
if self.changed:
|
||||||
|
self.results['updates'] = self.updates_cmd
|
||||||
|
else:
|
||||||
|
self.results['updates'] = list()
|
||||||
|
|
||||||
|
self.module.exit_json(**self.results)
|
||||||
|
|
||||||
|
def get_lldp_exist_config(self):
|
||||||
|
"""Get lldp existed configure"""
|
||||||
|
|
||||||
|
lldp_config = list()
|
||||||
|
lldp_dict = dict()
|
||||||
|
|
||||||
|
conf_enable_str = CE_NC_GET_GLOBAL_LLDPENABLE_CONFIG
|
||||||
|
conf_enable_obj = get_nc_config(self.module, conf_enable_str)
|
||||||
|
|
||||||
|
xml_enable_str = conf_enable_obj.replace('\r', '').replace('\n', '').\
|
||||||
|
replace('xmlns="urn:ietf:params:xml:ns:netconf:base:1.0"', "").\
|
||||||
|
replace('xmlns="http://www.huawei.com/netconf/vrp"', "")
|
||||||
|
|
||||||
|
# get lldp enable config info
|
||||||
|
root_enable = ElementTree.fromstring(xml_enable_str)
|
||||||
|
ntpsite_enable = root_enable.findall("lldp/lldpSys")
|
||||||
|
for nexthop_enable in ntpsite_enable:
|
||||||
|
for ele_enable in nexthop_enable:
|
||||||
|
if ele_enable.tag in ["lldpEnable", "mdnStatus"]:
|
||||||
|
lldp_dict[ele_enable.tag] = ele_enable.text
|
||||||
|
|
||||||
|
if self.state == "present":
|
||||||
|
cur_lldp_cfg = dict(lldpenable=lldp_dict['lldpEnable'], mdnstatus=lldp_dict['mdnStatus'])
|
||||||
|
exp_lldp_cfg = dict(lldpenable=self.lldpenable, mdnstatus=self.mdnstatus)
|
||||||
|
if lldp_dict['lldpEnable'] == 'enabled':
|
||||||
|
self.enable_flag = 1
|
||||||
|
if cur_lldp_cfg == exp_lldp_cfg:
|
||||||
|
self.conf_exsit = True
|
||||||
|
lldp_config.append(dict(lldpenable=lldp_dict['lldpEnable'], mdnstatus=lldp_dict['mdnStatus']))
|
||||||
|
|
||||||
|
conf_str = CE_NC_GET_GLOBAL_LLDP_CONFIG
|
||||||
|
conf_obj = get_nc_config(self.module, conf_str)
|
||||||
|
if "<data/>" in conf_obj:
|
||||||
|
pass
|
||||||
|
|
||||||
|
else:
|
||||||
|
xml_str = conf_obj.replace('\r', '').replace('\n', '').\
|
||||||
|
replace('xmlns="urn:ietf:params:xml:ns:netconf:base:1.0"', "").\
|
||||||
|
replace('xmlns="http://www.huawei.com/netconf/vrp"', "")
|
||||||
|
|
||||||
|
# get all ntp config info
|
||||||
|
root = ElementTree.fromstring(xml_str)
|
||||||
|
ntpsite = root.findall("lldp/lldpSys/lldpSysParameter")
|
||||||
|
for nexthop in ntpsite:
|
||||||
|
for ele in nexthop:
|
||||||
|
if ele.tag in ["messageTxInterval", "messageTxHoldMultiplier", "reinitDelay", "txDelay",
|
||||||
|
"notificationInterval", "fastMessageCount", "mdnNotificationInterval",
|
||||||
|
"configManAddr", "bindifName"]:
|
||||||
|
lldp_dict[ele.tag] = ele.text
|
||||||
|
|
||||||
|
if self.state == "present":
|
||||||
|
cur_ntp_cfg = dict(interval=lldp_dict['messageTxInterval'],
|
||||||
|
hold_multiplier=lldp_dict['messageTxHoldMultiplier'],
|
||||||
|
restart_delay=lldp_dict['reinitDelay'],
|
||||||
|
transmit_delay=lldp_dict['txDelay'],
|
||||||
|
notification_interval=lldp_dict['notificationInterval'],
|
||||||
|
fast_count=lldp_dict['fastMessageCount'],
|
||||||
|
mdn_notification_interval=lldp_dict['mdnNotificationInterval'],
|
||||||
|
management_address=lldp_dict['configManAddr'],
|
||||||
|
bind_name=lldp_dict['bindifName'])
|
||||||
|
|
||||||
|
exp_ntp_cfg = dict(interval=self.interval, hold_multiplier=self.hold_multiplier,
|
||||||
|
restart_delay=self.restart_delay, transmit_delay=self.transmit_delay,
|
||||||
|
notification_interval=self.notification_interval,
|
||||||
|
fast_count=self.fast_count, mdn_notification_interval=self.mdn_notification_interval,
|
||||||
|
management_address=self.management_address, bind_name=self.bind_name)
|
||||||
|
|
||||||
|
if cur_ntp_cfg == exp_ntp_cfg:
|
||||||
|
self.conf_exsit_lldp = True
|
||||||
|
|
||||||
|
lldp_config.append(dict(interval=lldp_dict['messageTxInterval'],
|
||||||
|
hold_multiplier=lldp_dict['messageTxHoldMultiplier'],
|
||||||
|
restart_delay=lldp_dict['reinitDelay'], transmit_delay=lldp_dict['txDelay'],
|
||||||
|
notification_interval=lldp_dict['notificationInterval'],
|
||||||
|
fast_count=lldp_dict['fastMessageCount'],
|
||||||
|
mdn_notification_interval=lldp_dict['mdnNotificationInterval'],
|
||||||
|
management_address=lldp_dict['configManAddr'],
|
||||||
|
bind_name=lldp_dict['bindifName']))
|
||||||
|
|
||||||
|
tmp_dict = dict()
|
||||||
|
str_1 = str(lldp_config)
|
||||||
|
temp_1 = str_1.replace('[', '').replace(']', '').replace('{', '').replace('}', '').replace('\'', '')
|
||||||
|
if temp_1:
|
||||||
|
tmp_2 = temp_1.split(',')
|
||||||
|
for i in tmp_2:
|
||||||
|
tmp_value = re.match(r'(.*):(.*)', i)
|
||||||
|
key_tmp = tmp_value.group(1)
|
||||||
|
key_value = tmp_value.group(2)
|
||||||
|
tmp_dict[key_tmp] = key_value
|
||||||
|
return tmp_dict
|
||||||
|
|
||||||
|
def get_existing(self):
|
||||||
|
"""Get existing info"""
|
||||||
|
|
||||||
|
self.existing = self.get_lldp_exist_config()
|
||||||
|
|
||||||
|
def get_proposed(self):
|
||||||
|
"""Get proposed info"""
|
||||||
|
|
||||||
|
if self.enable_flag == 1:
|
||||||
|
if self.lldpenable == 'enabled':
|
||||||
|
self.proposed = dict(lldpenable=self.lldpenable)
|
||||||
|
if self.mdnstatus:
|
||||||
|
self.proposed = dict(mdnstatus=self.mdnstatus)
|
||||||
|
elif self.lldpenable == 'disabled':
|
||||||
|
self.proposed = dict(lldpenable=self.lldpenable)
|
||||||
|
self.changed = True
|
||||||
|
else:
|
||||||
|
if self.mdnstatus:
|
||||||
|
self.proposed = dict(mdnstatus=self.mdnstatus)
|
||||||
|
else:
|
||||||
|
if self.lldpenable == 'enabled':
|
||||||
|
self.proposed = dict(lldpenable=self.lldpenable)
|
||||||
|
self.changed = True
|
||||||
|
if self.mdnstatus:
|
||||||
|
self.proposed = dict(mdnstatus=self.mdnstatus)
|
||||||
|
if self.enable_flag == 1 or self.lldpenable == 'enabled':
|
||||||
|
if self.interval:
|
||||||
|
self.proposed = dict(interval=self.interval)
|
||||||
|
if self.hold_multiplier:
|
||||||
|
self.proposed = dict(hold_multiplier=self.hold_multiplier)
|
||||||
|
if self.restart_delay:
|
||||||
|
self.proposed = dict(restart_delay=self.restart_delay)
|
||||||
|
if self.transmit_delay:
|
||||||
|
self.proposed = dict(transmit_delay=self.transmit_delay)
|
||||||
|
if self.notification_interval:
|
||||||
|
self.proposed = dict(notification_interval=self.notification_interval)
|
||||||
|
if self.fast_count:
|
||||||
|
self.proposed = dict(fast_count=self.fast_count)
|
||||||
|
if self.mdn_notification_interval:
|
||||||
|
self.proposed = dict(mdn_notification_interval=self.mdn_notification_interval)
|
||||||
|
if self.management_address:
|
||||||
|
self.proposed = dict(management_address=self.management_address)
|
||||||
|
if self.bind_name:
|
||||||
|
self.proposed = dict(bind_name=self.bind_name)
|
||||||
|
|
||||||
|
def get_end_state(self):
|
||||||
|
"""Get end state info"""
|
||||||
|
|
||||||
|
self.end_state = self.get_lldp_exist_config()
|
||||||
|
existing_key_list = self.existing.keys()
|
||||||
|
end_state_key_list = self.end_state.keys()
|
||||||
|
for i in end_state_key_list:
|
||||||
|
for j in existing_key_list:
|
||||||
|
if i == j and self.existing[i] != self.end_state[j]:
|
||||||
|
self.changed = True
|
||||||
|
|
||||||
|
def get_update_cmd(self):
|
||||||
|
"""Get updated commands"""
|
||||||
|
|
||||||
|
if self.conf_exsit and self.conf_exsit_lldp:
|
||||||
|
return
|
||||||
|
|
||||||
|
if self.state == "present":
|
||||||
|
if self.lldpenable == "enabled":
|
||||||
|
self.updates_cmd.append("lldp enable")
|
||||||
|
|
||||||
|
if self.mdnstatus:
|
||||||
|
self.updates_cmd.append("lldp mdn enable")
|
||||||
|
if self.mdnstatus == "rxOnly":
|
||||||
|
self.updates_cmd.append("lldp mdn enable")
|
||||||
|
else:
|
||||||
|
self.updates_cmd.append("undo lldp mdn enable")
|
||||||
|
if self.interval:
|
||||||
|
self.updates_cmd.append("lldp transmit interval %s" % self.interval)
|
||||||
|
if self.hold_multiplier:
|
||||||
|
self.updates_cmd.append("lldp transmit multiplier %s" % self.hold_multiplier)
|
||||||
|
if self.restart_delay:
|
||||||
|
self.updates_cmd.append("lldp restart %s" % self.restart_delay)
|
||||||
|
if self.transmit_delay:
|
||||||
|
self.updates_cmd.append("lldp transmit delay %s" % self.transmit_delay)
|
||||||
|
if self.notification_interval:
|
||||||
|
self.updates_cmd.append("lldp trap-interval %s" % self.notification_interval)
|
||||||
|
if self.fast_count:
|
||||||
|
self.updates_cmd.append("lldp fast-count %s" % self.fast_count)
|
||||||
|
if self.mdn_notification_interval:
|
||||||
|
self.updates_cmd.append("lldp mdn trap-interval %s" % self.mdn_notification_interval)
|
||||||
|
if self.management_address:
|
||||||
|
self.updates_cmd.append("lldp management-address %s" % self.management_address)
|
||||||
|
if self.bind_name:
|
||||||
|
self.updates_cmd.append("lldp management-address bind interface %s" % self.bind_name)
|
||||||
|
elif self.lldpenable == "disabled":
|
||||||
|
self.updates_cmd.append("undo lldp enable")
|
||||||
|
else:
|
||||||
|
if self.enable_flag == 1:
|
||||||
|
if self.mdnstatus:
|
||||||
|
if self.mdnstatus == "rxOnly":
|
||||||
|
self.updates_cmd.append("lldp mdn enable")
|
||||||
|
else:
|
||||||
|
self.updates_cmd.append("undo lldp mdn enable")
|
||||||
|
if self.interval:
|
||||||
|
self.updates_cmd.append("lldp transmit interval %s" % self.interval)
|
||||||
|
if self.hold_multiplier:
|
||||||
|
self.updates_cmd.append("lldp transmit multiplier %s" % self.hold_multiplier)
|
||||||
|
if self.restart_delay:
|
||||||
|
self.updates_cmd.append("lldp restart %s" % self.restart_delay)
|
||||||
|
if self.transmit_delay:
|
||||||
|
self.updates_cmd.append("lldp transmit delay %s" % self.transmit_delay)
|
||||||
|
if self.notification_interval:
|
||||||
|
self.updates_cmd.append("lldp trap-interval %s" % self.notification_interval)
|
||||||
|
if self.fast_count:
|
||||||
|
self.updates_cmd.append("lldp fast-count %s" % self.fast_count)
|
||||||
|
if self.mdn_notification_interval:
|
||||||
|
self.updates_cmd.append("lldp mdn trap-interval %s" % self.mdn_notification_interval)
|
||||||
|
if self.management_address:
|
||||||
|
self.updates_cmd.append("lldp management-address %s" % self.management_address)
|
||||||
|
if self.bind_name:
|
||||||
|
self.updates_cmd.append("lldp management-address bind interface %s" % self.bind_name)
|
||||||
|
|
||||||
|
def work(self):
|
||||||
|
"""Execute task"""
|
||||||
|
self.check_params()
|
||||||
|
self.get_existing()
|
||||||
|
self.get_proposed()
|
||||||
|
self.config_lldp()
|
||||||
|
self.get_update_cmd()
|
||||||
|
self.get_end_state()
|
||||||
|
self.show_result()
|
||||||
|
|
||||||
|
|
||||||
|
def main():
|
||||||
|
"""Main function entry"""
|
||||||
|
|
||||||
|
argument_spec = dict(
|
||||||
|
lldpenable=dict(required=False, choices=['enabled', 'disabled']),
|
||||||
|
mdnstatus=dict(required=False, choices=['rxOnly', 'disabled']),
|
||||||
|
interval=dict(required=False, type='int'),
|
||||||
|
hold_multiplier=dict(required=False, type='int'),
|
||||||
|
restart_delay=dict(required=False, type='int'),
|
||||||
|
transmit_delay=dict(required=False, type='int'),
|
||||||
|
notification_interval=dict(required=False, type='int'),
|
||||||
|
fast_count=dict(required=False, type='int'),
|
||||||
|
mdn_notification_interval=dict(required=False, type='int'),
|
||||||
|
management_address=dict(required=False, type='str'),
|
||||||
|
bind_name=dict(required=False, type='str'),
|
||||||
|
state=dict(choices=['absent', 'present'], default='present'),
|
||||||
|
)
|
||||||
|
lldp_obj = Lldp(argument_spec)
|
||||||
|
lldp_obj.work()
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
main()
|
3
test/integration/targets/ce_lldp/defaults/main.yaml
Normal file
3
test/integration/targets/ce_lldp/defaults/main.yaml
Normal file
|
@ -0,0 +1,3 @@
|
||||||
|
---
|
||||||
|
testcase: "[^_].*"
|
||||||
|
test_items: []
|
1
test/integration/targets/ce_lldp/meta/main.yml
Normal file
1
test/integration/targets/ce_lldp/meta/main.yml
Normal file
|
@ -0,0 +1 @@
|
||||||
|
|
2
test/integration/targets/ce_lldp/tasks/main.yaml
Normal file
2
test/integration/targets/ce_lldp/tasks/main.yaml
Normal file
|
@ -0,0 +1,2 @@
|
||||||
|
---
|
||||||
|
- { include: netconf.yaml, tags: ['netconf'] }
|
17
test/integration/targets/ce_lldp/tasks/netconf.yaml
Normal file
17
test/integration/targets/ce_lldp/tasks/netconf.yaml
Normal file
|
@ -0,0 +1,17 @@
|
||||||
|
---
|
||||||
|
- name: collect all netconf test cases
|
||||||
|
find:
|
||||||
|
paths: "{{ role_path }}/tests/netconf"
|
||||||
|
patterns: "{{ testcase }}.yaml"
|
||||||
|
use_regex: true
|
||||||
|
connection: local
|
||||||
|
register: test_cases
|
||||||
|
|
||||||
|
- name: set test_items
|
||||||
|
set_fact: test_items="{{ test_cases.files | map(attribute='path') | list }}"
|
||||||
|
|
||||||
|
- name: run test case (connection=netconf)
|
||||||
|
include: "{{ test_case_to_run }} ansible_connection=netconf"
|
||||||
|
with_items: "{{ test_items }}"
|
||||||
|
loop_control:
|
||||||
|
loop_var: test_case_to_run
|
108
test/integration/targets/ce_lldp/tests/netconf/absent.yaml
Normal file
108
test/integration/targets/ce_lldp/tests/netconf/absent.yaml
Normal file
|
@ -0,0 +1,108 @@
|
||||||
|
---
|
||||||
|
- debug:
|
||||||
|
msg: "START ce_lldp absent integration tests on connection={{ ansible_connection }}"
|
||||||
|
|
||||||
|
- block:
|
||||||
|
|
||||||
|
- name: present the provided configuration befor absent
|
||||||
|
ce_lldp:
|
||||||
|
lldpenable: enabled
|
||||||
|
mdnstatus: rxOnly
|
||||||
|
interval: 35
|
||||||
|
hold_multiplier: 5
|
||||||
|
restart_delay: 3
|
||||||
|
transmit_delay: 5
|
||||||
|
notification_interval: 6
|
||||||
|
fast_count: 5
|
||||||
|
mdn_notification_interval: 10.1.1.1
|
||||||
|
management_address: 10.10.10.1
|
||||||
|
bind_name: vlanif100
|
||||||
|
register: result
|
||||||
|
|
||||||
|
- name: change ansible_connection to network_cli
|
||||||
|
set_fact:
|
||||||
|
ansible_connection: network_cli
|
||||||
|
|
||||||
|
- name: display lldp
|
||||||
|
ce_command:
|
||||||
|
commands:
|
||||||
|
- display current-configuration | include lldp
|
||||||
|
register: result_display
|
||||||
|
|
||||||
|
- name: change ansible_connection to netconf
|
||||||
|
set_fact:
|
||||||
|
ansible_connection: netconf
|
||||||
|
|
||||||
|
# There should be some configuration(LLDP) on host befor absent
|
||||||
|
- name: Assert the configuration is reflected on host
|
||||||
|
assert:
|
||||||
|
that:
|
||||||
|
- "'lldp enable' in result_display.stdout[0]"
|
||||||
|
- "'undo lldp mdn disable' in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit interval 35' in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit multiplier 5' in result_display.stdout[0]"
|
||||||
|
- "'lldp restart 3' in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit delay 5' in result_display.stdout[0]"
|
||||||
|
- "'lldp fast-count 5' in result_display.stdout[0]"
|
||||||
|
- "'lldp management-address 10.10.10.1' in result_display.stdout[0]"
|
||||||
|
- "'lldp mdn trap-interval 6' in result_display.stdout[0]"
|
||||||
|
- "'lldp trap-interval 6' in result_display.stdout[0]"
|
||||||
|
- "'lldp management-address bind interface vlanif100' in result_display.stdout[0]"
|
||||||
|
|
||||||
|
- name: absent the provided configuration with the exisiting running configuration
|
||||||
|
ce_lldp: &absent
|
||||||
|
lldpenable: enabled
|
||||||
|
mdnstatus: rxOnly
|
||||||
|
interval: 35
|
||||||
|
hold_multiplier: 5
|
||||||
|
restart_delay: 3
|
||||||
|
transmit_delay: 5
|
||||||
|
notification_interval: 6
|
||||||
|
fast_count: 5
|
||||||
|
mdn_notification_interval: 10.1.1.1
|
||||||
|
management_address: 10.10.10.1
|
||||||
|
bind_name: vlanif100
|
||||||
|
state: absent
|
||||||
|
register: result
|
||||||
|
|
||||||
|
- name: change ansible_connection to network_cli
|
||||||
|
set_fact:
|
||||||
|
ansible_connection: network_cli
|
||||||
|
|
||||||
|
- name: display lldp
|
||||||
|
ce_command:
|
||||||
|
commands:
|
||||||
|
- display current-configuration | include lldp
|
||||||
|
register: result_display
|
||||||
|
|
||||||
|
- name: change ansible_connection to netconf
|
||||||
|
set_fact:
|
||||||
|
ansible_connection: netconf
|
||||||
|
|
||||||
|
- name: Assert the configuration is reflected on host
|
||||||
|
assert:
|
||||||
|
that:
|
||||||
|
- "result['changed'] == true"
|
||||||
|
- "'lldp enable' not in result_display.stdout[0]"
|
||||||
|
- "'undo lldp mdn disable' not in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit interval 35' not in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit multiplier 5' not in result_display.stdout[0]"
|
||||||
|
- "'lldp restart 3' not in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit delay 5' not in result_display.stdout[0]"
|
||||||
|
- "'lldp fast-count 5' not in result_display.stdout[0]"
|
||||||
|
- "'lldp management-address 10.10.10.1' not in result_display.stdout[0]"
|
||||||
|
- "'lldp mdn trap-interval 6' not in result_display.stdout[0]"
|
||||||
|
- "'lldp trap-interval 6' not in result_display.stdout[0]"
|
||||||
|
- "'lldp management-address bind interface vlanif100' not in result_display.stdout[0]"
|
||||||
|
|
||||||
|
- name: Merge the provided configuration with the existing running configuration (IDEMPOTENT)
|
||||||
|
ce_lldp: *absent
|
||||||
|
register: result
|
||||||
|
|
||||||
|
- name: Assert that the previous task was idempotent
|
||||||
|
assert:
|
||||||
|
that:
|
||||||
|
- "result['changed'] == false"
|
||||||
|
|
||||||
|
- debug:
|
||||||
|
msg: "END ce_lldp absent integration tests on connection={{ ansible_connection }}"
|
20
test/integration/targets/ce_lldp/tests/netconf/clean.yaml
Normal file
20
test/integration/targets/ce_lldp/tests/netconf/clean.yaml
Normal file
|
@ -0,0 +1,20 @@
|
||||||
|
---
|
||||||
|
- debug:
|
||||||
|
msg: "Start ce_lldp deleted remove interface config ansible_connection={{ ansible_connection }}"
|
||||||
|
|
||||||
|
- name: change ansible_connection to network_cli
|
||||||
|
set_fact:
|
||||||
|
ansible_connection: network_cli
|
||||||
|
# After the global LLDP function is disabled, all LLDP configuration restore defaults except the LLDP alarm function.
|
||||||
|
- name: display lldp
|
||||||
|
ce_command:
|
||||||
|
commands:
|
||||||
|
- undo lldp enable
|
||||||
|
- lldp mdn disable
|
||||||
|
|
||||||
|
- name: change ansible_connection to netconf
|
||||||
|
set_fact:
|
||||||
|
ansible_connection: netconf
|
||||||
|
|
||||||
|
- debug:
|
||||||
|
msg: "End ce_lldp deleted remove interface config ansible_connection={{ ansible_connection }}"
|
66
test/integration/targets/ce_lldp/tests/netconf/present.yaml
Normal file
66
test/integration/targets/ce_lldp/tests/netconf/present.yaml
Normal file
|
@ -0,0 +1,66 @@
|
||||||
|
---
|
||||||
|
- debug:
|
||||||
|
msg: "START ce_lldp merged integration tests on connection={{ ansible_connection }}"
|
||||||
|
|
||||||
|
- block:
|
||||||
|
|
||||||
|
- include_tasks: cleanup.yaml
|
||||||
|
|
||||||
|
- name: Merge the provided configuration with the exisiting running configuration
|
||||||
|
ce_lldp: &merged
|
||||||
|
lldpenable: enabled
|
||||||
|
mdnstatus: rxOnly
|
||||||
|
interval: 35
|
||||||
|
hold_multiplier: 5
|
||||||
|
restart_delay: 3
|
||||||
|
transmit_delay: 5
|
||||||
|
notification_interval: 6
|
||||||
|
fast_count: 5
|
||||||
|
mdn_notification_interval: 10.1.1.1
|
||||||
|
management_address: 10.10.10.1
|
||||||
|
bind_name: vlanif100
|
||||||
|
register: result
|
||||||
|
|
||||||
|
- name: change ansible_connection to network_cli
|
||||||
|
set_fact:
|
||||||
|
ansible_connection: network_cli
|
||||||
|
|
||||||
|
- name: display lldp
|
||||||
|
ce_command:
|
||||||
|
commands:
|
||||||
|
- display current-configuration | include lldp
|
||||||
|
register: result_display
|
||||||
|
|
||||||
|
- name: change ansible_connection to netconf
|
||||||
|
set_fact:
|
||||||
|
ansible_connection: netconf
|
||||||
|
|
||||||
|
- name: Assert the configuration is reflected on host
|
||||||
|
assert:
|
||||||
|
that:
|
||||||
|
- "result['changed'] == true"
|
||||||
|
- "'lldp enable' in result_display.stdout[0]"
|
||||||
|
- "'undo lldp mdn disable' in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit interval 35' in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit multiplier 5' in result_display.stdout[0]"
|
||||||
|
- "'lldp restart 3' in result_display.stdout[0]"
|
||||||
|
- "'lldp transmit delay 5' in result_display.stdout[0]"
|
||||||
|
- "'lldp fast-count 5' in result_display.stdout[0]"
|
||||||
|
- "'lldp management-address 10.10.10.1' in result_display.stdout[0]"
|
||||||
|
- "'lldp mdn trap-interval 6' in result_display.stdout[0]"
|
||||||
|
- "'lldp trap-interval 6' in result_display.stdout[0]"
|
||||||
|
- "'lldp management-address bind interface vlanif100' in result_display.stdout[0]"
|
||||||
|
|
||||||
|
- name: Merge the provided configuration with the existing running configuration (IDEMPOTENT)
|
||||||
|
ce_lldp: *merged
|
||||||
|
register: result
|
||||||
|
|
||||||
|
- name: Assert that the previous task was idempotent
|
||||||
|
assert:
|
||||||
|
that:
|
||||||
|
- "result['changed'] == false"
|
||||||
|
|
||||||
|
- include_tasks: cleanup.yaml
|
||||||
|
|
||||||
|
- debug:
|
||||||
|
msg: "END ce_lldp merged integration tests on connection={{ ansible_connection }}"
|
|
@ -0,0 +1,21 @@
|
||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<rpc-reply xmlns="urn:ietf:params:xml:ns:netconf:base:1.0" message-id="1024">
|
||||||
|
<data>
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys>
|
||||||
|
<lldpSysParameter>
|
||||||
|
<messageTxInterval>30</messageTxInterval>
|
||||||
|
<messageTxHoldMultiplier>4</messageTxHoldMultiplier>
|
||||||
|
<reinitDelay>2</reinitDelay>
|
||||||
|
<txDelay>2</txDelay>
|
||||||
|
<notificationInterval>5</notificationInterval>
|
||||||
|
<fastMessageCount>4</fastMessageCount>
|
||||||
|
<mdnNotificationInterval>5</mdnNotificationInterval>
|
||||||
|
<mdnNotificationEnable>disabled</mdnNotificationEnable>
|
||||||
|
<configManAddr></configManAddr>
|
||||||
|
<bindifName></bindifName>
|
||||||
|
</lldpSysParameter>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</data>
|
||||||
|
</rpc-reply>
|
|
@ -0,0 +1,21 @@
|
||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<rpc-reply xmlns="urn:ietf:params:xml:ns:netconf:base:1.0" message-id="1024">
|
||||||
|
<data>
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys>
|
||||||
|
<lldpSysParameter>
|
||||||
|
<messageTxInterval>8</messageTxInterval>
|
||||||
|
<messageTxHoldMultiplier>8</messageTxHoldMultiplier>
|
||||||
|
<reinitDelay>8</reinitDelay>
|
||||||
|
<txDelay>8</txDelay>
|
||||||
|
<notificationInterval>8</notificationInterval>
|
||||||
|
<fastMessageCount>8</fastMessageCount>
|
||||||
|
<mdnNotificationInterval>8</mdnNotificationInterval>
|
||||||
|
<mdnNotificationEnable>enabled</mdnNotificationEnable>
|
||||||
|
<configManAddr>1.1.1.1</configManAddr>
|
||||||
|
<bindifName>bind-name</bindifName>
|
||||||
|
</lldpSysParameter>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</data>
|
||||||
|
</rpc-reply>
|
|
@ -0,0 +1,11 @@
|
||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<rpc-reply xmlns="urn:ietf:params:xml:ns:netconf:base:1.0" message-id="1024">
|
||||||
|
<data>
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys>
|
||||||
|
<lldpEnable>disabled</lldpEnable>
|
||||||
|
<mdnStatus>disabled</mdnStatus>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</data>
|
||||||
|
</rpc-reply>
|
|
@ -0,0 +1,11 @@
|
||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<rpc-reply xmlns="urn:ietf:params:xml:ns:netconf:base:1.0" message-id="1024">
|
||||||
|
<data>
|
||||||
|
<lldp xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
|
||||||
|
<lldpSys>
|
||||||
|
<lldpEnable>enabled</lldpEnable>
|
||||||
|
<mdnStatus>rxOnly</mdnStatus>
|
||||||
|
</lldpSys>
|
||||||
|
</lldp>
|
||||||
|
</data>
|
||||||
|
</rpc-reply>
|
|
@ -0,0 +1,3 @@
|
||||||
|
<rpc-reply message-id="801" xmlns="urn:ietf:params:xml:ns:netconf:base:1.0" flow-id="98">
|
||||||
|
<ok/>
|
||||||
|
</rpc-reply>
|
113
test/units/modules/network/cloudengine/test_ce_lldp.py
Normal file
113
test/units/modules/network/cloudengine/test_ce_lldp.py
Normal file
|
@ -0,0 +1,113 @@
|
||||||
|
# (c) 2019 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 <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
# Make coding more python3-ish
|
||||||
|
from __future__ import (absolute_import, division, print_function)
|
||||||
|
|
||||||
|
__metaclass__ = type
|
||||||
|
|
||||||
|
from units.compat.mock import patch
|
||||||
|
from ansible.modules.network.cloudengine import ce_lldp
|
||||||
|
from units.modules.network.cloudengine.ce_module import TestCloudEngineModule, load_fixture
|
||||||
|
from units.modules.utils import set_module_args
|
||||||
|
|
||||||
|
|
||||||
|
class TestCloudEngineLacpModule(TestCloudEngineModule):
|
||||||
|
module = ce_lldp
|
||||||
|
|
||||||
|
def setUp(self):
|
||||||
|
super(TestCloudEngineLacpModule, self).setUp()
|
||||||
|
|
||||||
|
self.mock_get_config = patch('ansible.modules.network.cloudengine.ce_lldp.get_nc_config')
|
||||||
|
self.get_nc_config = self.mock_get_config.start()
|
||||||
|
|
||||||
|
self.mock_set_config = patch('ansible.modules.network.cloudengine.ce_lldp.set_nc_config')
|
||||||
|
self.set_nc_config = self.mock_set_config.start()
|
||||||
|
self.set_nc_config.return_value = None
|
||||||
|
xml_existing_1 = load_fixture('ce_lldp', 'ce_lldp_global_00.txt')
|
||||||
|
xml_existing_2 = load_fixture('ce_lldp', 'ce_lldp_global_01.txt')
|
||||||
|
xml_end_state_1 = load_fixture('ce_lldp', 'ce_lldpSysParameter_00.txt')
|
||||||
|
xml_end_state_2 = load_fixture('ce_lldp', 'ce_lldpSysParameter_01.txt')
|
||||||
|
self.get_side_effect = (xml_existing_1, xml_existing_2, xml_end_state_1, xml_end_state_2)
|
||||||
|
self.result_ok = load_fixture('ce_lldp', 'result_ok.txt')
|
||||||
|
|
||||||
|
def tearDown(self):
|
||||||
|
super(TestCloudEngineLacpModule, self).tearDown()
|
||||||
|
self.mock_set_config.stop()
|
||||||
|
self.mock_get_config.stop()
|
||||||
|
|
||||||
|
def test_lldp_global_present(self):
|
||||||
|
update = ['lldp enable',
|
||||||
|
'lldp mdn enable',
|
||||||
|
'lldp mdn enable',
|
||||||
|
'lldp transmit interval 8',
|
||||||
|
'lldp transmit multiplier 8',
|
||||||
|
'lldp restart 8',
|
||||||
|
'lldp transmit delay 8',
|
||||||
|
'lldp trap-interval 8',
|
||||||
|
'lldp fast-count 8',
|
||||||
|
'lldp mdn trap-interval 8',
|
||||||
|
'lldp management-address 1.1.1.1',
|
||||||
|
'lldp management-address bind interface bind-name']
|
||||||
|
self.get_nc_config.side_effect = self.get_side_effect
|
||||||
|
self.set_nc_config.side_effect = [self.result_ok] * 11
|
||||||
|
set_module_args(dict(
|
||||||
|
lldpenable='enabled',
|
||||||
|
mdnstatus='rxOnly',
|
||||||
|
interval=8,
|
||||||
|
hold_multiplier=8,
|
||||||
|
restart_delay=8,
|
||||||
|
transmit_delay=8,
|
||||||
|
notification_interval=8,
|
||||||
|
fast_count=8,
|
||||||
|
mdn_notification_interval=8,
|
||||||
|
management_address='1.1.1.1',
|
||||||
|
bind_name='bind-name')
|
||||||
|
)
|
||||||
|
result = self.execute_module(changed=True)
|
||||||
|
self.assertEquals(sorted(result['updates']), sorted(update))
|
||||||
|
|
||||||
|
def test_lacp_sys_parameter_present(self):
|
||||||
|
update = ['lldp enable',
|
||||||
|
'lldp mdn enable',
|
||||||
|
'lldp mdn enable',
|
||||||
|
'lldp transmit interval 8',
|
||||||
|
'lldp transmit multiplier 8',
|
||||||
|
'lldp restart 8',
|
||||||
|
'lldp transmit delay 8',
|
||||||
|
'lldp trap-interval 8',
|
||||||
|
'lldp fast-count 8',
|
||||||
|
'lldp mdn trap-interval 8',
|
||||||
|
'lldp management-address 1.1.1.1',
|
||||||
|
'lldp management-address bind interface bind-name']
|
||||||
|
self.get_nc_config.side_effect = self.get_side_effect
|
||||||
|
self.set_nc_config.side_effect = [self.result_ok] * 11
|
||||||
|
set_module_args(dict(
|
||||||
|
lldpenable='enabled',
|
||||||
|
mdnstatus='rxOnly',
|
||||||
|
interval=8,
|
||||||
|
hold_multiplier=8,
|
||||||
|
restart_delay=8,
|
||||||
|
transmit_delay=8,
|
||||||
|
notification_interval=8,
|
||||||
|
fast_count=8,
|
||||||
|
mdn_notification_interval=8,
|
||||||
|
management_address='1.1.1.1',
|
||||||
|
bind_name='bind-name')
|
||||||
|
)
|
||||||
|
result = self.execute_module(changed=True)
|
||||||
|
self.assertEquals(sorted(result['updates']), sorted(update))
|
Loading…
Reference in a new issue