golden hour

/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules

File/Folder	Size	Actions
__init__.py	35 B
__pycache__	-
acme.py	12.74 KB
aix_group.py	4.12 KB
aix_shadow.py	1.93 KB
aixpkg.py	24.15 KB
aliases.py	5.07 KB
alternatives.py	5.71 KB
ansiblegate.py	19.51 KB
apache.py	12.47 KB
apcups.py	2.15 KB
apf.py	3.09 KB
apkpkg.py	16 KB
aptly.py	15.28 KB
aptpkg.py	116.64 KB
archive.py	48.63 KB
arista_pyeapi.py	22.06 KB
artifactory.py	24.78 KB
at.py	10.72 KB
at_solaris.py	8.51 KB
augeas_cfg.py	13.93 KB
aws_sqs.py	6.55 KB
azurearm_compute.py	20.8 KB
azurearm_dns.py	15.8 KB
azurearm_network.py	82.99 KB
azurearm_resource.py	35.75 KB
bamboohr.py	7.36 KB
baredoc.py	11.13 KB
bcache.py	28.97 KB
beacons.py	27.82 KB
bigip.py	69.11 KB
bluez_bluetooth.py	6.76 KB
boto3_elasticache.py	37.34 KB
boto3_elasticsearch.py	53.17 KB
boto3_route53.py	39.82 KB
boto3_sns.py	12.93 KB
boto_apigateway.py	61.86 KB
boto_asg.py	35.69 KB
boto_cfn.py	7.95 KB
boto_cloudfront.py	12.75 KB
boto_cloudtrail.py	14.45 KB
boto_cloudwatch.py	10.99 KB
boto_cloudwatch_event.py	9.48 KB
boto_cognitoidentity.py	14.63 KB
boto_datapipeline.py	6.94 KB
boto_dynamodb.py	14.98 KB
boto_ec2.py	79.27 KB
boto_efs.py	14.05 KB
boto_elasticache.py	23.69 KB
boto_elasticsearch_domain.py	15.85 KB
boto_elb.py	35.53 KB
boto_elbv2.py	10.78 KB
boto_iam.py	75.62 KB
boto_iot.py	26.2 KB
boto_kinesis.py	19.62 KB
boto_kms.py	17.29 KB
boto_lambda.py	35.05 KB
boto_rds.py	34.92 KB
boto_route53.py	32.55 KB
boto_s3.py	4.24 KB
boto_s3_bucket.py	31.8 KB
boto_secgroup.py	25.22 KB
boto_sns.py	7.22 KB
boto_sqs.py	6.43 KB
boto_ssm.py	3.63 KB
boto_vpc.py	113.08 KB
bower.py	5.85 KB
bridge.py	10.81 KB
bsd_shadow.py	6.25 KB
btrfs.py	33.66 KB
cabal.py	3.79 KB
capirca_acl.py	40.04 KB
cassandra_cql.py	54.16 KB
cassandra_mod.py	4.3 KB
celery.py	3.33 KB
ceph.py	15.82 KB
chassis.py	1.52 KB
chef.py	4.66 KB
chocolatey.py	41.55 KB
chronos.py	2.89 KB
chroot.py	11.73 KB
cimc.py	23.02 KB
ciscoconfparse_mod.py	14.79 KB
cisconso.py	3.83 KB
cloud.py	9.39 KB
cmdmod.py	163.73 KB
composer.py	10.31 KB
config.py	16.98 KB
consul.py	69.3 KB
container_resource.py	12.94 KB
cp.py	31.98 KB
cpan.py	5.54 KB
cron.py	28.09 KB
cryptdev.py	10.08 KB
csf.py	16.04 KB
cyg.py	8.32 KB
daemontools.py	5.41 KB
data.py	3.85 KB
datadog_api.py	7.76 KB
ddns.py	7.12 KB
deb_apache.py	7.41 KB
deb_postgres.py	4.18 KB
debconfmod.py	4.06 KB
debian_ip.py	64.91 KB
debian_service.py	6.55 KB
debuild_pkgbuild.py	34.68 KB
defaults.py	6.55 KB
devinfo.py	9.07 KB
devmap.py	627 B
dig.py	8.75 KB
disk.py	30.82 KB
djangomod.py	7.53 KB
dnsmasq.py	5.71 KB
dnsutil.py	11.51 KB
dockercompose.py	32.62 KB
dockermod.py	224.85 KB
dpkg_lowpkg.py	12.94 KB
drac.py	10.97 KB
dracr.py	38.53 KB
drbd.py	7.19 KB
dummyproxy_pkg.py	2.46 KB
dummyproxy_service.py	2.91 KB
ebuildpkg.py	38.74 KB
eix.py	1.58 KB
elasticsearch.py	51.44 KB
environ.py	8.96 KB
eselect.py	4.99 KB
esxcluster.py	1.66 KB
esxdatacenter.py	1.68 KB
esxi.py	2.79 KB
esxvm.py	1.63 KB
etcd_mod.py	8.56 KB
ethtool.py	11.12 KB
event.py	7.67 KB
extfs.py	8.78 KB
file.py	232.18 KB
firewalld.py	20.51 KB
freebsd_sysctl.py	4.99 KB
freebsd_update.py	6.19 KB
freebsdjail.py	7.16 KB
freebsdkmod.py	6.17 KB
freebsdpkg.py	17.04 KB
freebsdports.py	13.13 KB
freebsdservice.py	12.53 KB
freezer.py	10.2 KB
gcp_addon.py	4.07 KB
gem.py	10.6 KB
genesis.py	21.75 KB
gentoo_service.py	9.18 KB
gentoolkitmod.py	8.39 KB
git.py	172.01 KB
github.py	53.19 KB
glanceng.py	4.69 KB
glassfish.py	19.49 KB
glusterfs.py	19.55 KB
gnomedesktop.py	6.85 KB
google_chat.py	1.52 KB
gpg.py	39.09 KB
grafana4.py	30.27 KB
grains.py	21.81 KB
groupadd.py	11.87 KB
grub_legacy.py	3.08 KB
guestfs.py	2.37 KB
hadoop.py	3.76 KB
haproxyconn.py	10.17 KB
hashutil.py	6.77 KB
heat.py	25.25 KB
helm.py	39.27 KB
hg.py	7.16 KB
highstate_doc.py	22.76 KB
hosts.py	10.47 KB
http.py	3.76 KB
icinga2.py	4.46 KB
idem.py	1.75 KB
ifttt.py	2.28 KB
ilo.py	15.98 KB
incron.py	7.68 KB
influxdb08mod.py	15.07 KB
influxdbmod.py	16.13 KB
infoblox.py	17.53 KB
ini_manage.py	14.63 KB
inspectlib	-
inspector.py	8.19 KB
introspect.py	4.02 KB
iosconfig.py	14.78 KB
ipmi.py	25.47 KB
ipset.py	17.97 KB
iptables.py	57.44 KB
iwtools.py	3.99 KB
jboss7.py	20.51 KB
jboss7_cli.py	15.23 KB
jenkinsmod.py	11.9 KB
jinja.py	2.66 KB
jira_mod.py	7.07 KB
junos.py	73.96 KB
k8s.py	24.87 KB
kapacitor.py	5.37 KB
kerberos.py	5.42 KB
kernelpkg_linux_apt.py	6.71 KB
kernelpkg_linux_yum.py	7.26 KB
key.py	1007 B
keyboard.py	2.64 KB
keystone.py	43.14 KB
keystoneng.py	21.82 KB
keystore.py	7.18 KB
kmod.py	7.65 KB
kubeadm.py	34.64 KB
kubernetesmod.py	46.77 KB
launchctl_service.py	9.69 KB
layman.py	4.22 KB
ldap3.py	18.81 KB
ldapmod.py	5.9 KB
libcloud_compute.py	23.48 KB
libcloud_dns.py	9.73 KB
libcloud_loadbalancer.py	13.14 KB
libcloud_storage.py	12.16 KB
linux_acl.py	7.7 KB
linux_ip.py	5.55 KB
linux_lvm.py	17.86 KB
linux_service.py	4.64 KB
linux_shadow.py	12.96 KB
linux_sysctl.py	7.5 KB
localemod.py	11.84 KB
locate.py	2.58 KB
logadm.py	9.44 KB
logmod.py	1.25 KB
logrotate.py	7.72 KB
lvs.py	11.54 KB
lxc.py	147.27 KB
lxd.py	90.07 KB
mac_assistive.py	11.37 KB
mac_brew_pkg.py	19.91 KB
mac_desktop.py	2.77 KB
mac_group.py	6.62 KB
mac_keychain.py	6.39 KB
mac_pkgutil.py	2.84 KB
mac_portspkg.py	11.36 KB
mac_power.py	13.29 KB
mac_service.py	19.64 KB
mac_shadow.py	14.23 KB
mac_softwareupdate.py	14.52 KB
mac_sysctl.py	5.13 KB
mac_system.py	15.07 KB
mac_timezone.py	8.34 KB
mac_user.py	16.41 KB
mac_xattr.py	6.27 KB
macdefaults.py	2.33 KB
macpackage.py	6.66 KB
makeconf.py	17.31 KB
mandrill.py	6.31 KB
marathon.py	5.36 KB
match.py	13 KB
mattermost.py	3.4 KB
mdadm_raid.py	9.86 KB
mdata.py	3.38 KB
memcached.py	6.13 KB
mine.py	18.84 KB
minion.py	7.68 KB
mod_random.py	7.18 KB
modjk.py	12.48 KB
mongodb.py	29.75 KB
monit.py	5.51 KB
moosefs.py	3.87 KB
mount.py	58.44 KB
mssql.py	14.64 KB
msteams.py	2.11 KB
munin.py	2.4 KB
mysql.py	90.66 KB
nacl.py	9.72 KB
nagios.py	6.53 KB
nagios_rpc.py	5.09 KB
namecheap_domains.py	12.84 KB
namecheap_domains_dns.py	5.93 KB
namecheap_domains_ns.py	4.51 KB
namecheap_ssl.py	25.69 KB
namecheap_users.py	2.4 KB
napalm_bgp.py	9.72 KB
napalm_formula.py	11.33 KB
napalm_mod.py	61.37 KB
napalm_netacl.py	28.59 KB
napalm_network.py	93.22 KB
napalm_ntp.py	10.22 KB
napalm_probes.py	13.25 KB
napalm_route.py	5.09 KB
napalm_snmp.py	7.05 KB
napalm_users.py	6.49 KB
napalm_yang_mod.py	20.28 KB
netaddress.py	1.6 KB
netbox.py	32.22 KB
netbsd_sysctl.py	3.92 KB
netbsdservice.py	6.43 KB
netmiko_mod.py	19.61 KB
netscaler.py	27.02 KB
network.py	63.42 KB
neutron.py	44.92 KB
neutronng.py	15.02 KB
nexus.py	22.95 KB
nfs3.py	3.9 KB
nftables.py	33.58 KB
nginx.py	3.83 KB
nilrt_ip.py	36.18 KB
nix.py	8.03 KB
nova.py	19.6 KB
npm.py	10.4 KB
nspawn.py	41.35 KB
nxos.py	24.65 KB
nxos_api.py	14.72 KB
nxos_upgrade.py	14.74 KB
omapi.py	3.6 KB
openbsd_sysctl.py	3.74 KB
openbsdpkg.py	10.97 KB
openbsdrcctl_service.py	6.33 KB
openbsdservice.py	8.31 KB
openscap.py	2.81 KB
openstack_config.py	3.21 KB
openstack_mng.py	2.71 KB
openvswitch.py	17.19 KB
opkg.py	49.67 KB
opsgenie.py	3.29 KB
oracle.py	5.82 KB
osquery.py	24.93 KB
out.py	2.53 KB
pacmanpkg.py	31.92 KB
pagerduty.py	4.7 KB
pagerduty_util.py	13.48 KB
pam.py	2.01 KB
panos.py	61.05 KB
parallels.py	19.85 KB
parted_partition.py	21.53 KB
pcs.py	14.11 KB
pdbedit.py	10.79 KB
pecl.py	3.79 KB
peeringdb.py	8.39 KB
pf.py	9.51 KB
philips_hue.py	1.55 KB
pillar.py	21.37 KB
pip.py	53.42 KB
pkg_resource.py	12.3 KB
pkgin.py	17.29 KB
pkgng.py	61.07 KB
pkgutil.py	9.85 KB
portage_config.py	22.73 KB
postfix.py	16.24 KB
postgres.py	88.24 KB
poudriere.py	7.85 KB
powerpath.py	2.57 KB
proxy.py	11.49 KB
ps.py	20.89 KB
publish.py	10.25 KB
puppet.py	10.9 KB
purefa.py	33.59 KB
purefb.py	13.69 KB
pushbullet.py	1.88 KB
pushover_notify.py	3.48 KB
pw_group.py	4.62 KB
pw_user.py	12.47 KB
pyenv.py	6.93 KB
qemu_img.py	1.53 KB
qemu_nbd.py	3.28 KB
quota.py	6.43 KB
rabbitmq.py	38.4 KB
rallydev.py	6.09 KB
random_org.py	23.76 KB
rbac_solaris.py	16.05 KB
rbenv.py	10.75 KB
rdp.py	6.08 KB
rebootmgr.py	7.68 KB
redismod.py	16.36 KB
reg.py	16.36 KB
rest_pkg.py	2.26 KB
rest_sample_utils.py	558 B
rest_service.py	3.63 KB
restartcheck.py	24.1 KB
restconf.py	3.15 KB
ret.py	1.27 KB
rh_ip.py	38.55 KB
rh_service.py	16.61 KB
riak.py	5.19 KB
rpm_lowpkg.py	27.67 KB
rpmbuild_pkgbuild.py	24.53 KB
rsync.py	8.04 KB
runit.py	17.17 KB
rvm.py	11.1 KB
s3.py	9.93 KB
s6.py	3.62 KB
salt_proxy.py	4.48 KB
salt_version.py	4.58 KB
saltcheck.py	46.66 KB
saltcloudmod.py	954 B
saltutil.py	57.49 KB
schedule.py	50.81 KB
scp_mod.py	6.22 KB
scsi.py	2.66 KB
sdb.py	2.48 KB
seed.py	8.87 KB
selinux.py	24.2 KB
sensehat.py	7.79 KB
sensors.py	1.3 KB
serverdensity_device.py	8.1 KB
servicenow.py	4.36 KB
slack_notify.py	7.83 KB
slackware_service.py	6.84 KB
slsutil.py	19.04 KB
smartos_imgadm.py	12.04 KB
smartos_nictagadm.py	6.46 KB
smartos_virt.py	5.21 KB
smartos_vmadm.py	26.2 KB
smbios.py	10.05 KB
smf_service.py	8.52 KB
smtp.py	5.41 KB
snapper.py	27.14 KB
solaris_fmadm.py	11.2 KB
solaris_group.py	2.8 KB
solaris_shadow.py	7.98 KB
solaris_system.py	3.72 KB
solaris_user.py	11.06 KB
solarisipspkg.py	18.68 KB
solarispkg.py	15.4 KB
solr.py	45.54 KB
solrcloud.py	14.63 KB
splunk.py	8.14 KB
splunk_search.py	8.76 KB
sqlite3.py	2.54 KB
ssh.py	43.89 KB
ssh_pkg.py	1.08 KB
ssh_service.py	3.39 KB
state.py	82.34 KB
status.py	57.79 KB
statuspage.py	14.67 KB
supervisord.py	11.15 KB
suse_apache.py	2.45 KB
suse_ip.py	35.72 KB
svn.py	10.75 KB
swarm.py	13.5 KB
swift.py	5.53 KB
sysbench.py	6.62 KB
sysfs.py	6.61 KB
syslog_ng.py	31.52 KB
sysmod.py	22.59 KB
sysrc.py	3.38 KB
system.py	19.28 KB
system_profiler.py	3.54 KB
systemd_service.py	46.29 KB
telegram.py	3.28 KB
telemetry.py	12.87 KB
temp.py	831 B
test.py	15.4 KB
test_virtual.py	237 B
testinframod.py	9.92 KB
textfsm_mod.py	16.22 KB
timezone.py	19.98 KB
tls.py	58.63 KB
tomcat.py	18.59 KB
trafficserver.py	10.44 KB
transactional_update.py	35.83 KB
travisci.py	2.05 KB
tuned.py	2.34 KB
twilio_notify.py	2.95 KB
udev.py	3.72 KB
upstart_service.py	16.92 KB
uptime.py	3.23 KB
useradd.py	22.63 KB
uwsgi.py	996 B
vagrant.py	20.4 KB
varnish.py	3.08 KB
vault.py	15.61 KB
vbox_guest.py	10.55 KB
vboxmanage.py	14.71 KB
vcenter.py	1.61 KB
victorops.py	6.54 KB
virt.py	287.71 KB
virtualenv_mod.py	15.09 KB
vmctl.py	9.56 KB
vsphere.py	380.41 KB
webutil.py	3.66 KB
win_auditpol.py	4.74 KB
win_autoruns.py	2.29 KB
win_certutil.py	4.55 KB
win_dacl.py	32.27 KB
win_disk.py	1.8 KB
win_dism.py	20.7 KB
win_dns_client.py	4.19 KB
win_dsc.py	27.54 KB
win_event.py	22.32 KB
win_file.py	64.39 KB
win_firewall.py	20.15 KB
win_groupadd.py	11.27 KB
win_iis.py	68.78 KB
win_ip.py	11.43 KB
win_lgpo.py	491.76 KB
win_lgpo_reg.py	17.9 KB
win_license.py	2.72 KB
win_network.py	13.9 KB
win_ntp.py	1.8 KB
win_path.py	11.12 KB
win_pkg.py	86.43 KB
win_pki.py	15.8 KB
win_powercfg.py	9.85 KB
win_psget.py	8.97 KB
win_servermanager.py	14.21 KB
win_service.py	32.96 KB
win_shadow.py	3.03 KB
win_shortcut.py	16.49 KB
win_smtp_server.py	17.67 KB
win_snmp.py	13.38 KB
win_status.py	16.94 KB
win_system.py	40.61 KB
win_task.py	79.17 KB
win_timezone.py	13.3 KB
win_useradd.py	27.39 KB
win_wua.py	38.29 KB
win_wusa.py	5.88 KB
winrepo.py	6.09 KB
wordpress.py	4.71 KB
x509.py	63.1 KB
x509_v2.py	74.15 KB
xapi_virt.py	24.07 KB
xbpspkg.py	15.84 KB
xfs.py	15.35 KB
xml.py	2.14 KB
xmpp.py	5.28 KB
yaml.py	1.94 KB
yumpkg.py	116.5 KB
zabbix.py	97.55 KB
zcbuildout.py	28.16 KB
zenoss.py	5.64 KB
zfs.py	34.44 KB
zk_concurrency.py	11.16 KB
znc.py	2.26 KB
zoneadm.py	15.05 KB
zonecfg.py	21.85 KB
zookeeper.py	14.72 KB
zpool.py	44.02 KB
zypperpkg.py	94.87 KB

