jddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl mZmZmZddlmZddlmZmZmZmZmZmZddlmZmZmZddlmZm Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(dd l)m*Z*dd l+m,Z,dd l-m.Z.m/Z/ddl0m1Z1m2Z2ddl3m4Z4m5Z5m6Z6m7Z7ddl8m9Z9ddlm:Z:m;Z;mZ>ddl?m@Z@mAZAddlBmCZCddlDmEZEgdZFeGejjddZJGddeCZKGddZLedddddddddddddddddddddd dd(ZM d? d@d)ZNe dAdd* dBd+ZOe dA dCd,ZO d?dd* dDd-ZO dd.lPmQZQdd/lRm4ZSeQjeQjeQjeQjd0ZVd#d1d#d1d0ZW dEd2ZXdFd4ZZdddd5 dGd6Z[ed7Z\ed8ede\f9Z]Gd:d;Z^y#eY$r dEd3ZXYSwxYw)H) annotationsN) GeneratorIteratorSequence) TracebackType)AnyCallableLiteralTypeVarcastoverload)ClientProtocolbackoffprocess_exception)Headers HeadersLike)InvalidProxyMessageInvalidProxyStatus InvalidStatus ProxyError SecurityError)ClientExtensionFactory) enable_client_permessage_deflate)validate_subprotocols) USER_AGENTResponse) CONNECTINGEvent)Proxy get_proxy parse_proxyprepare_connect_request) StreamReader) BytesLike LoggerLikeOriginPathLike Subprotocol) WebSocketURI parse_uri) Connection)Deadline)connect unix_connect reconnectunix_reconnectClientConnectionWEBSOCKETS_MAX_REDIRECTS10ceZdZdZddddd d fdZdfd ZddZd ed f dd Zdfd Z dfd Z xZ S)r3a+ :mod:`threading` implementation of a WebSocket client connection. :class:`ClientConnection` provides :meth:`recv` and :meth:`send` methods for receiving and sending messages. It supports iteration to receive messages:: for message in websocket: process(message) The iterator exits normally when the connection is closed with code 1000 (OK) or 1001 (going away) or without a close code. It raises a :exc:`~websockets.exceptions.ConnectionClosedError` when the connection is closed with any other code. The ``ping_interval``, ``ping_timeout``, ``close_timeout``, and ``max_queue`` arguments have the same meaning as in :func:`connect`. Args: socket: Socket connected to a WebSocket server. protocol: Sans-I/O connection.   ping_interval ping_timeout close_timeout max_queuect|tj|_d|_t|||||||y)NTr:) threadingr response_rcvdpending_legacy_warningsuper__init__)selfsockprotocolr;r<r=r> __class__s ]/var/www/html/streamforge-license/venv/lib/python3.12/site-packages/websockets/sync/client.pyrDzClientConnection.__init__EsC &__.&*#   '%'  c.d|_t| S)NF)rBrC __enter__rErHs rIrLzClientConnection.__enter__[s&+#w ""rJcd|jr$d|_tjdtdyy)NFzconnect() must be used as a context manager: with connect(...) as websocket: ...; alternatively, use websocket = connect(..., legacy=True) to connect directly) stacklevel)rBwarningswarnDeprecationWarningrEs rImaybe_raise_legacy_warningz+ClientConnection.maybe_raise_legacy_warning_s2  & &*/D ' MML#   'rJNc$|jj|_|%|jjj ||&|jjj d||j t5|jj|jddd|jj|s td|jj|jjy#1swY\xYw)z1 Perform the opening handshake. Nz User-Agent)expected_statez.timed out while waiting for handshake response) rGr/requestheadersupdate setdefault send_contextr send_requestrAwait TimeoutError handshake_exc)rEadditional_headersuser_agent_headertimeouts rI handshakezClientConnection.handshakejs}},,.  ) LL ' '(: ;  ( LL + +L:K L   j  9 5 MM & &t|| 4 5!!&&w/OP P == & & 2---- - 3 5 5s &DDc|j4t|tsJ||_|jj yt ||y)z. Process one incoming event. N)response isinstancerrAsetrC process_event)rEeventrHs rIrizClientConnection.process_eventsG == eX. ..!DM    " " $ G !% (rJc t||jjy#|jjwxYw)zI Read incoming data from the socket and process events. N)rC recv_eventsrArhrMs rIrlzClientConnection.recv_eventss:  % G  !    " " $D   " " $s ,A)rF socket.socketrGrr; float | Noner<rnr=rnr>*int | None | tuple[int | None, int | None]returnNonerpr3)rprq)raHeadersLike | Nonerb str | Nonercrnrprq)rjrrprq) __name__ __module__ __qualname____doc__rDrLrUrrdrirl __classcell__)rHs@rIr3r3+s<')%'&(@B  ! $  #  $ >   ,# 26(2 $ ...&. .  .8 ) % %rJr3ceZdZdZddddddddedddeddddeddddd  dd Zdd Zdd Z dd Z ddZ ddZ ddZ ddZddZy)r1as Similar to :func:`connect`, with support for automatic reconnection. :func:`reconnect` can also be treated as an infinite iterator to reconnect automatically on errors:: for websocket in reconnect(...): try: ... except websockets.exceptions.ConnectionClosed: continue If the connection fails with a transient error, it is retried with exponential backoff. If it fails with a fatal error, the exception is raised, breaking out of the loop. The connection is closed automatically after each iteration of the loop. :func:`reconnect` accepts the same arguments as :func:`connect`, minus the ``legacy`` flag, plus those listed below. It raises the same exceptions. Args: process_exception: When reconnecting automatically, tell whether an error is transient or fatal. The default behavior is defined by :func:`~websockets.client.process_exception`. Refer to its documentation for details. reconnect_delays: Delays in seconds between reconnection attempts. Default is exponential backoff with 5s jitter, capped at 60s. .. admonition:: Why is :func:`reconnect` a separate API from :func:`connect`? :class: tip A new API was necessary to maintain backwards compatibility with this historical behavior of :func:`connect`:: websocket = connect(...) for message in websocket: ... Once the deprecation period elapses, :func:`connect` will be changed to behave like :func:`reconnect` by default. NdeflateTr8r7r9)rFsslserver_hostnameorigin extensions subprotocols compressionrarbproxy proxy_sslproxy_server_hostnamer open_timeoutr;r<r=reconnect_delaysmax_sizer>loggercreate_connectionc |/d|vr+|jd}tjdt||_t ||_|j js | td| t||dk(r t|}n|td||tjd}|t}||_||_||_| |_| |_| |_| |_| |_||_||_||_||_||_||_t9||||||_t9|||||_y) N ssl_contextzssl_context was renamed to sslz-ssl argument is incompatible with a ws:// URIr{zunsupported compression: zwebsockets.client)rrrrrr:)poprQrRrSurir+ws_urisecure ValueErrorrrlogging getLoggerr3rFr}r~rarbrrrrrrrropen_socket_kwargsdictprotocol_kwargsconnection_kwargs)rErrFr}r~rrrrrarbrrrrrr;r<r=rrr>rrkwargss rIrDzreconnect.__init__s_J ;=F2**]+C MM0"  n {{!!coLM M  # !, / ) #9*EJ  $8 FG G >&&':;F  $ 0  ."4!2 "%:"!2( 0 !2"(#!%  "&'%' " rJc |jj}|jdd}|j}|rd}|durt |j }|rt j t jt j} |j|j|jtj|jdn8|t!|}|j"dddk(r*t%||j ||jdd }n|j"dd d k(ra|j"d k7r|j& t)d t+||j |f|j,|j&|j.d|}n|t1d|j3d|j j4|j j6f|j3d|jt j8di|}|jd|S#t$r|jwxYw)zFOpen a TCP or Unix connection to the server, possibly through a proxy.unixFNTpathsockssource_address) local_addrhttphttpsz8proxy_ssl argument is incompatible with an http:// proxyrbr}r~z&parse_proxy returned unsupported proxyaddressrc)rcopyrrr!rsocketAF_UNIX SOCK_STREAM settimeoutrcr/osfspath Exceptioncloser"schemeconnect_socks_proxyrrconnect_http_proxyrbrAssertionErrorr[hostportr)rEdeadlinerrrrF proxy_parseds rI open_socketzreconnect.open_socket(s((--/zz&%(  E D=dkk*E ==1C1CDD  0 0 23 RYYvzz&'9:;  &u-L""2A&'1* KK &zz*:DA $$Ra(F2&&'1dnn6P$R* KK'+&<&<$($>$> %%MNN   i$++*:*:DKK> !??4?ID!$_MF v.D  rJc|j|j|}n |j} |jtjtj hvr/|j tjtjd|jjr|j||}t|jfi|j}|j||fi|j} |j%|j&|j(|j+|S#t $r|j#wxYw#t $r,|j-|j.j1wxYw)zCreate a WebSocket connection.T)rFrfamilyrAF_INETAF_INET6 setsockopt IPPROTO_TCP TCP_NODELAYrrrrrrrrrrdrarbrc close_socketrecv_events_threadjoin)rErrFrG connections rIopen_connectionzreconnect.open_connectionwsL 99 ##H-D99D {{v~~v?? 2 2F4F4FM{{!!tX6% &&H 0//((J   ''&&  "   JJL     # # %  ) ) . . 0  sCD%.5E%E5E8ct|tr0|jjdvrd|jjvs|S|j }t jj|j|jjd}t|}|jtd|dS|jr|jstd|S|j|jk7s2|j|jk7s|j |j k7r|j"j%ddrtd|d S|j"j%d td|d S|j&8t)d t)|j&j+D|_|S) z Determine whether a connection error is a redirect that can be followed. Return the new URI if it's a valid redirect. Else, return an exception. ),i-i.i/i3i4Locationzcannot follow redirect to z with a preexisting socketz)cannot follow redirect to non-secure URI rFz'cannot follow cross-origin redirect to z with a Unix socketrz with an explicit host and portc3NK|]\}}|jdvr||fyw)) authorizationcookiezproxy-authorizationN)lower).0keyvalues rI z-reconnect.process_redirect..s2&C99;QRe s#%)rgrrf status_coderYrurllibparseurljoinrr+rFrrrrrrgetrar raw_items)rEexc old_ws_urinew_uri new_ws_uris rIprocess_redirectzreconnect.process_redirects sM * ((cll222J[[ ,,&&txx1E1Ej1QRw'  99 ,WI5OP    Z%6%6 #LWI!VW W   !2!2 2*//1*//1&&**659!=gYG)* &&**95A!=gYG56 &&2*1*1$2I2I*J*T*T*V+'rJcpt|j}ttD]'} |j |}|j |cStdtd#t $rJ}|j|}t|t r||ur||||_ t||_ Yd}~d}~wwxYw)z3Connect to a WebSocket server, following redirects.Nz more than z redirects) r.rrange MAX_REDIRECTSrstart_keepaliverrrgrr+rr)rEr_rr exc_or_uris rIr/zreconnect.connects D--.}% HA "!11(; **,!!' H* *]O: FG G% !2237 j)4!S((c1 *DH"+J"7DK sA"" B5+AB00B5ct|dr td|j|_d|j_|jS)Nrzconnect() isn't reentrantF)hasattr RuntimeErrorr/rrBrTs rIrLzreconnect.__enter__s; 4 &:; ;,,.16.rJcL |jj|`y#|`wxYwN)rr)rEexc_type exc_value exc_tracebacks rI__exit__zreconnect.__exit__s"  OO ! ! #s#c#Kd} |5}|dddd}#1swY xYw#t$r} |j|}n#t$r }|}Yd}~nd}~wwxYw||ur|||||j}t|}|jj d|t j|djtj|Yd}~d}~wwxYww)Nz0connect failed; reconnecting in %.1f seconds: %sr) rrrnextrinfo tracebackformat_exception_onlystriptimesleep)rEdelaysrrnew_exc raised_excdelays rI__iter__zreconnect.__iter__s*." %Z$$%BG%% " )"44S9G )(G) c>&!s*>!224FV    F33C8;AAC  5!!7 "s_C#%%C#"% C AC A A CABCC#C  C#)2rstrrFsocket.socket | Noner}ssl_module.SSLContext | Noner~rtr Origin | Noner'Sequence[ClientExtensionFactory] | NonerSequence[Subprotocol] | Nonerrtrarsrbrtrstr | Literal[True] | Nonerrrrtrz'Callable[[Exception], Exception | None]rrnr;rnr<rnr=rnrzCallable[[], Generator[float]]rror>rorLoggerLike | Nonertype[ClientConnection] | Nonerrrprq)rr.rprm)rFrmrr.rprm)rr.rpr3)rrrpzException | strrr)rztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonerprq)rpzIterator[ClientConnection])rurvrwrxrrrrDrrrrr/rLrrrrJrIr1r1s*b&*,0&* $>B59"+15(2,026,0EV%'&(%'&(;B?D@B$(;?AY Y # Y * Y $Y Y <Y 3Y  Y /Y &Y *!Y "0#Y $ *%Y &C'Y *#+Y ,$-Y .#/Y 0$1Y 293Y 6=7Y 8>9Y <"=Y @9AY DEY F GY v9v()VCJH@  ,  (  ,    %rJr1.)rFr}r~rrrrrarbrrrrr;r<r=rr>rrlegacyc yrrrrFr}r~rrrrrarbrrrrr;r<r=rr>rrrrs rIr/r/CsFrJ)rFr}r~rrrrrarbrrrrr;r<r=rr>rrc yrrr s rIr/r/isFrJr{Tr8r7r|r9c t|fid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d|d|d|d|d||}|dur|S|j}|rd|_|S)a Connect to the WebSocket server at ``uri``. :func:`connect` should be treated as a context manager yielding a :class:`ClientConnection`, which can then receive and send messages:: from websockets.sync.client import connect with connect(...) as websocket: ... The connection is closed automatically when exiting the context. Use :func:`reconnect` to reconnect automatically on errors. For backwards compatibility, :func:`connect` can be called directly:: websocket = connect(..., legacy=True) In that case, you're responsible for closing the connection with :meth:`ClientConnection.close` when no longer needed. When the ``legacy`` flag is enabled, :func:`connect` returns directly a :class:`ClientConnection` and iterating that connection yields messages. Currently, this is the default behavior when ``legacy`` isn't specified. When the ``legacy`` flag is explicitly disabled, :func:`connect` behaves like :func:`reconnect`: using it as an iterator returns a new connection at each iteration, making it easy to reconnect automatically on errors. Args: uri: URI of the WebSocket server. sock: Preexisting TCP socket. ``sock`` overrides the host and port from ``uri``. You may call :func:`socket.create_connection` to create a suitable TCP socket. ssl: Configuration for enabling TLS on the connection. server_hostname: Host name for the TLS handshake. ``server_hostname`` overrides the host name from ``uri``. origin: Value of the ``Origin`` header, for servers that require it. extensions: List of supported extensions, in order in which they should be negotiated and run. subprotocols: List of supported subprotocols, in order of decreasing preference. compression: The "permessage-deflate" extension is enabled by default. Set ``compression`` to :obj:`None` to disable it. See the :doc:`compression guide <../../topics/compression>` for details. additional_headers: Arbitrary HTTP headers to add to the handshake request. user_agent_header: Value of the ``User-Agent`` request header. It defaults to ``"Python/x.y.z websockets/X.Y"``. Setting it to :obj:`None` removes the header. proxy: If a proxy is configured, it is used by default. Set ``proxy`` to :obj:`None` to disable the proxy or to the address of a proxy to override the system configuration. See the :doc:`proxy docs <../../topics/proxies>` for details. proxy_ssl: Configuration for enabling TLS on the proxy connection. proxy_server_hostname: Host name for the TLS handshake with the proxy. ``proxy_server_hostname`` overrides the host name from ``proxy``. open_timeout: Timeout for opening the connection in seconds. :obj:`None` disables the timeout. ping_interval: Interval between keepalive pings in seconds. :obj:`None` disables keepalive. ping_timeout: Timeout for keepalive pings in seconds. :obj:`None` disables timeouts. close_timeout: Timeout for closing the connection in seconds. :obj:`None` disables the timeout. max_size: Maximum size of incoming messages in bytes. :obj:`None` disables the limit. You may pass a ``(max_message_size, max_fragment_size)`` tuple to set different limits for messages and fragments when you expect long messages sent in short fragments. max_queue: High-water mark of the buffer where frames are received. It defaults to 16 frames. The low-water mark defaults to ``max_queue // 4``. You may pass a ``(high, low)`` tuple to set the high-water and low-water marks. If you want to disable flow control entirely, you may set it to ``None``, although that's a bad idea. logger: Logger for this client. It defaults to ``logging.getLogger("websockets.client")``. See the :doc:`logging guide <../../topics/logging>` for details. legacy: Set to :obj:`True` to opt into the historical behavior of returning a :class:`ClientConnection`, without deprecation warning. create_connection: Factory for the :class:`ClientConnection` managing the connection. Set it to a wrapper or a subclass to customize connection handling. Any other keyword arguments are passed to :func:`~socket.create_connection`. For example, you can set ``address`` to a ``(host, port)`` tuple to connect to a different host and port from those found in ``uri``. This only changes the destination of the TCP connection. The host name from ``uri`` is still used in the TLS handshake for secure connections and in the ``Host`` header. Raises: InvalidURI: If ``uri`` isn't a valid WebSocket URI. InvalidProxy: If ``proxy`` isn't a valid proxy. OSError: If the TCP connection fails. InvalidHandshake: If the opening handshake fails. TimeoutError: If the opening handshake times out. rFr}r~rrrrrarbrrrrr;r<r=rr>rrF)r1r/rB)rrFr}r~rrrrrarbrrrrr;r<r=rr>rrrr connecterrs rIr/r/s J   (     " .,4"$ "!"$#$%&'()*, -I4""$J,1 ) rJc |jd}| | td| | td|'|jd|jdd}nd}td |d|d |S) z Similar to :func:`unix_connect`, with support for automatic reconnection. Refer to the documentation of :func:`reconnect` for details on its behavior. rFzmissing path argumentzpath is incompatible with sockr}rzws://localhost/zwss://localhost/T)rrrr)rrr1)rrrrFs rIr2r28s ::f D | 011 d.9:: { ::e  $M)B)J#C$C  =4d =f ==rJ)rc yrrrrrrs rIr0r0SsrJc yrrrs rIr0r0]srJc ^t||fi|}|dur|S|j}|rd|_|S)a Connect to a WebSocket server listening on a Unix socket. This function accepts the same keyword arguments as :func:`connect`. It's only available on Unix. It's mainly useful for debugging servers listening on Unix sockets. Args: path: File system path to the Unix socket. uri: URI of the WebSocket server. ``uri`` defaults to ``ws://localhost/`` or, when a ``ssl`` is provided, to ``wss://localhost/``. F)r2r/rB)rrrrr rs rIr0r0gsE.tS3F3I""$J,1 ) rJ) ProxyType)r )socks5hsocks5socks4asocks4Fc tt|j|j|j|j |j t|j}|jd|j |j|j|jfi|S#tttjf$rt$r}td|d}~wwxYw)z0Connect via a SOCKS proxy and return the socket.rcz failed to connect to SOCKS proxyN) SocksProxySOCKS_PROXY_TYPESrrrusernamepasswordSOCKS_PROXY_RDNSr[rcr/OSErrorr_rrr)rrrr socks_proxyrs rIrrs! ell + JJ JJ NN NN U\\ *   )X%5%5%78 J&;&&v{{FKKJ6J Jv~~6   J?@c I Js<'B$$'C CCc td)Nz6connecting through a SOCKS proxy requires python-socks) ImportError)rrrrs rIrrs RSSrJct}tj|j|j|j d} |j |j|jd}|r|j|n|jt|`#t$rr}t|jtsJ|j}d|jcxkrdkr%n t!||cYd}~|j dSt!|d}~wt"j$r t%dt&$r}t)d|d}~wwxYw#|j dwxYw)NT)rirz(timed out while connecting to HTTP proxyz0did not receive a valid HTTP response from proxy)r$rr read_line read_exact read_to_eofrrcrecv feed_datafeed_eofr StopIterationrgrrrrr_rr)rFrreaderparserdatarrfs rIread_connect_responser-s; ^F ^^ F  OOH,,. /99T?D  &! L /#))X...99 (&& , ,%X. .O %X. . >>GEFF ! >   sDA!B$$ E-A D8E9E D)E EEEE*rc |jd|jtj|j|j ffi|}|j dk(rg|tj}| |j}|j|j|j||}|jdt|||}|j| t|||S#t$r|jwxYw)Nrcrr)r[rcrrrrrrrrrr#sendallr-rr) rrrrbr}r~rrFrXs rIrrs i!1!1!34  # #UZZ$< G GD ||w ;335C  "#jjO ((*+t_E &eV5FGGLLdH- K   s " C00D TF)boundcVeZdZdZdZ d d dZd dZd dZddZddZ dd Z y)rzr Socket-like object providing TLS-in-TLS. Only methods that are used by websockets are implemented. iNctj|_tj|_||_|j |j|j||_|j|j jy)Nr) r MemoryBIOincomingoutgoing ssl_socketwrap_bio ssl_objectrun_io do_handshake)rErFrr~s rIrDzSSLSSLSocket.__init__sk #,,. ",,. %.. MM MM+/  DOO001rJc d}d} ||}|jj }|r|j j ||r^|j j|j}|r|jj|n|jj|rS#tj$rd}Ytj$rd}YwxYw)NTF) rSSLWantReadErrorSSLWantWriteErrorr7readr8r/r& recv_bufsizer6write write_eof)rEfuncargs want_read want_writeresultr,s rIr;zSSLSSLSocket.run_io)sIJ "t==%%'D''-++D,=,=>MM''-MM++-M-.. ! // "!  "sB((C?CCc |j|jj|S#tj$rYywxYw)NrJ)r;r:r@r SSLEOFError)rEbuflens rIr&zSSLSSLSocket.recvGs: ;;t33V< <%%  s %(>>cN|j|jj|Sr)r;r:rB)rEr,s rIsendzSSLSSLSocket.sendMs{{4??00$77rJcd}t|5}|jd5}t|}||kr||j||dz }||krddddddy#1swYxYw#1swYyxYw)NrB) memoryviewr lenrM)rEr,countview byte_viewamounts rIr/zSSLSSLSocket.sendallPsz   6tyy~ 6^F&.9UV#455&. 6 6 6 6 6 6s"A+-AA+A( $A++A4c.t|j|Sr)getattrr8)rEnames rI __getattr__zSSLSSLSocket.__getattr__[st--rJr)rFrmrzssl_module.SSLContextr~rtrprq)rDzCallable[..., T]rErrpr0)rKintrpbytes)r,r%rprZ)r,r%rprq)rXrrpr) rurvrwrxrArDr;r&rMr/rYrrJrIrrsWL '+ 22+2$ 2  2 < 86.rJr)0rrrFrr}rr~rtrrrrrrrrtrarsrbrtrrrrrrtrrnr;rnr<rnr=rnrror>rorrrrrLiteral[True] | Nonerrrpr3)0rrrFrr}rr~rtrrrrrrrrtrarsrbrtrrrrrrtrrnr;rnr<rnr=rnrror>rorrrrrLiteral[False]rrrpr1)0rrrFrr}rr~rtrrrrrrrrtrarsrbrtrrrrrrtrrnr;rnr<rnr=rnrror>rorrrrr bool | NonerrrpClientConnection | reconnect)NN)rPathLike | Nonerrtrrrpr1)..) rr`rrtrr\rrrpr3) rr`rrtrr]rrrpr1) rr`rrtrr^rrrpr_) rr rr*rr.rrrprm)rFrmrr.rpr)rr rr*rr.rbrtr}rr~rtrrrprm)_ __future__rrrrr}rr@rr urllib.parserrQcollections.abcrrrtypesrtypingrr r r r r clientrrrdatastructuresrr exceptionsrrrrrextensions.baserextensions.permessage_deflaterrYrhttp11rrrGrrrr r!r"r#streamsr$r%r&r'r(r)rr*r+rr-utilsr.__all__rZenvironrrr3r1r/r2r0 python_socksrpython_socks.syncrSOCKS5SOCKS4rrrr r-rr0r1rrrJrIrts"  99BB??15L+)(JJ"II)" YBJJNN#=tDE r%zr%j``F  "%(+"%:=14!-0$'(+.1(+!$"%!$"%;> !?"BC"DE" "J "%(+"%:=14!-0$'(+.1(+!$"%!$"%;> ?"BC"DE" "R"&(,"& :>15'-1$.(,.2(,!#"$!#"$;@<> $7;?f f  f & f  f f8f/ff+f"f &f ,!f"&#f&'f( )f*+f, -f091f2:3f6 7f:5;f> ?fBCfD"EfT!> > >> >6 $'    !                !! ! ! !  !  ! " !H4J&5##""##""  JJJJ J  J4N%)(,"&$ $ $$ " $ & $ $$$N CL CxQ'(M.M.ATTTTT T  TTs2 KKK