U
    ¸mœdå  ã                   @   s˜   d Z ddlmZ ddlmZ ddlmZ ddlmZ	 ddl
mZ dd	lmZ 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 Telegram bot.

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

![screenshot](https://img.tqdm.ml/screenshot-telegram.gif)
é    )Úgetenv)Úwarn)ÚSessioné   )Útqdm)ÚTqdmWarningé   )Ú
MonoWorkerzgithub.com/Z	casperdclÚ
TelegramIOÚtqdm_telegramÚttgranger   Útrangec                       s@   e Zd ZdZdZ‡ fdd„Zedd„ ƒZdd„ Zd	d
„ Z	‡  Z
S )r
   z/Non-blocking file-like IO using a Telegram Bot.zhttps://api.telegram.org/botc                    s6   t t| ƒ ¡  || _|| _tƒ | _| jj| _	| j
 dS )z-Creates a new message in the given `chat_id`.N)Úsuperr
   Ú__init__ÚtokenÚchat_idr   ÚsessionÚ	__class__Ú__name__ÚtextÚ
message_id)Úselfr   r   ©r   © úN/home/sam/Atlas/atlas_env/lib/python3.8/site-packages/tqdm/contrib/telegram.pyr      s    
zTelegramIO.__init__c              
   C   s°   t | dƒr| jS z8| jj| jd| j  d| j d | jddœd� ¡ }W n0 t	k
rx } zt
 t|ƒ¡ W 5 d }~X Y n4X | d¡dkr˜td	td
d� n|d d | _| jS d S )NÚ_message_idz%s/sendMessageú`Ú
MarkdownV2)r   r   Ú
parse_mode©ÚdataZ
error_codei­  z2Creation rate limit: try increasing `mininterval`.r   )Ú
stacklevelÚresultr   )Úhasattrr   r   ÚpostÚAPIr   r   r   ÚjsonÚ	ExceptionÚ	tqdm_autoÚwriteÚstrÚgetr   r   )r   ÚresÚer   r   r   r   %   s$    
ÿþ  ÿzTelegramIO.message_idc              
   C   s°   |sd}|  dd¡ ¡ }|| jkr&dS | j}|dkr8dS || _z8| j| jj| jd| j  d| d | j	|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_id`'s text with `s`.z...úÚ Nz%s/editMessageTextr   r   )r   r   r   r   r   )ÚreplaceÚstripr   r   Úsubmitr   r$   r%   r   r   r'   r(   r)   r*   )r   Úsr   Úfuturer-   r   r   r   r)   8   s*    
  ÿþ
 zTelegramIO.writec              
   C   sh   z.| j | jj| jd| j  | j| jdœd�}W n0 tk
r^ } zt 	t
|ƒ¡ W 5 d}~X Y nX |S dS )zDeletes internal `message_id`.z%s/deleteMessage)r   r   r   N)r2   r   r$   r%   r   r   r   r'   r(   r)   r*   )r   r4   r-   r   r   r   ÚdeleteM   s     þ
 zTelegramIO.delete)r   Ú
__module__Ú__qualname__Ú__doc__r%   r   Úpropertyr   r)   r5   Ú__classcell__r   r   r   r   r
      s   	
c                       sD   e Zd ZdZ‡ fd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 Telegram Bot.
    May take a few seconds to create (`__init__`).

    - create a bot <https://core.telegram.org/bots#6-botfather>
    - copy its `{token}`
    - add the bot to a chat and send it a message such as `/start`
    - go to <https://api.telegram.org/bot`{token}`/getUpdates> to find out
      the `{chat_id}`
    - paste the `{token}` & `{chat_id}` below

    >>> from tqdm.contrib.telegram import tqdm, trange
    >>> for i in tqdm(iterable, token='{token}', chat_id='{chat_id}'):
    ...     ...
    c                    sL   |  d¡s6| ¡ }t| dtdƒ¡| dtdƒ¡ƒ| _tt| ƒj||Ž dS )a.  
        Parameters
        ----------
        token  : str, required. Telegram token
            [default: ${TQDM_TELEGRAM_TOKEN}].
        chat_id  : str, required. Telegram chat ID
            [default: ${TQDM_TELEGRAM_CHAT_ID}].

        See `tqdm.auto.tqdm.__init__` for other parameters.
        Údisabler   ZTQDM_TELEGRAM_TOKENr   ZTQDM_TELEGRAM_CHAT_IDN)	r+   Úcopyr
   Úpopr   Útgior   r   r   ©r   ÚargsÚkwargsr   r   r   r   i   s    
þztqdm_telegram.__init__c                    sb   t t| ƒjf |Ž | j}| dd ¡rB|d  dd¡ dd¡|d< nd|d< | j | jf |Ž¡ d S )NZ
bar_formatz<bar/>z	{bar:10u}z{bar}z{l_bar}{bar:10u}{r_bar})	r   r   ÚdisplayZformat_dictr+   r0   r>   r)   Zformat_meter)r   rA   Úfmtr   r   r   rB   {   s     ÿ ÿ
ztqdm_telegram.displayc                    s(   t t| ƒj||Ž | js$| j d¡ d S )Nr/   )r   r   Úclearr;   r>   r)   r?   r   r   r   rD   …   s    ztqdm_telegram.clearc                    s@   | j r
d S tt| ƒ ¡  | js<| jd kr2| jdks<| j ¡  d S )Nr   )r;   r   r   ÚcloseZleaveÚposr>   r5   )r   r   r   r   rE   Š   s
    ztqdm_telegram.close)	r   r6   r7   r8   r   rB   rD   rE   r:   r   r   r   r   r   Y   s
   
c                  O   s   t t| Ž f|ŽS )zBShortcut for `tqdm.contrib.telegram.tqdm(range(*args), **kwargs)`.)r   Úrange)r@   rA   r   r   r   r   ’   s    N)r8   Úosr   Úwarningsr   Úrequestsr   Úautor   r(   Zstdr   Zutils_workerr	   Ú
__author__Ú__all__r
   r   r   r   r   r   r   r   Ú<module>   s   

A9