Edit: rabbitmq.py

"""
Module to provide RabbitMQ compatibility to Salt.
Todo: A lot, need to add cluster support, logging, and minion configuration
data.
"""

import logging
import os
import random
import re
import string

import salt.utils.itertools
import salt.utils.json
import salt.utils.path
import salt.utils.platform
import salt.utils.user
from salt.exceptions import CommandExecutionError, SaltInvocationError
from salt.utils.versions import Version

log = logging.getLogger(__name__)

RABBITMQCTL = None
RABBITMQ_PLUGINS = None

def __virtual__():
    """
    Verify RabbitMQ is installed.
    """
    global RABBITMQCTL
    global RABBITMQ_PLUGINS

if salt.utils.platform.is_windows():
        import winreg

key = None
        try:
            key = winreg.OpenKeyEx(
                winreg.HKEY_LOCAL_MACHINE,
                "SOFTWARE\\VMware, Inc.\\RabbitMQ Server",
                0,
                winreg.KEY_READ | winreg.KEY_WOW64_32KEY,
            )
            (dir_path, value_type) = winreg.QueryValueEx(key, "Install_Dir")
            if value_type != winreg.REG_SZ:
                raise TypeError(
                    "Invalid RabbitMQ Server directory type: {}".format(value_type)
                )
            if not os.path.isdir(dir_path):
                raise OSError("RabbitMQ directory not found: {}".format(dir_path))
            subdir_match = ""
            for name in os.listdir(dir_path):
                if name.startswith("rabbitmq_server-"):
                    subdir_path = os.path.join(dir_path, name)
                    # Get the matching entry that is last in ASCII order.
                    if os.path.isdir(subdir_path) and subdir_path > subdir_match:
                        subdir_match = subdir_path
            if not subdir_match:
                raise OSError(
                    '"rabbitmq_server-*" subdirectory not found in: {}'.format(dir_path)
                )
            RABBITMQCTL = os.path.join(subdir_match, "sbin", "rabbitmqctl.bat")
            RABBITMQ_PLUGINS = os.path.join(
                subdir_match, "sbin", "rabbitmq-plugins.bat"
            )
        except Exception:  # pylint: disable=broad-except
            pass
        finally:
            if key is not None:
                winreg.CloseKey(key)
    else:
        RABBITMQCTL = salt.utils.path.which("rabbitmqctl")
        RABBITMQ_PLUGINS = salt.utils.path.which("rabbitmq-plugins")

