File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/rabbitmq_user.cpython-310.pyc
Back
o ;j# � @ s^ d Z ddlZddlZddlmZ e�e�Zdd� Z ddd�Z ddd �Z dd d �Z ddd�Z dS )a\ Manage RabbitMQ Users ===================== Example: .. code-block:: yaml rabbit_user: rabbitmq_user.present: - password: password - force: True - tags: - monitoring - user - perms: - '/': - '.*' - '.*' - '.*' - runas: rabbitmq � N)�CommandExecutionErrorc C s t jj�d�r dS dS )z- Only load if RabbitMQ is installed. Z rabbitmqctlT)Fz Command not found: rabbitmqctl)�salt�utils�path�which� r r �M/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/rabbitmq_user.py� __virtual__ s r c C s� |sdS |du r,z t d | |d�}W n ty+ } z t�d|� W Y d}~dS d}~ww dddd�}d}|D ]1}|�� D ]*\}} ||v rd| d | d | d d�} || } | | krc| |kra| |kraq<d }q<d }q<q6|S ) zG Check whether Rabbitmq user's permissions need to be changed. FN� rabbitmq.list_user_permissions��runas� Error: %s� �Z configure�write�readr � � T)�__salt__r �log�error�items) �nameZnewpermsr �existing�errZ empty_permsZperm_need_changeZ vhost_perms�vhost�perms� new_permsZexisting_vhostr r r �_check_perms_changes) s2 �� ��r c C sN z t td |d�| �W S ty& } zt�d|� g W Y d}~S d}~ww )z9 Whether Rabbitmq user's tags need to be changed zrabbitmq.list_usersr r N)�listr r r r )r r r r r r �_get_current_tagsK s ��r Fr c C sx | ddi d�}z t d | |d�}W n ty, } zd|� �|d< |W Y d}~S d}~ww d} |rd|durdzt d | ||d�sGd } t�d | � W n tyc } zd|� �|d< |W Y d}~S d}~ww |r�t|||| f�s�t�d | � d | � d�|d< d |d< |S |s�|d �dd| d�i� td r�d|d< d | � d�|d< |S t�d| � z t d | ||d� W n� ty� } zd|� �|d< |W Y d}~S d}~ww t�d| � |s�| �rW|du�rtd �s z t d | ||d� W n t�y } zd|� �|d< |W Y d}~S d}~ww |d �dddd�i� n>td �sKt�d| � z t d | |d� W n t�yJ } zd|� �|d< |W Y d}~S d}~ww |d �dd dd�i� |du�r�t| |d�} t|t ��rl|� � }t |�t | �A �r�td �s�z t d | ||d� W n t�y� } zd|� �|d< |W Y d}~S d}~ww |d �d | |d�i� z t d | |d�} W n t�y� } zd|� �|d< |W Y d}~S d}~ww t | ||| d!��r�|D ]�} | � � D ]�\} }td �s$zt d" | | |d# |d$ |d% |d� W n t�y# } zd|� �|d< |W Y d}~ S d}~ww | |d# |d$ |d% d&�i}| | v �rp| | || k�rn|d �d'�du �rV|d �d'i i d�i� |d d' d( �| | � |d d' d) �|� �q�|d �d'd)i ii� |d d' d) �|� �q�q�d |d< |d i k�r�d*| � d+�|d< |S td �r�d|d< d,| � d-�|d< |S d*| � d.�|d< |S )/a� Ensure the RabbitMQ user exists. name User name password The user's password force If force is ``True``, the password will be automatically updated without extra password change check. tags Optional list of tags for the user perms A list of dicts with vhost keys and 3-tuple values runas Name of the user to run the command Fr �r �result�comment�changes�rabbitmq.user_existsr �Error: r# Nzrabbitmq.check_passwordTz)RabbitMQ user %s password update requiredzGRabbitMQ user '%s' exists, password is up to date and force is not set.zUser 'z' is already present.r" r$ �user��old�new�testz' is set to be created.z,RabbitMQ user '%s' doesn't exist - Creating.zrabbitmq.add_userzRabbitMQ user '%s' existszrabbitmq.change_password�passwordz Set password.z/Password for %s is not set - Clearing password.zrabbitmq.clear_passwordzRemoved password.zrabbitmq.set_user_tags�tagsr )r r zrabbitmq.set_permissionsr r r r r r) r* �'z"' is already in the desired state.zConfiguration for 'z' will change.z' was configured.)r r r �debug�any�update�__opts__r � isinstance�str�split�setr r �get)r r, �forcer- r r �retr' r Zpasswd_reqs_updateZ current_tagsZexisting_permsZ vhost_permr �permr r r r �presentV s� �� ���� �� ��� �� � ���� ���� �� r; c C s0 | ddi d�}z t d | |d�}W n ty, } zd|� �|d< |W Y d}~S d}~ww |rftd sYz t d | |d� W n tyX } zd|� �|d< |W Y d}~S d}~ww |d �d | dd �i� nd|d< d| � d�|d< |S td r�|d r�d|d< d| � d�|d< |S d|d< d| � d�|d< |S )z� Ensure the named user is absent name The name of the user to remove runas User to run the command Fr r! r% r r& r# Nr+ zrabbitmq.delete_userr$ r r( Tr" z The user 'z' is not present.z' will be removed.z' was removed.)r r r2 r1 )r r r9 Z user_existsr r r r �absent� s8 ����r< )NN)N)NFNr N)�__doc__�loggingZsalt.utils.pathr Zsalt.exceptionsr � getLogger�__name__r r r r r; r< r r r r �<module> s "
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings