iL4dZddlZddlZddlZddlZddlmZmZddlm Z m Z m Z m Z m Z ddlmZddlmZdZd Zejd Zejd ZGd d ejZGddeejZdS)z? An ``asyncio.Protocol`` subclass for lower level IO handling. N)Callablecast) SMTPDataErrorSMTPReadTimeoutErrorSMTPResponseExceptionSMTPServerDisconnectedSMTPTimeoutError) SMTPResponse) SMTPStatus) SMTPProtocoli s(?:\r\n|\n|\r(?!\n))s(?m)^\.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 ]/var/www/html/jarvis.com/web/backend/venv/lib/python3.11/site-packages/aiosmtplib/protocol.py__init__zFlowControlMixin.__init__*sK < /11DJJDJ     !&cd|_dSNT)rrs r pause_writingzFlowControlMixin.pause_writing6s  rczd|_|jD]+}|s|d,dSr)rrdone set_resultrwaiters rresume_writingzFlowControlMixin.resume_writing9sJ ) ( (F;;== (!!$''' ( (rexccd|_|jsdS|jD]C}|s-||d.||DdSr!)rrrr%r& set_exception)rr*r(s rconnection_lostz FlowControlMixin.connection_lost@sv $|  F) . .F;;== .;%%d++++((---  . .rc2K|jrtd|jsdS|j}|j| |d{V|j|dS#|j|wxYwNConnection lost)rConnectionResetErrorrr create_futurerappendremover's r _drain_helperzFlowControlMixin._drain_helperMs   :&'899 9|  F))++ ""6*** /LLLLLLL   & &v . . . . .D  & &v . . . .s A::Bstreamasyncio.Future[None]ctN)NotImplementedErrorrr6s r_get_close_waiterz"FlowControlMixin._get_close_waiterYs!!rr9rN)__name__ __module__ __qualname____doc__rAbstractEventLooprr#r) Exceptionr-r5 StreamWriterr<rrrrs   & &W6= & & & & &(((( .9t#3 . . . . . / / / /"(<"AW""""""rrc 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__^st d### {{ EI7;266:j6N6N6P6P)A&&&rr6r7c|jSr9)rPr;s rr<zSMTPProtocol._get_close_waiterns ""rc.|dSr9)_retrieve_response_exceptionr"s r__del__zSMTPProtocol.__del__qs ))+++++rcbt|jduo|j S)z< Check if our transport is still connected. N)boolrN is_closingr"s r is_connectedzSMTPProtocol.is_connectedvs/ DN$.Rt~7P7P7R7R3RSSSrrNcttj||_|ddu|_|j|_tj |_ d|_ dS)N sslcontextF) rr TransportrNget_extra_inforJrr2rMLockrOrQ)rrNs rconnection_madezSMTPProtocol.connection_made}s_g/;;"11,??tK $ 8 8 : :$\^^rr*cRt||jsRtd}|r||_|jr3|js|j|d|_d|_ |j r| dSdSr/) rIr-rQr __cause__rMr%r,rNrOrR)rr*smtp_excrSs rr-zSMTPProtocol.connection_losts $$$ >-.?@@H )%("$ >T-B-G-G-I-I >%33H===!  ) -  * * , , , , , - -rdatac|jtd||jrdS|j||d}|dks||dz|dzdkrdS |}||j|dSdS#t$r%}|j |Yd}~dSd}~wwxYw)Nz4data_received called without a response waiter set:  -) rM RuntimeErrorr%rLextendrfind_read_response_from_bufferr&rCr,)rrelast_linebreakresponser*s r data_receivedzSMTPProtocol.data_receiveds+  (OtOO  " ' ' ) )  F D!!!E** b NQ&!);;<DD F ;6688H#%00:::::$# 5 5 5  ! / / 4 4 4 4 4 4 4 4 4 5sB55 C$?CC$ctd}|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 4urc|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 4trcJd}t}d}d} |jd|}|dkrn+t|j||dz}t |t krt tjd t|dd }nH#t$r;| d d }t tj j d |dwxYw|t |z }t |r|d||ddd|d ddkrd}nN|r=t!|t| d d}|jd|=|SdS)z7Parse the actual response (if any) from the data bufferrhrFTrgrzResponse too longNrizutf-8ignore)errorszMalformed SMTP response line: rjs rksurrogateescape)rKrLfindbyteslenMAX_LINE_LENGTHrr unrecognized_commandint ValueErrordecodeinvalid_responsevaluermstripr ) rcodemessageoffsetmessage_completeline_end_indexline error_textrqs rroz'SMTPProtocol._read_response_from_buffers++  !\..uf==N##f~/A&ABCCD4yy?**+35H 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:rl)rres rrzSMTPProtocol.writes > !T^%>%>%@%@ !():;; ;  ' 8 8 > >t D D D D D 34   IT^III  s 2A%%+BrargscDK|jtdd|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. NServer not connected  sQUIT Tr)rOr joinrrQr)rrrcommandrqs rexecute_commandzSMTPProtocol.execute_commandsb   %()?@@ @))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 BBrcK|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_responserqs rexecute_data_commandz!SMTPProtocol.execute_data_command1s   %()?@@ @$(('::""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 JK|jrtd|jtd|j4d{V|d||d{V}|jtjkrt|j|j |j |j rtd |j tt 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)rJrlrOr rrrr readyrrrNrZr start_tlsrrrrr ConnectionAbortedErrorConnectionError)rrrrrq tls_transportr*s rrzSMTPProtocol.start_tlsQs > 5344 4   %()?@@ @% + + + + + + + + JJ ' ' '!///@@@@@@@@H} 000+HM8;KLLL~%)B)B)D)D%,->??? &*j&:&:/@@ %$3*1 ';''!!!!!! !'"67 W W W&'LMMSVV)   &B#   ,@  +DN? + + + + + + + + + + + + + + + + + + + + + + + + + + +BsOBF ADFE6'D77 E6E E6!E11E66 F FF)NNr=r9)"r>r?r@rrBrrrDr<rWpropertyrYr[ BaseTransportrarCr-r}rrrt BaseExceptionrVr rofloatrrrrssl SSLContextstrr __classcell__)rSs@rr r ]s26>BBB'$.B#+2t8"4t";B  BBBBBB #(<#AW####,,,, TdTTTXT  )> 4    -9t#3-------";%;D;;;;6d md.B    +L4,?++++Z54<<8 % D    59%*T\ ,7;',t| F'+ $ //^/t/ /  ////////rr )rArrrertypingrrrzrrrr r rqr r __all__rcompilerrProtocolr BaseProtocolr rErrrs` !!!!!!!!#""""" RZ 899rz+&& <"<"<"<"<"w'<"<"<"~ccccc#W%9cccccr