if not RABBITMQCTL:
        return (False, "Module rabbitmq: module only works when RabbitMQ is installed")
    return True

def _check_response(response):
    if isinstance(response, dict):
        if response["retcode"] != 0 or response["stderr"]:
            raise CommandExecutionError(
                "RabbitMQ command failed: {}".format(response["stderr"])
            )
    else:
        if "Error" in response:
            raise CommandExecutionError("RabbitMQ command failed: {}".format(response))

def _format_response(response, msg):
    if isinstance(response, dict):
        if response["retcode"] != 0 or response["stderr"]:
            raise CommandExecutionError(
                "RabbitMQ command failed: {}".format(response["stderr"])
            )
        else:
            response = response["stdout"]
    else:
        if "Error" in response:
            raise CommandExecutionError("RabbitMQ command failed: {}".format(response))
    return {msg: response}

def _get_rabbitmq_plugin():
    """
    Returns the rabbitmq-plugin command path if we're running an OS that
    doesn't put it in the standard /usr/bin or /usr/local/bin
    This works by taking the rabbitmq-server version and looking for where it
    seems to be hidden in /usr/lib.
    """
    global RABBITMQ_PLUGINS

if RABBITMQ_PLUGINS is None:
        version = __salt__["pkg.version"]("rabbitmq-server").split("-")[0]
        RABBITMQ_PLUGINS = (
            "/usr/lib/rabbitmq/lib/rabbitmq_server-{}/sbin/rabbitmq-plugins".format(
                version
            )
        )

