ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Resolves issue with vmware_dvswitch module for v2.0

Browse source 
When this module was written back in May 2015 we were using 1.9.x. Being lazy I added to param the objects that the other functions would need. What I have noticed is in 2.0 exit_json is trying to jsonify those complex objects and failing. This PR resolves that issue with the vmware_dvswitch module.

@kamsz reported this issue in https://github.com/ansible/ansible-modules-extras/pull/1568

Playbook
```
- name: Create dvswitch
      local_action:
        module: vmware_dvswitch
        hostname: "{{ mgmt_ip_address }}"
        username: "{{ vcsa_user }}"
        password: "{{ vcsa_pass }}"
        datacenter_name: "{{ mgmt_vdc }}"
        switch_name: dvSwitch
        mtu: 1500
        uplink_quantity: 2
        discovery_proto: lldp
        discovery_operation: both
        state: present
```
Module Testing
```
TASK [Create dvswitch] *********************************************************
task path: /opt/autodeploy/projects/emmet/tasks/deploy/dvs_network.yml:3
ESTABLISH LOCAL CONNECTION FOR USER: root
localhost EXEC ( umask 22 && mkdir -p "$( echo $HOME/.ansible/tmp/ansible-tmp-1454693792.01-113207408596014 )" && echo "$( echo $HOME/.ansible/tmp/ansible-tmp-1454693792.01-113207408596014 )" )
localhost PUT /tmp/tmptb3e2c TO /root/.ansible/tmp/ansible-tmp-1454693792.01-113207408596014/vmware_dvswitch
localhost EXEC LANG=en_US.UTF-8 LC_ALL=en_US.UTF-8 LC_MESSAGES=en_US.UTF-8 /usr/bin/python /root/.ansible/tmp/ansible-tmp-1454693792.01-113207408596014/vmware_dvswitch; rm -rf "/root/.ansible/tmp/ansible-tmp-1454693792.01-113207408596014/" > /dev/null 2>&1
changed: [foundation-vcsa -> localhost] => {"changed": true, "invocation": {"module_args": {"datacenter_name": "Test-Lab", "discovery_operation": "both", "discovery_proto": "lldp", "hostname": "172.27.0.100", "mtu": 1500, "password": "VALUE_SPECIFIED_IN_NO_LOG_PARAMETER", "state": "present", "switch_name": "dvSwitch", "uplink_quantity": 2, "username": "root"}, "module_name": "vmware_dvswitch"}, "result": "'vim.dvs.VmwareDistributedVirtualSwitch:dvs-9'"}
```
This commit is contained in:
Joseph Callen 2016-02-05 14:25:47 -05:00 committed by Matt Clay
parent bb417d2b62
commit 9ab5b367bd
1 changed files with 76 additions and 79 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

155
lib/ansible/modules/extras/cloud/vmware/vmware_dvswitch.py
View file

