y v d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl m Z d dl
mZ d dlmZ d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZmZm Z m Z m Z m Z m Z m!Z! d d l"m#Z#m$Z$ d d l%m&Z& n
# e'$ r dZ&Y nw xY wd dl(Z)d d
l)m*Z* d dl+m,Z, d dl-m.Z/ d dl0m1Z1m2Z2m3Z3m4Z4m5Z5 ddl*m6Z6m7Z7 ddl8m9Z9 ddl:m;Z;mm?Z?m@Z@mAZA d dlBmCZC eCd ZDn
# eE$ r dZDY nw xY wdZF ejG eH ZIdZJdZKdZLd ZMd ZNd ZOd ZPd ZQ eReQ ZSd!ZTd"ZUd#ZVeMeQz ZWeNeQz ZXd$ZYd%ZZd&Z[d'Z\d(Z]d)Z^d'Z_d*Z`d+Zad,Zbd'Zcd-Zdd+Ze efd. Zg eReg Zhd/Zid0Zjd1Zke g ed f Zle eEged f Zme g e!efenf f Zoe epgenf Zqe g epf Zr G d2 d3e Zse!epe epepf esef Zte G d4 d5 Zue G d6 d7 Zve e eu e epef ge e eu ewf f Zx G d8 d9 ZydAd>Zz G d? d@ Z{dS )B ) annotationsN)
UserString) dataclass) BytesParser)BytesIO)Path)shuffle) token_hex)Any AwaitableCallableDictListOptionalTupleUnion) ParseResulturlparse) parse_email)errors)NUID)command)AUTHORIZATION_VIOLATIONPERMISSIONS_ERRPONGSTALE_CONNECTIONParser )ErrInvalidUserCredentialsErrStaleConnection)Msg) DEFAULT_SUB_PENDING_BYTES_LIMIT DEFAULT_SUB_PENDING_MSGS_LIMIT Subscription) TcpTransport TransportWebSocketTransport)versionznats-pyz0.0.0python3s INFOs CONNECTs PINGs PONGs +OKs -ERRs
s _INBOXi i < x i i
s NATS/1.0503100 c e Zd ZdS )RawCredentialsN)__name__
__module__ __qualname__ o/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/nats/aio/client.pyr6 r6 s s Dr; r6 c , e Zd ZU dZded< dZded< dS )ServerzA
Server represents a NATS server in the connection pool.
r urir int
reconnectsN)r7 r8 r9 __doc____annotations__rA r: r; r< r> r> z s; Jr; r> c r e Zd ZU dZded< dZded< dZded < d
Zd ed < d
Zd ed
< dZ ded< dZ
ded< dS )SrvzC
Srv is a helper data structure to hold state of a server.
r r? r r@ rA NOptional[float] last_attemptFbool did_connect
discovered
Optional[str]tls_nameserver_version) r7 r8 r9 rB rC rA rG rI rJ rL rM r: r; r< rE rE s J$(L(((( K J "H""""$(N((((((r; rE c e Zd ZddZddZedd Zedd Zedd
Zedd Z edd Z
edd
Z ddZ dS )
ServerVersionrM strreturnNonec h || _ d | _ d | _ d | _ d | _ d | _ d | _ d S N)_server_version_major_version_minor_version_patch_version_prerelease_version_build_version _dev_version)selfrM s r< __init__zServerVersion.__init__ s@ - -1-1-126 -1+/r; c $ d}t j |t j }| | j }|t | j d | }t |d | _ t |d | _ t |d | _
|d pd| _ |d pd| _ | j r(d
| j | j g | _ d S | j | _ d S )
Na
^
(?P0|[1-9]\d*)
\.
(?P0|[1-9]\d*)
\.
(?P0|[1-9]\d*)
(?:-(?P
(?:0|[1-9]\d*|\d*[a-zA-Z-][0-9a-zA-Z-]*)
(?:\.(?:0|[1-9]\d*|\d*[a-zA-Z-][0-9a-zA-Z-]*))*
))?
(?:\+(?P
[0-9a-zA-Z-]+
(?:\.[0-9a-zA-Z-]+)*
))?
$
z is not a valid Semantic Versionmajorminorpatch
prereleaser,
buildmetadata+)recompileVERBOSEmatchrU
ValueError groupdictr@ rV rW rX rY rZ joinr[ )r\
_SEMVER_REGEX_REGEXrh matchess r<
parse_versionzServerVersion.parse_version s
" M2:66 T 122 = 4 V V VWW W//## !''"2 3 3 !''"2 3 3 !''"2 3 3#*<#8#>B %o 6 <" 9 #$*BDDW)X Y YD $ 8D r; r@ c F | j s| | j S rT )rV ro r\ s r< r_ zServerVersion.major ( " ! ""r; c F | j s| | j S rT )rW ro rq s r< r` zServerVersion.minor rr r; c F | j s| | j S rT )rX ro rq s r< ra zServerVersion.patch rr r; c F | j s| | j S rT )rY ro rq s r< rb zServerVersion.prerelease s( ' ! ''r; c F | j s| | j S rT )rZ ro rq s r< buildzServerVersion.build rr r; c J | j s| | j pdS )Nr, )r[ ro rq s r< devzServerVersion.dev s- ! &B&r; c d| j dS )Nz)rU rq s r< __repr__zServerVersion.__repr__ s 7 47777r; N)rM rP rQ rR rQ rR rQ r@ rQ rP )
r7 r8 r9 r] ro propertyr_ r` ra rb rw ry r| r: r; r< rO rO s 0 0 0 0 9 9 9 9D # # # X#
# # # X#
# # # X#
( ( ( X(
# # # X#
' ' ' X'
8 8 8 8 8 8r; rO ex ExceptionrQ rR c B K t d| dS )z]
Provides a default way to handle async errors if the user
does not provide one.
nats: encountered errorexc_infoN)_loggererror)r s r< _default_error_callbackr s%
MM+bM99999r; c # e Zd ZU dZeZded< dZdZdZ dZ
dZ d Z d
Z
dd
ZddZdgdddddddddeeeeededddddddedddddeedddf#ddFZddGZddHZddLZ ddNZ ddOZ ddPZ dddSZ ddTZ! ddd]Z"dd`Z#dVddde$e%fddjZ&dddlZ'ddnZ(ddoZ)ddrZ* dddwZ+ dddxZ,ddyZ-dddzZ.ddd|Z/e0fdd}Z1e2dd Z3e2dd Z4e2dd Z5e2dd Z6ddZ7e2dd Z8e2dd Z9e2dd Z:e2dd Z;e2dd Ze2dd Z?e2dd Z@e2dd ZAe2dd ZBe2dd ZCdddZD dddZEeFdd ZGddZHddZIddZJddZKddZLddZMddZNddZOddZPddZQddZRddZSddZTddZUdddZVddZWddZXdddZYddZZddZ[ddZ\ddZ]ddÄZ^ddńZ_ddDŽZ`dS )Clientz(
Asyncio based client for NATS.
z type[Msg] msg_classr r r- r4 rQ rP c dt dS )Nz )$(D ! ! -1A1MQUQeQq$(D ! % % ' ' ' $M2D E E E ". , <( )U 2 2 D% & & & 9
9..00000000000222222222+dd-ddd+23$/(
< 89A== HHHH V\7+?@
9
9
9 nnQ''''''''' |$56 Gkk&"5u========='38<8H8HD(5(33q833
9 9s, :AK
N9 K;2 K;;$N9 BN44N9c h | j | d S | d S rT )r _setup_nkeys_jwt_connect_setup_nkeys_seed_connectrq s r< r zClient._setup_nkeys_connect@ s; ! - ) ) + + + + + * * , , , , ,r; c j s
J d dd ldd l j t t r4t dk sJ d
fd }| _ dfd
}| _ d S t t s*t t st t r d
fd }| _ d fd }| _ d S d S )Nz_user_credentials requiredr r- rQ r c d } t d d 5 }t | j } | | d d d n # 1 swxY w Y | S Nr rb)openr fstatfilenost_sizereadinto)contentsfcredsoss r< user_cbz0Client._setup_nkeys_jwt_connect..user_cbQ s %(D)) )Q (!((**)=)=)E F FHJJx((() ) ) ) ) ) ) ) ) ) ) ) ) ) ) AA55A9<A9noncerP r c d }t d d 5 }t | j }| | d d d n # 1 swxY w Y | }| | }t j
| }| ~~|S )Nr r ) r r r r r r from_seedsignr base64 b64encodewipe) r# seedr kp
raw_signedsigr nkeysr s r< sig_cbz/Client._setup_nkeys_jwt_connect..sig_cbZ s %(D)) %Q$RXXahhjj%9%9%ABBDJJt$$$% % % % % % % % % % % % % % % __T** WWU\\^^ 4 4
&z22
r" c . S rT )_read_creds_user_jwt)r r\ s r< r! z0Client._setup_nkeys_jwt_connect..user_cbl s 00777r; c } | }| | }t j | }| ~~|S rT )_read_creds_user_nkeyr% r& r r' r( r) )r# user_seedr+ r, r- r r. r\ s r< r/ z/Client._setup_nkeys_jwt_connect..sig_cbq sj 6 6u = = __Y// WWU\\^^ 4 4
&z22
r; )rQ r r# rP rQ r ) r r r. r tupler r r rP r r )r\ r! r/ r r. r s ` @@@r< r z Client._setup_nkeys_jwt_connectF sg %CC'CCC% ! 3 eU # # / (u::????
!(D
"(D
s
#
# (z%'D'D (
SXZ^H_H_ (
8
8
8
8
8
8
8 !(D
"(D ' ( (r; r str | UserString | Pathr c d }t |t r/ |t |j S t |dd 5 } || cd d d S # 1 swxY w Y d S )Nc > | D ]}d|v r| } t | n# t $ r t w xY w| }||z
dz
}| | t | }| | |c S d S )Ns BEGIN USER NKEY SEEDr )tellnext
StopIterationr seekr r )r linenkey_start_pos nkey_end_pos nkey_sizer4 s r<
get_user_seedz3Client._read_creds_user_nkey..get_user_seed s
%
% +d22%&VVXXN8 Q( 8 8 8 778#$6688L ,~ = AIFF>*** !*) 4 4IJJy)))$$$$ 3
%
%s .A r r ) bufferingr r r datar r )r\ r rB r s r< r3 z Client._read_creds_user_nkey s % % %* eZ ( ( ? =):):)<)> >
%
+
+
+ $q =## $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s A22A69A6str | RawCredentials | Pathc d }t |t r/ |t |j S t |d 5 } || cd d d S # 1 swxY w Y d S )Nc d } t | }d|v r"t | }nH|d t | dz
S )NTs BEGIN NATS USER JWTr )r readliner )r user_jwtr> s r< get_user_jwtz1Client._read_creds_user_jwt..get_user_jwt sg H
..)T11 ( 6 6H
/c(mma / /0 0r; r rD )r\ r rK r s r< r1 zClient._read_creds_user_jwt s 1 1 1 eZ ( ( > <
(9(9(;(; < <== =
%
#! <?? # # # # # # # # # # # # # # # # # #s A00A47A4c j s j s
J d dd ld
fd }|j _ | ~d fd }| _ d S ) N#Client.connect must be called firstr rQ
nkeys.KeyPairc dd l } j r't j }n}j }t |d 5 }t | | j }| | d d d n # 1 swxY w Y
| }~|S r ) r r r r r r r r r r r% )r r* r r key_pairr. r\ s r< _get_nkeys_seedz9Client._setup_nkeys_seed_connect.._get_nkeys_seed s III#
% !5!!>?? (%&& %!$RXXahhjj%9%9%ABBDJJt$$$% % % % % % % % % % % % % % % t,,HOs AB&&B*-B*r# rP r c }| | }t j | }| ~|S rT )r& r r' r( r) )r# r+ r, r- rQ s r< r/ z0Client._setup_nkeys_seed_connect..sig_cb sP ""B 00J":..C
GGIIIJr; )rQ rN r5 )r r r.
public_keydecoder r) r )r\ r+ r/ rQ r. s ` @@r< r z Client._setup_nkeys_seed_connect s ^4#7^^9^^^7 _
M 0 0 2 2
$r; c T K | t j d{V dS )z
Closes the socket to which we are connected and
sets the client to be in the CLOSED state.
No further reconnections occur once reaching this point.
Nr r CLOSEDrq s r< closez Client.close s4 kk&-(((((((((((r; statusdo_cbsc x K | j r || _ d S t j | _ | d {V | j 2| j s| j | j 2| j s| j | j 2| j s| j | j
| j
s| j
| j D| j s+t j | j | j d d {V n!# t j t j f$ r Y nw xY wt j d d {V | j f| j r_| j dk rT| j | j d d g | _ d| _ | j d {V | j D ]}|j r2|j s|j |j r|j |j rI|j D ]}| |j | j | j l| j | j ! d {V n2# tD $ r%}| # | d {V Y d }~nd }~ww xY w|rB| j$ | $ d {V | j% | % d {V d | _& d | _' d S )Nr r )( is_closedr r rW _flush_pendingr cancelledcancelr r r doner r wait_forr CancelledErrorr sleepr r r
writelinesr drainr values_wait_for_msgs_task_message_iterator_cancel_pending_next_msgs_callsclearrX wait_closedr r r r r r )r\ rY rZ subfutr s r< r z
Client._close s, > !DL F } !!######### )$2D2N2N2P2P ) % % ' ' ' # /8P8Z8Z8\8\ / $ + + - - - )$2D2N2N2P2P ) % % ' ' ' " .t7N7S7S7U7U . # * * , , ,
1=dFdFnFnFpFp=!* 6 %:; *G,@A
mA + +&****4=+;<<< "
*+'o++--------- :$$&& 5 5C&
1s/F/K/K/M/M
1'..000$
0%--/// +
5 7>>@@ ! !CJJLLLL,22444
? & O ! ! # # #
(o113333333333
(
(
(nnQ''''''''''''''
( ($0++---------*oo''''''''' $ s+ #A E/ /F
F
L6 6
M% M M%c N K | j rdS | j r t j | j s| j r t j g }| j D ]Q}| }t j | }|
| Rt j | }t j d d{V t j | _ t j || j d d{V ny# t j $ rW | | | t j d{V Y nt j $ r Y nw xY wt j | _ | d{V | t j d{V dS # t j | _ | d{V | t j d{V w xY w)a
drain will put a connection into a drain state. All subscriptions will
immediately be put into a drain state. Upon completion, the publishers
will be drained and can not publish any additional messages. Upon draining
of the publishers, the connection will be closed. Use the `closed_cb`
option to know when the connection has moved from draining to closed.
Nr r ) is_drainingr\ r ConnectionClosedError
is_connectingis_reconnectingConnectionReconnectingErrorr rf _drainr get_running_loop create_taskappendgatherrc r
DRAINING_SUBSr ra r r exceptionr_ r DrainTimeoutErrorrb
DRAINING_PUBSflushr rW )r\ drain_tasksrm corotask
drain_is_dones r< re z Client.drain# sY F > /. . 5!5 54 4 :$$&& % %C::< /. . 10 07|| 6%**lT=T.TW[Wm.m.m 55 $+ + +( ( %,PPPPPPPPPPPr; r Optional[Dict[str, Any]]c K |dk r t j d}|t j ||| }n5t }| t | t | D ]\ }} | }
|
s | |
| d | } | |
| t | t t j |||| }| j dxx dz
cc< | j dxx |z
cc< |
| d{V | j 5| j r | d{V dS dS dS )z7
Sends PUB command to the NATS server.
r, Ns : r r r )r BadSubjectError prot_commandpub_cmdr extend
NATS_HDR_LINE_CRLF_itemsstripr hpub_cmdr
_send_commandr emptyr] ) r\ r r r r r r hdrkvkeyvalues r< r zClient._send_publish s b==( ( ?"*7E7CCGG++C JJ} % % % JJv
#
#1ggii
3::<<(((
5!!!
5<<>>***
6"""" JJv "+GUCIIG
: !#
; </ ))))))))) (T->-D-D-F-F (%%'' ' ' ' ' ' ' ' ' ' ) ( ( (r; queuer *Optional[Callable[[Msg], Awaitable[None]]]futureOptional[asyncio.Future]max_msgspending_msgs_limitpending_bytes_limitr$ c z K |rd|v r t j |rd|v r t j | j r t j | j r t j | xj dz
c_ | j }t | |||||||| } | | j | | j
|< | | d{V | S )a
subscribe registers interest in a given subject.
If a callback is provided, messages will be processed asynchronously.
If a callback isn't provided, messages can be retrieved via an
asynchronous iterator on the returned subscription object.
r )r r r r r r N) r r r\ rq rp r r r$ _startr r _send_subscribe)
r\ r r r r r r r sidrm s
r< subscribezClient.subscribe s $ )3'>>( ( )cUll( ( > /. . 10 0 Q i 1 3
4>"""
3""3'''''''''
r; r c < | j |d d S rT )r pop)r\ r r s r< _remove_subzClient._remove_sub s
sD!!!!!r; rm c K d }|j &t j |j t |j }n%t j |j |j |j }| | d {V | d {V d S rT )_queuer sub_cmd_subjectEMPTY_idr r] )r\ rm r s r< r zClient._send_subscribe s : "*3<HHGG"*3<SWMMG )))))))))!!###########r; c K i | _ | j d d | _ | j d | j | j | j d | j d d }| d | | | j d {V d S )N . *)r ) r r r r r r; r rT _request_sub_callback)r\ resp_mux_subjects r< _init_request_subzClient._init_request_sub s $ 2111 5 $$T*** $$TZ__%6%6777 $$T*** 03 %%%nn - 4 4 6 64;UnVVVVVVVVVVVr; msgr! c K |j t | j dz dz d }| j | }|sd S | s| | d S d S )N r- )r r r r getr`
set_result)r\ r r r s r< r z Client._request_sub_callback s C 2 3 3b 81 < > >? ##E** F{{}} # c " " " " " # #r; ?timeoutfloat old_stylec & K |r | ||| d{V S | |||| d{V }|j rH|j t j j j j t k r t j |S )z
Implements the request/response pattern via pub/sub
using a single wildcard subscription that handles
the responses.
)r N)r r ) _request_old_style_request_new_styler r natsjsapiHeaderSTATUSNO_RESPONDERS_STATUSr NoRespondersError)r\ r r r r r r s r< requestzClient.request s d 00'70SSSSSSSS S //'[b/ccccccccC ; +3;??47;+=+DEEI]]]* *
r; c K j r t j j s d {V j sJ j t d j d d }| t j }| fd | j
< ||| | d {V t j || d {V S # t j $ r
t j w xY w)Nr- c ^ j d S rT )r r rT )r r\ r s r< z+Client._request_new_style..; s! 4>+=+=ellnnd+S+S r; )r r )r r r r r r r; r r
r r Futureadd_done_callbackr rT r ra r )r\ r r r r inboxr r s ` @r< r zClient._request_new_style% s 10 0$ +((** * * * * * * *$$$$
!!
Yq\\((**+++%aaa(
U ") !1!1 !S!S!S!S!STTT)/u||~~& ll7G5<<>>7lSSSSSSSSS & )&':::::::: :# & & &% % &s -E E$c | j dd }| d | | j | S )aW
new_inbox returns a unique inbox that can be used
for NATS requests or subscriptions::
# Create unique subscription to receive direct messages.
inbox = nc.new_inbox()
sub = await nc.subscribe(inbox)
nc.publish('broadcast', b'', reply=inbox)
msg = sub.next_msg()
Nr )r r r r; rT )r\
next_inboxs r< new_inboxzClient.new_inboxG s[ '*
$ $*//++,,, """r; c x K | }t j }| ||d d{V }| d d{V | ||| d{V t j || d{V }|j rH|j t j
j j j
t k r t j |S # t j $ r; | d{V | t j w xY w)z
Implements the request/response pattern via pub/sub
using an ephemeral subscription which will be published
with a limited interest of 1 reply returning the response
or raising a Timeout error.
r )r r N)limit)r )r r r r unsubscriber ra r r r r r r r r r r r r_ )r\ r r r r r rm r s r< r zClient._request_old_styleW sX &-n&6&6NN5!NDDDDDDDDooAo&&&&&&&&&ll7G5l999999999 & (99999999C{
3;??47;#5#<==AUUU 22J# & & &//## # # # # # # # MMOOO% % &s A+C/ /A
D9r c K t j || }| | d {V | d {V d S rT )r unsub_cmdr r] )r\ r r r s r< _send_unsubscribezClient._send_unsubscribep sh *366 +++++++++!!###########r; c N K |dk r t j | j r t j t j } | | d{V t j || d{V dS # t j $ r! | t j
w xY w)a7
Sends a ping to the server expecting a pong back ensuring
what we have written so far has made it to the server and
also enabling measuring of roundtrip time.
In case a pong is not returned within the allowed timeout,
then it will raise nats.errors.TimeoutError
r N) r BadTimeoutErrorr\ rq r r
_send_pingra r r_ FlushTimeoutError)r\ r r s r< r~ z Client.flushu s a<<( ( > /. .!( !1!1 +//&)) ) ) ) ) ) ) )"6733 3 3 3 3 3 3 3 3 3# + + + MMOOO* * +s 6A4 40B$Optional[ParseResult]c : | j r| j r | j j S d S rT )r r r? rq s r<
connected_urlzClient.connected_url s( ,D$5 ,'+ +tr; List[ParseResult]c R g }| j D ] }| |j |S rT )r rx r? r\ r srvs r< r zClient.servers s5 $ $ $C NN37 # # # #r; c ` g }| j D ]#}|j r| |j $|S rT )r rJ rx r? r s r< discovered_serverszClient.discovered_servers s= $ ( (C~
(sw'''r; List[Server]c $ d | j D S )z<
Returns a copy of the current server pool.
c D g | ] }t |j |j S )r? rA r> r? rA ).0r s r<
z&Client.server_pool.. s) \\\337s~>>>\\\r; )r rq s r< server_poolzClient.server_pool s
]\$J[\\\\r; List[str]c | j r t j g }|D ]}| | }t | }| j D ]=}|j j |j k r&|j |_ |j |_ |j
|_
n>| | || _ | j W| j j j }d}|D ] }|j j |k r || _ d} n |s$t | dk r|d | _ dS dS dS dS )a
Replaces the current server pool with the provided list of server URLs.
The new pool will be used on the next reconnect attempt. It does not
trigger an immediate reconnect. The new pool is subject to the same
rules as the default one (randomization unless disabled, max reconnect
attempts, etc).
Unless advertised server discovery is disabled, the client will
continue to discover and add new servers to the pool as it receives
INFO messages from the server.
:param servers: List of server URLs to use as the new pool.
:raises errors.ConnectionClosedError: If the connection is closed.
NFTr )r\ r rq _parse_server_urirE r r? netlocrA rI rG rx r r ) r\ r new_poolr r? r old_srvcurrent_netlocfounds r< set_server_poolzClient.set_server_pool sN > /. . !
!
!F((00Cc((C ,
;%33%,%7CN&-&9CO'.';C$E 4
OOC $ + ! 1 5 ^33+.D( EE 4
3S]]Q . .'/{$$$ , +
3
3 . .r; c | j S )zQ
Returns the max payload which we received from the servers INFO
)r rq s r< max_payloadzClient.max_payload s
r;
Optional[int]c | j S )zO
Returns the client id which we received from the servers INFO
)r rq s r< client_idzClient.client_id s
r; Optional[Exception]c | j S )zA
Returns the last error which may have occurred.
)r rq s r<
last_errorzClient.last_error s
yr; c | j S rT )r rq s r< pending_data_sizezClient.pending_data_size s &&r; c , | j t j k S rT )r r rW rq s r< r\ zClient.is_closed s |v},,r; c , | j t j k S rT )r r RECONNECTINGrq s r< rs zClient.is_reconnecting s |v 222r; c : | j t j k p| j S rT )r r CONNECTEDrp rq s r< r zClient.is_connected s 00ET5EEr; c , | j t j k S rT )r r
CONNECTINGrq s r< rr zClient.is_connecting s |v 000r; c V | j t j k p| j t j k S rT )r r rz r} rq s r< rp zClient.is_draining s! |v 33[t|vG[7[[r; c , | j t j k S rT )r r r} rq s r< r zClient.is_draining_pubs s |v 333r; rO c x | j r%| j j rt | j j S t d S )zm
Returns the ServerVersion of the server to which the client
is currently connected.
z
0.0.0-unknown)r rM rO rq s r< connected_server_versionz Client.connected_server_version s@ FD$8$G F !5!DEE E _---r; ssl.SSLContextc d }d| j v r| j d }nt j }|t j d |S )Nr z nats: no ssl context provided)r r sslcreate_default_contextr r )r\ ssl_contexts r< r zClient.ssl_context sV 04 DL ,**511KK 466K , >?? ?r; cmdpriorityc * K |r | j d| n| j | | xj t | z
c_ | j dk r.| j | j k r | d d {V d S d S d S )Nr T) force_flush)r insertrx r r r r] )r\ r r s r< r zClient._send_command s & M C ( ( ( ( M % % % 3s88+ !A % %$*ADDZ*Z*Z%%$%77 7 7 7 7 7 7 7 7 7 & %*Z*Zr; r r c K | j s
J d t j }| j s| d |S | j | d {V |re t j || j d {V d S # t j $ r0 | t j d {V Y d S w xY wd S # t j $ r Y d S w xY wNrM )
r r r r r putra r r r r r rb )r\ r r s r< r] zClient._flush_pending' sI GG"GGG %,^%5%5F$
!!$'''
#''// / / / / / / /
EE!*643FGGGGGGGGGGG + E E E ..)A)C)CDDDDDDDDDDDDE
E
E % DD s5 0C "C ) B ;C
C C
C C"!C" connect_urlr c d| v sd| v rt | }nBd| v sd| v rt | }n*d| v rt d| }nt d| d }|j !|j dvrt d|j d }n"# t $ r t j d w xY w|j |j d
k rt j d |S ) zy
Parse a single server URL string into a ParseResult.
Handles scheme defaults and port defaults.
znats://ztls://zws://zwss://:z:4222Nwswss nats: invalid connect url optionnonez%nats: invalid hostname in connect url)r portschemehostnameri r r )r" r? s r< r zClient._parse_server_uri? s
CK''8{+B+B {++K''8{+B+B {++ ## 6 6 677 ; ; ; ;<<x CJm$C$C < < < <== C C C, ABB B C < 3<6#9#9, FGG G
s BB B$Union[List[str]]c ` t |t r>| | }| j t | d S t |t r |D ]8}t | }| j t | 9n"# t $ r t j
d w xY wt d | j D s2t d | j D st j
d d S d S t j
d )Nr( c 3 2 K | ]}|j j d v V dS ))r r Nr? r+ r r s r< z,Client._setup_server_pool..e s, YYVFJ% 8YYYYYYr; c 3 2 K | ]}|j j d v V dS )r% Nr0 r1 s r< r2 z,Client._setup_server_pool..f s, ZZfvz(M9ZZZZZZr; z?nats: mixing of websocket and non websocket URLs is not allowed) r rP r r rx rE listr ri r r all)r\ r" r? r s r< r zClient._setup_server_poolX s] k3 ' ' C((55C $ $SXX . . . . .
T
*
* C
G ) 7 7F"6**C%,,SXX66667
G
G
G l#EFFF
G YYtGXYYYYY
fZZHYZZZZZ
f l#deee
f
f
f
f , ABB Bs *;B& & CsrE c K t j |_ | j sB|j j dv r!t
| j d | _ nt | _ |j j dk r@| j |j | j
t | j d d{V dS | j |j t | j d d{V dS ) zM
Establishes a TCP/WebSocket connection to the given server.
r% r )
ws_headersr' r )r buffer_sizer N)r9 r )
r
r rG r r? r+ r' r r% connect_tlsr DEFAULT_BUFFER_SIZEr )r\ r6 s r< _connect_to_serverzClient._connect_to_serverl s" )) 1u|},,"4 Md@e"f"f"f"... 5<5 /-- , / $ -> ? .
/)) / $ -> ? *
r; c K t | j dk rd| _ t j t j }| j d }| j d dk r|j | j d k r| j
| |j >||j | j d z k r%t j
| j d d{V | | d{V || _ dS # t $ rU}t j |_ |xj dz
c_ || _ | | d{V Y d}~_d}~ww xY w)zf
Looks up in the server pool for an available server
and attempts to connect.
Tr Nr r r )r r r r r r
r r r rA rx rG r rc r< r r r )r\ nowr6 r s r< r zClient._select_next_server s 4$%%**'+$ ++.""C!%%a((A| 4599<$,/G"HHH
$ $Q ' ' '~)cANT\RgEh4h.h.h mDL1F$GHHHHHHHHH
--a000000000'($
!% !1!1 ! nnQ'''''''''
s $"D
E'A
E""E'err_msgc K t |v r.| t j d{V dS t |v rt j | _ n[| d }d| }t j | }|| _ t |v r |
| d{V dS d}| j sd}t j
| t j | dS )zv
Processes the raw error message sent by the server
and close connection with current server.
N'nats: FT)r _process_op_errr StaleConnectionErrorr AuthorizationErrorr r r r r rr r rw r r rW )r\ r? prot_errmerrrZ s r< _process_errzClient._process_err s
w & &&&v'B'D'DEE E E E E E E E F "g - - 133DII }}S))H###A,q//CDI !##nnS)))))))))! F
DKK
v > >?????r; r r c & K | j s| j rdS | j d r| j s| j rt
j | _ | j | j
2| j
s| j
t j | | _
dS | || _ | t
j d d{V dS )z
Process errors which occurred while reading or parsing
the protocol. If allow_reconnect is enabled it will
try to switch the server to which it is currently connected
otherwise it will disconnect.
Nr T)r\ rs r r rr r r r r resetr r^ r_ r rv rw _attempt_reconnect_process_disconnectr r rW )r\ r s r< rC zClient._process_op_err s > T 1 F <) * 30A 3TEW 3!.DL HNN &24;R;\;\;^;^2'..000&-&>&@&@&L<MdMdMfMf&g&gD # # # $ $ & & &DI++fmT22 2 2 2 2 2 2 2 2 2r; c \ K | j s
J d | j 2| j s| j | j 2| j s| j | j 2| j s| j | j l| j | j d {V n2# t $ r%}|
| d {V Y d }~nd }~ww xY wd | _ | j | d {V | j
rd S d| j vs
| j d st | j t# j | _ | j y| j d dk rfd| j D }nt+ | j }t- | dk r t. j d |D } | || j \ }}n2# t $ r%}|
| d {V Y d }~d }~ww xY w|]d }|D ] }|j j |j j k r|} n!||| _ n.|
t/ j d {V d }|
|d | _ |dk rt# j | d {V | | j d {V n| d {V | j sJ | ! d {V | j" dxx d z
cc< d| j _# d| j _$ g }| j% & D ]\ } }
d} |
j' dk r5|
j( |
j' k r|) | 8|
j' |
j( z
} tU j+ |
j, |
j- | } | j . | | dk r/tU j/ | | }
| j . |
|D ] } | j% 0 | | j 1 d {V | 2 d {V tf j4 | _5 | 6 d {V | j7 | 7 d {V d | _ n# t. j $ r+}|| _ | d {V Y d }~nd }~wtp t. j9 t" j: f$ ro}|| _ |
| d {V tf j; | _5 ty j= | j _> | j xj$ d z
c_$ Y d }~nd }~wt" j? $ r Y nw xY wG| j 5| j s | j @ d d S d S d S )
NrM r Tr r c * g | ]}|j k
|S r: )rA )r r6
max_reconnects r< r z-Client._attempt_reconnect.. s& #b#b#b!ALTaDaDaADaDaDar; c D g | ] }t |j |j S r r )r r6 s r< r z-Client._attempt_reconnect..
s* &d&d&dVWv!%AL'Q'Q'Q&d&d&dr; rA r )Ar r r^ r_ r r r rX rl r r r r r\ r r r r r r r r4 r r r r copyr? r ServerNotInPoolErrorrc r< r r r rI rA r r _max_msgs _receivedrx r r r r writer r re r] r r r r~ r r r r r r
r rG rb r )r\ r eligibleserver_snapshotselectedcallback_delaymatchedr6 subs_to_remover rm r r r rP s @r< rL zClient._attempt_reconnect sT #JJ%JJJ# )$2D2N2N2P2P ) % % ' ' ' # /8P8Z8Z8\8\ / $ + + - - - )$2D2N2N2P2P ) % % ' ' ' ? & O ! ! # # #
(o113333333333
(
(
(nnQ''''''''''''''
( ,'')) ) ) ) ) ) ) ) > F 4< / /t|DT7U / D% & & & *1 )9)9&h g
4@$(L1I$JM$q((#b#b#b#bt/@#b#b#b#'(9#:#:8}})) $ 33&d&d[c&d&d&dO!373T3T +T->-C-C-E-E4 40.. % ! ! ! "nnQ / //////// ! +"&!) & &A u|x|/B B B*+ % C #.3:D 0 0"&..1L1N1N"O"O O O O O O O O'+H '/7{,%)) %mN ; ;;;;;;;; 11$2FGGGGGGGGGG 22444444444&&00222222222
<(((A-((( 48$023$/ "$ $
0 0 2 2 9 9HC H}q(( =CM99 * 1 1# 6 6 6 $#&=3=#@ * 23<S Q QGO))'222 !||$0$:3$I$I --i888) ( (CJNN3''''o++--------- ))+++++++++ % / jjll"""""""'3 ..00000000015.(
jjll"""""""V\7+?@
5
5
5 nnQ''''''''' % 2 48N4D4D$1$//14///////)
Oh T ) 5d>\>f>f>h>h 5 * 5 5d ; ; ; ; ; 6 5 5 5so ! D
D0 D++D0(A.T 0I T
I7I2-T 2I77JT W) !U$W)*A%WW)(W)c | j d | j d t t t d}d| j v r | j d |d< | j d |d< | j rfd| j v r| j || | j d }| |d< | j ,| }| |d < n| j
| j |d
< n| j d .| j d !| j d |d < | j d |d
< n| j d ,| j d }t | r
| }||d< nf| j r_| j j j
N| j j j | j j j
|d< n(| j j j
|d < | j j j |d
< | j d | j d |d< | j d | j d |d< t j |d }d t$ t& z | z t* z g S )z
Generates a JSON string with the params to be used
when sending CONNECT to the server.
->> CONNECT {"lang": "python3"}
r r )r r langr( protocolr
no_respondersr# Nr- jwtnkeyr r passr
auth_tokenr r echoT) sort_keysr; )r __lang__r PROTOCOLr r r rT r r callabler r? r r jsondumpsrk
CONNECT_OP_SPC_r r )r\ r r- ra r connect_optss r< _connect_commandzClient._connect_commandj sR |I. Z0 "
) ) )!%!29!=GI '+'8'CGO $ H$+++0B0N(():7)CDD!$ $0 ++--C%(ZZ\\GENN&2&*&7GFO f%1dl:6N6Z"&,v"6"&,z": g&2 W-E?? $ !EGGE(- %%%
H$*>*B*K*W'+4<,0,@,D,MGL))&*&:&>&GGFO&*&:&>&GGFO < + "l6 2GFO < " ."&,y"9 9GFOz'T::: xxe+l.A.A.C.CCfLMNNNr; c ~ K | t d{V | d{V dS )z.
Process PING sent by server.
N)r r r] rq s r<
_process_pingzClient._process_ping sX &&&&&&&&&!!###########r; c K t | j dk rH| j d }| d | xj dz
c_ d| _ dS dS )z.
Process PONG sent by server.
r Tr N)r r r r r r r\ r s r<
_process_pongzClient._process_pong sn t{ a [__Q''F d # # # A % &'D # # # r; headerDict[str, str]c t | dk rd S | t j j j j }|t k r.| t j j j j S d S )Nr ) r r r r r r r CTRL_STATUS DESCRIPTION)r\ rE ru rY s r< _is_control_messagezClient._is_control_message s] t99q==4DGK . 566 [ ::dgk 0 <== =tr; c b
K |sd S d }|t d }|d t k r|t t dz d }|d t }|t dz t | t
z
t
z
}| }i }| r#||t j
j j j
j < | t }||t
z d }t | dk r| t }|dk r|d | |t j
j j j < | j ||t
z d } | D ]
\
}
|
|
< n0| |t j
j j j < t | t
k s|S |t t
z d } t* rt+ | j } n6d | j | D } |r| | n| }t* r[g } | D ]<
t3
fdt4 j D r|
=| D ]
|
= n4# t: $ r'} | | d {V |cY d } ~ S d } ~ ww xY w|pd S )Nr r c b i | ],\ }}| | -S r: )r )r r r s r<
z+Client._process_headers.. s. p p ptq!aggii p p pr; c 3 K | ]}|v V d S rT r: )r cr s r< r2 z*Client._process_headers.. s' ==a16======r; ) NATS_HDR_LINE_SIZE
_SPC_BYTE_r r STATUS_MSG_LEN
_CRLF_LEN_r rT isdigitr r r r r r findr ry r
parsebytesr r r updatekeysanystring
whitespacerx r r )r\ r r raw_headersr> rY descstripped_statusi
parsed_hdrr to_deleter r s @r< _process_headerszClient._process_headers s= 4(, 0 1 12 q>Z ' '3}--1334D/>/*F*SYY-Cj-PPQD $llnn 3 3 5 5O C &&((
G7FDGK&-34 ((A%a*n&6&67K4yy1}} IIf%%q55:>rr(//:K:KC *67!%!1!>
L 3 3F ; ; L "wwtw{'9'J K KH
::39EE6!9~~6!9~~39$$&)&@&@Q &O&O O O O O O OII !%qCI $CI F + C{
;((** F &&s+++
w!!\1!!+a//C4EIa4a4a %% 5%% .. 0CI[^dghhh F"--c2222$
w
w
w!!S]]2!!nnV%=ckY\Ybhkqt%u%u%uvvvvvvvvvvv
w x
4((333
(
(
CSY
C38
C x((**ch.>>> 9 77 BBB ),,x(( ( ( ( ( ( ( ( @CI @(*=*=f*E*E @x
@h::3??????????? @ @ @ @ @ @
@
@s 5A6K -K A,L76L7c | | | ||| | S )N)r r rE r _clientr )r rT )r\ r r r rE r s r< r zClient._build_message sC ~~NN$$,,..
r; c ( t j | _ dS )zf
Process disconnection from the server and set client status
to DISCONNECTED.
N)r r r rq s r< rM zClient._process_disconnect s
* r; infoDict[str, Any]initial_connectionc K | j s
J d d|v r@|d r9g }|d D ]}d}| j j j dk rd}nd}t | d| }t | }d|_ d| j v r=| j d r0| |j r| j j j |_ d}| j
D ]} |j | j j k rd }|r| | | j
d
durt | |D ] }| j
| |s)|r)| j r$| d {V d S d S d S d S d S d S ) z
Process INFO lines sent by the server to reconfigure client
with latest updates from cluster to enable server discovery.
rM connect_urlsr, r r z://T tls_requiredFr N)r r? r+ r rE rJ r _host_is_ipr, rL r r rx r r r )
r\ r r r r" r+ r? r
should_addr6 s
r<
_process_infozClient._process_info s
#JJ%JJJ# T ! !N# #
7 ! #'#7 1 1K F+/6%??!&!'"f#>#>#>#>??C c((C%)CN '$*;;; -n = < , ,S\ : : < (,';'?'H "&J ! . / / : 55).J! 1$++C000< 01==L)))' 2 2C%,,S1111) 7l 7t?Y 7 4466666666666I " !#
7 #
7D7 7 7 7 7 7r; c Z |dS t j | dS # t $ r Y dS w xY w)NFT) ipaddress
ip_addressr )r\ r" s r< r zClient._host_is_ip sJ 5 - - -4 55 s
**c X K | j s
J d | j s
J d t j | _ d}d| j v r| j d }n*| j j
| j j }n| j j j }| j d }|r8| j || j
t | j d d{V | j }t j || j d d{V }t |vrt! j d | t t& z d \ }} t) j | }|| _ n"# t0 $ r t! j d w xY w| d d
rd | _ | |d d{V d
| j v r| j d
| j _ d| j v r| j d | _ d| j v r| j d | _ d| j v r{| j d rn| j j j dk rY|sW| j d{V | j || j
t | j d d{V | j! r| j" # | j sJ | $ }| j % | | j d{V | j d r| j } t j | | j d d{V }
tL |
v rn`tN |
v rW|
} | dd \ }} t! j d| ( d z | j % tR | j d{V | j } t j | | j d d{V }
tT |
v rt j+ | _ n`tN |
v rW|
} | dd \ }} t! j d| ( d z tT |
v rt j+ | _ t j, - | . | _/ g | _0 d| _1 t j, - | 2 | _3 t j, - | 4 | _5 dS )z
Process INFO received from the server and CONNECT to the server
with authentication. It is also responsible of setting up the
reading and ping interval tasks from the client.
z'must be called only from Client.connectNr r r z>++ %^^C 3 3
7
l8gnnV.D.D#DEEE j)))o##%%%%%%%%% ))++ ( >O1PQQQQQQQQ !+DLL
w
~~''H! Q//JAw
,x'..*@*@ @AA A !+DL $ 5 7 7 C CDOODUDU V V "# #*#;#=#=#I#I$J]J]J_J_#`#` % 5 7 7 C CDMMOO T Ts -E1 1 Fc @ K | j s
J d |t j }| j | | j t | xj t t z
c_ | d {V d S r )
r r r r rx rV r r r r] rs s r< r zClient._send_pingO s EE EEE > ^%%F 6""" j))) 3z??2 !!###########r; c K | j s
J d | j s
J d | j r| j rdS | j d{V } | j dk rT| j | j dd g | _ d| _ | j d{V n# t $ rl}|
| d{V | | d{V Y d}~| s|
d dS dS d}~wt j t t" f$ r/ Y | s|
d dS dS w xY w| s|
d n/# | s|
d w w xY w)z}
Coroutine which continuously tries to consume pending commands
and then flushes them to the socket.
rM TNr )r r r rr r r rd r re r r rC r` r r rb RuntimeErrorAttributeError)r\ r r s r< r zClient._flusherX sB
EE EEE GG"GGG ,$
(:
+/+<+@+@+B+B%B%B%B%B%B%BF
,*Q..O..t}QQQ/?@@@$&DM./D+ ///111111111
nnQ'''''''''**1--------- {{}} ,%%d+++++, , *L.I
{{}} ,%%d+++++, ,
{{}} ,%%d+++ {{}} ,%%d++++,+ ,s= A B6 5F" 6
E5 6D'6F" ' E5F" 4E55F" ",Gc K t j | j d d {V | j s. | xj dz
c_ | j | j d k r)| t
d {V d S | d {V n## t j t t f$ r Y d S w xY w)NTr r r ) r rc r r r rC r r rb r r rq s r< r zClient._ping_intervalw s - _ =>> > > > > > > >$
''1,''*T\:Q-RRR ../A/C/CDDDDDDDDDFoo''''''''''*L.I
s A
B B B<;B<c K | j p| j }|s| j dS | j rKt j }| | d{V | | d{V dS | j t d{V }| j
| d{V n# t j $ r0 | t j d{V Y dS t $ r&}| | d{V Y d}~dS d}~wt j $ r Y dS t $ r'}t" d| Y d}~dS d}~ww xY wv)z
Coroutine which gathers bytes sent by the server
and feeds them to the protocol parser.
In case of error while reading, it will stop running
and its task has to be rescheduled.
TNr r )r\ rs r at_eofr
UnexpectedEOFr rC readr; r parse
ProtocolErrorr r rb r r r )r\ should_bailrH br r s r< r zClient._read_loop s
"n D0D $/"9E?))++ .00C ..--------- ..s333333333E /../BCCCCCCCChnnQ'''''''''''
**6+?+A+ABBBBBBBBB
**1---------)
7"
EEE
+ s< C A"C AC ;E5 E5D00E5 E5 E00E5'Client'c
K | S )z1For when NATS client is used in a context managerr: rq s r<
__aenter__zClient.__aenter__ s r; c X K | t j d d{V dS )z7Close connection to NATS when used in a context managerT)rZ NrV )r\ r s r< __aexit__zClient.__aexit__ s6 kk&-k55555555555r; nats.js.JetStreamContextc 0 t j j | fi |S )aA
jetstream returns a context that can be used to produce and consume
messages from NATS JetStream.
:param prefix: Default JetStream API Prefix.
:param domain: Optional domain used by the JetStream API.
:param timeout: Timeout for all JS API actions.
::
import asyncio
import nats
async def main():
nc = await nats.connect()
js = nc.jetstream()
await js.add_stream(name='hello', subjects=['hello'])
ack = await js.publish('hello', b'Hello JS!')
print(f'Ack: stream={ack.stream}, sequence={ack.seq}')
# Ack: stream=hello, sequence=1
await nc.close()
if __name__ == '__main__':
asyncio.run(main())
)r r JetStreamContextr\ optss r< jetstreamzClient.jetstream s 6 w'55555r; nats.js.JetStreamManagerc 0 t j j | fi |S )z3JetStream context for managing JetStream via JS API)r r JetStreamManagerr s r< jsmz
Client.jsm s w'55555r; r r} )Hr r r r r r r r r r r r r rK r rH r rH r rH r r@ r r@ r r@ r r@ r r@ r rH r r@ r rH r r r rK r rH r rK r rK r r r r@ r r r r r r r rK r rK r r r r@ r rF r r r r rQ rR )r r7 rQ r )r rF )T)rY r@ rZ rH rQ rR )r; r, N)
r rP r r r rP r r rQ rR ) r rP r rP r r r r@ r r rQ rR )r rP r rP r r r r r r@ r r@ r r@ rQ r$ )r )r r@ r r@ rQ rR )rm r$ rQ rR )r r! rQ rR )r; r FN) r rP r r r r r rH r r rQ r! )r N)
r rP r r r r r r rQ r! )r )r rP r r r r rQ r! )r r@ r r@ rQ rR )r r@ rQ rR )rQ r )rQ r )rQ r )r r rQ rR r~ )rQ r )rQ r )rQ rH )rQ rO )rQ r )F)r r r rH rQ rR )r rH rQ r )r" rP rQ r )r" r- rQ rR )r6 rE rQ rR )r? rP rQ rR )r r rQ rR )rQ r )ru rv rQ rK )rQ r ) r r@ r r r r rE r r r rQ rR )
r r@ r r r r rE r r r )r r r rH rQ rR )r" rK rQ rH rT )r r rQ rR )rQ r )rQ r )rQ r )ar7 r8 r9 rB r! r rC r r rW r r rz r} r| r] DEFAULT_CONNECT_TIMEOUTDEFAULT_RECONNECT_TIME_WAIT DEFAULT_MAX_RECONNECT_ATTEMPTSDEFAULT_PING_INTERVAL DEFAULT_MAX_OUTSTANDING_PINGS DEFAULT_MAX_FLUSHER_QUEUE_SIZEDEFAULT_DRAIN_TIMEOUTr DEFAULT_PENDING_SIZEr r r r3 r1 r rX r re r r r# r" r r r r r r r r r r DEFAULT_FLUSH_TIMEOUTr~ r r r r r r r r r r r\ rs r rr rp r r r r r] staticmethodr r r< r rI rC rL ro rq rt rz r r r rM r r r r r r r r r r r r: r; r< r r s I LI
FLJMM/ / / /O
O
O
O
f +B)B,0.2(,37-1 " $ 6#>&D 2%B $"@ (,&*$) ""&59 248-126$((,*> 0)-@DJNIh9 h9 h9 h9 h9T- - - - 7( 7( 7( 7(r$ $ $ $8# # # #""$ "$ "$ "$H) ) ) )I% I% I% I% I%V)- )- )- )-\ ,0 BQ BQ BQ BQ BQH'( '( '( '(X 9=+/"@#B0 0 0 0 0d" " " " "$ $ $ $ W W W W# # # # ,0
6 ,0 & & & & &D# # # # & & & & &2$ $ $ $ $
*? + + + + +, X
X X ] ] ] X] .3 .3 .3 .3` ! ! ! X! X X ' ' ' X' - - - X- 3 3 3 X3 F F F XF 1 1 1 X1 \ \ \ X\ 4 4 4 X4 . . . X. X8 8 8 8 8 " 0 \0C C C C( 0" " " "H @ @ @ @<3 3 3 30J< J< J< J D 6 6 6 66 6 6 6:6 6 6 6 6 6r; r )r r rQ rR )|
__future__r r r' r rj loggingre r r r
collectionsr dataclassesr email.parserr ior pathlibr randomr secretsr
typingr r r
r r r r r urllib.parser r fast_mail_parserr ImportErrornats.jsr r nats.nuidr
nats.protocolr r nats.protocol.parserr r r r r r r r r! subscriptionr" r# r$ transportr% r& r' importlib.metadatar( r r rg getLoggerr7 r rh r rl PING_OPPONG_OPr r r r r rm r r r r r r r; r r r r r r r r r MAX_CONTROL_LINE_SIZEr r r r rx r Callback
ErrorCallbackr JWTCallbackrP SignatureCallback
TokenCallbackr6 Credentialsr> rE r ReconnectToServerHandlerrO r r r: r; r< r s # " " " " "
" " " " " " ! ! ! ! ! ! $ $ $ $ $ $ O O O O O O O O O O O O O O O O O O O O . . . . . . . .,,,,,,, KKK 1 1 1 1 1 1 B A A A A A A A
C B B B B B B B B B******')$$KK KKK
'
H
%
%
S[[
v
v
& !# ! " !% +&&
S '' B $' ()io56
r5E!1223 cUE\* S!
Z CsCx .$>? ) ) ) ) ) ) ) ) $T&\4S>$BE(SYJZ\aJaDb$bc Q8 Q8 Q8 Q8 Q8 Q8 Q8 Q8h: : : :^ 6 ^ 6 ^ 6 ^ 6 ^ 6 ^ 6 ^ 6 ^ 6 ^ 6 ^ 6s$ 2A9 9BB
C C)(C)