return RABBITMQ_PLUGINS

def _safe_output(line):
    """
    Looks for rabbitmqctl warning, or general formatting, strings that aren't
    intended to be parsed as output.
    Returns a boolean whether the line can be parsed as rabbitmqctl output.
    """
    return not any(
        [
            line.startswith("Listing") and line.endswith("..."),
            line.startswith("Listing") and "\t" not in line,
            "...done" in line,
            line.startswith("WARNING:"),
            len(line) == 0,
        ]
    )

def _strip_listing_to_done(output_list):
    """
    Conditionally remove non-relevant first and last line,
    "Listing ..." - "...done".
    outputlist: rabbitmq command output split by newline
    return value: list, conditionally modified, may be empty.
    """
    return [line for line in output_list if _safe_output(line)]

def _output_to_dict(cmdoutput, values_mapper=None):
    """
    Convert rabbitmqctl output to a dict of data
    cmdoutput: string output of rabbitmqctl commands
    values_mapper: function object to process the values part of each line
    """
    if isinstance(cmdoutput, dict):
        if cmdoutput["retcode"] != 0 or cmdoutput["stderr"]:
            raise CommandExecutionError(
                "RabbitMQ command failed: {}".format(cmdoutput["stderr"])
            )
        cmdoutput = cmdoutput["stdout"]

