
    +hz                         d Z ddlZddlmZ 	 ddlmZmZ ddlm	Z
 dd	lmZ 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# e$ r	  ed      w xY w)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)
    N)getenv)ClientClientConfigzPlease `pip install disco-py`   )tqdm   )
MonoWorkerzgithub.com/	casperdcl)	DiscordIOtqdm_discordtdranger   trangec                   (     e Zd ZdZ fdZd Z xZS )r   z.Non-blocking file-like IO using a Discord Bot.c                 f   t         t        |           t               }||_        t        |      }| j                  j                  | _        	 |j                  j                  || j                        | _        y# t        $ r/}t        j                  t        |             d| _        Y d}~yd}~ww xY w)z0Creates a new message in the given `channel_id`.N)superr   __init__r   tokenr   	__class____name__textapichannels_messages_createmessage	Exception	tqdm_autowritestr)selfr   
channel_idconfigclienter   s         G/var/www/html/venv/lib/python3.12/site-packages/tqdm/contrib/discord.pyr   zDiscordIO.__init__   s    i')NN++		 !::>>z499UDL 	 OOCF#DLL	 s   +A8 8	B0%B++B0c                 H   |sd}|j                  dd      j                         }|| j                  k(  ry| j                  }|y|| _        	 | j	                  |j
                  d|z   dz         }|S # t        $ r(}t        j                  t        |             Y d}~yd}~ww xY w)z,Replaces internal `message`'s text with `s`.z... N`)
replacestripr   r   submiteditr   r   r   r   )r   sr   futurer"   s        r#   r   zDiscordIO.write)   s    AIIdB%%'		>,,?		[[sQw}=F M  	$OOCF##	$s   "A0 0	B!9BB!)r   
__module____qualname____doc__r   r   __classcell__r   s   @r#   r   r      s    8     r   c                   6     e Zd Z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      s|j                         }t        j                  d      j	                  t        j
                         t        |j                  dt        d            |j                  dt        d                  | _	        t        d|j                  dd            |d<   t        t        | 6  |i | y	)
a  
        Parameters
        ----------
        token  : str, required. Discord token
            [default: ${TQDM_DISCORD_TOKEN}].
        channel_id  : int, required. Discord channel ID
            [default: ${TQDM_DISCORD_CHANNEL_ID}].
        mininterval  : float, optional.
          Minimum of [default: 1.5] to avoid rate limit.

        See `tqdm.auto.tqdm.__init__` for other parameters.
        disable
HTTPClientr   TQDM_DISCORD_TOKENr   TQDM_DISCORD_CHANNEL_IDg      ?minintervalN)getcopylogging	getLoggersetLevelWARNINGr   popr   diomaxr   r   r   r   argskwargsr   s      r#   r   ztqdm_discord.__init__J   s     zz)$[[]Fl+44W__E 

7F+?$@A

<0I)JKMDH %(VZZs-K$LF=!lD*D;F;r3   c                    t        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   r   displayformat_dictr;   r(   rB   r   format_meter)r   rF   fmtr   s      r#   rJ   ztqdm_discord.display`   s    lD)3F377<& #L 1 9 9+!''.ww'D  !:C(t((/3/0r3   c                 |    t        t        | 
  |i | | j                  s| j                  j                  d       y y )Nr&   )r   r   clearr6   rB   r   rD   s      r#   rO   ztqdm_discord.clearj   s3    lD'88||HHNN2 r3   )r   r.   r/   r0   r   rJ   rO   r1   r2   s   @r#   r   r   <   s    <,1 r3   r   c                  &    t        t        |  fi |S )zAShortcut for `tqdm.contrib.discord.tqdm(range(*args), **kwargs)`.)r   range)rE   rF   s     r#   r   r   p   s    t///r3   )r0   r=   osr   disco.clientr   r   ImportErrorautor   r   utils_workerr	   
__author____all__r   r   r   r   rI   r3   r#   <module>rY      s|   	  71 % $k]+

D
 D19 1h0 	O  7
5
667s   A	 	A