0RjdZddlmZddlmZddlmZddlmZ ddl m Z ddl m Z dd lmZd d lmZd d dgiZgdZGddeZGdde ZdZeZeZy)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_discordtdrangertrangec\eZdZdZdZdedeZfdZe dZ dZ dZ xZ S) rz.Non-blocking file-like IO using a Discord Bot.zhttps://discord.com/api/v10ztqdm (https://tqdm.github.io, z) ct|||_||_t |_|j j|_|jy)z0Creates a new message in the given `channel_id`.N) super__init__token channel_idrsession __class____name__text message_id)selfrrrs \/var/www/html/meridian/meridian-ai/venv/lib/python3.12/site-packages/tqdm/contrib/discord.pyrzDiscordIO.__init__s=  $y NN++  ct|dr |jS |jj|jd|j dd|j |jddd|jdi}|j}|j|d |_|jS#t$rO}jd k(rtd td n#tj t#|Yd}~yYd}~yd}~wwxYw)N _message_id /channels/z /messagesBot  Authorizationz User-Agentcontent`headersjsonidiz2Creation rate limit: try increasing `mininterval`.r) stacklevel)hasattrr"rpostAPIrrUArr+raise_for_status Exception status_coderr tqdm_autowritestr)rreqreses rrzDiscordIO.message_id(s 4 '## # $,,##88*Jt&7yA,0 *=TWWU1TYYKq!12$4C((*C  " #4yD ## # (#%I Q0A''0 (sBB22 D ;ADD c |sd}|jddj}||jk(ry|j}|y||_ |j |j j |jd|jd|d|j|jdd d |jd i }|S#t$r(}tjt|Yd}~yd}~wwxYw) z/Replaces internal `message_id`'s text with `s`.z... Nr# /messages/r$r%r'r(r))replacestriprrsubmitrpatchr0rrr1r3r5r6r7)rsrfuturer:s rr6zDiscordIO.write=sA IIdB  % % '  > __     [[ ""88*Jt&7z*N,0 *=TWWU1TYYKq!12 !4FM $ OOCF # # $s A/B== C.C))C.c@ |j|jj|jd|jd|j d|j |jd}|S#t$r(}tjt|Yd}~yd}~wwxYw)zDeletes internal `message_id`.r#r>r$r%)r*N) rArdeleter0rrrr1r3r5r6r7)rrDr:s rrFzDiscordIO.deleteSs [[ ##88*Jt&7z$//ARS,0 *=TWWU!WFM $ OOCF # # $sA(A,, B5BB)r __module__ __qualname____doc__r0r rr1rpropertyrr6rF __classcell__rs@rrrsE8 'C )+b9K9M8N OB$$(, r rcdeZdZdZeddddddfd Zfd Zfd Zfd ZxZ S) ra 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: - 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}'): ... ... rdiscordT) is_methodN)rrc|jds!|j}t|||_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. disableN)getcopyrdiorr)rrrargskwargsrs rrztqdm_discord.__init__ns<zz)$[[]F  3DH $)&)r c t|di||j}|jddr(|dj ddj dd|d<|j j |jdi|y)N bar_formatzz {bar:10u}z{bar})rdisplay format_dictrRr?rTr6 format_meter)rrVfmtrs rrZztqdm_discord.displaysz !&! 77< & #L 1 9 9+!''.ww 'D   (t((/3/0r ctt||i||js|jj dyy)Nr=)rclearrQrTr6)rrUrVrs rr_ztqdm_discord.clears0  t&v&|| HHNN2 r c|jryt| |js7|j|jdk(s|j j yyy)Nr)rQrcloseleaveposrTrF)rrs rraztqdm_discord.closesF <<    tzz1dhh!m HHOO 7D r ) rrGrHrIr rrZr_rarKrLs@rrr`s>  VY$/$(T*0* 1 r rc&tt|fi|S)zAShortcut for `tqdm.contrib.discord.tqdm(range(*args), **kwargs)`.)rrange)rUrVs rrrs t / //r N)rIwarningsrrequestsrrequests.utilsrautorr5stdrutilsr versionr utils_workerr __author____all__rrrrrYr rrpse -$!$k<8 9 DC CL191h0  r