python (3.11.7)
e2- d Z ddlZddlmZ ddlmZ dZ eeed G d d ej Z G d
d Z
d Z dS )
a A class supporting chat-style (command/response) protocols.
This class adds support for 'chat' style protocols - where one side
sends a 'command', and the other sends a response (examples would be
the common internet protocols - smtp, nntp, ftp, etc..).
The handle_read() method looks at the input stream for the current
'terminator' (usually '\r\n' for single-line responses, '\r\n.\r\n'
for multi-line output), calling self.found_terminator() on its
receipt.
for example:
Say you build an async nntp client using this class. At the start
of the connection, you'll have self.terminator set to '\r\n', in
order to process the single-line greeting. Just before issuing a
'LIST' command you'll set it to '\r\n.\r\n'. The output of the LIST
command will be accumulated (using your own 'collect_incoming_data'
method) up to the terminator, and then control will be returned to
you - by calling your self.found_terminator() method.
N)deque) _deprecatedznThe {name} module is deprecated and will be removed in Python {remove}. The recommended replacement is asyncio) )removec e Zd ZdZdZdZdZdZddZd Z d Z
d Z d
Z d Z
d Zd
Zd Zd Zd Zd Zd Zd Zd Zd Zd ZdS )
async_chatzThis is an abstract class. You must derive from this class, and add
the two methods collect_incoming_data() and found_terminator()i r zlatin-1Nc d| _ g | _ t | _ t j | || d S N ) ac_in_bufferincomingr
producer_fifoasyncore
dispatcher__init__)selfsockmaps </BuggyBox/python/3.11.7/bootstrap/lib/python3.11/asynchat.pyr zasync_chat.__init__J sB
#WW$$T455555r c t d Nz must be implemented in subclassNotImplementedErrorr datas r collect_incoming_dataz async_chat.collect_incoming_dataX !"CDDDr c : | j | d S N)r appendr s r _collect_incoming_dataz!async_chat._collect_incoming_data[ s
T"""""r c N d | j }| j d d = |S r )joinr )r ds r _get_datazasync_chat._get_data^ s( HHT] # # M!!! r c t d r r r s r found_terminatorzasync_chat.found_terminatorc r r c t |t r | j rt || j }n*t |t
r|dk rt
d || _ dS )zdSet the input delimiter.
Can be a fixed string of any length, an integer, or None.
r z-the number of received bytes must be positiveN)
isinstancestr use_encodingbytesencodingint
ValueError
terminator)r terms r set_terminatorzasync_chat.set_terminatorf sj
dC NT%6 Nt}--DD
c
"
" Ntaxx LMM M r c | j S r )r2 r( s r get_terminatorzasync_chat.get_terminatorq s
r c | | j }n1# t $ r Y d S t $ r | Y d S w xY wt |t r!| j rt t | j }| j
|z | _
| j
rt | j
}| }|s#|
| j
d| _
nt |t r|}||k r2|
| j
d| _
| j |z
| _ nM|
| j
d | | j
|d | _
d| _ | nt | }| j
| }|dk rT|dk r"|
| j
d | | j
||z d | _
| nxt% | j
| }|r@||k r8|
| j
d | | j
| d | _
d S |
| j
d| _
| j
d S d S )Nr r )recvac_in_buffer_sizeBlockingIOErrorOSError handle_errorr+ r, r- r. r/ r
lenr6 r r0 r2 r) findfind_prefix_at_end)r r lbr2 nterminator_lenindexs r handle_readzasync_chat.handle_ready s 99T 344DD FF FF dC -T%6 -dm,,D - 4 3 0T&''B ,,..J 0
0**4+<===$'!!J,, ,
0 66..t/@AAA(+D%&*o&:DOO..t/@!/DEEE(,(9!""(=D%&'DO))++++ "%Z )..z::B;; qyy 2243DVeV3LMMM(,(9%:N:O:O(PD% ))++++ /t/@* M ME 0 B;; 6 6t7H5&7Q R R R040A5&''0JD - 2243DEEE,/)g 3 0 3 0 3 0 3 0 3 0s
A A
A c . | d S r )
initiate_sendr( s r handle_writezasync_chat.handle_write s r c . | d S r )closer( s r handle_closezasync_chat.handle_close s
r c t |t t t f s t dt | | j }t | |k rGt dt | | D ]'}| j
||||z (n| j
| | d S )Nz#data argument must be byte-ish (%r)r ) r+ r. bytearray
memoryview TypeErrortypeac_out_buffer_sizer> ranger r! rG )r r sabsis r pushzasync_chat.push s $ : >?? ( A JJ( (
(& t99t 1c$ii..
:
:"))$q4x.9999
:
% %d + + + r c b | j | | d S r )r r! rG )r producers r push_with_producerz async_chat.push_with_producer s1 !!(+++ r c dS )z4predicate for inclusion in the readable for select() r( s r readablezasync_chat.readable s qr c | j p| j S )z4predicate for inclusion in the writable for select())r connectedr( s r writablezasync_chat.writable s !9$.&89r c : | j d dS )zAautomatically close this channel once the outgoing queue is emptyN)r r! r( s r close_when_donezasync_chat.close_when_done s !!$'''''r c | j rE| j r?| j d }|s | j d= || d S | j } |d | }nI# t $ r< | }|r| j | n| j d= Y w xY wt |t r | j rt || j } | | }n%# t $ r | Y d S w xY w|rA|t | k s|t | k r||d | j d< n| j d= d S d S d S )Nr )r r^ rK rQ rO more
appendleftr+ r, r- r. r/ sendr< r= r> )r firstobsr num_sents r rG zasync_chat.initiate_send s % T^ % &q)E
&q)=%%'''F )C
TcT{
zz|| .&11$7777 *1-
$$$
2):
2 T4=11
99T??
!!###
.c$ii''3U+;+;,1()),<D&q)) *1- FK% % % % s%
A ABBC$ $ DDc Z d| _ | j d d = | j d S r )r
r r clearr( s r discard_bufferszasync_chat.discard_buffers s3 M!!! """""r )NN)__name__
__module__ __qualname____doc__r: rQ r- r/ r r r" r& r) r4 r6 rE rH rK rU rX r\ r_ ra rG rk r[ r r r r ; sI F F
LH 6 6 6 6 E E E# # #
E E E F0 F0 F0P
: : :( ( (& & &P# # # # #r r c e Zd ZddZd ZdS )simple_producer c " || _ || _ d S r )r buffer_size)r r rt s r r zsimple_producer.__init__ s &r c t | j | j k r/| j d | j }| j | j d | _ |S | j }d| _ |S r )r> r rt )r results r rc zsimple_producer.more s\ ty>>D , , ,Y 0 0 01F $"2"3"34DIMYFDIMr N)rr )rl rm rn r rc r[ r r rq rq s7 ' ' ' ' r rq c t | dz
}|rA| |d | s$|dz }|r | |d | $|S )NrZ )r> endswith)haystackneedlels r r@ r@ 6 sk F aA
H%%fRaRj11 Q H%%fRaRj11 Hr ) ro r collectionsr warningsr _DEPRECATION_MSGrl r r rq r@ r[ r r <module>r s 8 ( N H&w 7 7 7 7X# X# X# X# X#$ X# X# X#v @
r 
Browse
Usage
Versions