ret = {}
    if values_mapper is None:
        values_mapper = lambda string: string.split("\t")

# remove first and last line: Listing ... - ...done
    data_rows = _strip_listing_to_done(cmdoutput.splitlines())

for row in data_rows:
        try:
            key, values = row.split("\t", 1)
        except ValueError:
            # If we have reached this far, we've hit an edge case where the row
            # only has one item: the key. The key doesn't have any values, so we
            # set it to an empty string to preserve rabbitmq reporting behavior.
            # e.g. A user's permission string for '/' is set to ['', '', ''],
            # Rabbitmq reports this only as '/' from the rabbitmqctl command.
            log.debug(
                "Could not find any values for key '%s'. "
                "Setting to '%s' to an empty string.",
                row,
                row,
            )
            ret[row] = ""
            continue
        ret[key] = values_mapper(values)
    return ret

def _output_to_list(cmdoutput):
    """
    Convert rabbitmqctl output to a list of strings (assuming whitespace-delimited output).
    Ignores output lines that shouldn't be parsed, like warnings.
    cmdoutput: string output of rabbitmqctl commands
    """
    return [
        item
        for line in cmdoutput.splitlines()
        if _safe_output(line)
        for item in line.split()
    ]

def _output_lines_to_list(cmdoutput):
    """
    Convert rabbitmqctl output to a list of strings (assuming newline-delimited output).
    Ignores output lines that shouldn't be parsed, like warnings.
    cmdoutput: string output of rabbitmqctl commands
    """
    return [line.strip() for line in cmdoutput.splitlines() if _safe_output(line)]

def list_users(runas=None):
    """
    Return a list of users based off of rabbitmqctl user_list.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_users
    """
    # Windows runas currently requires a password.
    # Due to this, don't use a default value for
    # runas in Windows.
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "list_users", "-q"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )

# func to get tags from string such as "[admin, monitoring]"
    func = (
        lambda string: [x.strip() for x in string[1:-1].split(",")]
        if "," in string
        else [x for x in string[1:-1].split(" ")]
    )
    return _output_to_dict(res, func)

def list_vhosts(runas=None):
    """
    Return a list of vhost based on rabbitmqctl list_vhosts.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_vhosts
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "list_vhosts", "-q"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return _output_to_list(res["stdout"])

def list_upstreams(runas=None):
    """
    Returns a dict of upstreams based on rabbitmqctl list_parameters.

:param str runas: The name of the user to run this command as.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_upstreams

.. versionadded:: 3000
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    ret = {}
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "list_parameters", "-q"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    for raw_line in res["stdout"].split("\n"):
        if _safe_output(raw_line):
            (_, name, definition) = raw_line.split("\t")
            ret[name] = definition
    return ret

def user_exists(name, runas=None):
    """
    Return whether the user exists based on rabbitmqctl list_users.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.user_exists rabbit_user
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    return name in list_users(runas=runas)

def vhost_exists(name, runas=None):
    """
    Return whether the vhost exists based on rabbitmqctl list_vhosts.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.vhost_exists rabbit_host
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    return name in list_vhosts(runas=runas)

def upstream_exists(name, runas=None):
    """
    Return whether the upstreamexists based on rabbitmqctl list_parameters.

:param str name: The name of the upstream to check for.
    :param str runas: The name of the user to run the command as.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.upstream_exists rabbit_upstream

.. versionadded:: 3000
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    return name in list_upstreams(runas=runas)

def add_user(name, password=None, runas=None):
    """
    Add a rabbitMQ user via rabbitmqctl user_add <user> <password>

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.add_user rabbit_user password
    """
    clear_pw = False

if password is None:
        # Generate a random, temporary password. RabbitMQ requires one.
        clear_pw = True
        password = "".join(
            random.SystemRandom().choice(string.ascii_uppercase + string.digits)
            for x in range(15)
        )

if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()

if salt.utils.platform.is_windows():
        # On Windows, if the password contains a special character
        # such as '|', normal execution will fail. For example:
        # cmd: rabbitmq.add_user abc "asdf|def"
        # stderr: 'def' is not recognized as an internal or external
        #         command,\r\noperable program or batch file.
        # Work around this by using a shell and a quoted command.
        python_shell = True
        cmd = '"{}" add_user "{}" "{}"'.format(RABBITMQCTL, name, password)
    else:
        python_shell = False
        cmd = [RABBITMQCTL, "add_user", name, password]

res = __salt__["cmd.run_all"](
        cmd,
        reset_system_locale=False,
        output_loglevel="quiet",
        runas=runas,
        python_shell=python_shell,
    )

if clear_pw:
        # Now, Clear the random password from the account, if necessary
        try:
            clear_password(name, runas)
        except Exception:  # pylint: disable=broad-except
            # Clearing the password failed. We should try to cleanup
            # and rerun and error.
            delete_user(name, runas)
            raise

msg = "Added"
    return _format_response(res, msg)

def delete_user(name, runas=None):
    """
    Deletes a user via rabbitmqctl delete_user.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.delete_user rabbit_user
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "delete_user", name],
        reset_system_locale=False,
        python_shell=False,
        runas=runas,
    )
    msg = "Deleted"

