U
    a+d                     @   s   d Z ddlZddlmZ zddlmZ W n ek
rD   edY nX ddlmZ	 dd	l
mZ d
ddgiZdddddgZG dd deZG dd de	Zdd ZeZeZdS )z
Sends updates to a Slack app.

Usage:
>>> from tqdm.contrib.slack import tqdm, trange
>>> for i in trange(10, token='{token}', channel='{channel}'):
...     ...

![screenshot](https://img.tqdm.ml/screenshot-slack.png)
    N)getenv)	WebClientzPlease `pip install slack-sdk`   )tqdm   )
MonoWorkerzgithub.com/Z	0x2b3bfa0Z	casperdclSlackIO
tqdm_slacktsranger   trangec                       s(   e Zd ZdZ fddZdd Z  ZS )r   z,Non-blocking file-like IO using a Slack app.c              
      sx   t t|   t|d| _| jj| _z| jj|| jd| _	W n6 t
k
rr } ztt| d| _	W 5 d}~X Y nX dS )z-Creates a new message in the given `channel`.)token)channeltextN)superr   __init__r   client	__class____name__r   Zchat_postMessagemessage	Exception	tqdm_autowritestr)selfr   r   er    6/tmp/pip-unpacked-wheel-tf4cttdx/tqdm/contrib/slack.pyr      s    
zSlackIO.__init__c              
   C   s   |sd}| dd }|| jkr&dS | j}|dkr8dS || _z*| j| jj|d |d d| d d}W n0 tk
r } zt	t
| W 5 d}~X Y nX |S dS )	z,Replaces internal `message`'s text with `s`.z... Nr   ts`)r   r    r   )replacestripr   r   Zsubmitr   Z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   c                       s8   e Zd ZdZ fddZ fddZ fddZ  ZS )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tj t|dtd|dtd| _	t
d| dd|d< tt| j|| 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.
        disableZ
HTTPClientr   ZTQDM_SLACK_TOKENr   ZTQDM_SLACK_CHANNELg      ?ZminintervalN)getcopylogging	getLoggersetLevelWARNINGr   popr   siomaxr   r	   r   r   argskwargsr   r   r   r   G   s    
ztqdm_slack.__init__c                    s   t t| jf | | j}|dd rB|d dddd|d< nd|d< |d dkrnd	d
ddg|d< d|d< | j| jf | d S )NZ
bar_formatz<bar/>z
`{bar:10}`z{bar}z`{bar:10u}`z{l_bar}`{bar:10}`{r_bar}asciiFz:black_square:z:small_blue_diamond:z:large_blue_diamond:z:large_blue_square:iP  Zncols)	r   r	   displayZformat_dictr+   r"   r2   r   Zformat_meter)r   r6   fmtr   r   r   r8   ]   s"      
ztqdm_slack.displayc                    s(   t t| j|| | js$| jd d S )Nr   )r   r	   clearr*   r2   r   r4   r   r   r   r:   k   s    ztqdm_slack.clear)r   r&   r'   r(   r   r8   r:   r)   r   r   r   r   r	   ;   s   c                  O   s   t t|  f|S )z?Shortcut for `tqdm.contrib.slack.tqdm(range(*args), **kwargs)`.)r	   range)r5   r6   r   r   r   r
   q   s    )r(   r-   osr   Z	slack_sdkr   ImportErrorautor   r   Zutils_workerr   
__author____all__r   r	   r
   r   r   r   r   r   <module>   s   
!6