golden hour

/opt/saltstack/salt/lib/python3.10/site-packages/salt/netapi/rest_cherrypy/__pycache__

File/Folder	Size	Actions
__init__.cpython-310.pyc	2.24 KB
app.cpython-310.pyc	82.32 KB
event_processor.cpython-310.pyc	5.11 KB
wsgi.cpython-310.pyc	2.64 KB

Edit: event_processor.cpython-310.pyc

�����xe�����������������������@���s4���d�dl�Z�d�dlZd�dlZe��e�ZG�dd��d�ZdS�)�����Nc�������������������@���sX���e�Zd�ZdZdd��Zdd��Zdd��Zdd	��Zd
d��Zdd
��Z	dd��Z
dd��Zdd��ZdS�)�SaltInfozP
    Class to  handle processing and publishing of "real time" Salt upates.
    c�����������������C���s���||�_�i�|�_i�|�_dS�)zb
        handler is expected to be the server side end of a websocket
        connection.
        N)�handler�jobs�minions)�selfr�����r����]/opt/saltstack/salt/lib/python3.10/site-packages/salt/netapi/rest_cherrypy/event_processor.py�__init__���s���
zSaltInfo.__init__c�����������������C���sb���g�}|�j����D�]\}}i�}|�|��|�d|i��|�|��qd|i}|�j�tjj�	|�d��dS�)z7
        Publishes minions as a list of dicts.
        �idr���FN)
r����items�update�appendr����send�salt�utils�json�dumps)r���r����minionZminion_infoZcurr_minion�retr���r���r����publish_minions���s���
zSaltInfo.publish_minionsc�����������������C���s$���||i}|�j��tjj�|�d��dS�)z9
        Publishes the data to the event stream.
        FN)r���r���r���r���r���r���)r����key�dataZpublish_datar���r���r����publish*���s���zSaltInfo.publishc�����������������C���sd���|d�}|d�}|��d�\}}}}}|�j�|d�si�|�j|<�|�j|�}|�d|d�i��|�����dS�)zO
        Associate grains data with a minion and publish minion update
        �tagr����/NZgrains�return)�splitr����getr���r���)r����
event_datar����
event_info�_�midr���r���r���r����process_minion_update1���s���

zSaltInfo.process_minion_updatec�����������
������C���s����|d�}|d�}|��d�\}}}}}|�j�|i��}|�di���|i��}|�d|d�i��|�d|d�i��|�d|d�i��tdd	��|d����D���}	|	rQd
|d<�|��d|�j��d
S�)z�
        Process a /ret event returned by Salt for a particular minion.
        These events contain the returned results from a particular execution.
        r���r���r���r���r����retcode�successc�����������������S���s���g�|�]\}}|d���qS�)r$���r���)�.0r!���r���r���r���r����
<listcomp>T���s����z2SaltInfo.process_ret_job_event.<locals>.<listcomp>Zcomplete�stater���N)r���r����
setdefaultr����allr���r���)
r���r���r���r���r ����jidr!����jobr���Zjob_completer���r���r����process_ret_job_eventC���s����zSaltInfo.process_ret_job_eventc�����������������C���sz���d}|d�}|d�}i�}|d�D�]}ddi||<�q|d�|d�||d	�|d
�|d�dd
�}||�j�|d�<�|��d|�j���dS�)z�
        Creates a new job with properties from the event data
        like jid, function, args, timestamp.

Also sets the initial state to started.

Minions that are participating in this job are also noted.

Nr���r���r���r$���Fr*���Z_stamp�fun�tgt�tgt_typeZrunning)r*���Z
start_timer���r-���r.���r/���r'���r���)r���r���)r���r���r+���r���r���r���r!���r���r���r����process_new_job_event\���s ���
�	zSaltInfo.process_new_job_eventc�����������������C���sZ���|d�}|d�}|d�dkr|�j��|d�d��n|d�dkr'|�j��|d�i���|�����dS�)z�
        Tag: salt/key
        Data:
        {'_stamp': '2014-05-20T22:45:04.345583',
         'act': 'delete',
         'id': 'compute.home',
         'result': True}
        r���r���Zact�deleter
���N�accept)r����popr(���r���)r���r���r���r���r���r���r����process_key_eventy���s���
zSaltInfo.process_key_eventc��������������
���C���s����|d�}|d�}|d�}|�j����}d}t|�t|��}	|	D�]}
d}|�j��|
d��qt|�t|��}d�|�}|rMd}tj�|�}
|
�d|d	d
dd|d
���|rU|��	���dS�dS�)zt
        Check if any minions have connected or dropped.
        Send a message to the client if they have.
        r���r���ZpresentFTN�,�grains.items�list�client�localZlocal_async)r-���r.���Z	expr_type�moder8���Zasynchronous�token)
r����keys�setr3����joinr���ZnetapiZNetapiClient�runr���)r���r���r;����optsr���r���Zminions_detectedZcurr_minions�changedZdropped_minionsr���Znew_minionsr.���r8���r���r���r����process_presence_events����s6���

���z SaltInfo.process_presence_eventsc�����������������C���s����|d���d�}t|�dk�rdS�|d�dkrD|d�dkr,|��|��|d	�d
�dkr+i�|�_n|d�dkrD|��|��|d	�d
�dkrD|��|��|d�d
krO|��|��|d�dkr^|��|||��dS�dS�)z1
        Process events and publish data
        r���r�������N����r+��������newr���r-���r6���r���r���Zpresence)r����lenr0���r���r,���r"���r4���rB���)r���Z	salt_datar;���r@����partsr���r���r����process����s$���
�

�zSaltInfo.processN)
�__name__�
__module__�__qualname__�__doc__r	���r���r���r"���r,���r0���r4���rB���rI���r���r���r���r���r���	���s����
+r���)ZloggingZsalt.netapir���Zsalt.utils.jsonZ	getLoggerrJ����loggerr���r���r���r���r����<module>���s
����