Refactors device group (#44599)

Make module use patterns that other modules use
pull/44652/head
Tim Rupp 6 years ago committed by GitHub
parent 9db3e597f3
commit 639cfe3b6f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -29,12 +29,13 @@ options:
required: True required: True
type: type:
description: description:
- Specifies that the type of group. A C(sync-failover) device group - Specifies that the type of group.
contains devices that synchronize their configuration data and fail - A C(sync-failover) device group contains devices that synchronize their
over to one another when a device becomes unavailable. A C(sync-only) configuration data and fail over to one another when a device becomes
device group has no such failover. When creating a new device group, unavailable.
this option will default to C(sync-only). This setting cannot be - A C(sync-only) device group has no such failover. When creating a new
changed once it has been set. device group, this option will default to C(sync-only).
- This setting cannot be changed once it has been set.
choices: choices:
- sync-failover - sync-failover
- sync-only - sync-only
@ -44,38 +45,39 @@ options:
auto_sync: auto_sync:
description: description:
- Indicates whether configuration synchronization occurs manually or - Indicates whether configuration synchronization occurs manually or
automatically. When creating a new device group, this option will automatically.
default to C(false). - When creating a new device group, this option will default to C(no).
type: bool type: bool
save_on_auto_sync: save_on_auto_sync:
description: description:
- When performing an auto-sync, specifies whether the configuration - When performing an auto-sync, specifies whether the configuration
will be saved or not. If C(false), only the running configuration will be saved or not.
will be changed on the device(s) being synced to. When creating a - When C(no), only the running configuration will be changed on the
new device group, this option will default to C(false). device(s) being synced to.
- When creating a new device group, this option will default to C(no).
type: bool type: bool
full_sync: full_sync:
description: description:
- Specifies whether the system synchronizes the entire configuration - Specifies whether the system synchronizes the entire configuration
during synchronization operations. When C(false), the system performs during synchronization operations.
incremental synchronization operations, based on the cache size - When C(no), the system performs incremental synchronization operations,
specified in C(max_incremental_sync_size). Incremental configuration based on the cache size specified in C(max_incremental_sync_size).
synchronization is a mechanism for synchronizing a device-group's - Incremental configuration synchronization is a mechanism for synchronizing
configuration among its members, without requiring a full configuration a device-group's configuration among its members, without requiring a
load for each configuration change. In order for this to work, all full configuration load for each configuration change.
devices in the device-group must initially agree on the configuration. - In order for this to work, all devices in the device-group must initially
Typically this requires at least one full configuration load to each agree on the configuration. Typically this requires at least one full
device. When creating a new device group, this option will default configuration load to each device.
to C(false). - When creating a new device group, this option will default to C(no).
type: bool type: bool
max_incremental_sync_size: max_incremental_sync_size:
description: description:
- Specifies the size of the changes cache for incremental sync. For example, - Specifies the size of the changes cache for incremental sync.
using the default, if you make more than 1024 KB worth of incremental - For example, using the default, if you make more than 1024 KB worth of
changes, the system performs a full synchronization operation. Using incremental changes, the system performs a full synchronization operation.
incremental synchronization operations can reduce the per-device sync/load - Using incremental synchronization operations can reduce the per-device sync/load
time for configuration changes. This setting is relevant only when time for configuration changes.
C(full_sync) is C(false). - This setting is relevant only when C(full_sync) is C(no).
state: state:
description: description:
- When C(state) is C(present), ensures the device group exists. - When C(state) is C(present), ensures the device group exists.
@ -84,6 +86,12 @@ options:
- present - present
- absent - absent
default: present default: present
network_failover:
description:
- Indicates whether failover occurs over the network or is hard-wired.
- This parameter is only valid for C(type)'s that are C(sync-failover).
type: bool
version_added: 2.7
notes: notes:
- This module is primarily used as a component of configuring HA pairs of - This module is primarily used as a component of configuring HA pairs of
BIG-IP devices. BIG-IP devices.
@ -145,6 +153,11 @@ max_incremental_sync_size:
returned: changed returned: changed
type: int type: int
sample: 1000 sample: 1000
network_failover:
description: Whether or not network failover is enabled.
returned: changed
type: bool
sample: yes
''' '''
from ansible.module_utils.basic import AnsibleModule from ansible.module_utils.basic import AnsibleModule
@ -179,38 +192,79 @@ class Parameters(AnsibleF5Parameters):
'saveOnAutoSync': 'save_on_auto_sync', 'saveOnAutoSync': 'save_on_auto_sync',
'fullLoadOnSync': 'full_sync', 'fullLoadOnSync': 'full_sync',
'autoSync': 'auto_sync', 'autoSync': 'auto_sync',
'incrementalConfigSyncSizeMax': 'max_incremental_sync_size' 'incrementalConfigSyncSizeMax': 'max_incremental_sync_size',
'networkFailover': 'network_failover',
} }
api_attributes = [ api_attributes = [
'saveOnAutoSync', 'fullLoadOnSync', 'description', 'type', 'autoSync', 'saveOnAutoSync',
'incrementalConfigSyncSizeMax' 'fullLoadOnSync',
'description',
'type',
'autoSync',
'incrementalConfigSyncSizeMax',
'networkFailover'
] ]
returnables = [ returnables = [
'save_on_auto_sync', 'full_sync', 'description', 'type', 'auto_sync', 'save_on_auto_sync',
'max_incremental_sync_size' 'full_sync',
'description',
'type',
'auto_sync',
'max_incremental_sync_size',
'network_failover',
] ]
updatables = [ updatables = [
'save_on_auto_sync', 'full_sync', 'description', 'auto_sync', 'save_on_auto_sync',
'max_incremental_sync_size' 'full_sync',
'description',
'auto_sync',
'max_incremental_sync_size',
'network_failover',
] ]
@property @property
def save_on_auto_sync(self): def max_incremental_sync_size(self):
if self._values['save_on_auto_sync'] is None: if not self.full_sync and self._values['max_incremental_sync_size'] is not None:
if self._values['__warnings'] is None:
self._values['__warnings'] = []
self._values['__warnings'].append(
[
dict(
msg='"max_incremental_sync_size has no effect if "full_sync" is not true',
version='2.4'
)
]
)
if self._values['max_incremental_sync_size'] is None:
return None return None
elif self._values['save_on_auto_sync'] in BOOLEANS_TRUE: return int(self._values['max_incremental_sync_size'])
class ApiParameters(Parameters):
@property
def network_failover(self):
if self._values['network_failover'] is None:
return None
elif self._values['network_failover'] == 'enabled':
return True return True
else:
return False return False
@property @property
def auto_sync(self): def auto_sync(self):
if self._values['auto_sync'] is None: if self._values['auto_sync'] is None:
return None return None
elif self._values['auto_sync'] in [True, 'enabled']: elif self._values['auto_sync'] == 'enabled':
return 'enabled' return True
return False
@property
def save_on_auto_sync(self):
if self._values['save_on_auto_sync'] is None:
return None
elif self._values['save_on_auto_sync'] in BOOLEANS_TRUE:
return True
else: else:
return 'disabled' return False
@property @property
def full_sync(self): def full_sync(self):
@ -221,23 +275,12 @@ class Parameters(AnsibleF5Parameters):
else: else:
return False return False
@property
def max_incremental_sync_size(self):
if not self.full_sync and self._values['max_incremental_sync_size'] is not None:
if self._values['__warnings'] is None:
self._values['__warnings'] = []
self._values['__warnings'].append(
[
dict(
msg='"max_incremental_sync_size has no effect if "full_sync" is not true',
version='2.4'
)
]
)
if self._values['max_incremental_sync_size'] is None:
return None
return int(self._values['max_incremental_sync_size'])
class ModuleParameters(Parameters):
pass
class Changes(Parameters):
def to_return(self): def to_return(self):
result = {} result = {}
try: try:
@ -249,22 +292,83 @@ class Parameters(AnsibleF5Parameters):
return result return result
class Changes(Parameters): class UsableChanges(Changes):
@property
def network_failover(self):
if self._values['network_failover'] is None:
return None
elif self._values['network_failover']:
return 'enabled'
return 'disabled'
@property @property
def auto_sync(self): def auto_sync(self):
if self._values['auto_sync'] in BOOLEANS_TRUE: if self._values['auto_sync'] is None:
return True return None
elif self._values['auto_sync']:
return 'enabled'
return 'disabled'
@property
def save_on_auto_sync(self):
if self._values['save_on_auto_sync'] is None:
return None
elif self._values['save_on_auto_sync'] in BOOLEANS_TRUE:
return "true"
else: else:
return False return "false"
@property
def full_sync(self):
if self._values['full_sync'] is None:
return None
elif self._values['full_sync'] in BOOLEANS_TRUE:
return "true"
else:
return "false"
class ReportableChanges(Changes):
@property
def network_failover(self):
if self._values['network_failover'] is None:
return None
elif self._values['network_failover'] == 'enabled':
return 'yes'
return 'no'
@property
def auto_sync(self):
if self._values['auto_sync'] is None:
return None
elif self._values['auto_sync'] == 'enabled':
return 'yes'
return 'no'
@property
def save_on_auto_sync(self):
if self._values['save_on_auto_sync'] is None:
return None
elif self._values['save_on_auto_sync'] in BOOLEANS_TRUE:
return "yes"
return "no"
@property
def full_sync(self):
if self._values['full_sync'] is None:
return None
elif self._values['full_sync'] in BOOLEANS_TRUE:
return "yes"
return "no"
class ModuleManager(object): class ModuleManager(object):
def __init__(self, *args, **kwargs): def __init__(self, *args, **kwargs):
self.module = kwargs.get('module', None) self.module = kwargs.get('module', None)
self.client = kwargs.get('client', None) self.client = kwargs.get('client', None)
self.want = Parameters(params=self.module.params) self.want = ModuleParameters(params=self.module.params)
self.have = None self.have = None
self.changes = Parameters() self.changes = UsableChanges()
def _set_changed_options(self): def _set_changed_options(self):
changed = {} changed = {}
@ -272,7 +376,7 @@ class ModuleManager(object):
if getattr(self.want, key) is not None: if getattr(self.want, key) is not None:
changed[key] = getattr(self.want, key) changed[key] = getattr(self.want, key)
if changed: if changed:
self.changes = Changes(params=changed) self.changes = UsableChanges(params=changed)
def _update_changed_options(self): def _update_changed_options(self):
changed = {} changed = {}
@ -283,7 +387,7 @@ class ModuleManager(object):
if attr1 != attr2: if attr1 != attr2:
changed[key] = attr1 changed[key] = attr1
if changed: if changed:
self.changes = Changes(params=changed) self.changes = UsableChanges(params=changed)
return True return True
return False return False
@ -306,10 +410,10 @@ class ModuleManager(object):
except iControlUnexpectedHTTPError as e: except iControlUnexpectedHTTPError as e:
raise F5ModuleError(str(e)) raise F5ModuleError(str(e))
changes = self.changes.to_return() reportable = ReportableChanges(params=self.changes.to_return())
changes = reportable.to_return()
result.update(**changes) result.update(**changes)
result.update(dict(changed=changed)) result.update(dict(changed=changed))
self._announce_deprecations(result)
return result return result
def _announce_deprecations(self, result): def _announce_deprecations(self, result):
@ -344,27 +448,40 @@ class ModuleManager(object):
def remove(self): def remove(self):
if self.module.check_mode: if self.module.check_mode:
return True return True
self.remove_members_in_group_from_device()
self.remove_from_device() self.remove_from_device()
if self.exists(): if self.exists():
raise F5ModuleError("Failed to delete the device group") raise F5ModuleError("Failed to delete the device group")
return True return True
def remove_members_in_group_from_device(self):
resource = self.client.api.tm.cm.device_groups.device_group.load(
name=self.want.name
)
collection = resource.devices_s.get_collection()
for item in collection:
item.delete()
def create(self): def create(self):
self._set_changed_options() self._set_changed_options()
if self.want.type == 'sync-only' and self.want.network_failover is not None:
raise F5ModuleError(
"'network_failover' may only be specified when 'type' is 'sync-failover'."
)
if self.module.check_mode: if self.module.check_mode:
return True return True
self.create_on_device() self.create_on_device()
return True return True
def create_on_device(self): def create_on_device(self):
params = self.want.api_params() params = self.changes.api_params()
self.client.api.tm.cm.device_groups.device_group.create( self.client.api.tm.cm.device_groups.device_group.create(
name=self.want.name, name=self.want.name,
**params **params
) )
def update_on_device(self): def update_on_device(self):
params = self.want.api_params() params = self.changes.api_params()
resource = self.client.api.tm.cm.device_groups.device_group.load( resource = self.client.api.tm.cm.device_groups.device_group.load(
name=self.want.name name=self.want.name
) )
@ -387,7 +504,7 @@ class ModuleManager(object):
name=self.want.name name=self.want.name
) )
result = resource.attrs result = resource.attrs
return Parameters(params=result) return ApiParameters(params=result)
class ArgumentSpec(object): class ArgumentSpec(object):
@ -415,7 +532,8 @@ class ArgumentSpec(object):
state=dict( state=dict(
default='present', default='present',
choices=['absent', 'present'] choices=['absent', 'present']
) ),
network_failover=dict(type='bool')
) )
self.argument_spec = {} self.argument_spec = {}
self.argument_spec.update(f5_argument_spec) self.argument_spec.update(f5_argument_spec)

