Zj9.dZddlZddlZddlZddlZddlmZmZddlm Z m Z m Z m Z m Z ddlmZddlmZdZd Zed zZejd Zejd Zejd ZGddejZGddeejZdS)z? An ``asyncio.Protocol`` subclass for lower level IO handling. N)Callablecast) SMTPDataErrorSMTPReadTimeoutErrorSMTPResponseExceptionSMTPServerDisconnectedSMTPTimeoutError) SMTPResponse) SMTPStatus) SMTPProtocoli s(?:\r\n|\n|\r(?!\n))s(?m)^\.s[\x00-\x1f\x7f]c|eZdZdZddejdzddfdZddZddZde dzddfd Z dd Z d ej dd fd Z dS)FlowControlMixina Reusable flow control logic for StreamWriter.drain(). This implements the protocol methods pause_writing(), resume_writing() and connection_lost(). If the subclass overrides these it must call the super methods. StreamWriter.drain() must wait for _drain_helper() coroutine. Copied from stdlib as per recommendation: https://bugs.python.org/msg343685. Logging and asserts removed, type annotations added. Nloopreturnc|tj|_n||_d|_t j|_d|_dSNF)asyncioget_event_loop_loop_paused collectionsdeque_drain_waiters_connection_lost)selfrs W/var/www/app.qaans.com/backend/venv/lib/python3.11/site-packages/aiosmtplib/protocol.py__init__zFlowControlMixin.__init__0sK < /11DJJDJ     !&cd|_dSNT)rrs r pause_writingzFlowControlMixin.pause_writing<s  r czd|_|jD]+}|s|d,dSr)rrdone set_resultrwaiters rresume_writingzFlowControlMixin.resume_writing?sJ ) ( (F;;== (!!$''' ( (r exccd|_|jsdS|jD]C}|s-||d.||DdSr")rrrr&r' set_exception)rr+r)s rconnection_lostz FlowControlMixin.connection_lostFsv $|  F) . .F;;== .;%%d++++((---  . .r c2K|jrtd|jsdS|j}|j| |d{V|j|dS#|j|wxYw)NConnection lost)rConnectionResetErrorrr create_futurerappendremover(s r _drain_helperzFlowControlMixin._drain_helperSs   :&'899 9|  F))++ ""6*** /LLLLLLL   & &v . . . . .D  & &v . . . .s A::Bstreamasyncio.Future[None]ctN)NotImplementedErrorrr6s r_get_close_waiterz"FlowControlMixin._get_close_waiter_s!!r r9rN)__name__ __module__ __qualname____doc__rAbstractEventLooprr$r* Exceptionr.r5 StreamWriterr<r rrr$s   & &W6= & & & & &(((( .9t#3 . . . . . / / / /"(<"AW""""""r rc eZdZ ddejdzdegdfdzddffd ZdejddfdZd d Z e de fd Z d ej ddfd Zd edzddffd ZdeddfdZde fdZdedzfdZdedzfdZd!dedzdefdZdeddfdZdddededzdefdZ d!dededzdefdZ ddejdedzdedzdefdZ xZ!S)"r Nrconnection_lost_callbackrct|d|_t|_d|_d|_d|_|j |_ d|_ ||_ dS)N)rF) superr _over_ssl bytearray_buffer_response_waiter transport _command_lockrr2_closed_future _quit_sent_connection_lost_callback)rrrG __class__s rrzSMTPProtocol.__init__dst d### {{ EI7;266:j6N6N6P6P)A&&&r r6r7c|jSr9)rPr;s rr<zSMTPProtocol._get_close_waiterts ""r c.|dSr9)_retrieve_response_exceptionr#s r__del__zSMTPProtocol.__del__ws ))+++++r cbt|jduo|j S)z< Check if our transport is still connected. N)boolrN is_closingr#s r is_connectedzSMTPProtocol.is_connected|s/ DN$.Rt~7P7P7R7R3RSSSr rNcttj||_|ddu|_|j|_tj |_ d|_ dS)N sslcontextF) rr TransportrNget_extra_inforJrr2rMLockrOrQ)rrNs rconnection_madezSMTPProtocol.connection_mades_g/;;"11,??tK $ 8 8 : :$\^^r r+ct||jr|jsq|jr8|jt tjj dn2td}|r||_ |j |d|_ d|_|jr|dSdS)Nr0)rIr.rMr&rQr'r r closingvaluer __cause__r-rNrOrR)rr+smtp_excrSs rr.zSMTPProtocol.connection_losts $$$  >)>)C)C)E)E > >%00 !3!92>>22CDD-),H&%33H===!  ) -  * * , , , , , - -r datac|jtd||jrdS|j|t |jt krC|jdd=|jttj j ddS| d}|dks||dz|dzdkrdS | }||j|dSdS#t$r%}|j|Yd}~dSd}~wwxYw)Nz4data_received called without a response waiter set: Response too long r-)rM RuntimeErrorr&rLextendlenMAX_RESPONSE_LENGTHr-rr invalid_responsererfind_read_response_from_bufferr'rC)rrhlast_linebreakresponser+s r data_receivedzSMTPProtocol.data_receiveds  (OtOO  " ' ' ) )  F D!!! t|  2 2 2 QQQ  ! / /%/57J    FE** b NQ&!);;<DD F ;6688H#%00:::::$# 5 5 5  ! / / 4 4 4 4 4 4 4 4 4 5s!D ED??Ectd}|jr3|js|j|dS)NzUnexpected EOF receivedF)r rMr&r-)rr+s r eof_receivedzSMTPProtocol.eof_receivedsO$%>??   5)>)C)C)E)E 5  ! / / 4 4 4ur c|jrK|jr2|js|jSdS)z Return any exception that has been set on the response waiter. Used to avoid 'Future exception was never retrieved' warnings N)rMr& cancelled exceptionr#s rrVz)SMTPProtocol._retrieve_response_exceptions[  ! 5%**,, 5)3355 5 (2244 4tr cTd}t}d}d} |jd|}|dkrn0t|j||dz}t |t krt tjj d t|dd }nH#t$r;| d d }t tjj d |dwxYw|t |z }t |r| d| |ddd|d ddkrd}nS|r=t|t| d d}|jd|=|SdS)z7Parse the actual response (if any) from the data bufferrlrFTrkrrjNrmzutf-8ignore)errorszMalformed SMTP response line: rs rnsurrogateescape)rKrLfindbytesrqMAX_LINE_LENGTHrr rsreint ValueErrordecoderpstripr ) rcodemessageoffsetmessage_completeline_end_indexline error_textrws rruz'SMTPProtocol._read_response_from_buffers++  !\..uf==N##f~/A&ABCCD4yy?**+/57J 48}}   ![[[BB +/5AZAA  c$ii F7|| &u%%% NN48>>*55 6 6 6AaCyD  #' 7 :  #eGnn++G5FGGH WfW%O4s B((AC-timeoutcK|jtd tj|j|d{V}n.#ttjf$r}t d|d}~wwxYw |jd|_nQ|j|_n2#|jd|_n|j|_wxYw|S)a Get a status response from the server. This method must be awaited once per command sent; if multiple commands are written to the transport without awaiting, response data will be lost. Returns an :class:`.response.SMTPResponse` namedtuple consisting of: - server response code (e.g. 250, or such, if all goes well) - server response string (multiline responses are converted to a single, multiline string). Nr0z%Timed out waiting for server response) rMr rwait_for TimeoutErrorrrNrr2)rrresultr+s r read_responsezSMTPProtocol.read_responses  (():;; ; C"+D,A7KKKKKKKKFFg23 Y Y Y&'NOOUX X Y  ~%(,%%(, (@(@(B(B%%~%(,%%(, (@(@(B(B%BBBB s& ;BA&A!!A&&B/Cc&|j|jrtd ttj|j|dS#ttf$rtd|jddwxYw)Nr0z Transport z does not support writing.) rNrZr rrWriteTransportwriteAttributeErrorr:ro)rrhs rrzSMTPProtocol.write"s > !T^%>%>%@%@ !():;; ;  ' 8 8 > >t D D D D D 34   IT^III  s 2A%%+BrargscK|D]+}t|rtd,|jt dd|dz}|j4d{V|||dkrd|_||d{V}dddd{Vn#1d{VswxYwY|S) zj Sends an SMTP command along with any args to the server, and returns a response. z3Command arg contains a prohibited control characterNServer not connected  sQUIT Tr) COMMAND_INJECTION_REGEXsearchrrOr joinrrQr)rrrargcommandrws rexecute_commandzSMTPProtocol.execute_command.s X XC&--c22 X !VWWW X   %()?@@ @))D//G+% A A A A A A A A JJw   +%%"&!///@@@@@@@@H  A A A A A A A A A A A A A A A A A A A A A A A A A A As,?B== C CrcK|jtdtd|}td|}|ds|dz }|dz }|j4d{V|d||d{V}|jtj krt|j|j ||||d{V}|jtj krt|j|j  dddd{Vn#1d{VswxYwY|S)z Sends an SMTP DATA command to the server, followed by encoded message content. Automatically quotes lines beginning with a period per RFC821. Lone \\r and \\n characters are converted to \\r\\n characters. Nrrs..s. sDATA r)rOr LINE_ENDINGS_REGEXsub PERIOD_REGEXendswithrrrr start_inputrr completed)rrrstart_responserws rexecute_data_commandz!SMTPProtocol.execute_data_commandFs   %()?@@ @$(('::""5'22((  w G8% E E E E E E E E JJ{ # # ##'#5#5g#5#F#FFFFFFFN"j&<<<#N$79OPPP JJw   !///@@@@@@@@H} 444#HM83CDDDD E E E E E E E E E E E E E E E E E E E E E E E E E E Es;CE EE tls_contextserver_hostnamec ^K|jrtd|jtd|j4d{V|d||d{V}|jtjkrt|j|j |j |j rtd|j dd= |jt!t"j|j ||d||d{V}nh#t&t"jf$r}t)d |d}~wt*$r}t)d |d}~wt,$r}td |d}~wwxYw||_ dddd{Vn#1d{VswxYwY|S) zG Puts the connection to the SMTP server into TLS mode. zAlready using TLS.Nrs STARTTLS rr0F) server_siderssl_handshake_timeoutz#Timed out while upgrading transportz,Connection aborted while upgrading transportz*Connection reset while upgrading transport)rJrorOr rrrr readyrrrNrZrLr start_tlsrrrrr ConnectionAbortedErrorConnectionError)rrrrrw tls_transportr+s rrzSMTPProtocol.start_tlsfs > 5344 4   %()?@@ @%& +& +& +& +& +& +& +& + JJ ' ' '!///@@@@@@@@H} 000+HM8;KLLL~%)B)B)D)D%,->??? QQQ &*j&:&:/@@ %$3*1 ';''!!!!!! !'"67 W W W&'LMMSVV)   &B#   ,@  +DNM& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +& +PsOBFADFF1E FE F+E;;F F F&)F&)NNr=r9)"r>r?r@rrBrrrDr<rWpropertyrYr[ BaseTransportrarCr.rrxrz BaseExceptionrVr rufloatrrrrssl SSLContextstrr __classcell__)rSs@rr r cs26>BBB'$.B#+2t8"4t";B  BBBBBB #(<#AW####,,,, TdTTTXT  )> 4    -9t#3-------(";%";D";";";";Hd md.B    +L4,?++++Z54<<8 % D    59%*T\ 27;',t| F'+ $ 66^6t6 6  66666666r r )rArrrertypingrrrrrrr r rwr r __all__rrrcompilerrrProtocolr BaseProtocolr rEr rrs !!!!!!!!#""""" &)RZ 899rz+&& $"*%899<"<"<"<"<"w'<"<"<"~yyyyy#W%9yyyyyr