>/iN0dZddlZddlZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZdd lmZdd lmZmZmZmZ dd l m!Z!m"Z"d Z#e rddl%m&Z&eddZ'ee(Z)Gdde dZ*y#e$$rd Z#Y2wxYw)z]This module contains the class Updater, which tries to make creating Telegram bots intuitive.N)Path) TracebackType) TYPE_CHECKINGAnyAsyncContextManagerCallable CoroutineListOptionalTypeTypeVarUnion) DEFAULT_NONE) get_logger)build_repr_with_selected_attrs)ODVInput) InvalidToken RetryAfter TelegramErrorTimedOut)WebhookAppClass WebhookServerTF)Bot _UpdaterTypeUpdater)boundceZdZdZdZ d:dZdedefdZdee e d ee d ee dd fd Z de fd ZedefdZd;dZd;dZdddeeeed d d f dedededeedeedeedeedeee deedeeegd fddfdZdededeedeedeedeededeedeee dej:deeegd fdd fd Z dd4ed&ee deee deed$ee'd5ed'ee d(ed)ee dd fd6Z(d;d7Z)d;d8Z*d;d9Z+y )?ra]This class fetches updates for the bot either via long polling or by starting a webhook server. Received updates are enqueued into the :attr:`update_queue` and may be fetched from there to handle them appropriately. Instances of this class can be used as asyncio context managers, where .. code:: python async with updater: # code is roughly equivalent to .. code:: python try: await updater.initialize() # code finally: await updater.shutdown() .. seealso:: :meth:`__aenter__` and :meth:`__aexit__`. .. seealso:: :wiki:`Architecture Overview `, :wiki:`Builder Pattern ` .. versionchanged:: 20.0 * Removed argument and attribute ``user_sig_handler`` * The only arguments and attributes are now :attr:`bot` and :attr:`update_queue` as now the sole purpose of this class is to fetch updates. The entry point to a PTB application is now :class:`telegram.ext.Application`. Args: bot (:class:`telegram.Bot`): The bot used with this Updater. update_queue (:class:`asyncio.Queue`): Queue for the updates. Attributes: bot (:class:`telegram.Bot`): The bot used with this Updater. update_queue (:class:`asyncio.Queue`): Queue for the updates. )bot update_queue_last_update_id_running _initialized_httpd__lock__polling_taskasyncio.Queue[object]c||_||_d|_d|_d|_d|_t j|_d|_ d|_ y)NrF) rrr r!r"r#asyncioLock_Updater__lock_Updater__polling_task_Updater__polling_cleanup_cb)selfrrs K/srv/sistema/bot/venv/lib/python3.12/site-packages/telegram/ext/_updater.py__init__zUpdater.__init__rsN 3?  !/3 lln 6:W[!r-returncK |jd{|S7#t$r }|jd{7|d}~wwxYww)a0 |async_context_manager| :meth:`initializes ` the Updater. Returns: The initialized Updater instance. Raises: :exc:`Exception`: If an exception is raised during initialization, :meth:`shutdown` is called in this case. N) initialize Exceptionshutdown)r-excs r. __aenter__zUpdater.__aenter__sH //# # #K $ --/ ! !I s9A   A  A A?AA  A exc_typeexc_valexc_tbNc@K|jd{y7w)zB|async_context_manager| :meth:`shuts down ` the Updater.N)r5)r-r8r9r:s r. __aexit__zUpdater.__aexit__smmos c0t||jS)aGive a string representation of the updater in the form ``Updater[bot=...]``. As this class doesn't implement :meth:`object.__str__`, the default implementation will be used, which is equivalent to :meth:`__repr__`. Returns: :obj:`str` )r)rrr-s r.__repr__zUpdater.__repr__s.dAAr0c|jS)N)r!r>s r.runningzUpdater.runnings }}r0cK|jrtjdy|jj d{d|_y7 w)zInitializes the Updater & the associated :attr:`bot` by calling :meth:`telegram.Bot.initialize`. .. seealso:: :meth:`shutdown` z$This Updater is already initialized.NT)r"_LOGGERdebugrr3r>s r.r3zUpdater.initializesD    MM@ A hh!!###  $sAAA AcK|jr td|jstj dy|j j d{d|_tj dy7!w)z Shutdown the Updater & the associated :attr:`bot` by calling :meth:`telegram.Bot.shutdown`. .. seealso:: :meth:`initialize` Raises: :exc:`RuntimeError`: If the updater is still running. zThis Updater is still running!z-This Updater is already shut down. Returning.NFzShut down of Updater complete)rA RuntimeErrorr"rCrDrr5r>s r.r5zUpdater.shutdownsd <<?@ @  MMI J hh!!!! 56 "sAA=A;"A=g poll_intervaltimeoutbootstrap_retries read_timeout write_timeoutconnect_timeout pool_timeoutallowed_updatesdrop_pending_updateserror_callbackc K| r tj| r td|j4d{|jr t d|j s t dd|_ tj} |j|||||||| || |  d{tjd| jd{tjd|jcdddd{S77e7:7 #t$r} d |_| d} ~ wwxYw#1d{7swYyxYww) aMStarts polling updates from Telegram. .. versionchanged:: 20.0 Removed the ``clean`` argument in favor of :paramref:`drop_pending_updates`. Args: poll_interval (:obj:`float`, optional): Time to wait between polling updates from Telegram in seconds. Default is ``0.0``. timeout (:obj:`int`, optional): Passed to :paramref:`telegram.Bot.get_updates.timeout`. Defaults to ``10`` seconds. bootstrap_retries (:obj:`int`, optional): Whether the bootstrapping phase of the :class:`telegram.ext.Updater` will retry on failures on the Telegram server. * < 0 - retry indefinitely (default) * 0 - no retries * > 0 - retry up to X times read_timeout (:obj:`float`, optional): Value to pass to :paramref:`telegram.Bot.get_updates.read_timeout`. Defaults to :attr:`~telegram.request.BaseRequest.DEFAULT_NONE`. .. versionchanged:: 20.7 Defaults to :attr:`~telegram.request.BaseRequest.DEFAULT_NONE` instead of ``2``. .. deprecated:: 20.7 Deprecated in favor of setting the timeout via :meth:`telegram.ext.ApplicationBuilder.get_updates_read_timeout` or :paramref:`telegram.Bot.get_updates_request`. write_timeout (:obj:`float` | :obj:`None`, optional): Value to pass to :paramref:`telegram.Bot.get_updates.write_timeout`. Defaults to :attr:`~telegram.request.BaseRequest.DEFAULT_NONE`. .. deprecated:: 20.7 Deprecated in favor of setting the timeout via :meth:`telegram.ext.ApplicationBuilder.get_updates_write_timeout` or :paramref:`telegram.Bot.get_updates_request`. connect_timeout (:obj:`float` | :obj:`None`, optional): Value to pass to :paramref:`telegram.Bot.get_updates.connect_timeout`. Defaults to :attr:`~telegram.request.BaseRequest.DEFAULT_NONE`. .. deprecated:: 20.7 Deprecated in favor of setting the timeout via :meth:`telegram.ext.ApplicationBuilder.get_updates_connect_timeout` or :paramref:`telegram.Bot.get_updates_request`. pool_timeout (:obj:`float` | :obj:`None`, optional): Value to pass to :paramref:`telegram.Bot.get_updates.pool_timeout`. Defaults to :attr:`~telegram.request.BaseRequest.DEFAULT_NONE`. .. deprecated:: 20.7 Deprecated in favor of setting the timeout via :meth:`telegram.ext.ApplicationBuilder.get_updates_pool_timeout` or :paramref:`telegram.Bot.get_updates_request`. allowed_updates (List[:obj:`str`], optional): Passed to :meth:`telegram.Bot.get_updates`. drop_pending_updates (:obj:`bool`, optional): Whether to clean any pending updates on Telegram servers before actually starting to poll. Default is :obj:`False`. .. versionadded :: 13.4 error_callback (Callable[[:exc:`telegram.error.TelegramError`], :obj:`None`], optional): Callback to handle :exc:`telegram.error.TelegramError` s that occur while calling :meth:`telegram.Bot.get_updates` during polling. Defaults to :obj:`None`, in which case errors will be logged. Callback signature:: def callback(error: telegram.error.TelegramError) Note: The :paramref:`error_callback` must *not* be a :term:`coroutine function`! If asynchronous behavior of the callback is wanted, please schedule a task from within the callback. Returns: :class:`asyncio.Queue`: The update queue that can be filled from the main thread. Raises: :exc:`RuntimeError`: If the updater is already running or was not initialized. zYThe `error_callback` must not be a coroutine function! Use an ordinary function instead. N This Updater is already running!:This Updater was not initialized via `Updater.initialize`!T) rIrJrLrMrNrOrKrQrPreadyrRzWaiting for polling to startz%Polling updates from Telegram startedF)r(iscoroutinefunction TypeErrorr*rArFr"r!Event_start_pollingrCrDwaitrr4) r-rIrJrKrLrMrNrOrPrQrR polling_readyr6s r. start_pollingzUpdater.start_pollings@z g99.I  ;;! ! ||"#EFF$$"#_`` DM  '  ))"/#!-"/$3!-&7)=$3'#1*    <=#((*** EF((=! ! !  +7! >  %   ?! ! ! s3D>DD>6D)03D#D $,DD $D5 D>D D> D D D> D& D!!D&&D))D;/D2 0D;7D>rVc  Ktjdj||ddd{tjddtf fd } dtddfd} t j j| | xs| d | d _d fd }|_ | | jyy7w)NzUpdater started (polling))rQ webhook_urlrPzBootstrap doner1c K jjj d{}|rcjst j dy|D]%}jj|d{'|djdz_y7j#t$r}|d}~wt$r!}t j d|Yd}~yd}~wwxYw7[w)NoffsetrJrLrNrMrOrPzcSomething went wrong processing the data received from Telegram. Received data was *not* processed!exc_infoTzYUpdater stopped unexpectedly. Pulled updates will be ignored and pulled again on restart.rH) r get_updatesr rr4rCcriticalrArput update_id) updatesr6updaterPrNrOrLr-rJrMs r.polling_action_cbz1Updater._start_polling..polling_action_cbss  $ 4 4//#!-$3"/!-$3!5!*||$$, #*<"//33F;;;<+22;+@+@1+DD(A!     9 !  ".default_error_callbacks   MX[  \r0zgetting Updates) action_cb on_err_cb descriptionintervalz"Updater:start_polling:polling_task)namec Ktjd jjjdd{y7#t $r!}tj d|Yd}~yd}~wwxYww)NzHCalling `get_updates` one more time to mark all fetched updates as read.rrba-Error while calling `get_updates` one more time to mark all fetched updates as read: %s. Suppressing error to ensure graceful shutdown. When polling for updates is restarted, updates may be fetched again. Please adjust timeouts via `ApplicationBuilder` or the parameter `get_updates_request` of `Bot`.rd)rCrDrrgr rerror)r6rPrNrOrLr-rMs r._get_updates_cleanupz4Updater._start_polling.._get_updates_cleanups MMZ  hh**//!-$3"/!-$3+   !  `!  s@A>/A A AA>A A;A61A>6A;;A>r1N) rCrD _bootstrapboolrr( create_task_network_loop_retryr+r,set)r-rIrJrLrMrNrOrKrQrPrVrRrmrprxs` ````` ` r.rZzUpdater._start_pollingWs  12 oo !5      &'" " " H ]  ]$ ] &11  $ $+(B,B-& %  6   0%9!   IIK y s.C CBC listenporturl_pathcertkeyr` ip_addressmax_connections secret_tokenc bKts td|j4d{|jr td|js tdd|_ t j} |j||||||| ||| | | |  d{tjd| jd{tjd|jcdddd{S77e7:#t$r}d |_|d}~wwxYw7%#1d{7swYyxYww) aD Starts a small http server to listen for updates via webhook. If :paramref:`cert` and :paramref:`key` are not provided, the webhook will be started directly on ``http://listen:port/url_path``, so SSL can be handled by another application. Else, the webhook will be started on ``https://listen:port/url_path``. Also calls :meth:`telegram.Bot.set_webhook` as required. Important: If you want to use this method, you must install PTB with the optional requirement ``webhooks``, i.e. .. code-block:: bash pip install "python-telegram-bot[webhooks]" .. seealso:: :wiki:`Webhooks` .. versionchanged:: 13.4 :meth:`start_webhook` now *always* calls :meth:`telegram.Bot.set_webhook`, so pass ``webhook_url`` instead of calling ``updater.bot.set_webhook(webhook_url)`` manually. .. versionchanged:: 20.0 * Removed the ``clean`` argument in favor of :paramref:`drop_pending_updates` and removed the deprecated argument ``force_event_loop``. Args: listen (:obj:`str`, optional): IP-Address to listen on. Defaults to `127.0.0.1 `_. port (:obj:`int`, optional): Port the bot should be listening on. Must be one of :attr:`telegram.constants.SUPPORTED_WEBHOOK_PORTS` unless the bot is running behind a proxy. Defaults to ``80``. url_path (:obj:`str`, optional): Path inside url (http(s)://listen:port/). Defaults to ``''``. cert (:class:`pathlib.Path` | :obj:`str`, optional): Path to the SSL certificate file. key (:class:`pathlib.Path` | :obj:`str`, optional): Path to the SSL key file. drop_pending_updates (:obj:`bool`, optional): Whether to clean any pending updates on Telegram servers before actually starting to poll. Default is :obj:`False`. .. versionadded :: 13.4 bootstrap_retries (:obj:`int`, optional): Whether the bootstrapping phase of the :class:`telegram.ext.Updater` will retry on failures on the Telegram server. * < 0 - retry indefinitely * 0 - no retries (default) * > 0 - retry up to X times webhook_url (:obj:`str`, optional): Explicitly specify the webhook url. Useful behind NAT, reverse proxy, etc. Default is derived from :paramref:`listen`, :paramref:`port`, :paramref:`url_path`, :paramref:`cert`, and :paramref:`key`. ip_address (:obj:`str`, optional): Passed to :meth:`telegram.Bot.set_webhook`. Defaults to :obj:`None`. .. versionadded :: 13.4 allowed_updates (List[:obj:`str`], optional): Passed to :meth:`telegram.Bot.set_webhook`. Defaults to :obj:`None`. max_connections (:obj:`int`, optional): Passed to :meth:`telegram.Bot.set_webhook`. Defaults to ``40``. .. versionadded:: 13.6 secret_token (:obj:`str`, optional): Passed to :meth:`telegram.Bot.set_webhook`. Defaults to :obj:`None`. When added, the web server started by this call will expect the token to be set in the ``X-Telegram-Bot-Api-Secret-Token`` header of an incoming request and will raise a :class:`http.HTTPStatus.FORBIDDEN ` error if either the header isn't set or it is set to a wrong token. .. versionadded:: 20.0 Returns: :class:`queue.Queue`: The update queue that can be filled from the main thread. Raises: :exc:`RuntimeError`: If the updater is already running or was not initialized. z`To use `start_webhook`, PTB must be installed via `pip install "python-telegram-bot[webhooks]"`.NrTrUT) rrrrrrKrQr`rPrVrrrz#Waiting for webhook server to startzWebhook server startedF)WEBHOOKS_AVAILABLErFr*rAr"r!r(rY_start_webhookrCrDr[r4r)r-rrrrrrKr`rPrQrrr webhook_readyr6s r. start_webhookzUpdater.start_webhooks:p"4  ;;$ %$ %||"#EFF$$"#_`` DM  '  ))!%&7)= +$3')$3!-*  CD#((*** 67 $$I$ %$ %$ %"+  %   ?$ %$ %$ %$ %s"D/C8D/6D5C>C:,C>C<C> D& D/2D3D/:C><C>> D DDDD/D, D# !D,(D/c Ktjd|jdsd|}t||j|j | }|C|A t jt jj}|j||nd}t|||||_| s|j|rdnd|||} |j!|rt#|j%nd||| || | | d{|jj'| d{y#t j$r}td|d}~wwxYw7P7.w) Nz Updater thread started (webhook)/zInvalid SSL Certificatehttpshttpprotocolrrr)r max_retriesrQr`rPrrr)rV)rCrD startswithrrrsslcreate_default_contextPurpose CLIENT_AUTHload_cert_chainSSLErrorrrr#_gen_webhook_urlrzr read_bytes serve_forever)r-rrrrKrPrrrQr`rVrrrappssl_ctxr6s r.rzUpdater._start_webhookMsd  89""3'8*~Hh$2C2C\R   H474N4NKK++5''c2G$FD#w? //$+! 0Koo-1d&&(d)!5#+!+%  kk''e'444=<< H#$=>CG H"  5sIAE?D&A(E<E =#E E!E&E 9 EE  EErc|d|d||S)Nz://:rs r.rzUpdater._gen_webhook_urls3vhavhZ88r0rq.rrrsrtcKtjd||} |jrA |d{sy |}|rtj|d{|jr@yy76#t$r/}tj d|d|j z}Yd}~cd}~wt $r#}tjd||d}Yd}~d}~wt$r}tjd|d}~wt$r?} tjd|| || |dk(rd ntd d |z}Yd} ~ d} ~ wwxYw7#tj$rtjd |YywxYww) aPerform a loop calling `action_cb`, retrying after network errors. Stop condition for loop: `self.running` evaluates :obj:`False` or return value of `action_cb` evaluates :obj:`False`. Args: action_cb (:term:`coroutine function`): Network oriented callback function to call. on_err_cb (:obj:`callable`): Callback to call when TelegramError is caught. Receives the exception object as a parameter. description (:obj:`str`): Description text to use for logs and exception raised. interval (:obj:`float` | :obj:`int`): Interval to sleep between each call to `action_cb`. zStart network loop retry %sNz%sg?zTimed out %s: %srzInvalid token; abortingzError while %s: %srfg?z#Network loop retry %s was cancelled)rCrDrArinfo retry_afterrrrwrminr(sleepCancelledError) r-rqrrrsrt cur_intervalr6toepex telegram_excs r.r}zUpdater._network_loop_retrys9*  3[A  N,,,!*,,-&$,L!-- 5551,,,!9LLs+#&#8L%MM"4k3G#$L#MM";<I$[MM"6 \Rl+)5(91s2s\GY?ZL [6%% N MM? M NsE+ D< A,A*A,E+D<D:D<(E+*A,, D75%BD< D7+C D< D7C,, D785D2-D<2D77D<<)E(%E+'E((E+rbootstrap_intervalc  Kd dtffd } dtf fd } dtddf fd } ssj| | d|d{d rj| | d |d{yy7&7w) zPrepares the setup for fetching updates: delete or set the webhook and drop pending updates if appropriate. If there are unsuccessful attempts, this will retry as specified by :paramref:`max_retries`. rr1cKtjdrtjdjjd{y7w)NzDeleting webhook-Dropping pending updates from Telegram server)rQF)rCrDrdelete_webhook)rQr-sr.bootstrap_del_webhookz1Updater._bootstrap..bootstrap_del_webhooksI MM, -# MN(())?S)T T T UsA AAAc Ktjdrtjdjjd{y7w)NzSetting webhookr)url certificaterPrrQrrF)rCrDr set_webhook)rPrrQrrrr-r`sr.bootstrap_set_webhookz1Updater._bootstrap..bootstrap_set_webhooksd MM+ ,# MN((&& /%%9 /)'   sAAAAr6Nct|ts'dkskrdz tjdytj d||)Nrrfz-Failed bootstrap phase; try=%s max_retries=%sz,Failed bootstrap phase after %s retries (%s)) isinstancerrCwarningrw)r6rretriess r.bootstrap_on_err_cbz/Updater._bootstrap..bootstrap_on_err_cbsR c<0kAoS^I^1 CWk LgWZ[ r0zbootstrap del webhookzbootstrap set webhook)r{r4r})r-rr`rPrQrrrrrrrrrs`````` ``` @r.rzzUpdater._bootstraps  T  T   Y 4 $ {**%#'"   G **%#'"      s$A BBB9B:BBcK|j4d{|js tdtj dd|_|j d{|jd{tj ddddd{y77D7.7 #1d{7swYyxYww)zStops the polling/webhook. .. seealso:: :meth:`start_polling`, :meth:`start_webhook` Raises: :exc:`RuntimeError`: If the updater is not running. NzThis Updater is not running!zStopping UpdaterFzUpdater.stop() is complete)r*rArFrCrDr! _stop_httpd _stop_pollingr>s r.stopz Updater.stops;; 8 8<<"#ABB MM, -!DM""$ $ $$$& & & MM6 7 8 8 8 % & 8 8 8 8siB>B!B>AB)B#B)6B%7B) B>B'B>#B)%B)'B>)B;/B2 0B;7B>cK|jr?tjd|jjd{d|_yy7 w)z@Stops the Webhook server by calling ``WebhookServer.shutdown()``z4Waiting for current webhook connection to be closed.N)r#rCrDr5r>s r.rzUpdater._stop_httpd0s? ;; MMP Q++&&( ( (DK  (s?AAAcK|jrtjd|jjt j t j5|jd{dddd|_|jr |jd{d|_ytjdyy7V#1swYUxYw71w)z&Stops the polling task by awaiting it.z-Waiting background polling task to finish up.NzmNo polling cleanup callback defined. The last fetched updates may be fetched again on the next polling start.) r+rCrDcancel contextlibsuppressr(rr,rr>s r.rzUpdater._stop_polling7s    MMI J    & & ($$W%;%;< *)))) * #'D ((//111,0)?  * * *2s<AC!C 1C2C 6.C$C%#CC  CC)rrrr&ry) z 127.0.0.1Pr_NNrNNNN(N)NNNNNNrN)NNrfNrN),__name__ __module__ __qualname____doc__ __slots__r/rr7r r BaseExceptionrr<strr?propertyr{rAr3r5rfloatintrr rrr]r(rYrZrrrr staticmethodrr r}bytesrzrrrrr0r.rr;sW)V I\ \.\ | $ 4 ./ -( '    B# B !7. #!#(4)5+7(4/3/3DHDDD D uo D   D"%DuoD"$s),D'tnD!=/4*?!@AD !DLpppuo p   p "% puopp'tnp"$s),p}}p!=/4*?!@Ap ph"+/*.!"%)/3/3$(!&*B%B%B% B% uS$Y'( B% eCI& ' B%B%c]B%"$s),B%'tnB%SMB%B%smB% !B%V,0*./3%))-$(!&*A5A5A5 A5  A5 "$s), A5uS$Y'(A5eCI& 'A5'tnA5c]A5 &A5SMA5A5smA5 A5F939939#9RU99 3NCN+3N]OT123N 3N  3N  3Nt04 $$%$(!&*MMc]M"$s), M 'tn M uo M"MSMMMsmM M^8,r0)+rr(rrpathlibrtypesrtypingrrrrr r r r r rtelegram._utils.defaultvaluertelegram._utils.loggingrtelegram._utils.reprrtelegram._utils.typesrtelegram.errorrrrr"telegram.ext._utils.webhookhandlerrrr ImportErrortelegramrrrrCrrr0r.rs&d    6.?*LLQ~Y7 X P !),P s B BB