File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/beacons/__pycache__/telegram_bot_msg.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlZddlZddlZzddlZe�d��ej � dZ W n e y. dZ Y nw e�e �Z dZdd� Zd d � Zd d � Zd d� Zdd� ZdS )zM Beacon to emit Telegram messages Requires the python-telegram-bot library � N�telegramTFZtelegram_bot_msgc � sZ �t �| �4 I dH �}|jdi |��I dH W d �I dH S 1 I dH s&w Y dS )z> Asynchronous helper to get updates from Telegram Bot N� )r �Bot� get_updates��token�kwargsZbotr r �Q/opt/saltstack/salt/lib/python3.10/site-packages/salt/beacons/telegram_bot_msg.py�_async_get_updates s �0�r c K sB t rt�tjj�rt�t| fi |���S t�| �}|jdi |��S )zL Synchronous wrapper for getting updates, handles both v13 and v20+ Nr ) � HAS_TELEGRAM�inspectZiscoroutinefunctionr r r �asyncio�runr r r r r � _get_updates$ s r c C s" t rtS d} t�dt| � d| fS )Nz telegram library is missing.z Unable to load %s beacon: %sF)r �__virtualname__�log�error)�err_msgr r r � __virtual__/ s r c sN t � t�sdS tjj�� �� t� fdd�dD ��sdS t � �d�t�s%dS dS ) z+ Validate the beacon configuration )Fz9Configuration for telegram_bot_msg beacon must be a list.c 3 s � | ]}� � |�V qd S )N)�get)�.0Zrequired_config��configr r � <genexpr>A s � �zvalidate.<locals>.<genexpr>)r � accept_from)Fz<Not all required configuration for telegram_bot_msg are set.r )FzLConfiguration for telegram_bot_msg, accept_from must be a list of usernames.)TzValid beacon configuration.)� isinstance�list�salt�utils�beacons� list_to_dict�allr r r r r �validate8 s �r" c C s� t jj�| �} t�d� g }i }g |d< t| d ddd�}t�dt|�� |s.t�d� |S d}|D ] }|j}|j |kr?|j }|j j | d v rP|d � |� � � q2t| d |d d � t�d t|d �� |d rn|� |� |S ) aU Emit a dict with a key "msgs" whose value is a list of messages sent to the configured bot by one of the allowed usernames. .. code-block:: yaml beacons: telegram_bot_msg: - token: "<bot access token>" - accept_from: - "<valid username>" - interval: 10 z telegram_bot_msg beacon startingZmsgsr �d r )�limit�timeoutzNum updates: %dz'Telegram Bot beacon has no new messagesr � )�offsetzEmitting %d messages.)r r r r r �debugr �len�messageZ update_idZchat�username�appendZto_dict)r �ret�outputZupdatesZlatest_update_id�updater* r r r �beaconS s. � r0 )�__doc__r r �loggingZsalt.utils.beaconsr r � getLogger�setLevel�CRITICALr � ImportError�__name__r r r r r r" r0 r r r r �<module> s& �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings