File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/beacons/__pycache__/watchdog.cpython-310.pyc
o
�N�g � @ s� d Z ddlZddlZddlZzddlmZ ddlmZ dZ W n e
y0 dZ G dd� d�ZY nw d Z e� e
�Zg d
�ZG d d � d e�Zd
d� Zdd� ZG dd� de�Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )!z�
Watch files and translate the changes into salt events.
.. versionadded:: 2019.2.0
:depends: - watchdog Python module >= 0.8.3
� N)�FileSystemEventHandler)�ObserverTFc @ s e Zd ZdZdd� ZdS )r z%A dummy class to make the import workc C s d S �N� )�selfr r �I/opt/saltstack/salt/lib/python3.10/site-packages/salt/beacons/watchdog.py�__init__ s z FileSystemEventHandler.__init__N)�__name__�
__module__� __qualname__�__doc__r r r r r r s r Zwatchdog)�create�delete�modify�movec sN e Zd Zd� fdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z � Z
S )�HandlerNc s t � �� |pt| _|| _d S r )�superr � DEFAULT_MASK�masks�queue)r r r �� __class__r r r . s
zHandler.__init__c C � | � |d� d S )Nr
��_append_if_mask�r �eventr r r �
on_created3 � zHandler.on_createdc C r )Nr r r r r r � on_modified6 r zHandler.on_modifiedc C r )Nr r r r r r �
on_deleted9 r zHandler.on_deletedc C r )Nr r r r r r �on_moved< r zHandler.on_movedc C s t �|� | �||� d S r )�logging�debug�_append_path_if_mask�r r �maskr r r r ? s
zHandler._append_if_maskc C s || j v r
| j�|� d S d S r )r r �appendr% r r r r$ D s
�z Handler._append_path_if_maskr ) r r
r r r r r r! r r$ �
__classcell__r r r r r - s r c C s" t rtS d} t�dt| � d| fS )Nz watchdog library is missing.z Unable to load %s beacon: %sF)� HAS_WATCHDOG�__virtualname__�log�error)�err_msgr r r � __virtual__I s
r. c C sz dt vr9t�� }t� }| �di �D ]}| �d��|�}|�dt�}t||�}|�||� q|�� |t d< |t d< t d S )zL
Check the context for the notifier and construct it if not present
�watchdog.observer� directoriesr& zwatchdog.queue) � __context__� collections�dequer �getr r Zschedule�start)�configr �observer�pathZ path_paramsr Z
event_handlerr r r �
_get_queueQ s
r9 c @ s e Zd ZdS )�ValidationErrorN)r r
r r r r r r: g s r: c
C s@ zt | � W dS ty } z dt|�fW Y d}~S d}~ww )z+
Validate the beacon configuration
)TzValid beacon configurationFN)� _validater: �str)r6 r, r r r �validatek s ��r= c C sr t | t�s td��i }| D ]}|�|� q
d|vr td��t |d t�s(td��|d D ]
}t|d | � q,d S )Nz1Configuration for watchdog beacon must be a list.r0 z;Configuration for watchdog beacon must include directories.zCConfiguration for watchdog beacon directories must be a dictionary.)�
isinstance�listr: �update�dict�_validate_path)r6 Z_config�partr8 r r r r; w s
�� �r; c C s. t | t�s td��d| v rt| d � d S d S )NzFConfiguration for watchdog beacon directory path must be a dictionary.r& )r> rA r: �_validate_mask)Z path_configr r r rB � s
��rB c s< g d�� t | t�s
td��t� fdd�| D ��r td��d S )N)r
r r r z4Configuration for watchdog beacon mask must be list.c 3 s � | ]}|� vV qd S r r )�.0r& �Z
valid_maskr r � <genexpr>� s � z!_validate_mask.<locals>.<genexpr>z7Configuration for watchdog beacon contains invalid mask)r> r? r: �any)Z mask_configr rF r rD � s
�rD c C s t | j| jd�S )N)�tagr8 Zchange)r* Zsrc_pathZ
event_type)r r r r �
to_salt_event� s �rJ c C s8 t jj�| �} t| �}g }|r|�t|�� �� |s|S )a�
Watch the configured directories
Example Config
.. code-block:: yaml
beacons:
watchdog:
- directories:
/path/to/dir:
mask:
- create
- modify
- delete
- move
The mask list can contain the following events (the default mask is create,
modify delete, and move):
* create - File or directory is created in watched directory
* modify - The watched directory is modified
* delete - File or directory is deleted from watched directory
* move - File or directory is moved or renamed in the watched directory
)�salt�utilsZbeaconsZ list_to_dictr9 r' rJ �popleft)r6 r �retr r r �beacon� s �rO c C s t �dd �}|r|�� d S d S )Nr/ )r1 �pop�stop)r6 r7 r r r �close� s �rR ) r r2 r" Zsalt.utils.beaconsrK Zwatchdog.eventsr Zwatchdog.observersr r) � ImportErrorr* � getLoggerr r+ r r r. r9 � Exceptionr: r= r; rB rD rJ rO rR r r r r �<module> s4 �
&