Skip to content

Commit

Permalink
meraki_syslog - Module properly handles net_id parameter (ansible#57286)
Browse files Browse the repository at this point in the history
  • Loading branch information
kbreit authored and agowa committed Jun 30, 2019
1 parent 00720f1 commit 474529e
Show file tree
Hide file tree
Showing 3 changed files with 34 additions and 53 deletions.
3 changes: 3 additions & 0 deletions changelogs/fragments/meraki_syslog_net_id.yaml
@@ -0,0 +1,3 @@
---
bugfixes:
- meraki_syslog - Module would ignore net_id parameter if passed.
62 changes: 18 additions & 44 deletions lib/ansible/modules/network/meraki/meraki_syslog.py
Expand Up @@ -148,46 +148,10 @@
from ansible.module_utils.basic import AnsibleModule, json, env_fallback
from ansible.module_utils.urls import fetch_url
from ansible.module_utils._text import to_native
from ansible.module_utils.common.dict_transformations import recursive_diff
from ansible.module_utils.network.meraki.meraki import MerakiModule, meraki_argument_spec


def is_net_valid(meraki, net_name, data):
for n in data:
if n['name'] == net_name:
return True
return False


def construct_tags(tags):
''' Assumes tags are a comma separated list '''
if tags is not None:
tags = tags.replace(' ', '')
tags = tags.split(',')
tag_list = str()
for t in tags:
tag_list = tag_list + " " + t
tag_list = tag_list + " "
return tag_list
return None

# This code was used but relying on API and/or server_arg_spec instead
# def validate_roles(meraki, data):
# ''' Validates whether provided rules are valid '''
# valid_roles = ['WIRELESS EVENT LOG',
# 'APPLIANCE EVENT LOG',
# 'SWITCH EVENT LOG',
# 'AIR MARSHAL EVENTS',
# 'FLOWS',
# 'URLS',
# 'IDS ALERTS',
# 'SECURITY EVENTS']
# for server in data['servers']:
# for role in server['roles']:
# if role.upper() not in valid_roles:
# # meraki.fail_json(msg="Heck yes")
# meraki.fail_json(msg='{0} is not a valid Syslog role.'.format(role))


def main():

# define the available arguments/parameters that a user can pass to
Expand Down Expand Up @@ -218,7 +182,7 @@ def main():
# args/params passed to the execution, as well as if the module
# supports check mode
module = AnsibleModule(argument_spec=argument_spec,
supports_check_mode=False,
supports_check_mode=True,
)

meraki = MerakiModule(module, function='syslog')
Expand All @@ -231,25 +195,25 @@ def main():
if not meraki.params['org_name'] and not meraki.params['org_id']:
meraki.fail_json(msg='org_name or org_id parameters are required')
if meraki.params['state'] != 'query':
if not meraki.params['net_name'] or meraki.params['net_id']:
if not meraki.params['net_name'] and not meraki.params['net_id']:
meraki.fail_json(msg='net_name or net_id is required for present or absent states')
if meraki.params['net_name'] and meraki.params['net_id']:
meraki.fail_json(msg='net_name and net_id are mutually exclusive')

# if the user is working with this module in only check mode we do not
# want to make any changes to the environment, just return the current
# state with no modifications
if module.check_mode:
return meraki.result

# manipulate or modify the state as needed (this is going to be the
# part where your module will do what it needs to do)

org_id = meraki.params['org_id']
if not org_id:
org_id = meraki.get_org_id(meraki.params['org_name'])
nets = meraki.get_nets(org_id=org_id)
net_id = meraki.get_net_id(net_name=meraki.params['net_name'], data=nets)
net_id = meraki.params['net_id']
if net_id is None:
nets = meraki.get_nets(org_id=org_id)
net_id = meraki.get_net_id(net_name=meraki.params['net_name'], data=nets)

if meraki.params['state'] == 'query':
path = meraki.construct_path('query_update', net_id=net_id)
Expand All @@ -265,20 +229,30 @@ def main():
for server in payload['servers']:
if server['port']:
server['port'] = str(server['port'])

path = meraki.construct_path('query_update', net_id=net_id)
r = meraki.request(path, method='GET')
if meraki.status == 200:
original = dict()
original['servers'] = r

if meraki.is_update_required(original, payload):
if meraki.module.check_mode is True:
diff = recursive_diff(original, payload)
original.update(payload)
meraki.result['diff'] = {'before': diff[0],
'after': diff[1]}
meraki.result['data'] = original
meraki.result['changed'] = True
meraki.exit_json(**meraki.result)
path = meraki.construct_path('query_update', net_id=net_id)
r = meraki.request(path, method='PUT', payload=json.dumps(payload))
if meraki.status == 200:
meraki.result['data'] = r
meraki.result['changed'] = True
else:
if meraki.module.check_mode is True:
meraki.result['data'] = original
meraki.exit_json(**meraki.result)
meraki.result['data'] = original

# in the event of a successful module execution, you will want to
Expand Down
22 changes: 13 additions & 9 deletions test/integration/targets/meraki_syslog/tasks/main.yml
Expand Up @@ -45,15 +45,19 @@
auth_key: '{{ auth_key }}'
state: present
org_name: '{{test_org_name}}'
net_name: '{{syslog_test_net_name}}'
net_name: '{{test_net_name}}'
type: appliance
delegate_to: localhost
register: new_net

- set_fact:
net_id: '{{new_net.data.id}}'

- name: Query syslog settings
meraki_syslog:
auth_key: '{{auth_key}}'
org_name: '{{test_org_name}}'
net_name: '{{syslog_test_net_name}}'
net_name: '{{test_net_name}}'
state: query
delegate_to: localhost
register: query_all
Expand All @@ -65,7 +69,7 @@
meraki_syslog:
auth_key: '{{auth_key}}'
org_name: '{{test_org_name}}'
net_name: '{{syslog_test_net_name}}'
net_name: '{{test_net_name}}'
state: present
servers:
- host: 192.0.1.2
Expand All @@ -86,7 +90,7 @@
meraki_syslog:
auth_key: '{{auth_key}}'
org_name: '{{test_org_name}}'
net_name: '{{syslog_test_net_name}}'
net_name: '{{test_net_name}}'
state: present
servers:
- host: 192.0.1.2
Expand All @@ -104,11 +108,11 @@
- create_server_idempotency.changed == False
- create_server_idempotency.data is defined

- name: Set multiple syslog servers # Broken
- name: Set multiple syslog servers
meraki_syslog:
auth_key: '{{auth_key}}'
org_name: '{{test_org_name}}'
net_name: '{{syslog_test_net_name}}'
net_id: '{{net_id}}'
state: present
servers:
- host: 192.0.1.3
Expand Down Expand Up @@ -141,7 +145,7 @@
meraki_syslog:
auth_key: '{{auth_key}}'
org_name: '{{test_org_name}}'
net_name: '{{syslog_test_net_name}}'
net_name: '{{test_net_name}}'
state: present
servers:
- host: 192.0.1.6
Expand All @@ -163,7 +167,7 @@
meraki_syslog:
auth_key: '{{auth_key}}'
org_name: '{{test_org_name}}'
net_name: '{{syslog_test_net_name}}'
net_name: '{{test_net_name}}'
state: present
servers:
- host: 192.0.1.2
Expand All @@ -187,7 +191,7 @@
auth_key: '{{ auth_key }}'
state: absent
org_name: '{{test_org_name}}'
net_name: '{{syslog_test_net_name}}'
net_name: '{{test_net_name}}'
delegate_to: localhost
register: delete_all
ignore_errors: yes

0 comments on commit 474529e

Please sign in to comment.