return _format_response(res, msg)

def change_password(name, password, runas=None):
    """
    Changes a user's password.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.change_password rabbit_user password
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    if salt.utils.platform.is_windows():
        # On Windows, if the password contains a special character
        # such as '|', normal execution will fail. For example:
        # cmd: rabbitmq.add_user abc "asdf|def"
        # stderr: 'def' is not recognized as an internal or external
        #         command,\r\noperable program or batch file.
        # Work around this by using a shell and a quoted command.
        python_shell = True
        cmd = '"{}" change_password "{}" "{}"'.format(RABBITMQCTL, name, password)
    else:
        python_shell = False
        cmd = [RABBITMQCTL, "change_password", name, password]
    res = __salt__["cmd.run_all"](
        cmd,
        reset_system_locale=False,
        runas=runas,
        output_loglevel="quiet",
        python_shell=python_shell,
    )
    msg = "Password Changed"

return _format_response(res, msg)

def clear_password(name, runas=None):
    """
    Removes a user's password.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.clear_password rabbit_user
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "clear_password", name],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    msg = "Password Cleared"

return _format_response(res, msg)

def check_password(name, password, runas=None):
    """
    .. versionadded:: 2016.3.0

Checks if a user's password is valid.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.check_password rabbit_user password
    """
    # try to get the rabbitmq-version - adapted from _get_rabbitmq_plugin

if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()

try:
        res = __salt__["cmd.run"](
            [RABBITMQCTL, "status"],
            reset_system_locale=False,
            runas=runas,
            python_shell=False,
        )
        # Check regex against older RabbitMQ version status output
        old_server_version = re.search(r'\{rabbit,"RabbitMQ","(.+)"\}', res)
        # Check regex against newer RabbitMQ version status output
        server_version = re.search(r"RabbitMQ version:\s*(.+)", res)

if server_version is None and old_server_version is None:
            raise ValueError

if old_server_version:
            server_version = old_server_version
        server_version = server_version.group(1).split("-")[0]
        version = [int(i) for i in server_version.split(".")]

except ValueError:
        version = (0, 0, 0)
    if len(version) < 3:
        version = (0, 0, 0)

# rabbitmq introduced a native api to check a username and password in version 3.5.7.
    if tuple(version) >= (3, 5, 7):
        if salt.utils.platform.is_windows():
            # On Windows, if the password contains a special character
            # such as '|', normal execution will fail. For example:
            # cmd: rabbitmq.add_user abc "asdf|def"
            # stderr: 'def' is not recognized as an internal or external
            #         command,\r\noperable program or batch file.
            # Work around this by using a shell and a quoted command.
            python_shell = True
            cmd = '"{}" authenticate_user "{}" "{}"'.format(RABBITMQCTL, name, password)
        else:
            python_shell = False
            cmd = [RABBITMQCTL, "authenticate_user", name, password]

res = __salt__["cmd.run_all"](
            cmd,
            reset_system_locale=False,
            runas=runas,
            output_loglevel="quiet",
            python_shell=python_shell,
        )

if res["retcode"] != 0 or res["stderr"]:
            return False
        return True

cmd = (
        "rabbit_auth_backend_internal:check_user_login"
        '(<<"{}">>, [{{password, <<"{}">>}}]).'.format(
            name.replace('"', '\\"'), password.replace('"', '\\"')
        )
    )

res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "eval", cmd],
        reset_system_locale=False,
        runas=runas,
        output_loglevel="quiet",
        python_shell=False,
    )
    msg = "password-check"

_response = _format_response(res, msg)
    _key = next(iter(_response))

if "invalid credentials" in _response[_key]:
        return False

return True

def add_vhost(vhost, runas=None):
    """
    Adds a vhost via rabbitmqctl add_vhost.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq add_vhost '<vhost_name>'
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "add_vhost", vhost],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )

msg = "Added"
    return _format_response(res, msg)

def delete_vhost(vhost, runas=None):
    """
    Deletes a vhost rabbitmqctl delete_vhost.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.delete_vhost '<vhost_name>'
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "delete_vhost", vhost],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    msg = "Deleted"
    return _format_response(res, msg)

def set_permissions(vhost, user, conf=".*", write=".*", read=".*", runas=None):
    """
    Sets permissions for vhost via rabbitmqctl set_permissions

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.set_permissions myvhost myuser
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "set_permissions", "-p", vhost, user, conf, write, read],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    msg = "Permissions Set"
    return _format_response(res, msg)

def list_permissions(vhost, runas=None):
    """
    Lists permissions for vhost via rabbitmqctl list_permissions

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_permissions /myvhost
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "list_permissions", "--formatter=json", "-p", vhost],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )

perms = salt.utils.json.loads(res["stdout"])
    perms_dict = {}
    for perm in perms:
        user = perm["user"]
        perms_dict[user] = perm
        del perms_dict[user]["user"]
    return perms_dict

def list_user_permissions(name, runas=None):
    """
    List permissions for a user via rabbitmqctl list_user_permissions

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_user_permissions user
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "list_user_permissions", name, "--formatter=json"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )

perms = salt.utils.json.loads(res["stdout"])
    perms_dict = {}
    for perm in perms:
        vhost = perm["vhost"]
        perms_dict[vhost] = perm
        del perms_dict[vhost]["vhost"]
    return perms_dict

def set_user_tags(name, tags, runas=None):
    """Add user tags via rabbitmqctl set_user_tags

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.set_user_tags myadmin administrator
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()

if not isinstance(tags, (list, tuple)):
        tags = [tags]

res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "set_user_tags", name] + list(tags),
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    msg = "Tag(s) set"
    return _format_response(res, msg)

def status(runas=None):
    """
    return rabbitmq status

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.status
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "status"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return res["stdout"]

def cluster_status(runas=None):
    """
    return rabbitmq cluster_status

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.cluster_status
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "cluster_status"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return res["stdout"]

