File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/netapi/rest_cherrypy/__pycache__/event_processor.cpython-310.pyc
Back
o ;j� � @ s4 d dl Z d dlZd dlZe �e�ZG dd� d�ZdS )� Nc @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dS )�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 �minionZ minion_infoZ curr_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�dataZ publish_datar r r �publish* s zSaltInfo.publishc C sd |d }|d }|� d�\}}}}}| j�|d�s i | 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 z SaltInfo.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 Z job_completer r r �process_ret_job_eventC s �z SaltInfo.process_ret_job_eventc C sz d}|d }|d }i }|d D ]}ddi||< q|d |d ||d |d |d d d �}|| 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 � z SaltInfo.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� q t|�t|� } d�| �} | rMd}tj�|�} | �d| d d d d |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�localZ local_async)r- r. Z expr_type�moder8 Z asynchronous�token) r �keys�setr3 �joinr ZnetapiZ NetapiClient�runr )r r r; �optsr r Zminions_detectedZ curr_minions�changedZdropped_minionsr Z new_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 d kr+i | _n|d d krD| �|� |d d d krD| �|� |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 )�loggingZ salt.netapir Zsalt.utils.json� getLoggerrJ �loggerr r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings