=h3dZddlZddlZddlZddlZddlmZmZddlm Z m Z m Z m Z m Z ddlmZddlmZdZd Zej&d Zej&d ZGd d ej,ZGddeej0Zy)z? An ``asyncio.Protocol`` subclass for lower level IO handling. N)Optionalcast) 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 c/var/www/html/phonemate/phone_mate_backend/venv/lib/python3.12/site-packages/aiosmtplib/protocol.py__init__zFlowControlMixin.__init__*sC < //1DJDJ     !&returncd|_yNT)rrs r pause_writingzFlowControlMixin.pause_writing6s  rcxd|_|jD]$}|jr|jd&yr)rrdone set_resultrwaiters rresume_writingzFlowControlMixin.resume_writing9s0 ))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_helperMs  &'89 9|| ))+ ""6* /LL    & &v .     & &v .s0AB%B"B#B'B%BB""B%streamasyncio.Future[None]ctN)NotImplementedErrorrr6s r_get_close_waiterz"FlowControlMixin._get_close_waiterYs!!rr9rN)__name__ __module__ __qualname____doc__rrAbstractEventLooprr#r) Exceptionr-r5 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)!r Nrrct||d|_t|_d|_d|_d|_|jj|_ d|_ y)N)rF) superr _over_ssl bytearray_buffer_response_waiter transport _command_lockrr2_closed_future _quit_sent)rr __class__s rrzSMTPProtocol.__init__^sX d# { HL:>596:jj6N6N6Prr6r7c|jSr9)rOr;s rr<zSMTPProtocol._get_close_waiterls"""rc$|jyr9)_retrieve_response_exceptionr"s r__del__zSMTPProtocol.__del__os ))+rcjt|jduxr|jj S)z< Check if our transport is still connected. N)boolrM is_closingr"s r is_connectedzSMTPProtocol.is_connectedts- DNN$.Rt~~7P7P7R3RSSrrMcttj||_|j ddu|_|j j|_tj|_ d|_ y)N sslcontextF) rr TransportrMget_extra_inforIrr2rLLockrNrP)rrMs rconnection_madezSMTPProtocol.connection_made{sWg//;"11,?tK $ 8 8 :$\\^rr*ct|||jsUtd}|r||_|j r5|j j s|j j|d|_d|_ yr/) rHr-rPr __cause__rLr%r,rMrN)rr*smtp_excrQs 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:  -) rL RuntimeErrorr%rKextendrfind_read_response_from_bufferr&rCr,)rrclast_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 rLr%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)rLr% cancelled exceptionr"s rrTz)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|ddjd|d ddk7rd}n|r6t!|t|jd d}|jd|=|Sy#t$r<|jd d }t tjjd |dwxYw)z7Parse the actual response (if any) from the data bufferrfrFTrerzResponse too longNrgzutf-8ignore)errorszMalformed SMTP response line: rhs risurrogateescape)rJrKfindbyteslenMAX_LINE_LENGTHrr unrecognized_commandint ValueErrordecodeinvalid_responsevaluerkstripr ) rcodemessageoffsetmessage_completeline_end_indexline error_textros rrmz'SMTPProtocol._read_response_from_buffersx+ !\\..uf=N#f~/ABCD4y?*+335H 48} c$i F7|u% NN48>>*5 6AayD #' 7: #eGn++G5FGH WfW%O- ![[[B +//554ZLA s <DAE!timeoutcK|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). Nr0z%Timed out waiting for server response) rLr rwait_for TimeoutErrorrrMrr2)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 td ttj |jj |y#ttf$rtd|jddwxYw)Nr0z Transport z does not support writing.) rMrXr rrWriteTransportwriteAttributeErrorr:rj)rrcs rrzSMTPProtocol.write s >> !T^^%>%>%@():; ;  '' 8 > >t D 34 T^^..HI  s 3A''*BrargscTK|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)rNr joinrrPr)rrrcommandros rexecute_commandzSMTPProtocol.execute_commands    %()?@ @))D/G+%%% JJw +%"&!///@@H &%& A &%%%sW>34 4    %()?@ @%%% JJ '!///@@H}} 0 00+HMM8;K;KLL~~%)B)B)D,->?? &*jj&:&://@ %$3*1 ';'! (+DN?&%BC&@!!'"6"67 W&'LMSVV) &B# ,@ 5&%%%Bs?GEG'F*,E-A2F* AE &E 'E +F*2 G=F(>GF* E  F%$ E00 F%< F F% F  F%%F*(G*F=0F3 1F=8Gr9r=)NN)"r>r?r@rrrBrrDr<rUpropertyrWrY BaseTransportr_rCr-r{rprr BaseExceptionrTr rmfloatrrrrssl SSLContextstrr __classcell__)rQs@rr r ]s59  w001     #(<(<#AW#, TdTT  )>)> 4  "8I#6 "4 ";%;D;6d h}.E +H\,B+Z8E?l8 % D 8<%-e_ ,:>'/ F*.#' /^^/"#/% /  /rr )rArrrertypingrrrxrrrr r ror r __all__r}compilerrProtocolr BaseProtocolr rErrrs !# RZZ 89rzz+& <"w''<"~^#W%9%9^r