@ -20,7 +20,8 @@ from ansible.compat.tests.mock import patch
from ansible.module_utils.basic import AnsibleModule from ansible.module_utils.basic import AnsibleModule
try: try:
from library.modules.bigip_device_group import Parameters from library.modules.bigip_device_group import ApiParameters
from library.modules.bigip_device_group import ModuleParameters
from library.modules.bigip_device_group import ModuleManager from library.modules.bigip_device_group import ModuleManager
from library.modules.bigip_device_group import ArgumentSpec from library.modules.bigip_device_group import ArgumentSpec
from library.module_utils.network.f5.common import F5ModuleError from library.module_utils.network.f5.common import F5ModuleError
@ -28,7 +29,8 @@ try:
from test.unit.modules.utils import set_module_args from test.unit.modules.utils import set_module_args
except ImportError: except ImportError:
try: try:
from ansible.modules.network.f5.bigip_device_group import Parameters from ansible.modules.network.f5.bigip_device_group import ApiParameters
from ansible.modules.network.f5.bigip_device_group import ModuleParameters
from ansible.modules.network.f5.bigip_device_group import ModuleManager from ansible.modules.network.f5.bigip_device_group import ModuleManager
from ansible.modules.network.f5.bigip_device_group import ArgumentSpec from ansible.modules.network.f5.bigip_device_group import ArgumentSpec
from ansible.module_utils.network.f5.common import F5ModuleError from ansible.module_utils.network.f5.common import F5ModuleError
@ -69,12 +71,12 @@ class TestParameters(unittest.TestCase):
auto_sync=True auto_sync=True
) )
p = Parameters(params=args) p = ModuleParameters(params=args)
assert p.save_on_auto_sync is True assert p.save_on_auto_sync is True
assert p.full_sync is False assert p.full_sync is False
assert p.description == "my description" assert p.description == "my description"
assert p.type == "sync-failover" assert p.type == "sync-failover"
assert p.auto_sync == 'enabled' assert p.auto_sync is True
def test_api_parameters(self): def test_api_parameters(self):
args = dict( args = dict(
@ -87,8 +89,8 @@ class TestParameters(unittest.TestCase):
type="sync-only" type="sync-only"
) )
p = Parameters(params=args) p = ApiParameters(params=args)
assert p.auto_sync == 'enabled' assert p.auto_sync is True
assert p.full_sync is False assert p.full_sync is False
assert p.max_incremental_sync_size == 1024 assert p.max_incremental_sync_size == 1024
assert p.save_on_auto_sync is False assert p.save_on_auto_sync is False
@ -136,7 +138,7 @@ class TestModuleManager(unittest.TestCase):
) )
) )
current = Parameters(params=load_fixture('load_tm_cm_device_group.json')) current = ApiParameters(params=load_fixture('load_tm_cm_device_group.json'))
module = AnsibleModule( module = AnsibleModule(
argument_spec=self.spec.argument_spec, argument_spec=self.spec.argument_spec,
supports_check_mode=self.spec.supports_check_mode supports_check_mode=self.spec.supports_check_mode

Loading…
Cancel
Save