mirror of
https://github.com/ansible-collections/community.general.git
synced 2024-09-14 20:13:21 +02:00
* eos_logging idempotence fix * fixed eos_logging idempotence issue * Fixed pylint and pep8 errors * Added tests for eos_logging & minor fix * Removed q statements
This commit is contained in:
parent
2272b6155c
commit
b9ea646839
2 changed files with 94 additions and 15 deletions
|
@ -114,8 +114,8 @@ commands:
|
||||||
|
|
||||||
import re
|
import re
|
||||||
|
|
||||||
from copy import deepcopy
|
|
||||||
|
|
||||||
|
from copy import deepcopy
|
||||||
from ansible.module_utils.basic import AnsibleModule
|
from ansible.module_utils.basic import AnsibleModule
|
||||||
from ansible.module_utils.network.common.utils import remove_default_spec
|
from ansible.module_utils.network.common.utils import remove_default_spec
|
||||||
from ansible.module_utils.network.eos.eos import get_config, load_config
|
from ansible.module_utils.network.eos.eos import get_config, load_config
|
||||||
|
@ -150,19 +150,32 @@ def map_obj_to_commands(updates, module):
|
||||||
del w['state']
|
del w['state']
|
||||||
|
|
||||||
if state == 'absent' and w in have:
|
if state == 'absent' and w in have:
|
||||||
if dest == 'host':
|
if dest:
|
||||||
commands.append('no logging host {}'.format(name))
|
if dest == 'host':
|
||||||
elif dest:
|
commands.append('no logging host {}'.format(name))
|
||||||
commands.append('no logging {}'.format(dest))
|
|
||||||
else:
|
elif dest in DEST_GROUP:
|
||||||
module.fail_json(msg='dest must be among console, monitor, buffered, host, on')
|
commands.append('no logging {}'.format(dest))
|
||||||
|
|
||||||
|
else:
|
||||||
|
module.fail_json(msg='dest must be among console, monitor, buffered, host, on')
|
||||||
|
|
||||||
if facility:
|
if facility:
|
||||||
commands.append('no logging facility {}'.format(facility))
|
commands.append('no logging facility {}'.format(facility))
|
||||||
|
|
||||||
if state == 'present' and w not in have:
|
if state == 'present' and w not in have:
|
||||||
if facility:
|
if facility:
|
||||||
commands.append('logging facility {}'.format(facility))
|
present = False
|
||||||
|
|
||||||
|
# Iterate over every dictionary in the 'have' list to check if
|
||||||
|
# similar configuration for facility exists or not
|
||||||
|
|
||||||
|
for entry in have:
|
||||||
|
if not entry['dest'] and entry['facility'] == facility:
|
||||||
|
present = True
|
||||||
|
|
||||||
|
if not present:
|
||||||
|
commands.append('logging facility {}'.format(facility))
|
||||||
|
|
||||||
if dest == 'host':
|
if dest == 'host':
|
||||||
commands.append('logging host {}'.format(name))
|
commands.append('logging host {}'.format(name))
|
||||||
|
@ -171,7 +184,28 @@ def map_obj_to_commands(updates, module):
|
||||||
commands.append('logging on')
|
commands.append('logging on')
|
||||||
|
|
||||||
elif dest == 'buffered' and size:
|
elif dest == 'buffered' and size:
|
||||||
commands.append('logging buffered {}'.format(size))
|
|
||||||
|
present = False
|
||||||
|
|
||||||
|
# Deals with the following two cases:
|
||||||
|
# Case 1: logging buffered <size> <level>
|
||||||
|
# logging buffered <same-size>
|
||||||
|
#
|
||||||
|
# Case 2: Same buffered logging configuration
|
||||||
|
# already exists (i.e., both size &
|
||||||
|
# level are same)
|
||||||
|
|
||||||
|
for entry in have:
|
||||||
|
if entry['dest'] == 'buffered' and entry['size'] == size:
|
||||||
|
|
||||||
|
if not level or entry['level'] == level:
|
||||||
|
present = True
|
||||||
|
|
||||||
|
if not present:
|
||||||
|
if size and level:
|
||||||
|
commands.append('logging buffered {} {}'.format(size, level))
|
||||||
|
else:
|
||||||
|
commands.append('logging buffered {}'.format(size))
|
||||||
|
|
||||||
else:
|
else:
|
||||||
dest_cmd = 'logging {}'.format(dest)
|
dest_cmd = 'logging {}'.format(dest)
|
||||||
|
@ -222,11 +256,20 @@ def parse_name(line, dest):
|
||||||
return name
|
return name
|
||||||
|
|
||||||
|
|
||||||
def parse_level(line, dest, module):
|
def parse_level(line, dest):
|
||||||
level = None
|
level = None
|
||||||
|
|
||||||
if dest is not 'host':
|
if dest is not 'host':
|
||||||
match = re.search(r'logging {} (\S+)'.format(dest), line, re.M)
|
|
||||||
|
# Line for buffer logging entry in running-config is of the form:
|
||||||
|
# logging buffered <size> <level>
|
||||||
|
|
||||||
|
if dest == 'buffered':
|
||||||
|
match = re.search(r'logging buffered (?:\d+) (\S+)', line, re.M)
|
||||||
|
|
||||||
|
else:
|
||||||
|
match = re.search(r'logging {} (\S+)'.format(dest), line, re.M)
|
||||||
|
|
||||||
if match:
|
if match:
|
||||||
if match.group(1) in LEVEL_GROUP:
|
if match.group(1) in LEVEL_GROUP:
|
||||||
level = match.group(1)
|
level = match.group(1)
|
||||||
|
@ -240,19 +283,21 @@ def map_config_to_obj(module):
|
||||||
data = get_config(module, flags=['section logging'])
|
data = get_config(module, flags=['section logging'])
|
||||||
|
|
||||||
for line in data.split('\n'):
|
for line in data.split('\n'):
|
||||||
|
|
||||||
match = re.search(r'logging (\S+)', line, re.M)
|
match = re.search(r'logging (\S+)', line, re.M)
|
||||||
|
|
||||||
if match:
|
if match:
|
||||||
if match.group(1) in DEST_GROUP:
|
if match.group(1) in DEST_GROUP:
|
||||||
dest = match.group(1)
|
dest = match.group(1)
|
||||||
|
|
||||||
else:
|
else:
|
||||||
pass
|
dest = None
|
||||||
|
|
||||||
obj.append({'dest': dest,
|
obj.append({'dest': dest,
|
||||||
'name': parse_name(line, dest),
|
'name': parse_name(line, dest),
|
||||||
'size': parse_size(line, dest),
|
'size': parse_size(line, dest),
|
||||||
'facility': parse_facility(line),
|
'facility': parse_facility(line),
|
||||||
'level': parse_level(line, dest, module)})
|
'level': parse_level(line, dest)})
|
||||||
|
|
||||||
return obj
|
return obj
|
||||||
|
|
||||||
|
@ -361,8 +406,8 @@ def main():
|
||||||
if warnings:
|
if warnings:
|
||||||
result['warnings'] = warnings
|
result['warnings'] = warnings
|
||||||
|
|
||||||
want = map_params_to_obj(module, required_if=required_if)
|
|
||||||
have = map_config_to_obj(module)
|
have = map_config_to_obj(module)
|
||||||
|
want = map_params_to_obj(module, required_if=required_if)
|
||||||
|
|
||||||
commands = map_obj_to_commands((want, have), module)
|
commands = map_obj_to_commands((want, have), module)
|
||||||
result['commands'] = commands
|
result['commands'] = commands
|
||||||
|
@ -377,5 +422,6 @@ def main():
|
||||||
|
|
||||||
module.exit_json(**result)
|
module.exit_json(**result)
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
main()
|
main()
|
||||||
|
|
|
@ -64,6 +64,7 @@
|
||||||
- 'result.changed == true'
|
- 'result.changed == true'
|
||||||
- '"logging console warnings" in result.commands'
|
- '"logging console warnings" in result.commands'
|
||||||
|
|
||||||
|
|
||||||
- name: Configure buffer size
|
- name: Configure buffer size
|
||||||
eos_logging:
|
eos_logging:
|
||||||
dest: buffered
|
dest: buffered
|
||||||
|
@ -76,11 +77,42 @@
|
||||||
- 'result.changed == true'
|
- 'result.changed == true'
|
||||||
- '"logging buffered 480000" in result.commands'
|
- '"logging buffered 480000" in result.commands'
|
||||||
|
|
||||||
|
- name: Set up logging destination and facility at the same time
|
||||||
|
eos_logging:
|
||||||
|
dest: buffered
|
||||||
|
size: 4096
|
||||||
|
facility: local7
|
||||||
|
level: informational
|
||||||
|
state: present
|
||||||
|
become: yes
|
||||||
|
register: result
|
||||||
|
|
||||||
|
- assert:
|
||||||
|
that:
|
||||||
|
- 'result.changed == true'
|
||||||
|
- '"logging buffered 4096 informational" in result.commands'
|
||||||
|
- '"logging facility local7" in result.commands'
|
||||||
|
|
||||||
|
- name: Set up logging destination and facility at the same time again (idempotent)
|
||||||
|
eos_logging:
|
||||||
|
dest: buffered
|
||||||
|
size: 4096
|
||||||
|
facility: local7
|
||||||
|
level: informational
|
||||||
|
state: present
|
||||||
|
become: yes
|
||||||
|
register: result
|
||||||
|
|
||||||
|
- assert:
|
||||||
|
that:
|
||||||
|
- 'result.changed == false'
|
||||||
|
|
||||||
- name: remove logging as collection tearDown
|
- name: remove logging as collection tearDown
|
||||||
eos_logging:
|
eos_logging:
|
||||||
aggregate:
|
aggregate:
|
||||||
- { dest: console, level: warnings, state: absent }
|
- { dest: console, level: warnings, state: absent }
|
||||||
- { dest: buffered, size: 480000, state: absent }
|
- { dest: buffered, level: informational, size: 4096, state: absent }
|
||||||
|
- { facility: local7, state: absent }
|
||||||
become: yes
|
become: yes
|
||||||
register: result
|
register: result
|
||||||
|
|
||||||
|
@ -89,3 +121,4 @@
|
||||||
- 'result.changed == true'
|
- 'result.changed == true'
|
||||||
- '"no logging console" in result.commands'
|
- '"no logging console" in result.commands'
|
||||||
- '"no logging buffered" in result.commands'
|
- '"no logging buffered" in result.commands'
|
||||||
|
- '"no logging facility local7" in result.commands'
|
||||||
|
|
Loading…
Reference in a new issue