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

kibana_plugin: fixed remove call + run_command with list instead of str (#2143) (#2149)

Browse source 
* fixed remove call + run_command with list instead of str

* fixed the other calls to run_command()

* added changelog fragment

* adjustment on run_command params

* Update changelogs/fragments/2143-kibana_plugin-fixed-function-calls.yml

Co-authored-by: Felix Fontein <felix@fontein.de>

Co-authored-by: Felix Fontein <felix@fontein.de>
(cherry picked from commit 3312ae08af)

Co-authored-by: Alexei Znamensky <103110+russoz@users.noreply.github.com>
This commit is contained in:
patchback[bot] 2021-04-02 22:25:57 +02:00 committed by GitHub
parent 35d81adabf
commit d260f7ffda
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 12 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
changelogs/fragments/2143-kibana_plugin-fixed-function-calls.yml Normal file
View file

@ -0,0 +1,2 @@
bugfixes:
- kibana_plugin - added missing parameters to ``remove_plugin`` when using ``state=present force=true``, and fix potential quoting errors when invoking ``kibana`` (https://github.com/ansible-collections/community.general/pull/2143).

25
plugins/modules/database/misc/kibana_plugin.py
View file

@ -170,25 +170,23 @@ def install_plugin(module, plugin_bin, plugin_name, url, timeout, allow_root, ki
cmd_args = [plugin_bin, "plugin", PACKAGE_STATE_MAP["present"], plugin_name] cmd_args = [plugin_bin, "plugin", PACKAGE_STATE_MAP["present"], plugin_name]
if url: if url:
cmd_args.append("--url %s" % url) cmd_args.extend(["--url", url])
if timeout: if timeout:
cmd_args.append("--timeout %s" % timeout) cmd_args.extend(["--timeout", timeout])
if allow_root: if allow_root:
cmd_args.append('--allow-root') cmd_args.append('--allow-root')
cmd = " ".join(cmd_args)
if module.check_mode: if module.check_mode:
return True, cmd, "check mode", "" return True, " ".join(cmd_args), "check mode", ""
rc, out, err = module.run_command(cmd) rc, out, err = module.run_command(cmd_args)
if rc != 0: if rc != 0:
reason = parse_error(out) reason = parse_error(out)
module.fail_json(msg=reason) module.fail_json(msg=reason)
return True, cmd, out, err return True, " ".join(cmd_args), out, err
def remove_plugin(module, plugin_bin, plugin_name, allow_root, kibana_version='4.6'): def remove_plugin(module, plugin_bin, plugin_name, allow_root, kibana_version='4.6'):
@ -201,17 +199,15 @@ def remove_plugin(module, plugin_bin, plugin_name, allow_root, kibana_version='4
if allow_root: if allow_root:
cmd_args.append('--allow-root') cmd_args.append('--allow-root')
cmd = " ".join(cmd_args)
if module.check_mode: if module.check_mode:
return True, cmd, "check mode", "" return True, " ".join(cmd_args), "check mode", ""
rc, out, err = module.run_command(cmd) rc, out, err = module.run_command(cmd_args)
if rc != 0: if rc != 0:
reason = parse_error(out) reason = parse_error(out)
module.fail_json(msg=reason) module.fail_json(msg=reason)
return True, cmd, out, err return True, " ".join(cmd_args), out, err
def get_kibana_version(module, plugin_bin, allow_root): def get_kibana_version(module, plugin_bin, allow_root):
@ -220,8 +216,7 @@ def get_kibana_version(module, plugin_bin, allow_root):
if allow_root: if allow_root:
cmd_args.append('--allow-root') cmd_args.append('--allow-root')
cmd = " ".join(cmd_args) rc, out, err = module.run_command(cmd_args)
rc, out, err = module.run_command(cmd)
if rc != 0: if rc != 0:
module.fail_json(msg="Failed to get Kibana version : %s" % err) module.fail_json(msg="Failed to get Kibana version : %s" % err)
@ -269,7 +264,7 @@ def main():
if state == "present": if state == "present":
if force: if force:
remove_plugin(module, plugin_bin, name) remove_plugin(module, plugin_bin, name, allow_root, kibana_version)
changed, cmd, out, err = install_plugin(module, plugin_bin, name, url, timeout, allow_root, kibana_version) changed, cmd, out, err = install_plugin(module, plugin_bin, name, url, timeout, allow_root, kibana_version)
elif state == "absent": elif state == "absent":