h2dZddlZddlZddlZddlZddlmZmZmZddl m Z m Z m Z m Z mZddlmZddlmZdZd Zejd Zejd ZGd d ejZGddeejZdS)z? An ``asyncio.Protocol`` subclass for lower level IO handling. N)DequeOptionalcast) SMTPDataErrorSMTPReadTimeoutErrorSMTPResponseExceptionSMTPServerDisconnectedSMTPTimeoutError) SMTPResponse) SMTPStatus) SMTPProtocoli s(?:\r\n|\n|\r(?!\n))s(?m)^\.ceZdZdZddeejfdZddZddZ dee ddfd Z dd Z d ej dd fd ZdS)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. Nloopc|tj|_n||_d|_t j|_d|_dSNF)asyncioget_event_loop_loop_paused collectionsdeque_drain_waiters_connection_lost)selfrs `/var/www/html/web-builder-api.evdpl.com/venv/lib/python3.11/site-packages/aiosmtplib/protocol.py__init__zFlowControlMixin.__init__)sF < /11DJJDJ ;F;L;N;N %returncd|_dSNT)rrs r pause_writingzFlowControlMixin.pause_writing3s  rczd|_|jD]+}|s|d,dSr)rrdone set_resultrwaiters rresume_writingzFlowControlMixin.resume_writing6sJ ) ( (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_helperJs   :&'899 9|  F))++ ""6*** /LLLLLLL   & &v . . . . .D  & &v . . . .s A::Bstreamasyncio.Future[None]ctN)NotImplementedErrorrr7s r_get_close_waiterz"FlowControlMixin._get_close_waiterVs!!rr:r N)__name__ __module__ __qualname____doc__rrAbstractEventLooprr$r* Exceptionr.r6 StreamWriterr=rrrrs  &&Xg&?@&&&&(((( .8I#6 .4 . . . . / / / /"(<"AW""""""rrc eZdZ ddeejddffd ZdejddfdZddZ e de fd Z d ej ddfd Zd eeddffd ZdeddfdZde fdZdeefdZdeefdZddeedefdZdeddfdZdddedeedefdZ ddedeedefdZ d dejdeedeedefdZ xZ!S)!rNrr ct|d|_t|_d|_d|_d|_|j |_ d|_ dS)N)rF) superr _over_ssl bytearray_buffer_response_waiter transport _command_lockrr3_closed _quit_sent)rr __class__s rrzSMTPProtocol.__init__[si d### {{ HL:>59/3z/G/G/I/I rr7r8c|jSr:)rPr<s rr=zSMTPProtocol._get_close_waiteris |rc.|dSr:)_retrieve_response_exceptionr#s r__del__zSMTPProtocol.__del__ls ))+++++rcbt|jduo|j S)z< Check if our transport is still connected. N)boolrN is_closingr#s r is_connectedzSMTPProtocol.is_connectedqs/ DN$.Rt~7P7P7R7R3RSSSrrNcttj||_|ddu|_|j|_tj |_ d|_ dS)N sslcontextF) rr TransportrNget_extra_inforJrr3rMLockrOrQ)rrNs rconnection_madezSMTPProtocol.connection_madexs_g/;;"11,??tK $ 8 8 : :$\^^rr+ct||jsRtd}|r||_|jr3|js|j|d|_d|_ dSr0) rIr.rQr __cause__rMr&r-rNrO)rr+smtp_excrRs 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'rDr-)rrdlast_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 rrUz)SMTPProtocol._retrieve_response_exceptions[  ! 5%**,, 5)3355 5 (2244 4trcd}t}d}d} |jd|}|dkrnt|j||dz}t |t krt tjd t|dd }n1#t$r$t tj j d |dwxYw|t |z }t |r| d| |d dd |d d d krd}n7|r=t|t|dd}|jd|=|SdS)z7Parse the actual response (if any) from the data bufferrgrFTrfrzResponse too longNrhzMalformed SMTP response line: ris rjzutf-8surrogateescape)rKrLfindbyteslenMAX_LINE_LENGTHr r unrecognized_commandint ValueErrorinvalid_responsevaluerlstripr decode)rcodemessageoffsetmessage_completeline_end_indexlinerps rrnz'SMTPProtocol._read_response_from_buffers++  !\..uf==N##f~/A&ABCCD4yy?**+35H 48}}   +/5=T==  c$ii F7|| &u%%% NN48>>*55 6 6 6AaCyD  #' 5 8  #eGnn++G5FGGH WfW%O4s B##.CtimeoutcK|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). Nr1z%Timed out waiting for server response) rMr rwait_for TimeoutErrorrrNrr3)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|jrtdt|jdst d|jd|j|dS)Nr1writez Transport z does not support writing.)rNrYr hasattrrkr)rrds rrzSMTPProtocol.writes > !T^%>%>%@%@ !():;; ;t~w// IT^III  T"""""rrargscDK|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)rrrcommandrps 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_responserps rexecute_data_commandz!SMTPProtocol.execute_data_command&s   %()?@@ @$(('::""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 |j ||d||d{V}n#tt jf$r}t#d |d}~wt$$r }t#|jd |d}~wt($r,}|jr|jd }nd }t||d}~wwxYw||_ dddd{Vn#1d{VswxYwY|S) zG Puts the connection to the SMTP server into TLS mode. zAlready using TLS.Nrs STARTTLS rr1F) server_siderssl_handshake_timeoutz#Timed out while upgrading transportrz.Connection was reset while upgrading transport)rJrkrOr rrrr readyr rrNrYr start_tlsrrr ConnectionAbortedErrorrr2)rrrrrp tls_transportr+rs rrzSMTPProtocol.start_tlsFs > 5344 4   %()?@@ @% + + + + + + + + JJ ' ' '!///@@@@@@@@H} 000+HM8;KLLL~%)B)B)D)D%,->??? ?&*j&:&:N %$3*1 ';''!!!!!! !'"67 W W W&'LMMSVV) = = =&sx{33<' ? ? ?8O!hqkGGNG,W553>  ?+DN? + + + + + + + + + + + + + + + + + + + + + + + + + + +BsNBF +C98F9FD F,E F'E;;F F F&)F&r:r>)NN)"r?r@rArrrCrrEr=rVpropertyrXrZ BaseTransportr`rDr.rzrqrs BaseExceptionrUr rnfloatrrrrssl SSLContextstrr __classcell__)rRs@rrrZs59   w01          (<AW,,,, TdTTTXT  )> 4     "8I#6 "4 " " " " " ";%;D;;;;6d h}.E    *H\,B****X8E?l8#%#D####8<%-e_ ,:>'/ F*.#' //^/"#/% /  ////////rr)rBrrrertypingrrrerrorsrrr r r rpr r __all__r|compilerrProtocolr BaseProtocolrrFrrrsf ((((((((((#""""" RZ 899rz+&& :":":":":"w':":":"z[[[[[#W%9[[[[[r