a /3e@sdZdZz4ddlZddlmZddlmZddlmZm Z Wne yRdZYn0ddl 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@s^eZdZdeeeeeeeeeddddZddZd d Z e e d d d Z 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_dependenciesfastapiZFastAPIapp _secret_token_bot_port_host _ssl_context _url_path_prepare_endpoint_urls)selfZbotr r r rrrK/home/pi/bot/my_env/lib/python3.9/site-packages/telebot/ext/aio/webhooks.py__init__s$ zAsyncWebhookListener.__init__cCs*ts tdddl}|jdkr&tddS)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)Zendpointpathmethods)rZ add_api_routeprocess_updater)rrrrrUsz+AsyncWebhookListener._prepare_endpoint_urls)requestupdatecsl|jd|jkr"tdddidS|jddkr\|}t|jt |gtdd d StdddidS) z< Processes updates. :meta private: zX-Telegram-Bot-Api-Secret-Tokenierror Forbidden) status_codecontentz content-typezapplication/json)r+) headersgetrrasyncioZ create_taskrZprocess_new_updatesrZde_json)rr'r(Z json_stringrrrr&Ys z#AsyncWebhookListener.process_updatecsNt|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 Z ssl_certfileZ ssl_keyfileN) rrrrrrZserverZ close_session)rconfigserverrrrrun_appkszAsyncWebhookListener.run_app)r r NN)__name__ __module__ __qualname__strrinttuplerrrrdictr&r5rrrrrs  0 r)__doc__rrZfastapi.responsesrZfastapi.requestsrZuvicornrrr r1Z telebot.typesrtypingrrrrrrs