o
    Œõ±jÙ  ã                   @   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g d¢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://tqdm.github.io/img/screenshot-telegram.gif)
é    )Úwarn)ÚSessioné   )Útqdm)ÚTqdmWarning)Úenvwrapé   )Ú
MonoWorkerzgithub.com/Ú	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                    s2   t ƒ  ¡  || _|| _tƒ | _| jj| _| j	 dS )z-Creates a new message in the given `chat_id`.N)
ÚsuperÚ__init__ÚtokenÚchat_idr   ÚsessionÚ	__class__Ú__name__ÚtextÚ
message_id)Úselfr   r   ©r   © úˆ/root/aizidognhua/tmp/workspace/projects/ec89d86c-575f-41c9-af57-ac45cbdbf775/venv/lib/python3.10/site-packages/tqdm/contrib/telegram.pyr      s   


zTelegramIO.__init__c              
   C   sÈ   t | dƒr| jS z#| jj| j› | j› d�d| j› d�| jddœd�}| ¡ }| 	¡  W n. t
yY } z"|jdkr@tdtd	d
� nt t|ƒ¡ W Y d }~d S W Y d }~d S d }~ww |d d | _| jS )NÚ_message_idz/sendMessageú`Ú
MarkdownV2)r   r   Ú
parse_mode©Údatai­  z2Creation rate limit: try increasing `mininterval`.r   )Ú
stacklevelÚresultr   )Úhasattrr   r   ÚpostÚAPIr   r   r   ÚjsonÚraise_for_statusÚ	ExceptionÚstatus_coder   r   Ú	tqdm_autoÚwriteÚstr)r   ÚreqÚresÚer   r   r   r   %   s,   
ÿþ
ÿý€þzTelegramIO.message_idc              
   C   s°   |sd}|  dd¡ ¡ }|| jkrdS | j}|du rdS || _z| j| jj| j› | j› d�d|› d�| j	|ddœd	�}W |S  t
yW } zt t|ƒ¡ W Y d}~dS d}~ww )
z/Replaces internal `message_id`'s text with `s`.z...úÚ Nz/editMessageTextr   r   )r   r   r   r   r    )ÚreplaceÚstripr   r   Úsubmitr   r%   r&   r   r   r)   r+   r,   r-   )r   Úsr   Úfuturer0   r   r   r   r,   :   s*   
ÿþý€ÿzTelegramIO.writec              
   C   sZ   z| j | jjd| j| jdœd�}W |S  ty, } zt t|ƒ¡ W Y d}~dS d}~ww )zDeletes internal `message_id`.z${self.API}{self.token}/deleteMessage)r   r   r    N)	r5   r   r%   r   r   r)   r+   r,   r-   )r   r7   r0   r   r   r   ÚdeleteO   s   þý€ÿzTelegramIO.delete)r   Ú
__module__Ú__qualname__Ú__doc__r&   r   Úpropertyr   r,   r8   Ú__classcell__r   r   r   r   r      s    	
r   c                       sZ   e Zd ZdZedddd�dddœ‡ 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}'):
    ...     ...
    r   ÚtelegramT)Ú	is_methodN)r   r   c                   s4   |  d¡s| ¡ }t||ƒ| _tƒ j|i |¤Ž 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.
        ÚdisableN)ÚgetÚcopyr   Útgior   r   )r   r   r   ÚargsÚkwargsr   r   r   r   k   s   
ztqdm_telegram.__init__c                    s\   t ƒ jdi |¤Ž | j}| dd ¡r |d  dd¡ dd¡|d< | j | jdi |¤Ž¡ d S )NÚ
bar_formatz<bar/>z	{bar:10u}z{bar}r   )r   ÚdisplayÚformat_dictrA   r3   rC   r,   Úformat_meter)r   rE   Úfmtr   r   r   rG   |   s   ÿÿztqdm_telegram.displayc                    s,   t ƒ j|i |¤Ž | js| j d¡ d S d S )Nr2   )r   Úclearr@   rC   r,   )r   rD   rE   r   r   r   rK   „   s   ÿztqdm_telegram.clearc                    sD   | j rd S tƒ  ¡  | js| jd u r| jdks | j ¡  d S d S d S )Nr   )r@   r   ÚcloseÚleaveÚposrC   r8   )r   r   r   r   rL   ‰   s   
ÿztqdm_telegram.close)
r   r9   r:   r;   r   r   rG   rK   rL   r=   r   r   r   r   r   [   s    r   c                  O   s   t t| Ž fi |¤ŽS )zBShortcut for `tqdm.contrib.telegram.tqdm(range(*args), **kwargs)`.)r   Úrange)rD   rE   r   r   r   r   ‘   s   r   N)r;   Úwarningsr   Úrequestsr   Úautor   r+   Ústdr   Úutilsr   Úutils_workerr	   Ú
__author__Ú__all__r   r   r   r   r   r   r   r   Ú<module>   s    

C6