ceph
/
ceph-ansible
mirror of https://github.com/ceph/ceph-ansible.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

radosgw_user: add support check mode 

Signed-off-by: Seena Fallah <seenafallah@gmail.com>
(cherry picked from commit a7e881439e)
pull/7519/head
Seena Fallah 2024-03-16 16:22:08 +01:00
parent 46fe58ec5e
commit ac3081ecbf
1 changed files with 16 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
library/radosgw_user.py
View File

@ -418,25 +418,14 @@ def run_module():
system = module.params.get('system') system = module.params.get('system')
admin = module.params.get('admin') admin = module.params.get('admin')
if module.check_mode:
module.exit_json(
changed=False,
stdout='',
stderr='',
rc=0,
start='',
end='',
delta='',
)
startd = datetime.datetime.now() startd = datetime.datetime.now()
changed = False changed = False
# will return either the image name or None # will return either the image name or None
container_image = is_containerized() container_image = is_containerized()
rc, cmd, out, err = exec_commands(module, get_user(module, container_image=container_image)) # noqa: E501
if state == "present": if state == "present":
rc, cmd, out, err = exec_commands(module, get_user(module, container_image=container_image)) # noqa: E501
if rc == 0: if rc == 0:
user = json.loads(out) user = json.loads(out)
current = { current = {
@ -452,32 +441,33 @@ def run_module():
if email: if email:
current['email'] = user['email'] current['email'] = user['email']
asked['email'] = email asked['email'] = email
if access_key:
current['access_key'] = user['keys'][0]['access_key']
asked['access_key'] = access_key
if secret_key:
current['secret_key'] = user['keys'][0]['secret_key']
asked['secret_key'] = secret_key
if current != asked: if access_key and secret_key:
asked['access_key'] = access_key
asked['secret_key'] = secret_key
for key in user['keys']:
if key['access_key'] == access_key and key['secret_key'] == secret_key: # noqa: E501
del asked['access_key']
del asked['secret_key']
break
changed = current != asked
if changed and not module.check_mode:
rc, cmd, out, err = exec_commands(module, modify_user(module, container_image=container_image)) # noqa: E501 rc, cmd, out, err = exec_commands(module, modify_user(module, container_image=container_image)) # noqa: E501
changed = True
else: else:
rc, cmd, out, err = exec_commands(module, create_user(module, container_image=container_image)) # noqa: E501 if not module.check_mode:
rc, cmd, out, err = exec_commands(module, create_user(module, container_image=container_image)) # noqa: E501
changed = True changed = True
elif state == "absent": elif state == "absent":
rc, cmd, out, err = exec_commands(module, get_user(module, container_image=container_image)) # noqa: E501
if rc == 0: if rc == 0:
rc, cmd, out, err = exec_commands(module, remove_user(module, container_image=container_image)) # noqa: E501 if not module.check_mode:
rc, cmd, out, err = exec_commands(module, remove_user(module, container_image=container_image)) # noqa: E501
changed = True changed = True
else: else:
rc = 0 rc = 0
out = "User {} doesn't exist".format(name) out = "User {} doesn't exist".format(name)
elif state == "info":
rc, cmd, out, err = exec_commands(module, get_user(module, container_image=container_image)) # noqa: E501
exit_module(module=module, out=out, rc=rc, cmd=cmd, err=err, startd=startd, changed=changed) # noqa: E501 exit_module(module=module, out=out, rc=rc, cmd=cmd, err=err, startd=startd, changed=changed) # noqa: E501