o @Mh@sdZdZzddlZddlmZddlmZddlmZm Z Wn e y)dZYnwddl Z ddl m Z dd lmZGd d d ZdS) z This file is used by AsyncTeleBot.run_webhooks() function. Fastapi and starlette(0.20.2+) libraries are required to run this script. TN) JSONResponse)Request)ServerConfigF)Update)Optionalc @sreZdZ    ddedeedeedeedeed df d d Zd d ZddZ de de fddZ ddZ dS)AsyncWebhookListener 127.0.0.1N secret_tokenhostport ssl_contexturl_pathreturncCsB|t|_||_||_||_||_||_||_ | dS)a( Aynchronous implementation of webhook listener for asynchronous version of telebot. Not supposed to be used manually by user. Use AsyncTeleBot.run_webhooks() instead. :param bot: AsyncTeleBot instance. :type bot: telebot.async_telebot.AsyncTeleBot :param secret_token: Telegram secret token :type secret_token: str :param host: Webhook host :type host: str :param port: Webhook port :type port: int :param ssl_context: SSL context :type ssl_context: tuple :param url_path: Webhook url path :type url_path: str :raises ImportError: If FastAPI or uvicorn is not installed. :raises ImportError: If Starlette version is too old. :return: None N) _check_dependenciesfastapiFastAPIapp _secret_token_bot_port_host _ssl_context _url_path_prepare_endpoint_urls)selfbotr r r rrrK/var/www/html/venv/lib/python3.10/site-packages/telebot/ext/aio/webhooks.py__init__s$  zAsyncWebhookListener.__init__cCs*tstdddl}|jdkrtddS)Nz?Fastapi or uvicorn is not installed. Please install it via pip.rz0.20.2zLStarlette version is too old. Please upgrade it: `pip3 install starlette -U`)fastapi_installed ImportError starlette __version__)rr#rrrrKs  z(AsyncWebhookListener._check_dependenciescCs|jj|j|jdgddS)NPOST)endpointpathmethods)r add_api_routeprocess_updater)rrrrrUsz+AsyncWebhookListener._prepare_endpoint_urlsrequestupdatecsn|jd|jkrtdddidS|jddkr/|}t|jt |gtdd d StdddidS) z< Processes updates. :meta private: zX-Telegram-Bot-Api-Secret-Tokenierror Forbidden) status_codecontentz content-typezapplication/json)r/) headersgetrrasyncio create_taskrprocess_new_updatesrde_json)rr+r, json_stringrrrr*Ys z#AsyncWebhookListener.process_updatecsPt|j|j|j|jd|jdd}t|}|IdH|jIdHdS)z Run app with the given parameters to init. Not supposed to be used manually by user. :return: None r)rr r ssl_certfile ssl_keyfileN) rrrrrrserver close_session)rconfigserverrrrrun_appkszAsyncWebhookListener.run_app)r r NN)__name__ __module__ __qualname__strrinttupler rrrdictr*rArrrrrs, 0  r)__doc__r!rfastapi.responsesrfastapi.requestsruvicornrrr"r5 telebot.typesrtypingrrrrrrs