File: //usr/local/lib/python3.10/dist-packages/tqdm/contrib/__pycache__/slack.cpython-310.pyc
o
���g� � @ s� d Z ddlZddlmZ zddlmZ W n ey ed��w ddlmZ dd l
m Z d
d d giZ g d
�Z
G dd� de �ZG dd� de �Zdd� ZeZeZdS )z�
Sends updates to a Slack app.
Usage:
>>> from tqdm.contrib.slack import tqdm, trange
>>> for i in trange(10, token='{token}', channel='{channel}'):
... ...
� N)�getenv)� WebClientz Please `pip install slack-sdk`� )�tqdm� )�
MonoWorkerz github.com/� 0x2b3bfa0� casperdcl)�SlackIO�
tqdm_slack�tsranger �trangec s( e Zd ZdZ� fdd�Zdd� Z� ZS )r
z,Non-blocking file-like IO using a Slack app.c
sv t � �� t|d�| _| jj| _z
| jj|| jd�| _W dS t y: } zt
� t |�� d| _W Y d}~dS d}~ww )z-Creates a new message in the given `channel`.)�token)�channel�textN)
�super�__init__r �client� __class__�__name__r �chat_postMessage�message� Exception� tqdm_auto�write�str)�selfr r �e�r � �=/usr/local/lib/python3.10/dist-packages/tqdm/contrib/slack.pyr s
��zSlackIO.__init__c
C s� |sd}|� dd��� }|| jkrdS | j}|du r dS || _z| j| jj|d |d d| d d�}W |S tyO } zt� t
|�� W Y d}~dS d}~ww ) z,Replaces internal `message`'s text with `s`.z...�
� Nr �ts�`)r r# r ) �replace�stripr r �submitr � chat_updater r r r )r �sr �futurer r r r r ' s$
�� ��z
SlackIO.write)r �
__module__� __qualname__�__doc__r r �
__classcell__r r r r r
s r
c s8 e Zd ZdZ� fdd�Z� fdd�Z� fdd�Z� ZS )r a�
Standard `tqdm.auto.tqdm` but also sends updates to a Slack app.
May take a few seconds to create (`__init__`).
- create a Slack app with the `chat:write` scope & invite it to a
channel: <https://api.slack.com/authentication/basics>
- copy the bot `{token}` & `{channel}` and paste below
>>> from tqdm.contrib.slack import tqdm, trange
>>> for i in tqdm(iterable, token='{token}', channel='{channel}'):
... ...
c st |� d�s/|�� }t�d��tj� t|�dtd��|�dtd���| _ t
d|� dd��|d< t � j |i |�� d S )
a�
Parameters
----------
token : str, required. Slack token
[default: ${TQDM_SLACK_TOKEN}].
channel : int, required. Slack channel
[default: ${TQDM_SLACK_CHANNEL}].
mininterval : float, optional.
Minimum of [default: 1.5] to avoid rate limit.
See `tqdm.auto.tqdm.__init__` for other parameters.
�disable�
HTTPClientr �TQDM_SLACK_TOKENr �TQDM_SLACK_CHANNELg �?� minintervalN)
�get�copy�logging� getLogger�setLevel�WARNINGr
�popr �sio�maxr r �r �args�kwargsr r r r G s
�ztqdm_slack.__init__c s� t � jd i |�� | j}|�dd �r!|d �dd��dd�|d< nd|d< |d du r5g d �|d< d
|d < | j�| jd i |��� d S )
N�
bar_formatz<bar/>z
`{bar:10}`z{bar}z `{bar:10u}`z{l_bar}`{bar:10}`{r_bar}�asciiF)z:black_square:z:small_blue_diamond:z:large_blue_diamond:z:large_blue_square:iP �ncolsr )r �display� format_dictr4 r% r; r � format_meter)r r? �fmtr r r rC ] s �� ztqdm_slack.displayc s, t � j|i |�� | js| j�d� d S d S )Nr" )r �clearr/ r; r r= r r r rG k s �ztqdm_slack.clear)r r+ r, r- r rC rG r. r r r r r ; s
r c O s t t| � fi |��S )z?Shortcut for `tqdm.contrib.slack.tqdm(range(*args), **kwargs)`.)r �range)r> r? r r r r q s r )r- r6 �osr � slack_sdkr � ImportError�autor r � utils_workerr �
__author__�__all__r
r r r
r r r r �<module> s"
� !6