i7tddlZddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z m Z mZmZddlZddlmZ dd lmZd Zn #e$rd ZYnwxYwdd lmZdd lmZddlmZe rddlmZeedZ GddZ!Gddej"j#Z$Gddej"j%Z&dS)N) HTTPStatus)Path)socket) SSLContext) TracebackType) TYPE_CHECKINGOptionalTypeUnion) HTTPServer)bind_unix_socketTF)Update) get_logger)ExtBot)BotUpdater) class_nameceZdZdZdZ ddededddeed ee ee e ff d Z dd ee jd dfd ZddZdS) WebhookServerz6Thin wrapper around ``tornado.httpserver.HTTPServer``.) _http_server _server_lock_shutdown_lock is_runninglistenportunixNrr webhook_appWebhookAppClassssl_ctxrc~|rtstdt|||_||_||_d|_d|_|rt|tr||_n#|r!tt||_tj |_tj |_dS)Nz.This OS does not support binding unix sockets.) ssl_optionsF)UNIX_AVAILABLE RuntimeErrorr rrrrr isinstancerr strasyncioLockrr)selfrrrrrs h/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/telegram/ext/_utils/webhookhandler.py__init__zWebhookServer.__init__As  Q QOPP P&{HHH    4JtV,, 4DII  4(T33DI#LNN%lnnreadyreturncvK|j4d{V|jr |j|jn&|j|j|jd|_||t ddddd{VdS#1d{VswxYwYdS)N)addressTzWebhook Server started.) rrr add_socketrrrset_LOGGERdebug)r(r,s r) serve_foreverzWebhookServer.serve_foreverWsA$ 5 5 5 5 5 5 5 5y I!,,TY7777!((DK(HHH"DO  MM3 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5sBB(( B25B2cK|j4d{V|js.td dddd{VdSd|_|j|jd{Vtddddd{VdS#1d{VswxYwYdS)Nz.Webhook Server is already shut down. ReturningFzWebhook Server stopped)rrr2r3rstopclose_all_connectionsr(s r)shutdownzWebhookServer.shutdownds& 4 4 4 4 4 4 4 4?  NOOO 4 4 4 4 4 4 4 4 4 4 4 4 4 4$DO   " " $ $ $#99;; ; ; ; ; ; ; ; MM2 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s#B2AB22 B<?B<Nr-N)__name__ __module__ __qualname____doc__ __slots__r%intr rr rrr*r&Eventr4r9r+r)rr4s@@I 48 ----' - *% - uS$./0 ----, 5 5'-)@ 5D 5 5 5 5444444r+rc heZdZdZ d dedddejdeefdZd e j j d dfd Z dS) rz!Application used in the WebserverN webhook_pathbotr update_queue secret_tokenc|||d|_|dt|jfg}tjj||dS)N)rFrGrHz/?)shared_objectsTelegramHandlertornadoweb Applicationr*)r(rErFrGrHhandlerss r)r*zWebhookAppClass.__init__rsZ((   &)))?Dr?r%r&Queuer r*rLrMRequestHandlerrRrCr+r)rros++'+ 9 9 9 9m 9 sm 9 9 9 9X7;#=X$XXXXXXr+rceZdZdZdZdZdddejdedd fd Z dd Z dd Z dd Z de eede ede edd fdZd S)rKz:BaseHandler that processes incoming requests from Telegram)rFrHrG)POSTrFrrGrHr-Ncl||_||_||_|rtddSdS)zFInitialize for each request - that's the interface provided by tornadozLThe webhook server has a secret token, expecting it in incoming requests nowN)rFrGrHr2r3)r(rFrGrHs r) initializezTelegramHandler.initializesP((   MM^       r+c2|dddS)zSets default headers Content-Typez!application/json; charset="utf-8"N) set_headerr8s r)set_default_headersz#TelegramHandler.set_default_headerss (KLLLLLr+cKtd||jj}t j|}|tj td| tj ||j }nZ#t$rM}td|t jtjd|d}~wwxYw|rvtd|jt+|j t,r|j ||j|d{VdSdS) zHandle incoming POST requestzWebhook triggeredzWebhook received data: %szcSomething went wrong processing the data received from Telegram. Received data was *not* processed!exc_infozUpdate could not be processedreasonNz%Received Update with ID %d on Webhook)r2r3_validate_postrequestbodydecodejsonloads set_statusrOKrde_jsonrF ExceptioncriticalrLrM HTTPError BAD_REQUEST update_idr$rinsert_callback_datarGput)r( json_stringdataupdateexcs r)postzTelegramHandler.posts )*** l'..00 z+&&  &&& 1;??? ^D$(33FF      5     +''&/N(     0 MM7    $(F++ 6--f555#''// / / / / / / / / / 0 0sB99 DAD  Dc$|jjdd}|dkr)tjt j|j|jjd}|sEt dtjt jd||jkrHt d|tjt jddSdS) z+Only accept requests with content type JSONrZNzapplication/jsonzX-Telegram-Bot-Api-Secret-Tokenz(Request did not include the secret tokenr`z&Request had the wrong secret token: %sz"Request had the wrong secret token) rcheadersgetrLrMrmr FORBIDDENrHr2r3)r( ct_headertokens r)rbzTelegramHandler._validate_postsL(,,^TBB * * *+'' (<== =   (L(,,-NOOE  HIIIk++(1[,))) FNNNk++(1U, ) (*)r+typvaluetbcltd|jjd|r |r|r|||fn|dS)z@Override the default logging and instead use our custom logging.z%s - %szException in TelegramHandlerr^N)r2r3rc remote_ip)r(r}r~rs r) log_exceptionzTelegramHandler.log_exceptionsU   L " *),HH2Hc5"%%5      r+r;)r<r=r>r?r@SUPPORTED_METHODSr&rSr%rXr\rvrbr r BaseExceptionrrrCr+r)rKrKsDD7I! e 7= PS X\    MMMM!0!0!0!0F&  d=) *   &   ] #         r+rK)'r&rfhttprpathlibrrsslrtypesrtypingrr r r tornado.webrLtornado.httpserverr tornado.netutilr r" ImportErrortelegramrtelegram._utils.loggingrtelegram.ext._extbotrrr<r2rrMrNrrTrKrCr+r)rs( 777777777777))))))000000NNNNN......'''''' *X) 4 4 48484848484848484vXXXXXgk-XXX.X X X X X gk0X X X X X sAAA