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	lmZ d
dlmZ d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 Discord bot.

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

![screenshot](https://tqdm.github.io/img/screenshot-discord.png)
é    )Úwarn)ÚSession)Údefault_user_agenté   )Útqdm)ÚTqdmWarning)Úenvwrap)Ú__version__é   )Ú
MonoWorkerzgithub.com/Ú	casperdclÚ
guigoruiz1)Ú	DiscordIOÚtqdm_discordÚtdranger   Útrangec                       sR   e Zd ZdZdZde› deƒ › �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 Discord Bot.zhttps://discord.com/api/v10ztqdm (https://tqdm.github.io, z) c                    s2   t ƒ  ¡  || _|| _tƒ | _| jj| _| j	 dS )z0Creates a new message in the given `channel_id`.N)
ÚsuperÚ__init__ÚtokenÚ
channel_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/discord.pyr      s   


zDiscordIO.__init__c              
   C   sÒ   t | dƒr| jS z*| jj| j› d| j› d�d| j› �| jdœdd| j› d�id�}| 	¡ }| 
¡  W n. ty` } z"|jd	krGtd
tdd� nt t|ƒ¡ W Y d }~d S W Y d }~d S d }~ww |d | _| jS )NÚ_message_idú
/channels/z	/messagesúBot ©ÚAuthorizationz
User-AgentÚcontentú`©ÚheadersÚjsoni­  z2Creation rate limit: try increasing `mininterval`.r   )Ú
stacklevelÚid)Úhasattrr   r   ÚpostÚAPIr   r   ÚUAr   r(   Úraise_for_statusÚ	ExceptionÚstatus_coder   r   Ú	tqdm_autoÚwriteÚstr)r   ÚreqÚresÚer   r   r   r   (   s*   
ý
ÿý€þ
zDiscordIO.message_idc              
   C   sÂ   |sd}|  dd¡ ¡ }|| jkrdS | j}|du rdS || _z'| j| jj| j› d| j› d|› �d| j	› �| j
dœd	d
| j› d
�id�}W |S  ty` } zt t|ƒ¡ W Y d}~dS d}~ww )z/Replaces internal `message_id`'s text with `s`.z...úÚ Nr    ú
/messages/r!   r"   r$   r%   r&   )ÚreplaceÚstripr   r   Úsubmitr   Úpatchr-   r   r   r.   r0   r2   r3   r4   )r   Úsr   Úfuturer7   r   r   r   r3   =   s*   
üý€ÿzDiscordIO.writec              
   C   sv   z | j | jj| j› d| j› d| 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`.r    r:   r!   r"   )r'   N)r=   r   Údeleter-   r   r   r   r.   r0   r2   r3   r4   )r   r@   r7   r   r   r   rA   S   s   ýý€ÿzDiscordIO.delete)r   Ú
__module__Ú__qualname__Ú__doc__r-   r	   r   r.   r   Úpropertyr   r3   rA   Ú__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 Discord Bot.
    May take a few seconds to create (`__init__`).

    - create a discord bot (not public, no requirement of OAuth2 code
      grant, only send message permissions) & invite it to a channel:
      <https://discordpy.readthedocs.io/en/latest/discord.html>
    - copy the bot `{token}` & `{channel_id}` and paste below

    >>> from tqdm.contrib.discord import tqdm, trange
    >>> for i in tqdm(iterable, token='{token}', channel_id='{channel_id}'):
    ...     ...
    r   ÚdiscordT)Ú	is_methodN)r   r   c                   s4   |  d¡s| ¡ }t||ƒ| _tƒ j|i |¤Ž dS )a7  
        Parameters
        ----------
        token  : str, required. Discord bot token
            [default: ${TQDM_DISCORD_TOKEN}].
        channel_id  : int, required. Discord channel ID
            [default: ${TQDM_DISCORD_CHANNEL_ID}].

        See `tqdm.auto.tqdm.__init__` for other parameters.
        ÚdisableN)ÚgetÚcopyr   Údior   r   )r   r   r   ÚargsÚkwargsr   r   r   r   n   s   
ztqdm_discord.__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_dictrJ   r;   rL   r3   Úformat_meter)r   rN   Úfmtr   r   r   rP      s   ÿÿztqdm_discord.displayc                    s,   t ƒ j|i |¤Ž | js| j d¡ d S d S )Nr9   )r   ÚclearrI   rL   r3   )r   rM   rN   r   r   r   rT   ‡   s   ÿztqdm_discord.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   )rI   r   ÚcloseÚleaveÚposrL   rA   )r   r   r   r   rU   Œ   s   
ÿztqdm_discord.close)
r   rB   rC   rD   r   r   rP   rT   rU   rF   r   r   r   r   r   `   s    r   c                  O   s   t t| Ž fi |¤ŽS )zAShortcut for `tqdm.contrib.discord.tqdm(range(*args), **kwargs)`.)r   Úrange)rM   rN   r   r   r   r   ”   s   r   N)rD   Úwarningsr   Úrequestsr   Úrequests.utilsr   Úautor   r2   Ústdr   Úutilsr   Úversionr	   Úutils_workerr   Ú
__author__Ú__all__r   r   r   r   r   r   r   r   Ú<module>   s     
F4