xj*ddlmZddlZddlZddlZddlZddlZddlZddl 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@mAZAddlBmCZCddlDmEZEgdZFeGejHIddZJGddeCZKGddZLedddddddddddddddddddddddodFZMedddddddddddddddddddddGdpdIZMdddddddJde.dKdddLdMdMdLdNdOdddddqdRZM drdsdUZNe dtddVdudWZOe dtdvdXZO drddVdwdYZO ddZlPmQZQdd[lRm4ZSeQjTeQjTeQjUeQjUd\ZVdKd]dKd]d\ZWdxddZXn#eY$rdxdeZXYnwxYwdydgZZddddhdzdiZ[edjZ\edkede\flZ]GdmdnZ^dS){) 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_REDIRECTS10cleZdZdZdddddd fdZd!fd Zd"dZdedfd#dZd$fd Z d"fd 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_queuesock socket.socketprotocolrr; float | Noner<r=r>*int | None | tuple[int | None, int | None]returnNonec|tj|_d|_t ||||||dS)NTr:) threadingr response_rcvdpending_legacy_warningsuper__init__)selfr?rAr;r<r=r> __class__s GC:\Projects\Historical\venv\Lib\site-packages\websockets/sync/client.pyrKzClientConnection.__init__Es` %&_..&*#   '%'      cRd|_tS)NF)rIrJ __enter__rLrMs rNrQzClientConnection.__enter__[s!&+#ww  """rOc^|jr%d|_tjdtddSdS)NFzconnect() must be used as a context manager: with connect(...) as websocket: ...; alternatively, use websocket = connect(..., legacy=True) to connect directly) stacklevel)rIwarningswarnDeprecationWarningrLs rNmaybe_raise_legacy_warningz+ClientConnection.maybe_raise_legacy_warning_sP  & */D ' ML#         rONadditional_headersHeadersLike | Noneuser_agent_header str | Nonetimeoutc|j|_||jj|| |jjd||t5|j|jdddn #1swxYwY|j |std|jj |jj dS)z1 Perform the opening handshake. Nz User-Agent)expected_statez.timed out while waiting for handshake response) rAr/requestheadersupdate setdefault send_contextr send_requestrHwait TimeoutError handshake_exc)rLr[r]r_s rN handshakezClientConnection.handshakejs*},,..  ) L ' '(: ; ; ;  ( L + +L:K L L L   j  9 9 5 5 M & &t| 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5!&&w// QOPP P = & 2-- - 3 2s= B))B-0B-eventrc|j9t|tsJ||_|jdSt |dS)z. Process one incoming event. N)response isinstancerrHsetrJ process_event)rLrlrMs rNrqzClientConnection.process_eventse = eX.. . ..!DM   " " $ $ $ $ $ GG ! !% ( ( ( ( (rOc t|jdS#|jwxYw)zI Read incoming data from the socket and process events. N)rJ recv_eventsrHrprRs rNrszClientConnection.recv_eventssV  % GG   ! ! !   " " $ $ $ $ $D  " " $ $ $ $s >A)r?r@rArr;rBr<rBr=rBr>rCrDrErDr3)rDrE)r[r\r]r^r_rBrDrE)rlrrDrE) __name__ __module__ __qualname____doc__rKrQrZrrkrqrs __classcell__)rMs@rNr3r3+s<')%'&(@B        ,######    26(2 $ .....8 ) ) ) ) ) ) % % % % % % % % % %rOr3ceZdZdZddddddddedddeddddeddddd dKd4ZdLd8ZdMd9Z dNd;Z dOd?Z dPd@Z dPdAZ dQdHZdRdJZdS)Sr1as 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)r?sslserver_hostnameorigin extensions subprotocols compressionr[r]proxy proxy_sslproxy_server_hostnamer open_timeoutr;r<r=reconnect_delaysmax_sizer>loggercreate_connectionuristrr?socket.socket | Noner}ssl_module.SSLContext | Noner~r^r Origin | Noner'Sequence[ClientExtensionFactory] | NonerSequence[Subprotocol] | Nonerr[r\r]rstr | Literal[True] | Nonerrr'Callable[[Exception], Exception | None]rrBr;r<r=rCallable[[], Generator[float]]rrCr>rLoggerLike | Nonertype[ClientConnection] | NonekwargsrrDrEc |3d|vr/|d}tjdt||_t ||_|jjs|td|t||dkrt|}n|td||tj d}|t}||_||_||_| |_| |_| |_| |_| |_||_||_||_||_||_||_t9||||||_t9|||||_dS) N ssl_contextzssl_context was renamed to sslz-ssl argument is incompatible with a ws:// URIr{zunsupported compression: zwebsockets.client)rrrrrr:)poprVrWrXrr+ws_urisecure ValueErrorrrlogging getLoggerr3r?r}r~r[r]rrrrrrrropen_socket_kwargsdictprotocol_kwargsconnection_kwargs)rLrr?r}r~rrrrr[r]rrrrrr;r<r=rrr>rrrs rNrKzreconnect.__init__sJ ;=F22**]++C M0"    nn {! NcoLMM M  # !, / / / ) # #9*EEJJ  $FFFGG G >&':;;F  $ 0  ."4!2 "%:"!2( 0 !2"(#!%    "&'%' " " " rOdeadliner.r@c z|j}|dd}|j}|rd}|durt |j}|rt jt jt j} | | | tj |dnD#t$r|wxYw|t!|}|jdddkr-t%||j||dd }n|jdd d krI|jd kr|jt)d t+||j|f|j|j|jd|}ntt1d|d|jj|jjf|d| t jdi|}| d|S)zFOpen a TCP or Unix connection to the server, possibly through a proxy.unixFNTpathsockssource_address) local_addrhttphttpsz8proxy_ssl argument is incompatible with an http:// proxyr]r}r~z&parse_proxy returned unsupported proxyaddressr_)rcopyrrr!rsocketAF_UNIX SOCK_STREAM settimeoutr_r/osfspath Exceptioncloser"schemeconnect_socks_proxyrrconnect_http_proxyr]rAssertionErrorrehostportr)rLrrrrr? proxy_parseds rN open_socketzreconnect.open_socket(s\(--//zz&%((   E D==dk**E + 6=1CDDD  0 0 2 2333 RYvzz&'9'9::;;;;      &u--L"2A2&'11* K &zz*:DAA $RaR(F22&'11dn6P$R* K'+&<$($> %%MNNN   i$+*:DK !??4?IIDD!$_MMMF v..D  rOr3c|j||}n|j} |jtjtjhvr+|tjtjd|j j r| ||}t|j fi|j }|j||fi|j}n##t $r|wxYw ||j|j|n<#t $r/||jwxYw|S)zCreate a WebSocket connection.NT)r?rfamilyrAF_INETAF_INET6 setsockopt IPPROTO_TCP TCP_NODELAYrrrrrrrrrrkr[r]r_ close_socketrecv_events_threadjoin)rLrr?rA connections rNopen_connectionzreconnect.open_connectionws 9 ##H--DD9D {v~v??? 2F4FMMM{! 7tX66% &H 0/(JJ     JJLLL     '&  ""          # # % % %  ) . . 0 0 0   sBB>> C"3D9EexcrException | strct|tr|jjdvrd|jjvs|S|j}t j|j |jjd}t|}|j td|dS|j r|j std|S|j |j ks |j|jks|j|jkr|jddrtd |d S|jd td |d S|jBt)d t)|jD|_|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/i3i4LocationNzcannot 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 portc3PK|]!\}}|dv||fV"dS)) authorizationcookiezproxy-authorizationN)lower).0keyvalues rN z-reconnect.process_redirect..s\&C99;;QRRe RRRRrO)rorrn status_codercrurllibparseurljoinrr+r?rrrrrrgetr[r raw_items)rLr old_ws_urinew_uri new_ws_uris rNprocess_redirectzreconnect.process_redirects sM * *  (cl222J[ ,&&tx1Ej1QRRw''  9 PWPPP    XZ%6 X !VW!V!VWW W  !2 2 2*/11*/11&**6599 !*g*** &**955A!6g666 &2*1*1$2I*J*J*T*T*V*V++'rOct|j}ttD]} ||}||cS#t $rW}||}t|t r||ur||||_ t||_ Yd}~d}~wwxYwtdtd)z3Connect to a WebSocket server, following redirects.Nz more than z redirects) r.rrange MAX_REDIRECTSrstart_keepaliverrrorr+rr)rLr_rr exc_or_uris rNr/zreconnect.connects D-..}%% H HA "!11(;; **,,,!!!!!   !22377 j)44 !S(((c1 *DH"+J"7"7DKHHHH $ F] F F FGG GsA B:#A B55B:ct|drtd||_d|j_|jS)Nrzconnect() isn't reentrantF)hasattr RuntimeErrorr/rrIrQrYs rNrQzreconnect.__enter__sP 4 & & <:;; ;,,..16.((***rOexc_typetype[BaseException] | None exc_valueBaseException | None exc_tracebackTracebackType | NonecN |j||||`S#|`wxYwN)r__exit__)rLrrrs rNrzreconnect.__exit__s6  ?++HiOO    s $Iterator[ClientConnection]c#Kd} |5}|Vdddn #1swxYwYd}n#t$r} ||}n#t$r }|}Yd}~nd}~wwxYw||ur|||||}t|}|jd|t j|dtj |Yd}~nd}~wwxYw)NTz0connect failed; reconnecting in %.1f seconds: %sr) rrrnextrinfo tracebackformat_exception_onlystriptimesleep)rLdelaysrrnew_exc raised_excdelays rN__iter__zreconnect.__iter__s*.# " %Z$$$$%%%%%%%%%%%%%%%B? " " " )"44S99GG )))(GGGGGG) c>>&!s*>!2244FV    F3C88;AACC  5!!!!!!!!7 " # sQ( ((( C5A C0 AAC0AB C00C5)2rrr?rr}rr~r^rrrrrrrr^r[r\r]r^rrrrrr^rrrrBr;rBr<rBr=rBrrrrCr>rCrrrrrrrDrE)rr.rDr@)r?r@rr.rDr@)rr.rDr3)rrrDrrt)rrrrrrrDrE)rDr)rurvrwrxrrrrKrrrrr/rQrr rrOrNr1r1s5**b&*,0&* $>B59"+15(2,026,0EV%'&(%'&(;B?D@B$(;?AY Y Y Y Y Y v9999v())))VCCCCJHHHH@++++     %%%%%%rOr1.)r?r}r~rrrrr[r]rrrrr;r<r=rr>rrlegacyrrr?rr}rr~r^rrrrrrrr[r\r]rrrrrrBr;r<r=rrCr>rrrrrLiteral[True] | NonerrrDc dSrrrr?r}r~rrrrr[r]rrrrr;r<r=rr>rrrrs rNr/r/Cs FsrO)r?r}r~rrrrr[r]rrrrr;r<r=rr>rrLiteral[False]c dSrrrs rNr/r/is FrOr{Tr8r7r|r9 bool | NoneClientConnection | reconnectc t|fid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d|d|d|d|d||}|dur|S|}|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. r?r}r~rrrrr[r]rrrrr;r<r=rr>rrF)r1r/rI)rr?r}r~rrrrr[r]rrrrr;r<r=rr>rrrr connecterrs rNr/r/sPJ  T C(  v  : "\ K.-,+e)43"\$m "\!"$m#$%&)'(v)*,+ -I4""$$J2,1 ) rOrPathLike | Nonec |d}||td||td|/|d|dd}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. r?Nzmissing path argumentzpath is incompatible with sockr}rzws://localhost/zwss://localhost/T)rrrr)rrr1)rrrr?s rNr2r28s ::f  D | 0111 d.9::: { ::e   $M)B)B)J#CC$C  =4d = =f = ==rO)rc dSrrrrrrs rNr0r0Ss srOc dSrrrs rNr0r0]s rOc ht||fi|}|dur|S|}|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/rI)rrrrrrs rNr0r0gsU.tS33F33I""$$J2,1 ) rO) ProxyType)r )socks5hsocks5socks4asocks4Fr rr*rr.r@c tt|j|j|j|j|jt|j}|d|  |j |j|jfi|S#tttj f$rt$r}td|d}~wwxYw)z0Connect via a SOCKS proxy and return the socket.r_z failed to connect to SOCKS proxyN) SocksProxySOCKS_PROXY_TYPESrrrusernamepasswordSOCKS_PROXY_RDNSrer_r/OSErrorrirrr)rrrr socks_proxyrs rNrrs! el + J J N N U\ *    )X%5%5%7%7888 J&;&v{FKJJ6JJ Jv~6     J J J?@@c I Js2B &C1CCc  td)Nz6connecting through a SOCKS proxy requires python-socks) ImportError)rrrrs rNrrs RSSSrOrct}tj|j|j|jd} |||d}|r| |n| t|x#t$rh}t|jtsJ|j}d|jcxkrdkrnn|cYd}~|dSt!|d}~wt"j$rt%dt&$r}t)d|d}~wwxYw#|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_eofrr_recv feed_datafeed_eofr StopIterationrorrrrrirr)r?rreaderparserdatarrns rNread_connect_responser9s ^^F ^ F   OOH,,.. / / /99T??D "  &&&&!!! LLL  ///#)X.....9 (& , , , , , , , , ,OOOOO %X.. . >GGGEFFF ! >    sBA9B00 E:9D3E4ED*EEEEE6rc @|d|tj|j|jffi|}|jdkrq|tj}||j}| || ||}| dt|||}| | t||n##t$r|wxYw|S)Nr_rr)rer_rrrrrrrrrr#sendallr9rr) rrrr]r}r~rr?rbs rNrrs+ i!1!1!3!3444  #UZ$< G G G GD |w ;355C  "#jO ((**+++t_EE &eV5FGGGLLdH----    Ks *C;; DTF)boundcJeZdZdZdZ ddd Zd dZd!dZd"dZd#dZ d$dZ dS)%rzr Socket-like object providing TLS-in-TLS. Only methods that are used by websockets are implemented. iNr?r@rssl_module.SSLContextr~r^rDrEctj|_tj|_||_||j|j||_||jjdS)Nr) r MemoryBIOincomingoutgoing ssl_socketwrap_bio ssl_objectrun_io do_handshake)rLr?rr~s rNrKzSSLSSLSocket.__init__ss #,.. ",.. %.. M M+/   DO011111rOfuncCallable[..., T]argsrr<c d}d} ||}n)#tj$rd}Yntj$rd}YnwxYw|j}|r|j||rV|j|j}|r|j |n|j |r|S)NTF) rSSLWantReadErrorSSLWantWriteErrorrDreadrEr;r2 recv_bufsizerCwrite write_eof)rLrJrL want_read want_writeresultr8s rNrHzSSLSSLSocket.run_io)s IJ "t. ! ! ! / " " "!  "=%%''D .''--- ++D,=>>.M''----M++--- Ms 333buflenintbytescp ||jj|S#tj$rYdSwxYw)NrO)rHrGrPr SSLEOFError)rLrWs rNr2zSSLSSLSocket.recvGsE ;;t3V<< <%   33 s "55r8r%cB||jj|Sr)rHrGrR)rLr8s rNsendzSSLSSLSocket.sendMs{{4?0$777rOc*d}t|5}|d5}t|}||kr&||||dz }||k&dddn #1swxYwYddddS#1swxYwYdS)NrB) memoryviewr lenr])rLr8countview byte_viewamounts rNr;zSSLSSLSocket.sendallPs    6tyy~~ 6^^F&..9UVV#4555&.. 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6s4BrCrrrrrrrrrDr3)0rrr?rr}rr~r^rrrrrrrr^r[r\r]r^rrrrrr^rrBr;rBr<rBr=rBrrCr>rCrrrrrrrrrDr1)0rrr?rr}rr~r^rrrrrrrr^r[r\r]r^rrrrrr^rrBr;rBr<rBr=rBrrCr>rCrrrrrrrrrDr)NN)rrrr^rrrDr1)..) rrrr^rrrrrDr3) rrrr^rrrrrDr1) rrrr^rrrrrDr) rr rr*rr.rrrDr@)r?r@rr.rDr)rr rr*rr.r]r^r}rr~r^rrrDr@)_ __future__rrrrr}rrGrr urllib.parserrVcollections.abcrrrtypesrtypingrr r r r r clientrrrdatastructuresrr exceptionsrrrrrextensions.baserextensions.permessage_deflaterrcrhttp11rrrArrrr r!r"r#streamsr$r%r&r'r(r)rr*r+rr-utilsr.__all__rXenvironrrr3r1r/r2r0 python_socksrpython_socks.syncr$SOCKS5SOCKS4r%r(rr,r9rr<r=rrrOrNr}sO""""""  9999999999BBBBBBBBBBBBBBBB??????????11111111544444LLLLLL++++++))))))))((((((((JJJJJJJJJJJJ""""""IIIIIIIIIIIIII))))))))"""""" Y X XBJNN#=tDDEE r%r%r%r%r%zr%r%r%j````````F  "%(+"%:=14!-0$'(+.1(+!$"%!$"%;>15'-1$.(,.2(,!#"$!#"$;@<> $7;?ffffffT!>>>>>6 $'    !! !!!!!!H4J&&&&&&555555#"#"  JJJJJ3TTTTTTTTTTfN%)(,"&$$$$$$N GCLL GCxQ'(((M.M.M.M.M.M.M.M.M.M.s G GG