def join_cluster(host, user="rabbit", ram_node=None, runas=None):
    """
    Join a rabbit cluster

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.join_cluster rabbit.example.com rabbit
    """
    cmd = [RABBITMQCTL, "join_cluster"]
    if ram_node:
        cmd.append("--ram")
    cmd.append("{}@{}".format(user, host))

if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    stop_app(runas)
    res = __salt__["cmd.run_all"](
        cmd, reset_system_locale=False, runas=runas, python_shell=False
    )
    start_app(runas)

return _format_response(res, "Join")

def stop_app(runas=None):
    """
    Stops the RabbitMQ application, leaving the Erlang node running.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.stop_app
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "stop_app"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return res["stdout"]

def start_app(runas=None):
    """
    Start the RabbitMQ application.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.start_app
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "start_app"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return res["stdout"]

def reset(runas=None):
    """
    Return a RabbitMQ node to its virgin state

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.reset
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "reset"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return res["stdout"]

def force_reset(runas=None):
    """
    Forcefully Return a RabbitMQ node to its virgin state

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.force_reset
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "force_reset"],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return res["stdout"]

def list_queues(runas=None, *args):
    """
    Returns queue details of the / virtual host

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_queues messages consumers
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    cmd = [RABBITMQCTL, "list_queues", "-q"]
    cmd.extend(args)
    res = __salt__["cmd.run_all"](
        cmd, reset_system_locale=False, runas=runas, python_shell=False
    )
    _check_response(res)
    return _output_to_dict(res["stdout"])

def list_queues_vhost(vhost, runas=None, *args):
    """
    Returns queue details of specified virtual host. This command will consider
    first parameter as the vhost name and rest will be treated as
    queueinfoitem. For getting details on vhost ``/``, use :mod:`list_queues
    <salt.modules.rabbitmq.list_queues>` instead).

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_queues messages consumers
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    cmd = [RABBITMQCTL, "list_queues", "-q", "-p", vhost]
    cmd.extend(args)
    res = __salt__["cmd.run_all"](
        cmd, reset_system_locale=False, runas=runas, python_shell=False
    )
    _check_response(res)
    return _output_to_dict(res["stdout"])

def list_policies(vhost="/", runas=None):
    """
    Return a dictionary of policies nested by vhost and name
    based on the data returned from rabbitmqctl list_policies.

Reference: http://www.rabbitmq.com/ha.html

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_policies
    """
    ret = {}
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "list_policies", "-q", "-p", vhost],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    output = res["stdout"]

if __grains__["os_family"] != "FreeBSD":
        version = __salt__["pkg.version"]("rabbitmq-server").split("-")[0]
    else:
        version = __salt__["pkg.version"]("rabbitmq").split("-")[0]

for line in _output_lines_to_list(output):
        parts = line.split("\t")

if len(parts) not in (5, 6):
            continue

vhost, name = parts[0], parts[1]
        if vhost not in ret:
            ret[vhost] = {}
        ret[vhost][name] = {}

if Version(version) >= Version("3.7"):
            # in version 3.7 the position of apply_to and pattern has been
            # switched
            ret[vhost][name]["pattern"] = parts[2]
            ret[vhost][name]["apply_to"] = parts[3]
            ret[vhost][name]["definition"] = parts[4]
            ret[vhost][name]["priority"] = parts[5]
        else:
            # How many fields are there? - 'apply_to' was inserted in position
            # 2 at some point
            # and in version 3.7 the position of apply_to and pattern has been
            # switched
            offset = len(parts) - 5
            if len(parts) == 6:
                ret[vhost][name]["apply_to"] = parts[2]
            ret[vhost][name].update(
                {
                    "pattern": parts[offset + 2],
                    "definition": parts[offset + 3],
                    "priority": parts[offset + 4],
                }
            )

return ret

def set_policy(
    vhost, name, pattern, definition, priority=None, runas=None, apply_to=None
):
    """
    Set a policy based on rabbitmqctl set_policy.

Reference: http://www.rabbitmq.com/ha.html

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.set_policy / HA '.*' '{"ha-mode":"all"}'
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    if isinstance(definition, dict):
        definition = salt.utils.json.dumps(definition)
    if not isinstance(definition, str):
        raise SaltInvocationError(
            "The 'definition' argument must be a dictionary or JSON string"
        )
    cmd = [RABBITMQCTL, "set_policy", "-p", vhost]
    if priority:
        cmd.extend(["--priority", priority])
    if apply_to:
        cmd.extend(["--apply-to", apply_to])
    cmd.extend([name, pattern, definition])
    res = __salt__["cmd.run_all"](
        cmd, reset_system_locale=False, runas=runas, python_shell=False
    )
    log.debug("Set policy: %s", res["stdout"])
    return _format_response(res, "Set")

def delete_policy(vhost, name, runas=None):
    """
    Delete a policy based on rabbitmqctl clear_policy.

Reference: http://www.rabbitmq.com/ha.html

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.delete_policy / HA
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "clear_policy", "-p", vhost, name],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    log.debug("Delete policy: %s", res["stdout"])
    return _format_response(res, "Deleted")

def policy_exists(vhost, name, runas=None):
    """
    Return whether the policy exists based on rabbitmqctl list_policies.

Reference: http://www.rabbitmq.com/ha.html

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.policy_exists / HA
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    policies = list_policies(runas=runas)
    return bool(vhost in policies and name in policies[vhost])

def list_available_plugins(runas=None):
    """
    Returns a list of the names of all available plugins (enabled and disabled).

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_available_plugins
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    cmd = [_get_rabbitmq_plugin(), "list", "-m"]
    ret = __salt__["cmd.run_all"](
        cmd, reset_system_locale=False, runas=runas, python_shell=False
    )
    _check_response(ret)
    return _output_to_list(ret["stdout"])