@ -95,78 +95,93 @@ try:
except ImportError: except ImportError:
HAS_PYVMOMI = False HAS_PYVMOMI = False
class VMwareDVSwitch(object):
def __init__(self, module):
self.module = module
self.dvs = None
self.switch_name = self.module.params['switch_name']
self.datacenter_name = self.module.params['datacenter_name']
self.mtu = self.module.params['mtu']
self.uplink_quantity = self.module.params['uplink_quantity']
self.discovery_proto = self.module.params['discovery_proto']
self.discovery_operation = self.module.params['discovery_operation']
self.switch_name = self.module.params['switch_name']
self.state = self.module.params['state']
self.content = connect_to_api(module)
def create_dvswitch(network_folder, switch_name, mtu, uplink_quantity, discovery_proto, discovery_operation): def process_state(self):
try:
result = None dvs_states = {
changed = False 'absent': {
'present': self.state_destroy_dvs,
spec = vim.DistributedVirtualSwitch.CreateSpec() 'absent': self.state_exit_unchanged,
spec.configSpec = vim.dvs.VmwareDistributedVirtualSwitch.ConfigSpec() },
spec.configSpec.uplinkPortPolicy = vim.DistributedVirtualSwitch.NameArrayUplinkPortPolicy() 'present': {
spec.configSpec.linkDiscoveryProtocolConfig = vim.host.LinkDiscoveryProtocolConfig() 'update': self.state_update_dvs,
'present': self.state_exit_unchanged,
spec.configSpec.name = switch_name 'absent': self.state_create_dvs,
spec.configSpec.maxMtu = mtu }
spec.configSpec.linkDiscoveryProtocolConfig.protocol = discovery_proto }
spec.configSpec.linkDiscoveryProtocolConfig.operation = discovery_operation dvs_states[self.state][self.check_dvs_configuration()]()
spec.productInfo = vim.dvs.ProductSpec() except vmodl.RuntimeFault as runtime_fault:
spec.productInfo.name = "DVS" self.module.fail_json(msg=runtime_fault.msg)
spec.productInfo.vendor = "VMware" except vmodl.MethodFault as method_fault:
self.module.fail_json(msg=method_fault.msg)
for count in range(1, uplink_quantity+1): except Exception as e:
spec.configSpec.uplinkPortPolicy.uplinkPortName.append("uplink%d" % count) self.module.fail_json(msg=str(e))
task = network_folder.CreateDVS_Task(spec)
changed, result = wait_for_task(task)
return changed, result
def state_exit_unchanged(module): def create_dvswitch(self, network_folder):
module.exit_json(changed=False) result = None
changed = False
spec = vim.DistributedVirtualSwitch.CreateSpec()
spec.configSpec = vim.dvs.VmwareDistributedVirtualSwitch.ConfigSpec()
spec.configSpec.uplinkPortPolicy = vim.DistributedVirtualSwitch.NameArrayUplinkPortPolicy()
spec.configSpec.linkDiscoveryProtocolConfig = vim.host.LinkDiscoveryProtocolConfig()
def state_destroy_dvs(module): spec.configSpec.name = self.switch_name
dvs = module.params['dvs'] spec.configSpec.maxMtu = self.mtu
task = dvs.Destroy_Task() spec.configSpec.linkDiscoveryProtocolConfig.protocol = self.discovery_proto
changed, result = wait_for_task(task) spec.configSpec.linkDiscoveryProtocolConfig.operation = self.discovery_operation
module.exit_json(changed=changed, result=str(result)) spec.productInfo = vim.dvs.ProductSpec()
spec.productInfo.name = "DVS"
spec.productInfo.vendor = "VMware"
for count in range(1, self.uplink_quantity+1):
spec.configSpec.uplinkPortPolicy.uplinkPortName.append("uplink%d" % count)
def state_update_dvs(module): task = network_folder.CreateDVS_Task(spec)
module.exit_json(changed=False, msg="Currently not implemented.") changed, result = wait_for_task(task)
return changed, result
def state_exit_unchanged(self):
self.module.exit_json(changed=False)
def state_create_dvs(module): def state_destroy_dvs(self):
switch_name = module.params['switch_name'] task = self.dvs.Destroy_Task()
datacenter_name = module.params['datacenter_name'] changed, result = wait_for_task(task)
content = module.params['content'] self.module.exit_json(changed=changed, result=str(result))
mtu = module.params['mtu']
uplink_quantity = module.params['uplink_quantity']
discovery_proto = module.params['discovery_proto']
discovery_operation = module.params['discovery_operation']
changed = True def state_update_dvs(self):
result = None self.module.exit_json(changed=False, msg="Currently not implemented.")
if not module.check_mode: def state_create_dvs(self):
dc = find_datacenter_by_name(content, datacenter_name) changed = True
changed, result = create_dvswitch(dc.networkFolder, switch_name, result = None
mtu, uplink_quantity, discovery_proto,
discovery_operation)
module.exit_json(changed=changed, result=str(result))
if not self.module.check_mode:
dc = find_datacenter_by_name(self.content, self.datacenter_name)
changed, result = self.create_dvswitch(dc.networkFolder)
def check_dvs_configuration(module): self.module.exit_json(changed=changed, result=str(result))
switch_name = module.params['switch_name']
content = connect_to_api(module) def check_dvs_configuration(self):
module.params['content'] = content self.dvs = find_dvs_by_name(self.content, self.switch_name)
dvs = find_dvs_by_name(content, switch_name) if self.dvs is None:
if dvs is None: return 'absent'
return 'absent' else:
else: return 'present'
module.params['dvs'] = dvs
return 'present'
def main(): def main():
@ -184,26 +199,8 @@ def main():
if not HAS_PYVMOMI: if not HAS_PYVMOMI:
module.fail_json(msg='pyvmomi is required for this module') module.fail_json(msg='pyvmomi is required for this module')
try: vmware_dvswitch = VMwareDVSwitch(module)
# Currently state_update_dvs is not implemented. vmware_dvswitch.process_state()
dvs_states = {
'absent': {
'present': state_destroy_dvs,
'absent': state_exit_unchanged,
},
'present': {
'update': state_update_dvs,
'present': state_exit_unchanged,
'absent': state_create_dvs,
}
}
dvs_states[module.params['state']][check_dvs_configuration(module)](module)
except vmodl.RuntimeFault as runtime_fault:
module.fail_json(msg=runtime_fault.msg)
except vmodl.MethodFault as method_fault:
module.fail_json(msg=method_fault.msg)
except Exception as e:
module.fail_json(msg=str(e))
from ansible.module_utils.vmware import * from ansible.module_utils.vmware import *
from ansible.module_utils.basic import * from ansible.module_utils.basic import *