o HEDiBW@sVddlZddlZddlmZddlmZddgZGdddeZGdd d ejZ dS) N)types)BaseMiddleware UnhandledHandledcseZdZeffdd ZddZdejdefddZdejdefd d Z d ej defd d Z d ej defddZ defddZ defddZdej defddZdej defddZdej defddZdej defddZdejdefdd Zdejdefd!d"Zd#ejdefd$d%Zdefd&d'Zd(ejdefd)d*Zdefd+d,Zd-ejdefd.d/Zdefd0d1Zd2ejdefd3d4Z defd5d6Z!defd7d8Z"d9d:Z#d;d<Z$d=d>Z%d?d@Z&dAdBZ'dCdDZ(dEdFZ)dGdHZ*dIdJZ+dKdLZ,Z-S)MLoggingMiddlewarecs.t|tjs t|}||_tt|dS)N) isinstanceloggingLogger getLoggerloggersuperr__init__)selfr  __class__r/var/www/www-root/data/www/ovozai.pdev.uz/venv/lib/python3.10/site-packages/aiogram/contrib/middlewares/logging.pyr s  zLoggingMiddleware.__init__cCs2|jdd}|r|jd=tt|dSdS)N_starti)confgetroundtime)robjstartrrr check_timeouts zLoggingMiddleware.check_timeoutupdatedatacs*t|jd<|jd|jddS)NrzReceived update [ID:])rrr debug update_id)rrrrrron_pre_process_updatesz'LoggingMiddleware.on_pre_process_updatec8||}|dkr|jd|jd|ddSdS)NrProcess update [ID:z]: [success] (in  ms)rr infor )rrresultrtimeoutrrron_post_process_update   z(LoggingMiddleware.on_post_process_updatemessagec 0|jd|jd|jjd|jjddS)NzReceived message [ID: ] in chat [:rr r& message_idchattypeid)rr+rrrron_pre_process_message#s.z(LoggingMiddleware.on_pre_process_messagec @|jttt|d|jd|jjd|jjddS)Nz message [ID:r-r.r r r HANDLED_STRboollenr0r1r2r3)rr+resultsrrrron_post_process_message&sz)LoggingMiddleware.on_post_process_messagec r,)NzReceived edited message [ID:r-r.rr/)redited_messagerrrron_pre_process_edited_message*s z/LoggingMiddleware.on_pre_process_edited_messagec r5)Nz edited message [ID:r-r.rr6)rr<r:rrrron_post_process_edited_message.z0LoggingMiddleware.on_post_process_edited_message channel_postc&|jd|jd|jjddS)NzReceived channel post [ID:] in channel [ID:rr r&r0r1r3)rr@rrrron_pre_process_channel_post3z-LoggingMiddleware.on_pre_process_channel_postc r5)Nz channel post [ID:r-r.rr6)rr@r:rrrron_post_process_channel_post7r?z.LoggingMiddleware.on_post_process_channel_postedited_channel_postcrA)Nz!Received edited channel post [ID:rBrrC)rrGrrrr"on_pre_process_edited_channel_post<rEz4LoggingMiddleware.on_pre_process_edited_channel_postc6|jttt|d|jd|jjddS)Nz edited channel post [ID:rBr)r rr7r8r9r0r1r3)rrGr:rrrr#on_post_process_edited_channel_post@ z5LoggingMiddleware.on_post_process_edited_channel_post inline_queryc&|jd|jd|jjddS)NzReceived inline query [ID:] from user [ID:rr r&r3 from_user)rrLrrrron_pre_process_inline_queryErEz-LoggingMiddleware.on_pre_process_inline_queryc6|jttt|d|jd|jjddS)Nz inline query [ID:rNrr rr7r8r9r3rP)rrLr:rrrron_post_process_inline_queryIrKz.LoggingMiddleware.on_post_process_inline_querychosen_inline_resultc s.|jd|jd|jjd|jddS)Nz-Received chosen inline result [Inline msg ID:rN ] result [ID:r)r r&inline_message_idrPr3 result_id)rrUrrrr#on_pre_process_chosen_inline_resultNs z5LoggingMiddleware.on_pre_process_chosen_inline_resultc s>|jttt|d|jd|jjd|jddS)Nz% chosen inline result [Inline msg ID:rNrVr) r rr7r8r9rWrPr3rX)rrUr:rrrr$on_post_process_chosen_inline_resultSsz6LoggingMiddleware.on_post_process_chosen_inline_resultcallback_queryc s|jr9|j}d|jd|jjd|jd|jjd|jjd|j }|jr1|d|jjd}|j|dS|jd|jd|jjd |j d dS) NzReceived callback query [ID:rN] for message [ID:r-r. ] with data:  originally posted by user [ID:rz] for inline message [ID:z] ) r+r3rPr0r1r2rr r&rW)rr[rr+textrrron_pre_process_callback_queryYs, z/LoggingMiddleware.on_pre_process_callback_queryc s|jrA|j}ttt|d|jd|jjd|jd|jjd|jjd|j }|jr9|d|jjd}|j |dS|j ttt|d|jd|jjd |j ddS) Nz callback query [ID:rNr\r-r.r]r^rz]from inline message [ID:)r+r7r8r9r3rPr0r1r2rr r&rrW)rr[r:rr+r_rrron_post_process_callback_queryls4z0LoggingMiddleware.on_post_process_callback_queryshipping_querycrM)NzReceived shipping query [ID:rNrrO)rrbrrrron_pre_process_shipping_queryrEz/LoggingMiddleware.on_pre_process_shipping_querycrR)Nz shipping query [ID:rNrrS)rrbr:rrrron_post_process_shipping_queryrKz0LoggingMiddleware.on_post_process_shipping_querypre_checkout_querycrM)Nz Received pre-checkout query [ID:rNrrO)rrerrrr!on_pre_process_pre_checkout_queryrEz3LoggingMiddleware.on_pre_process_pre_checkout_querycrR)Nz pre-checkout query [ID:rNrrS)rrer:rrrr"on_post_process_pre_checkout_queryrKz4LoggingMiddleware.on_post_process_pre_checkout_querycr")Nrr#z]: [failed] (in r$r%)rrerrorrr(rrron_pre_process_errorr*z&LoggingMiddleware.on_pre_process_errorcs|jd|jddS)NzReceived poll [ID:r)r r&r3)rpollrrrron_pre_process_pollsz%LoggingMiddleware.on_pre_process_pollcs,|jttt|d|jddS)Nz poll [ID:r)r rr7r8r9r3)rrjr:rrrron_post_process_polls*z&LoggingMiddleware.on_post_process_pollcrA)NzReceived poll answer [ID:rNr)r r&poll_iduserr3)r poll_answerrrrron_pre_process_poll_answerrEz,LoggingMiddleware.on_pre_process_poll_answercrI)Nz poll answer [ID:rNr)r rr7r8r9rmrnr3)rror:rrrron_post_process_poll_answers z-LoggingMiddleware.on_post_process_poll_answerc 6|jd|jjd|jd|jddSNz)Received chat member update for user [ID:z]. Old state: z New state:  r r&rPr3old_chat_member to_pythonnew_chat_member)rmy_chat_member_updaterrrron_pre_process_my_chat_memberz/LoggingMiddleware.on_pre_process_my_chat_memberc.|jttt|d|jjddS)Nz my_chat_member for user [ID:rr rr7r8r9rPr3)rryr:rrrron_post_process_my_chat_memberz0LoggingMiddleware.on_post_process_my_chat_memberc rrrsru)rchat_member_updaterrrron_pre_process_chat_memberr{z,LoggingMiddleware.on_pre_process_chat_membercr|)Nz chat_member for user [ID:rr})rrr:rrrron_post_process_chat_memberrz-LoggingMiddleware.on_post_process_chat_membercs(|jd|jjd|jjddS)Nz(Received chat join request for user [ID:] in chat [ID:r)r r&rPr3r1)rchat_join_requestrrrron_pre_chat_join_requests z*LoggingMiddleware.on_pre_chat_join_requestcs8|jttt|d|jjd|jjddS)Nz chat join request for user [ID:rr)r rr7r8r9rPr3r1)rrr:rrrron_post_chat_join_requests z+LoggingMiddleware.on_post_chat_join_request).__name__ __module__ __qualname__r rrUpdatedictr!r)Messager4r;r=r>rDrFrHrJ InlineQueryrQrTChosenInlineResultrYrZ CallbackQueryr`ra ShippingQueryrcrdPreCheckoutQueryrfrgrirkrlrprqrzr~rrrr __classcell__rrrrr sDrcseZdZdZd'fdd Zdejfdd Zd ej fd d Z d dZ dej fddZ dejfddZdejfddZdejfddZdejfddZdejfdd Zd!ejfd"d#Zd$ejfd%d&ZZS)( LoggingFiltera8 Extend LogRecord by data from Telegram Update object. Can be used in logging config: .. code-block: python3 'filters': { 'telegram': { '()': LoggingFilter, 'include_content': True, } }, ... 'handlers': { 'graypy': { '()': GELFRabbitHandler, 'url': 'amqp://localhost:5672/', 'routing_key': '#', 'localname': 'testapp', 'filters': ['telegram'] }, }, tgFcs"tt|j|d||_||_dS)z :param name: :param prefix: prefix for all records :param include_content: pass into record all data from Update object )nameN)r rr prefixinclude_content)rrrrrrrr s zLoggingFilter.__init__recordcCs>tjd}|r||j||D] \}}t|||qdS)zp Extend LogRecord by data from Telegram Update object. :param record: :return: T)rr get_current make_prefixrprocess_updatesetattr)rrrkeyvaluerrrfilters zLoggingFilter.filterrccs$d|jfV|jrdV||jEdH|jr%dV||jEdH|jr4dV||jEdH|jrCdV||jEdH|jrRdV||jEdH|jradV| |jEdH|j rpd V| |j EdH|j rd V| |j EdH|jrd V||jEdHdSdS) zN Parse Update object :param update: :return: r ) update_typer+N)rr<)rr@)rrG)rrL)rrU)rr[)rrb)rre)r r+process_messager<r@rGrLprocess_inline_queryrUprocess_chosen_inline_resultr[process_callback_queryrbprocess_shipping_queryreprocess_pre_checkout_query)rrrrrrs< zLoggingFilter.process_updateccs6|s|EdH|D]\}}|d||fVq dS)zk Add prefix to the label :param prefix: :param iterable: :return: N_r)rriterablerrrrrrs   zLoggingFilter.make_prefixrnccsL|sdSd|jfV|jr"d|jfV|jr$dd|jfVdSdSdS)zK Generate user data :param user: :return: Nuser_iduser_full_name user_name@)r3r full_nameusername)rrnrrr process_user+s  zLoggingFilter.process_userr1ccsX|sdSd|jfVd|jfV|jr(d|jfV|jr*dd|jfVdSdSdS)zK Generate chat data :param chat: :return: Nchat_id chat_type chat_title chat_namer)r3r2rrr)rr1rrr process_chat;s   zLoggingFilter.process_chatr+ccsd|jfV||jEdH||jEdH|jsdS|jr.|d||jEdH|j r>|d||j EdH|j rN|d||j EdH|j rWd|j fV|j r`d|j fV|j rid|j fV|jrrd|jfV|jr{d |jfV|jrd |jp|jfVd |jfVdS|jrd |jjfVdS|jrd |jjfVdS|jrd|jjfVdS|jrd|jjfVdS|jrd|jdjfVdS|jrd|jjfVdS|jrd|jjfVdS|jrd|jjfVdS|jrd|jjfVdS|jrd|jjfVd|jj fVdS|j!r.d|j!j"fVd|j!j#j$fVd|j!j#j%fVdS|j#rBd|j#j$fVd|j#j%fVdS|j&rSddd|j&DfVdS|j'rdddd|j&DfVdS|j(rd |j(jfVd!|j(j)fVd"|j(j*fVd#|j(j+fVd$|j(j,fVdS|j-rd%|j-j+fVd&|j-j,fVd'|j-j.fVd(|j-j/fVd)|j-j0fVd*|j-j1fVdS|j2rd+|j2fVdS|j3rd,|j3fVdS|j4rd-|j4fVdS|j5r|d.|j5EdHdS|j6rd/|j6fVdS|j7r d0|j7djfVdSdS)1Nmessage_content_typereply_to forward_fromforward_from_chatmessage_forward_from_message_idmessage_forward_datemessage_edit_datemessage_media_group_idmessage_author_signaturer_ html_textaudio animationdocumentgamephotorstickervideo video_notevoicecontact_full_namecontact_phone_number venue_addresslocation_latitudelocation_longitudenew_chat_memberscSg|]}|jqSrr3.0rnrrr z1LoggingFilter.process_message..left_chat_membercSrrrrrrrrr invoice_titleinvoice_descriptioninvoice_start_parameterinvoice_currencyinvoice_total_amountsuccessful_payment_currencysuccessful_payment_total_amount"successful_payment_invoice_payload%successful_payment_shipping_option_id-successful_payment_telegram_payment_charge_id-successful_payment_provider_payment_charge_idconnected_websitemigrate_from_chat_idmigrate_to_chat_idpinned_messagenew_chat_titlenew_chat_photo)8 content_typerrPrr1rreply_to_messagerrrrforward_from_message_id forward_date edit_datemedia_group_idauthor_signaturer_captionrrfile_idrrrtitlerrrrrcontactr phone_numbervenueaddresslocationlatitude longituderrinvoice descriptionstart_parametercurrency total_amountsuccessful_paymentinvoice_payloadshipping_option_idtelegram_payment_charge_idprovider_payment_charge_idrrrrrr)rr+rrrrLs      zLoggingFilter.process_messagerLccsrd|jfV||jEdH|jr5d|jfV|jr*d|jjfVd|jjfV|jr7d|jfVdSdSdS)Ninline_query_idinline_query_textrrinline_query_offset) r3rrPrqueryrrroffset)rrLrrrrs  z"LoggingFilter.process_inline_queryrUccs`d|jfV||jEdH|jr,d|jfV|jr.d|jjfVd|jjfVdSdSdS)Nchosen_inline_result_idrrr)rXrrPrrrrr)rrUrrrrs  z*LoggingFilter.process_chosen_inline_resultr[ccs~||jEdHd|jfV|jr |d||jEdH|jr)d|jfV|jr2d|jfV|jr=d|jfVdSdS)Ncallback_query_datacallback_query_message callback_query_inline_message_idcallback_query_chat_instancecallback_query_game_short_name) rrPrr+rrrW chat_instancegame_short_name)rr[rrrrs   z$LoggingFilter.process_callback_queryrbccs:d|jfV||jEdH|jrd|jfVdSdS)Nshipping_query_idshipping_query_invoice_payload)r3rrPrr)rrbrrrrs  z$LoggingFilter.process_shipping_queryreccs^d|jfV||jEdH|jr-d|jfVd|jfVd|jfVd|jfVdSdS)Npre_checkout_query_idpre_checkout_query_currencypre_checkout_query_total_amount"pre_checkout_query_invoice_payload%pre_checkout_query_shipping_option_id)r3rrPrrrrr)rrerrrrs    z(LoggingFilter.process_pre_checkout_query)rrF)rrr__doc__r r LogRecordrrrrrUserrChatrrrrrrrrrrrrrrrrrrrs %\   r) rraiogramraiogram.dispatcher.middlewaresrr7rFilterrrrrrs  <