՟fCLdZddlZddlZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZmZddlmZmZmZmZddlmZddlmZdd lmZmZdd lm Z m!Z!m"Z"m#Z# dd l$m%Z%m&Z&d Z'e r ddl)m)Z)ddl*m+Z+eddZ,ee-Z.Gdde dZ/y#e($rd Z'Y8wxYw)z]This module contains the class Updater, which tries to make creating Telegram bots intuitive.N)Path) TracebackType) TYPE_CHECKINGAnyAsyncContextManagerCallable CoroutineListOptionalTypeTypeVarUnion) DEFAULT_80 DEFAULT_IP DEFAULT_NONE DefaultValue) get_logger)build_repr_with_selected_attrs)DVTypeODVInput) InvalidToken RetryAfter TelegramErrorTimedOut)WebhookAppClass WebhookServerTF)socket)Bot _UpdaterTypeUpdater)boundc! eZdZdZdZ d@dZdedefdZdee e d ee d ee dd fd Z de fd ZedefdZdAdZdAdZdddeeeed d d f dedededeedeedeedeedeee deedeeegd fddfdZdededeedeedeedeededeedeee dej:deeegd fdd fd Zee d!d d d"d d d d d#d d f d$e!e d%e!ed&e d'ee"e e#fd(ee"e e#fded)ee deee deed*ee d+ed,ee d-ee"e e#d.fddfd/Z$ dBd$e d%ed&e dedeee d'ee"e e#fd(ee"e e#fdeed)ee deej:d*ee d+ed,ee d-ee"e e#d.fdd fd0Z%e&d1e d$e d%ed&e de f d2Z'd3ed4e(fd5eegd fd6e d7ed8eej:dd f d9Z) dCd:ed)ee deee deed'ee*d;ed*ee d+ed,ee dd fd<Z+dAd=Z,dAd>Z-dAd?Z.y )Dr a]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. ) __lock__polling_cleanup_cb__polling_task__polling_task_stop_event_httpd _initialized_last_update_id_runningbot update_queueasyncio.Queue[object]c||_||_d|_d|_d|_d|_t j|_d|_ t j|_ d|_ y)NrF) r+r,r)r*r(r'asyncioLock_Updater__lock_Updater__polling_taskEvent!_Updater__polling_task_stop_event_Updater__polling_cleanup_cb)selfr+r,s P/var/www/cvtools/html/venv/lib/python3.12/site-packages/telegram/ext/_updater.py__init__zUpdater.__init__vs\ 3?  !/3 lln 6:8? &W[!r6returncK |jd{|S7#t$r|jd{7wxYww)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 Exceptionshutdownr6s r7 __aenter__zUpdater.__aenter__sG //# # # $ --/ ! !  s.A  A A?AAexc_typeexc_valexc_tbNc@K|jd{y7w)zB|async_context_manager| :meth:`shuts down ` the Updater.N)r>)r6rArBrCs r7 __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+)rr+r?s r7__repr__zUpdater.__repr__s.dAAr9c|jS)N)r*r?s r7runningzUpdater.runnings }}r9cK|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(_LOGGERdebugr+r<r?s r7r<zUpdater.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)rI RuntimeErrorr(rKrLr+r>r?s r7r>zUpdater.shutdownsd <<?@ @  MMI J hh!!!! 56 "sAA=A;"A=g poll_intervaltimeoutbootstrap_retries read_timeout write_timeoutconnect_timeout pool_timeoutallowed_updatesdrop_pending_updateserror_callbackc vK| r tj| r td|j4d{|jr t d|j s t dd|_ tj} |j|||||||| || |  d{tjd| jd{tjd|jcdddd{S77e7:#t$r d |_wxYw7 #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) rQrRrTrUrVrWrSrYrXreadyrZzWaiting for polling to startz%Polling updates from Telegram startedF)r/iscoroutinefunction TypeErrorr1rIrNr(r*r3_start_pollingrKrLwaitr=r,) r6rQrRrSrTrUrVrWrXrYrZ polling_readys r7 start_pollingzUpdater.start_pollings>z g99.I  ;; % %||"#EFF$$"#_`` DM  '  ))"/#!-"/$3!-&7)=$3'#1*    <=#((*** EF$$A % % % +  %  ; % % % %s3D9DD96D$03D #D $,D D D * D$5 D9D"D9 D  D  DD$"D9$D6*D- +D62D9r^c  Ktjdj||ddd{tjddtf fd } dtddfd} t j j| | xs| d |j d _ d fd }|_ | | jyy7w)NzUpdater started (polling))rY webhook_urlrXzBootstrap doner:c K jjj d{}|rcjst j dy|D]%}jj|d{'|djdz_y7j#t$rt$r!}t j d|Yd}~yd}~wwxYw7Vw)NoffsetrRrTrVrUrWrXzcSomething 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.rP) r+ get_updatesr)rr=rKcriticalrIr,put update_id) updatesexcupdaterXrVrWrTr6rRrUs r7polling_action_cbz1Updater._start_polling..polling_action_cbws  $ 4 4//#!-$3"/!-$3!5!*||$$, #*<"//33F;;;<+22;+@+@1+DD(A!    9 !  ".default_error_callbacks   MX[  \r9zgetting Updates) action_cb on_err_cb descriptioninterval stop_eventz"Updater:start_polling:polling_task)namec Ktjd jjjdd{y7#t $rtj dYywxYww)NzHCalling `get_updates` one more time to mark all fetched updates as read.rria-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`.)rKrLr+rnr)rrw)rXrVrWrTr6rUsr7_get_updates_cleanupz4Updater._start_polling.._get_updates_cleanups{ MMZ  hh**//!-$3"/!-$3+   ! !!` s:A5/A A AA5AA2/A51A22A5r:N) rKrL _bootstrapboolrr/ create_task_network_loop_retryr4r2r5set)r6rQrRrTrUrVrWrSrYrXr^rZrurxrs` ````` ` r7razUpdater._start_polling[s  12 oo !5      &'" " " H ]  ]$ ] &11  $ $+(B,B-&99 % 6     .%9!   IIK y s.CCBCrfr(listenporturl_pathcertkeyrg ip_addressmax_connections secret_tokenunixrcpKts td| rcd}t|tst|j dt|tst|j d|s td|j 4d{|j r td|js tdd |_ tj}|jtj|tj|||||| |||| | | | d{tjd |jd{tjd |j"cdddd{S77e7:#t $r d |_wxYw7 #1d{7swYyxYww)a/ 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 unix (:class:`pathlib.Path` | :obj:`str` | :class:`socket.socket`, optional): Can be either: * the path to the unix socket file as :class:`pathlib.Path` or :obj:`str`. This will be passed to `tornado.netutil.bind_unix_socket `_ to create the socket. If the Path does not exist, the file will be created. * or the socket itself. This option allows you to e.g. restrict the permissions of the socket for improved security. Note that you need to pass the correct family, type and socket options yourself. Caution: This parameter is a replacement for the default TCP bind. Therefore, it is mutually exclusive with :paramref:`listen` and :paramref:`port`. When using this param, you must also run a reverse proxy to the unix socket and set the appropriate :paramref:`webhook_url`. .. versionadded:: 20.8 .. versionchanged:: 21.1 Added support to pass a socket instance itself. 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]"`.z|You can not pass unix and {0}, only use one. Unix if you want to initialize a unix socket, or {0} for a standard TCP server.rrzqSince you set unix, you also need to set the URL to the webhook of the proxy you run in front of the unix socket.Nr\r]T)rrrrrrSrYrgrXr^rrrrz#Waiting for webhook server to startzWebhook server startedF)WEBHOOKS_AVAILABLErN isinstancerformatr1rIr(r*r/r3_start_webhook get_valuerKrLrbr=r,)r6rrrrrrSrgrXrYrrrr error_msg webhook_readys r7 start_webhookzUpdater.start_webhooks\"4  N fl3"9#3#3H#=>>dL1"9#3#3F#;<<"H ;;% %% %||"#EFF$$"#_`` DM  '  ))'11&9%//5%&7)= +$3')$3!-*" CD#((*** 67 $$K% %% %% %$+  %  A% %% %% %% %sBF6 F F6 6F!AF  F!,F  FF ' F!2 F6>F?F6F F  FF!F6!F3'F* (F3/F6c Ktjd|jdsd|}t||j|j | }|C|A t jt jj}|j||nd}t||||||_| s,|j|rdndt!j"|||} |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_retriesrYrgrXrrr)r^)rKrL startswithrr+r,sslcreate_default_contextPurpose CLIENT_AUTHload_cert_chainSSLErrorrrr'_gen_webhook_urlrrrr read_bytes serve_forever)r6rrrrSrXrrrYrgr^rrrrappssl_ctxrss r7rzUpdater._start_webhookwso"  89""3'8*~Hh$2C2C\R   H474N4NKK++5''c2G#FD#wE //$+#--f5! 0Koo-1d&&(d)!5#+!+%  kk''e'444;<< H#$=>CG H  5sIAE%?D:A.do_actions&[(($00=N++JOO,=>I"),,+9P9P#MD'$$W%;%;< "#"DKKM" "D  C[Q!((* *) " "s: DC3A+D<C5=*D'C74D5D7D<DzStart network loop retry %sNz%sg?zTimed out %s: %srzInvalid token; abortingrmg?)rrKrLrIrinfo retry_afterrrrwrminr/sleep) r6ryrzr{r|r}r cur_intervalrstoe telegram_excs ` ` ` r7rzUpdater._network_loop_retrys 4 + +&  3[A ll (&[(()$ ( mmL111/ll( 5 T3'"S__4  ! 0+sC  !!";<  W,'%1A$5q3r3CU;V  W2s|3D0 A<A:A<D0 D0&D.'D08D0:A<< D+%B/*D0/ D+;CD0*D+D&!D0&D++D0rbootstrap_intervalc  Kd dtffd } dtf fd } dtddf fd } ss j| | d|d d{d rj| | d |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`. rr:cKtjdrtjdjjd{y7w)NzDeleting webhook-Dropping pending updates from Telegram server)rYF)rKrLr+delete_webhook)rYr6sr7bootstrap_del_webhookz1Updater._bootstrap..bootstrap_del_webhooksI MM, -# MN(())?S)T T T UsA AAAc Ktjdrtjdjjd{y7w)NzSetting webhookr)url certificaterXrrYrrF)rKrLr+ set_webhook)rXrrYrrrr6rgsr7bootstrap_set_webhookz1Updater._bootstrap..bootstrap_set_webhook!sd MM+ ,# MN((&& /%%9 /)'   sAAAArsNct|ts'dkskrdz tjdytj d||)Nrrmz-Failed bootstrap phase; try=%s max_retries=%sz,Failed bootstrap phase after %s retries (%s))rrrKwarningerror)rsrretriess r7bootstrap_on_err_cbz/Updater._bootstrap..bootstrap_on_err_cb0sR c<0kAoS^I^1 CWk LgWZ[ r9zbootstrap del webhook)r}zbootstrap set webhook)rr=r)r6rrgrXrYrrrrrrrrrs`````` ``` @r7rzUpdater._bootstraps  T  T   Y 4 $ {**%#'" +  G **%#'" +     s$ABB!B=B>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)r1rIrNrKrLr* _stop_httpd _stop_pollingr?s r7stopz Updater.stopYs;; 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'rKrLr>r?s r7rzUpdater._stop_httpdos? ;; MMP Q++&&( ( (DK  (s?AAAcK|jrtjd|jj t j tj5|jd{dddd|_|jj|jr |jd{d|_ ytjdyy7p#1swYoxYw71w)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.) r2rKrLr4rrrr/rclearr5rr?s r7rzUpdater._stop_pollingvs    MMI J  * * . . 0$$W%;%;< *)))) * #'D   * * 0 0 2((//111,0)?!  * * *2s=AC2!C$1C"2C$6AC2>C0?#C2"C$$C-)C2)r+rr,r-r) NNNNNNrNN)NNrmNrN)/__name__ __module__ __qualname____doc__ __slots__r8rr@r r BaseExceptionrrEstrrGpropertyrrIr<r>rfloatintrr rrrdr/r3rarrrrrrr staticmethodrr rbytesrrrrrr9r7r r =s)V I\ \.\"| $ 4 ./ -( '    B# B !7. #!#(4)5+7(4/3/3DHC%C%C% C% uo C%   C%"%C%uoC%"$s),C%'tnC%!=/4*?!@AC% !C%Jpppuo p   p "% puopp'tnp"$s),p}}p!=/4*?!@Ap ph)&+/*.!"%)/3/3$(!&*59h%s h%Skh% h% uS$Y'( h% eCI& ' h%h%c]h%"$s),h%'tnh%SMh%h%smh%uS$012h% !h%b,0*./3%))-$(!&*59A5A5A5 A5  A5 "$s), A5uS$Y'(A5eCI& 'A5'tnA5c]A5 &A5SMA5A5smA5uS$012A5 !A5F939939#9RU99 F2CN+F2]OT12F2 F2  F2 W]]+ F2 F2Z04 $$%$(!&*OOc]O"$s), O 'tn O uo O"OSMOOsmO Ob8,r9)0rr/rrpathlibrtypesrtypingrrrrr r r r r rtelegram._utils.defaultvaluerrrrtelegram._utils.loggingrtelegram._utils.reprrtelegram._utils.typesrrtelegram.errorrrrr"telegram.ext._utils.webhookhandlerrrr ImportErrorrtelegramrrrrKr rr9r7rs&d    \[.?2LLQ~Y7 X N !),N s BB#"B#