
    wg{                         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e      Z G d de      Zd ZeZ
eZy)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)
    )getenv)warn)Session)default_user_agent   )tqdm)TqdmWarning)__version__   )
MonoWorkerzgithub.com/	casperdcl
guigoruiz1)	DiscordIOtqdm_discordtdranger   trangec                   \     e Zd ZdZdZde d e        Z fdZe	d        Z
d Zd Z x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                     t         |           || _        || _        t	               | _        | j                  j                  | _        | j                   y)z0Creates a new message in the given `channel_id`.N)
super__init__token
channel_idr   session	__class____name__text
message_id)selfr   r   r   s      Y/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/tqdm/contrib/discord.pyr   zDiscordIO.__init__   s=    
$yNN++	    c                    t        | d      r| j                  S 	 | j                  j                  | j                   d| j
                   dd| j                   | j                  ddd| j                   di      j                         }|j                  d	      d
k(  rt        dt        d       y |d   | _        | j                  S # t        $ r(}t        j                  t!        |             Y d }~y d }~ww xY w)N_message_id
/channels/z	/messagesBot Authorizationz
User-Agentcontent`headersjson
error_codei  z2Creation rate limit: try increasing `mininterval`.r   )
stacklevelid)hasattrr"   r   postAPIr   r   UAr   r+   getr   r	   	Exception	tqdm_autowritestr)r   reses      r   r   zDiscordIO.message_id(   s    4'###	(,,##88*Jt&7yA,0*=TWWU1TYYKq!12 $ 4 59DF  ww|$+I Q0 $'t9 '''  	$OOCF##	$s   A0C 	C8C33C8c           	         |sd}|j                  dd      j                         }|| j                  k(  ry| j                  }|y|| _        	 | j	                  | j
                  j                  | j                   d| j                   d| d| j                   | j                  dd	d
| j                   d
i      }|S # t        $ r(}t        j                  t        |             Y d}~yd}~ww xY w)z/Replaces internal `message_id`'s text with `s`.z... Nr#   
/messages/r$   r%   r'   r(   r)   )replacestripr   r   submitr   patchr1   r   r   r2   r4   r5   r6   r7   )r   sr   futurer9   s        r   r6   zDiscordIO.write;   s    AIIdB%%'		>__
			[[""88*Jt&7z*N,0*=TWWU1TYYKq!12	 ! 4F M  	$OOCF##	$s   A/B= =	C.C))C.c                 @   	 | j                  | j                  j                  | j                   d| j                   d| j
                   d| j                   | j                  d      }|S # t        $ r(}t        j                  t        |             Y d}~yd}~ww xY w)zDeletes internal `message_id`.r#   r=   r$   r%   )r*   N)r@   r   deleter1   r   r   r   r2   r4   r5   r6   r7   )r   rC   r9   s      r   rE   zDiscordIO.deleteQ   s    	[[##88*Jt&7z$//ARS,0*=TWWU ! WF M  	$OOCF##	$s   A(A, ,	B5BB)r   
__module____qualname____doc__r1   r
   r   r2   r   propertyr   r6   rE   __classcell__r   s   @r   r   r      sE    8
'C)+b9K9M8N	OB ( ($,
r    r   c                   @     e Zd ZdZ fdZ fdZ fdZ fdZ x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}'):
    ...     ...
    c           	          |j                  d      sS|j                         }t        |j                  dt	        d            |j                  dt	        d                  | _        t        |   |i | y)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.
        disabler   TQDM_DISCORD_TOKENr   TQDM_DISCORD_CHANNEL_IDN)r3   copyr   popr   dior   r   r   argskwargsr   s      r   r   ztqdm_discord.__init__l   se     zz)$[[]F 

7F+?$@A

<0I)JKMDH 	$)&)r    c                    t        |   di | | j                  }|j                  dd       r)|d   j	                  dd      j	                  dd      |d<   nd|d<   | j
                  j                   | j                  di |       y )N
bar_formatz<bar/>z	{bar:10u}z{bar}z{l_bar}{bar:10u}{r_bar} )r   displayformat_dictr3   r>   rS   r6   format_meter)r   rV   fmtr   s      r   rZ   ztqdm_discord.display~   s    !&!77<& #L 1 9 9+!''.ww'D  !:C(t((/3/0r    c                 t    t        |   |i | | j                  s| j                  j	                  d       y y )Nr<   )r   clearrN   rS   r6   rT   s      r   r_   ztqdm_discord.clear   s0    t&v&||HHNN2 r    c                     | j                   ry t        | 	          | j                  s7| j                  | j                  dk(  s| j
                  j                          y y y )Nr   )rN   r   closeleaveposrS   rE   )r   r   s    r   ra   ztqdm_discord.close   sF    <<

tzz1dhh!mHHOO 7D
r    )	r   rF   rG   rH   r   rZ   r_   ra   rJ   rK   s   @r   r   r   ^   s!    *$1
 r    r   c                  &    t        t        |  fi |S )zAShortcut for `tqdm.contrib.discord.tqdm(range(*args), **kwargs)`.)r   range)rU   rV   s     r   r   r      s    t///r    N)rH   osr   warningsr   requestsr   requests.utilsr   autor   r5   stdr	   versionr
   utils_workerr   
__author____all__r   r   r   r   rY   r    r   <module>rp      se   	    - $  ! $k<89

DA
 AH49 4n0 	r    