qj2dZddlZddlZddlZddlZddlmZmZmZddl m Z m Z m Z m Z mZddlmZddlmZdZd Zej(d Zej(d ZGd d ej.ZGddeej2Zy)z? An ``asyncio.Protocol`` subclass for lower level IO handling. N)DequeOptionalcast) SMTPDataErrorSMTPReadTimeoutErrorSMTPResponseExceptionSMTPServerDisconnectedSMTPTimeoutError) SMTPResponse) SMTPStatus) SMTPProtocoli s(?:\r\n|\n|\r(?!\n))s(?m)^\.ceZdZdZddeej fdZddZddZ dee ddfd Z dd Z d ejdd fd Zy)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|_yNF)asyncioget_event_loop_loop_paused collectionsdeque_drain_waiters_connection_lost)selfrs T/var/www/html/kelly-backend/venv/lib/python3.12/site-packages/aiosmtplib/protocol.py__init__zFlowControlMixin.__init__*s> < //1DJDJ ;F;L;L;N %returncd|_yNT)rrs r pause_writingzFlowControlMixin.pause_writing4s  rcxd|_|jD]$}|jr|jd&yr)rrdone set_resultrwaiters rresume_writingzFlowControlMixin.resume_writing7s0 ))F;;=!!$'*rexccd|_|jsy|jD]8}|jr||j d(|j |:yr")rrrr&r' set_exception)rr+r)s rconnection_lostz FlowControlMixin.connection_lost>sN $|| ))F;;=;%%d+((- *rcNK|jr td|jsy|jj }|j j | |d{|j j|y7 #|j j|wxYwwNConnection lost)rConnectionResetErrorrr create_futurerappendremover(s r _drain_helperzFlowControlMixin._drain_helperKs  &'89 9|| ))+ ""6* /LL    & &v .     & &v .s0AB%B"B#B'B%BB""B%streamasyncio.Future[None]ctN)NotImplementedErrorrr7s r_get_close_waiterz"FlowControlMixin._get_close_waiterWs!!rr:r N)__name__ __module__ __qualname____doc__rrAbstractEventLooprr$r* Exceptionr.r6 StreamWriterr=rrrrs_ &Xg&?&?@&( .8I#6 .4 . /"(<(<"AW"rrc eZdZ ddeej ddffd ZdejddfdZddZ e de fd Z d ejddfd Zd eeddffd ZdeddfdZde fdZdeefdZdeefdZddeedefdZdeddfdZdddedeedefdZ ddedeedefdZ d dej<deedeedefdZ xZ!S)!rNrr ct||d|_t|_d|_d|_d|_|jj|_ d|_ y)N)rF) superr _over_ssl bytearray_buffer_response_waiter transport _command_lockrr3_closed _quit_sent)rr __class__s rrzSMTPProtocol.__init__\sW d# { HL:>59/3zz/G/G/I rr7r8c|jSr:)rPr<s rr=zSMTPProtocol._get_close_waiterjs ||rc$|jyr:)_retrieve_response_exceptionr#s r__del__zSMTPProtocol.__del__ms ))+rcjt|jduxr|jj S)z< Check if our transport is still connected. N)boolrN is_closingr#s r is_connectedzSMTPProtocol.is_connectedrs- DNN$.Rt~~7P7P7R3RSSrrNcttj||_|j ddu|_|j j|_tj|_ d|_ y)N sslcontextF) rr TransportrNget_extra_inforJrr3rMLockrOrQ)rrNs rconnection_madezSMTPProtocol.connection_madeysWg//;"11,?tK $ 8 8 :$\\^rr+ct|||jsUtd}|r||_|j r5|j j s|j j|d|_d|_ yr0) rIr.rQr __cause__rMr&r-rNrO)rr+smtp_excrRs rr.zSMTPProtocol.connection_lostsj $-.?@H%("$$T-B-B-G-G-I%%33H=!rdatac|jtd||jjry|jj ||j d}|dk(s||dz|dzdk(ry |j }||jj|yy#t$r%}|jj|Yd}~yd}~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  (FthO  " " ' ' )  D!E* b NQ&!);<D  ;668H#%%00:$ 5  ! ! / / 4 4 5s7B&& C/CCctd}|jr5|jjs|jj|y)NzUnexpected EOF receivedF)r rMr&r-)rr+s r eof_receivedzSMTPProtocol.eof_receiveds@$%>?  )>)>)C)C)E  ! ! / / 4rc|jrN|jjr4|jjs|jjSy)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_exceptionsI  ! !%%**,))335((224 4rcd}t}d}d} |jjd|}|dk(rnt|j||dz}t |t kDrt tjd t|dd }|t |z }t |r|jd|j|d djd |d d d k7rd}n|r6t|t|j!dd}|jd|=|Sy#t$r)t tjjd |dwxYw)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_buffersf+ !\\..uf=N#f~/ABCD4y?*+335H 48} c$i F7|u% NN48>>*5 6AayD #' 58 #eGn++G5FGH WfW%O+ +//554TH= s <D2EtimeoutcK|j td tj|j|d{} |j d|_|S|jj|_|S7;#ttjf$r}t d|d}~wwxYw#|j d|_w|jj|_wxYww)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,A,A7KKF ~~%(,% )- (@(@(B% Lg223 Y&'NOUX X Y~~%(,%(, (@(@(B%sDC!#A<A:A<6C!:A<<B& B!!B&&B))5CC!c|j|jjr tdt|jdst d|jd|jj |y)Nr1writez Transport z does not support writing.)rNrYr hasattrrkr)rrds rrzSMTPProtocol.writesh >> !T^^%>%>%@():; ;t~~w/T^^..HI  T"rrargscTK|j tddj|dz}|j4d{|j||dk(rd|_|j |d{}dddd{|S7M77 #1d{7swYSxYww)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_commands    %()?@ @))D/G+%%% JJw +%"&!///@@H &%& A &%%%sW>34 4    %()?@ @%%% JJ '!///@@H}} 0 00+HMM8;K;KLL~~%)B)B)D,->?? ?&*jj&:&:NN %$3*1 ';'! (+DN?&%BC&@!!'"6"67 W&'LMSVV) =&sxx{3<' ?88!hhqkGNG,W53>  ?1&%%%Bs?GD,G'F<,D.-A2F< .D2D0D2F< G%F:&G.F<0D22F7 E F7#E<< F7*F22F77F<:G<GG G Gr:r>)NN)"r?r@rArrrCrrEr=rVpropertyrXrZ BaseTransportr`rDr.rzrqrs BaseExceptionrUr rnfloatrrrrssl SSLContextstrr __classcell__)rRs@rrr[s59  w001     (<(<AW, TdTT  )>)> 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 BaseProtocolrrFrrrs ((# RZZ 89rzz+& :"w'':"z[#W%9%9[r