o "h}@s:dZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z ddl mZmZmZmZmZmZddlmZmZmZddlmZdd lmZdd lmZmZdd lm Z dd l!m"Z"z dd l#m$Z$m%Z%dZ&Wn e'ywdZ&Ynwerddl(m(Z(ddl)m*Z*edddZ+ee,Z-Gdddej.dZ/dS)z]This module contains the class Updater, which tries to make creating Telegram bots intuitive.N) CoroutineSequence)Path) TracebackType) TYPE_CHECKINGAnyCallableOptionalTypeVarUnion) DEFAULT_80 DEFAULT_IP DefaultValue) get_logger)build_repr_with_selected_attrs)DVType TimePeriod) TelegramError)network_retry_loop)WebhookAppClass WebhookServerTF)socket)Bot _UpdaterTypeUpdater)boundc!@seZdZdZdZ    dIddZd ed efd d Zd ee e dee dee d dfddZ d e fddZed efddZdJddZdJddZdejddddddfded ed!ed"eee d#eed$eeegdfd dfd%d&Zded ed!ed#eed"eee d'ejd$eeegdfd dfd(d)Ze e!d*dddddddd+ddf d,e"e d-e"ed.e d/ee#e e$fd0ee#e e$fd!ed1ee d"eee d#eed2ee d3ed4ee d5ee#e e$d6fd dfd7d8Z%       +  dKd,e d-ed.e d!ed"eee d/ee#e e$fd0ee#e e$fd#eed1ee d'eejd2ee d3ed4ee d5ee#e e$d6fd dfd9d:Z&e'd;e d,e d-ed.e d e f d  + dLd?ed1ee d"eee d#eed/ee)d@ed2ee d3ed4ee d dfdAdBZ*dJdCdDZ+dJdEdFZ,dJdGdHZ-dS)Mra]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_queuer$rr%asyncio.Queue[object]cCsH||_||_d|_d|_d|_d|_t|_d|_ t |_ d|_ dS)NrF) r$r%r"r#r!r asyncioLock_Updater__lock_Updater__polling_taskEvent!_Updater__polling_task_stop_event_Updater__polling_cleanup_cb)selfr$r%r/H/var/www/html/venv/lib/python3.10/site-packages/telegram/ext/_updater.py__init__os   zUpdater.__init__r.returncs6z |IdHW|Sty|IdHw)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 Exceptionshutdownr.r/r/r0 __aenter__s  zUpdater.__aenter__exc_typeexc_valexc_tbNcs|IdHdS)zB|async_context_manager| :meth:`shuts down ` the Updater.N)r5)r.r8r9r:r/r/r0 __aexit__s zUpdater.__aexit__cCst||jdS)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$r6r/r/r0__repr__s zUpdater.__repr__cCs|jSN)r#r6r/r/r0runningszUpdater.runningcs0|jr tddS|jIdHd|_dS)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$r3r6r/r/r0r3s   zUpdater.initializecsH|jrtd|jstddS|jIdHd|_tddS)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)r> RuntimeErrorr!r?r@r$r5r6r/r/r0r5s  zUpdater.shutdowng secondsr poll_intervaltimeoutbootstrap_retriesallowed_updatesdrop_pending_updateserror_callbackc s|r t|r td|j4IdHQ|jrtd|js"tdd|_z&t}|j |||||||dIdHt d| IdHt dWn t yVd |_w|jWdIdHS1IdHsjwYdS) aO Starts polling updates from Telegram. .. versionchanged:: 20.0 Removed the ``clean`` argument in favor of :paramref:`drop_pending_updates`. .. versionchanged:: 22.0 Removed the deprecated arguments ``read_timeout``, ``write_timeout``, ``connect_timeout``, and ``pool_timeout`` in favor of setting the timeouts via the corresponding methods of :class:`telegram.ext.ApplicationBuilder`. or by specifying the timeout via :paramref:`telegram.Bot.get_updates_request`. Args: poll_interval (:obj:`float`, optional): Time to wait between polling updates from Telegram in seconds. Default is ``0.0``. timeout (:obj:`int` | :class:`datetime.timedelta`, optional): Passed to :paramref:`telegram.Bot.get_updates.timeout`. Defaults to ``timedelta(seconds=10)``. .. versionchanged:: v22.2 |time-period-input| bootstrap_retries (:obj:`int`, optional): Whether the bootstrapping phase of will retry on failures on the Telegram server. * < 0 - retry indefinitely * 0 - no retries (default) * > 0 - retry up to X times .. versionchanged:: 21.11 The default value will be changed to from ``-1`` to ``0``. Indefinite retries during bootstrapping are not recommended. allowed_updates (Sequence[:obj:`str`], optional): Passed to :meth:`telegram.Bot.get_updates`. .. versionchanged:: 21.9 Accepts any :class:`collections.abc.Sequence` as input instead of just a list 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)rErFrGrIrHreadyrJzWaiting for polling to startz%Polling updates from Telegram startedF)r'iscoroutinefunction TypeErrorr)r>rAr!r#r+_start_pollingr?r@waitr4r%)r.rErFrGrHrIrJ polling_readyr/r/r0 start_pollings>G  0zUpdater.start_pollingrMc stdj||dddIdHtddtffdd }dtddfd d } tjtfd d ||p7| d |jdddd_ dfdd } | _ |durX| dSdS)NzUpdater started (polling))rI webhook_urlrHzBootstrap doner2c szjjjdIdH}Wn!tyty1}ztjd|dWYd}~dSd}~ww|rTjs>tddS|D] }j |IdHq@|dj d_dS)NoffsetrFrHzcSomething 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.) r$ get_updatesr"rr4r?criticalr>r%put update_id)updatesexcupdaterHr.rFr/r0polling_action_cbRs6   z1Updater._start_polling..polling_action_cbracSstjd|ddS)Nz-Exception happened while polling for updates.rX)r? exception)rar/r/r0default_error_callbackrsz6Updater._start_polling..default_error_callbackcjSr=r>r/r6r/r0zz(Updater._start_polling..zPolling UpdatesrZ) is_running action_cb on_err_cb descriptioninterval stop_event max_retriesz"Updater:start_polling:polling_task)namecsTtdzjjjtjdddIdHWdSty)tdYdSw)NzHCalling `get_updates` one more time to mark all fetched updates as read.rrCrVa-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`.) r?r@r$r\r"dtm timedeltarrer/)rHr.r/r0_get_updates_cleanups   z4Updater._start_polling.._get_updates_cleanupr2N) r?r@ _bootstrapboolrr' create_taskrr,r*r-set) r.rErFrGrIrHrMrJrdrfrur/rcr0rP:s8      zUpdater._start_pollingrT(listenporturl_pathcertkeyrU ip_addressmax_connections secret_tokenunixrcs6tstd| r)d}t|tst|dt|ts#t|d|s)td|j4IdH^|jr8td|js?tdd |_z3t }|j t |t |||||| |||| | | | d IdHt d |IdHt d Wn tyd |_w|jWdIdHS1IdHswYdS)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 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 (Sequence[:obj:`str`], optional): Passed to :meth:`telegram.Bot.set_webhook`. Defaults to :obj:`None`. .. versionchanged:: 21.9 Accepts any :class:`collections.abc.Sequence` as input instead of just a list 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.r|r}zqSince you set unix, you also need to set the URL to the webhook of the proxy you run in front of the unix socket.NrKrLT)r|r}r~rrrGrIrUrHrMrrrrz#Waiting for webhook server to startzWebhook server startedF)WEBHOOKS_AVAILABLErA isinstancerformatr)r>r!r#r'r+_start_webhook get_valuer?r@rQr4r%)r.r|r}r~rrrGrUrHrIrrrr error_msg webhook_readyr/r/r0 start_webhooksbq    0zUpdater.start_webhookc std|dsd|}t||j|j| }|durC|durCzttjj }| ||Wntj yB}zt d|d}~wwd}t ||||||_| s`|j|rVdndt|||d} |j|rjt|nd||| || | | dIdH|jj| dIdHdS) Nz Updater thread started (webhook)/zInvalid SSL Certificatehttpshttpprotocolr|r}r~)rrqrIrUrHrrr)rM)r?r@ startswithrr$r%sslcreate_default_contextPurpose CLIENT_AUTHload_cert_chainSSLErrorrrr _gen_webhook_urlrrrwr read_bytes serve_forever)r.r|r}r~rGrHrrrIrUrMrrrrappssl_ctxrar/r/r0rOsF       zUpdater._start_webhookrcCs|d|d||S)Nz://:r/rr/r/r0rszUpdater._gen_webhook_urlr[rqbootstrap_intervalc sdtffdd } dtffdd } ss0tfdd| d|d |d Id HrEtfd d| d |d |d Id Hd Sd S) 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`. r2cs2tdr tdjjdIdHdS)NzDeleting webhook-Dropping pending updates from Telegram server)rIF)r?r@r$delete_webhookr/)rIr.r/r0bootstrap_del_webhooks   z1Updater._bootstrap..bootstrap_del_webhookc s>tdr tdjjdIdHdS)NzSetting webhookr)url certificaterHrrIrrF)r?r@r$ set_webhookr/rHrrIrrrr.rUr/r0bootstrap_set_webhooks    z1Updater._bootstrap..bootstrap_set_webhookcrgr=rhr/r6r/r0rirjz$Updater._bootstrap..zBootstrap delete WebhookN)rkrlrnrorprqcrgr=rhr/r6r/r0rirjzBootstrap Set Webhook)rxr) r.rqrUrHrIrrrrrrrr/rr0rws,     zUpdater._bootstrapc s|j4IdH.|jstdtdd|_|IdH|IdHtdWdIdHdS1IdHsrAr?r@r# _stop_httpd _stop_pollingr6r/r/r0stops   .z Updater.stopcs0|jrtd|jIdHd|_dSdS)z@Stops the Webhook server by calling ``WebhookServer.shutdown()``z4Waiting for current webhook connection to be closed.N)r r?r@r5r6r/r/r0rs   zUpdater._stop_httpdcs|jrHtd|jttj|jIdHWdn1s%wYd|_|j |j rA| IdHd|_ dSt ddSdS)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*r?r@r,rz contextlibsuppressr'CancelledErrorclearr-warningr6r/r/r0rs     zUpdater._stop_polling)r$rr%r&rv) NNNNNNr{NN)NNr[Nr{N).__name__ __module__ __qualname____doc__ __slots__r1rr7r type BaseExceptionrr;strr<propertyrxr>r3r5rsrtfloatrintrrrrSr'r+rPr r rr rrr staticmethodrbytesrwrrrr/r/r/r0r6s`+           k  j      5       C      A )0rr'rdatetimersrcollections.abcrrpathlibrtypesrtypingrrrr r r telegram._utils.defaultvaluer r rtelegram._utils.loggingrtelegram._utils.reprrtelegram._utils.typesrrtelegram.errorrtelegram.ext._utils.networkloopr"telegram.ext._utils.webhookhandlerrrr ImportErrorrtelegramrrrr?AbstractAsyncContextManagerrr/r/r/r0s6