def list_enabled_plugins(runas=None):
    """
    Returns a list of the names of the enabled plugins.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.list_enabled_plugins
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    cmd = [_get_rabbitmq_plugin(), "list", "-m", "-e"]
    ret = __salt__["cmd.run_all"](
        cmd, reset_system_locale=False, runas=runas, python_shell=False
    )
    _check_response(ret)
    return _output_to_list(ret["stdout"])

def plugin_is_enabled(name, runas=None):
    """
    Return whether the plugin is enabled.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.plugin_is_enabled rabbitmq_plugin_name
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    return name in list_enabled_plugins(runas)

def enable_plugin(name, runas=None):
    """
    Enable a RabbitMQ plugin via the rabbitmq-plugins command.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.enable_plugin foo
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    cmd = [_get_rabbitmq_plugin(), "enable", name]
    ret = __salt__["cmd.run_all"](
        cmd, reset_system_locale=False, runas=runas, python_shell=False
    )
    return _format_response(ret, "Enabled")

def disable_plugin(name, runas=None):
    """
    Disable a RabbitMQ plugin via the rabbitmq-plugins command.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.disable_plugin foo
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    cmd = [_get_rabbitmq_plugin(), "disable", name]
    ret = __salt__["cmd.run_all"](
        cmd, reset_system_locale=False, runas=runas, python_shell=False
    )
    return _format_response(ret, "Disabled")

def set_upstream(
    name,
    uri,
    prefetch_count=None,
    reconnect_delay=None,
    ack_mode=None,
    trust_user_id=None,
    exchange=None,
    max_hops=None,
    expires=None,
    message_ttl=None,
    ha_policy=None,
    queue=None,
    runas=None,
):
    """
    Configures an upstream via rabbitmqctl set_parameter. This can be an exchange-upstream,
    a queue-upstream or both.

:param str name: The name of the upstream to configure.

The following parameters apply to federated exchanges and federated queues:

:param str uri: The AMQP URI(s) for the upstream.
    :param int prefetch_count: The maximum number of unacknowledged messages copied
        over a link at any one time. Default: 1000
    :param int reconnect_delay: The duration (in seconds) to wait before reconnecting
        to the broker after being disconnected. Default: 1
    :param str ack_mode: Determines how the link should acknowledge messages.
        If set to ``on-confirm`` (the default), messages are acknowledged to the
        upstream broker after they have been confirmed downstream. This handles
        network errors and broker failures without losing messages, and is the
        slowest option.
        If set to ``on-publish``, messages are acknowledged to the upstream broker
        after they have been published downstream. This handles network errors
        without losing messages, but may lose messages in the event of broker failures.
        If set to ``no-ack``, message acknowledgements are not used. This is the
        fastest option, but may lose messages in the event of network or broker failures.
    :param bool trust_user_id: Determines how federation should interact with the
        validated user-id feature. If set to true, federation will pass through
        any validated user-id from the upstream, even though it cannot validate
        it itself. If set to false or not set, it will clear any validated user-id
        it encounters. You should only set this to true if you trust the upstream
        server (and by extension, all its upstreams) not to forge user-ids.

The following parameters apply to federated exchanges only:

:param str exchange: The name of the upstream exchange. Default is to use the
        same name as the federated exchange.
    :param int max_hops: The maximum number of federation links that a message
        published to a federated exchange can traverse before it is discarded.
        Default is 1. Note that even if max-hops is set to a value greater than 1,
        messages will never visit the same node twice due to travelling in a loop.
        However, messages may still be duplicated if it is possible for them to
        travel from the source to the destination via multiple routes.
    :param int expires: The expiry time (in milliseconds) after which an upstream
        queue for a federated exchange may be deleted, if a connection to the upstream
        broker is lost. The default is 'none', meaning the queue should never expire.
        This setting controls how long the upstream queue will last before it is
        eligible for deletion if the connection is lost.
        This value is used to set the "x-expires" argument for the upstream queue.
    :param int message_ttl: The expiry time for messages in the upstream queue
        for a federated exchange (see expires), in milliseconds. Default is ``None``,
        meaning messages should never expire. This does not apply to federated queues.
        This value is used to set the "x-message-ttl" argument for the upstream queue.
    :param str ha_policy: Determines the "x-ha-policy" argument for the upstream
        queue for a federated exchange (see expires). This is only of interest
        when connecting to old brokers which determine queue HA mode using this
        argument. Default is ``None``, meaning the queue is not HA.

The following parameter applies to federated queues only:

:param str queue: The name of the upstream queue. Default is to use the same
        name as the federated queue.

:param str runas: The name of the user to run the command as.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.set_upstream upstream_name ack_mode=on-confirm max_hops=1 \
            trust_user_id=True uri=amqp://hostname

.. versionadded:: 3000
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    params = salt.utils.data.filter_falsey(
        {
            "uri": uri,
            "prefetch-count": prefetch_count,
            "reconnect-delay": reconnect_delay,
            "ack-mode": ack_mode,
            "trust-user-id": trust_user_id,
            "exchange": exchange,
            "max-hops": max_hops,
            "expires": expires,
            "message-ttl": message_ttl,
            "ha-policy": ha_policy,
            "queue": queue,
        }
    )
    res = __salt__["cmd.run_all"](
        [
            RABBITMQCTL,
            "set_parameter",
            "federation-upstream",
            name,
            salt.utils.json.dumps(params),
        ],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return True

def delete_upstream(name, runas=None):
    """
    Deletes an upstream via rabbitmqctl clear_parameter.

:param str name: The name of the upstream to delete.
    :param str runas: The name of the user to run the command as.

CLI Example:

.. code-block:: bash

salt '*' rabbitmq.delete_upstream upstream_name

.. versionadded:: 3000
    """
    if runas is None and not salt.utils.platform.is_windows():
        runas = salt.utils.user.get_user()
    res = __salt__["cmd.run_all"](
        [RABBITMQCTL, "clear_parameter", "federation-upstream", name],
        reset_system_locale=False,
        runas=runas,
        python_shell=False,
    )
    _check_response(res)
    return True