ޠjjSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKr SSK r SSK J r J r Jr SSKJr SSKJrJrJr SSKJr SSKJrJr SS KJrJrJrJrJr SS K J!r!J"r" SS K#J$r$ SS K%J&r&J'r'J(r(J)r)J*r*J+r+J,r, SS K-J.r. SSKJ/r/J0r0J1r1J2r2 SSK3J4r4J5r5 SSKJ6r6J7r7 SSK8J9r9J:r: SSK;Jr> /SQr?"SS\>5r@"SS5rA\ArBSSSjjrCg)) annotationsN) AsyncIterator GeneratorSequence) TracebackType)AnyCallablecast)asyncio_timeout)Headers HeadersLike) InvalidHeaderInvalidHeaderValueInvalidMessageNegotiationError SecurityError)ClientExtensionFactory Extension) enable_client_permessage_deflate)build_authorization_basicbuild_extension build_hostbuild_subprotocolparse_extensionparse_subprotocolvalidate_subprotocols) USER_AGENT)ExtensionHeader LoggerLikeOrigin Subprotocol) WebSocketURI parse_uri)InvalidStatusCodeRedirectHandshake) build_requestcheck_response) read_response)WebSocketCommonProtocol)connect unix_connectWebSocketClientProtocolc^\rSrSrSrSrSrSSSSS\S.SU4SjjjrSSjr SS jr \ SS j5r \ SS j5r SSS jjrS rU=r$)r./av WebSocket client connection. :class:`WebSocketClientProtocol` provides :meth:`recv` and :meth:`send` coroutines for receiving and sending messages. It supports asynchronous iteration to receive messages:: async for message in websocket: await process(message) The iterator exits normally when the connection is closed with close 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. See :func:`connect` for the documentation of ``logger``, ``origin``, ``extensions``, ``subprotocols``, ``extra_headers``, and ``user_agent_header``. See :class:`~websockets.legacy.protocol.WebSocketCommonProtocol` for the documentation of ``ping_interval``, ``ping_timeout``, ``close_timeout``, ``max_size``, ``max_queue``, ``read_limit``, and ``write_limit``. TclientN)loggerorigin extensions subprotocols extra_headersuser_agent_headerc >Uc[R"S5n[TU] "SSU0UD6 X lX0lX@lXPlX`lg)Nwebsockets.clientr2) logging getLoggersuper__init__r3available_extensionsavailable_subprotocolsr6r7) selfr2r3r4r5r6r7kwargs __class__s R/var/www/html/gaurav/venv/lib/python3.13/site-packages/websockets/legacy/client.pyr> WebSocketClientProtocol.__init__MsM >&&':;F 11&1 $.!&2#*!2cZXlX lUR(aQURRSU5 UR 5H!up4URRSX45 M# SUS3nU[ U5- nUR RUR55 g)z6 Write request line and headers to the HTTP request. z> GET %s HTTP/1.1z> %s: %szGET z HTTP/1.1 N) pathrequest_headersdebugr2 raw_itemsstr transportwriteencode)rArHheaderskeyvaluerequests rDwrite_http_request*WebSocketClientProtocol.write_http_requestas  & :: KK  14 8%//1  !!*c92 m,3w< W^^-.rFcv# [UR5IShvN upnUR(aQUR R SX5 UR 5H!upVUR R SXV5 M# X0lXR4$N|![an[S5UeSnAff=f7f)a Read status line and headers from the HTTP response. If the response contains a body, it may be read from ``self.reader`` after this coroutine returns. Raises: InvalidMessage: If the HTTP message is malformed or isn't an HTTP/1.1 GET response. Nz%did not receive a valid HTTP responsez< HTTP/1.1 %d %sz< %s: %s)r*reader ExceptionrrJr2rKresponse_headers)rA status_codereasonrPexcrQrRs rDread_http_response*WebSocketClientProtocol.read_http_responseus S1>t{{1K+K (K :: KK  0+ F%//1  !!*c92!(1111,L S !HIs R Ss8B9BBBA5B9B B6% B11B66B9c~/nURS5nU(aUc [S5e[UVs/sHn[U5PM sn/5nUHSupgUH9nURU:waMUR Xr5n UR U 5 MB [SUSU35e U$s snf![a Mdf=f)a Handle the Sec-WebSocket-Extensions HTTP response header. Check that each extension is supported, as well as its parameters. Return the list of accepted extensions. Raise :exc:`~websockets.exceptions.InvalidHandshake` to abort the connection. :rfc:`6455` leaves the rules up to the specification of each :extension. To provide this level of flexibility, for each extension accepted by the server, we check for a match with each extension available in the client configuration. If no match is found, an exception is raised. If several variants of the same extension are accepted by the server, it may be configured several times, which won't make sense in general. Extensions must implement their own requirements. For this purpose, the list of previously accepted extensions is provided. Other requirements, for example related to mandatory extensions or the order of extensions, may be implemented by overriding this method. Sec-WebSocket-Extensionszno extensions supportedzUnsupported extension: name = z , params = )get_allrsumrnameprocess_response_paramsappend) rPr?accepted_extensions header_values header_valueparsed_header_valuesrcresponse_paramsextension_factory extensions rDprocess_extensions*WebSocketClientProtocol.process_extensionss>02(BC #+&'@AA:=CPQ=<.=QSU; *>%)=%(--5 !$5$M$M+% (..y9#*>,+""&{?2CE/*>8#"?R,! !sB)-B.. B<;B<c4SnURS5nU(axUc [S5e[UVs/sHn[U5PM sn/5n[ U5S:a[ SSSR U535eUSnX!;a[SU35eU$s snf) z Handle the Sec-WebSocket-Protocol HTTP response header. Check that it contains exactly one supported subprotocol. Return the selected subprotocol. NSec-WebSocket-Protocolzno subprotocols supportedr%zmultiple values: z, rzunsupported subprotocol: )rarrbrlenrjoin)rPr@ subprotocolrgrhris rDprocess_subprotocol+WebSocketClientProtocol.process_subprotocols+/ (@A %-&'BCC:=ERS]\"<0]SUW; '(1,(,' 2F(G'HI /q1K8&)B;-'PQQTsBc# [5n[URURUR5US'UR (a[ UR 6US'UbX&S'[U5nUb9[UVs/sHnURUR54PM! sn5n XS'Ub[U5n XS'URbURUR5 UR(aURSUR5 UR!UR"U5 UR%5IShvN upU S;aS U ;a ['S 5e[)U S 5eU S :wa [+X5e[-X5 UR/X5UlUR3X5UlUR75 gs snfN7f) a Perform the client side of the opening handshake. Args: wsuri: URI of the WebSocket server. origin: Value of the ``Origin`` header. 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. extra_headers: Arbitrary HTTP headers to add to the handshake request. Raises: InvalidHandshake: If the handshake fails. Host AuthorizationNr!r`rpz User-Agent)i-i.i/i3i4Locatione)r rhostportsecure user_inforr(rrcget_request_paramsrr6updater7 setdefaultrT resource_namer]rr'r&r)rmr4rtrsconnection_open) rAwsurir3r?r@r6rIrQrkextensions_headerprotocol_headerrZrYs rD handshake!WebSocketClientProtocol.handshakes0")",UZZU\\"R ??/H0OO ,  (.H %O,  + /.B-A)'++->-Q-Q-ST-A!  ;L6 7 ! -/0FGO8G4 5    )  " "4#5#5 6  ! !  & &|T5K5K L  3 3_E.2.E.E.G(G% 3 3!11#J//#$4Z$@A A C #KB B'-11   33   K&)Hs A=G?%G $B!GGB G) r?r@r4r6r3rHrIrYrsr7)r2LoggerLike | Noner3 Origin | Noner4'Sequence[ClientExtensionFactory] | Noner5Sequence[Subprotocol] | Noner6HeadersLike | Noner7 str | NonerBrreturnNone)rHrLrPr rr)rztuple[int, Headers])rPr r?rrzlist[Extension])rPr r@rrzSubprotocol | None)NNNN) rr#r3rr?rr@rr6rrr)__name__ __module__ __qualname____firstlineno____doc__ is_clientsiderr>rTr] staticmethodrmrtr__static_attributes__ __classcell__)rCs@rDr.r./sH4I D %) $>B59,0(23"3 3 < 3 3 3*3&33 33(/(24F#F#EF# F#F#P""2N" ""N!%HL?C,0 MMMF M != M * M MMrFr.c6\rSrSrSr\"\RRSS55r SSSSSSS\ SSSSS S S S S .SS jjr SSjr \ "\RRSS55r\ "\RRSS55r\ "\RRSS55r\ "\RRSS55rSSjrS SjrS!SjrS"SjrS Sjr\rSrg)#ConnectiMa Connect to the WebSocket server at ``uri``. Awaiting :func:`connect` yields a :class:`WebSocketClientProtocol` which can then be used to send and receive messages. :func:`connect` can be used as a asynchronous context manager:: async with connect(...) as websocket: ... The connection is closed automatically when exiting the context. :func:`connect` can be used as an infinite asynchronous iterator to reconnect automatically on errors:: async for websocket in connect(...): try: ... except websockets.exceptions.ConnectionClosed: continue The connection is closed automatically after each iteration of the loop. If an error occurs while establishing the connection, :func:`connect` retries with exponential backoff. The backoff delay starts at three seconds and increases up to one minute. If an error occurs in the body of the loop, you can handle the exception and :func:`connect` will reconnect with the next iteration; or you can let the exception bubble up and break out of the loop. This lets you decide which errors trigger a reconnection and which errors are fatal. Args: uri: URI of the WebSocket server. create_protocol: Factory for the :class:`asyncio.Protocol` managing the connection. It defaults to :class:`WebSocketClientProtocol`. Set it to a wrapper or a subclass to customize connection handling. logger: Logger for this client. It defaults to ``logging.getLogger("websockets.client")``. See the :doc:`logging guide <../../topics/logging>` for details. 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. 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. extra_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. open_timeout: Timeout for opening the connection in seconds. :obj:`None` disables the timeout. See :class:`~websockets.legacy.protocol.WebSocketCommonProtocol` for the documentation of ``ping_interval``, ``ping_timeout``, ``close_timeout``, ``max_size``, ``max_queue``, ``read_limit``, and ``write_limit``. Any other keyword arguments are passed the event loop's :meth:`~asyncio.loop.create_connection` method. For example: * You can set ``ssl`` to a :class:`~ssl.SSLContext` to enforce TLS settings. When connecting to a ``wss://`` URI, if ``ssl`` isn't provided, a TLS context is created with :func:`~ssl.create_default_context`. * You can set ``host`` and ``port`` 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. OSError: If the TCP connection fails. InvalidHandshake: If the opening handshake fails. ~asyncio.TimeoutError: If the opening handshake times out. WEBSOCKETS_MAX_REDIRECTS10Ndeflate i i)create_protocolr2 compressionr3r4r5r6r7 open_timeout ping_interval ping_timeout close_timeoutmax_size max_queue read_limit write_limitc URSS5nUcSnO[R"S[5 U cUn URSS5nUc[nO[R"S[5 UcUnURSS5nURSS5nUc[ R "5nOUn[R"S [5 [U5nUR(aURS S 5 OURS 5b [S 5eUS :Xa [U5nOUb[SU35eUb [U5 [[S[4U5n[ R""U40SU_SU_SU_SU_SU_SU _SU _SU _SU _SU_SU_SU_SU_SUR$_SUR&_SUR_SU_SU_6nURS S5(a6URS!S5n[ R""UR(UU40UD6nOURS"5cUR$UR&nnO7S#unnURS 5(aURS$UR$5 URSU5nURSU5n[ R""UR*UUU40UD6nXlUc[.R0"S%5nX0lUUlXlUUlg)&Ntimeoutrzrename timeout to close_timeoutklasszrename klass to create_protocol legacy_recvFloopzremove loop argumentsslTzQconnect() received a ssl argument for a ws:// URI, use a wss:// URI to enable TLSrzunsupported compression: .r2r3r4r5r6r7rrrrrrrr{r|r}unixrHsock)NNserver_hostnamer9)popwarningswarnDeprecationWarningr.asyncioget_event_loopr$r}rget ValueErrorrrr r functoolspartialr{r|create_unix_connectioncreate_connectionrr;r<r2_create_connection_uri_wsuri)rAurirr2rr3r4r5r6r7rrrrrrrrrBrrr_looprrfactoryrHrr{r|s rDr>Connect.__init__s?.!' 9d ; ?G MM;=O P  #M7=jj$6O =+E MM;=O P  "#O#JJ}e< 39**VT2J =))+DD MM02D E# <<   eT * ZZ  *1  ) #9*EJ  $8 FG G  # !, /x-D(DEW##    "  &  (  0 ( & (    " $  ! "<<# $$% &' , ::fe $ $%zz&$7D ) 1 1++Wd!>D!  zz&!)"ZZdd( d::e$$%%&7D::fd+D::fd+D ) 1 1&&t!?E! ) >&&':;F #4  rFc URnURn[RR X!5n[ U5nUR (aUR (d [S5eUR UR :H=(a9 URUR:H=(a URUR:HnU(GdvURRSnUR (dFUR (a5SURS'URRRSS5 URRS5nUb6[S[U5R!555URS'["R$"UR&/URQ70[)URURURS9D6n["R$"URR&/XuRUR4Q70URRD6Ul X@lXPlg) Nzredirect from WSS to WSrTr}rr6c3V# UH upUR5S;dMX4v M" g7f)) authorizationcookiezproxy-authorizationN)lower).0rQrRs rD *Connect.handle_redirect..@s/*LJC99;QR% *Ls) ))r{r|)rrurllibparseurljoinr$r}rr{r|rargskeywordsrrr rKrrfuncdict) rArold_uri old_wsurinew_uri new_wsuri same_originrr6s rDhandle_redirectConnect.handle_redirect"s))KK ,,&&w4g&    I$4$4 9: :    0 0 0 1)..0 1)..0 --2215G## (8(8-1  *''00;;E4H#,,00AM(4;*1-*@*J*J*L5  1 '' w''inn9>>RG '0&7&7'',,'>>9>>:'))22'D #  rF WEBSOCKETS_BACKOFF_INITIAL_DELAY5WEBSOCKETS_BACKOFF_MIN_DELAYz3.1WEBSOCKETS_BACKOFF_MAX_DELAYz90.0WEBSOCKETS_BACKOFF_FACTORz1.618c^# URUR- nUIShvN nU7v SSS5IShvN URnM/N'N!,IShvN (df  N)=f![Ga5nXR:Xa[R"5UR-nUR R SU[R"U5SR55 [R"U5IShvN OsUR R S[U5[R"U5SR55 [R"[U55IShvN XR-n[XR5nSnAGMSnAff=f7f)Nz0connect failed; reconnecting in %.1f seconds: %srz0connect failed again; retrying in %d seconds: %s) BACKOFF_MINBACKOFF_FACTORrXrandomBACKOFF_INITIALr2info tracebackformat_exception_onlystriprsleepintmin BACKOFF_MAX)rA backoff_delayprotocolr\ initial_delays rD __aiter__Connect.__aiter___s?((4+>+>>  148"N 44!% 0 0 9444 !$4$44$*MMOd6J6J$JMKK$$J%!77UR5R5$r)__await_impl__ __await__rs rDrConnect.__await__s""$..00rFc # [UR5IShvN [UR5HnUR 5IShvN up#UR UR URURURURS9IShvN X0l Us sSSS5IShvN $ [)S5eNN~N0N![aOnUR5 UR5IShvN URUR 5 SnAMSnAf["[$R&4a+ UR5 UR5IShvN ef=f!,IShvN (df  g=f7f)N)r3r?r@r6ztoo many redirects)r rrangeMAX_REDIRECTS_ALLOWEDrrrr3r?r@r6rr'fail_connection wait_closedrrrXrCancelledErrorr)rA _redirects _transportrr\s rDrConnect.__await_impl__sC"4#4#455#D$>$>? -1-D-D-F'F$ $",, '-5-J-J/7/N/N&.&<&< -"%-M#O-655?.$$89916'F 6)2,,."..000((11!7#9#9:,,."..000!655sF C F ,E0 C  E0ACC C! E0* F 6C7F < E0 F  E0 CF  E-#D%>D ? D%E0%AE-%E( &E--E00F6E9 7 FF )rrrr2rr)&rrLrz-Callable[..., WebSocketClientProtocol] | Noner2rrrr3rr4rr5rr6rr7rr float | Nonerrrrrrr int | NonerrrrrrrBrrr)rrLrr)rz&AsyncIterator[WebSocketClientProtocol])rr.)rztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonerr)rz-Generator[Any, None, WebSocketClientProtocol])rrrrrrosenvironrrrr>rfloatrrrrrrrrr__iter__rr:rFrDrrMsQf  /I4 PQ JN$("+ $>B59,0(2%'&(%'&*$ $ '} }G } " }  }}<}3}*}&}#}$}#}$} !}"#}$%}&'}()}* +}~4 pBJJNN+MsSTO 'EuMNK 'EvNOK2::>>*EwOPN1D$,$($( $  $1::HrFrc [SXSS.UD6$)a Similar to :func:`connect`, but for connecting to a Unix socket. This function builds upon the event loop's :meth:`~asyncio.loop.create_unix_connection` method. It is 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; the host is used in the TLS handshake for secure connections and in the ``Host`` header. T)rrHrr:)r,)rHrrBs rDr-r-s*  ;sD ;F ;;rF)Nzws://localhost/)rHrrrLrBrrr)D __future__rrrr;rrr urllib.parserrcollections.abcrrrtypesrtypingrr r asyncio.compatibilityr datastructuresr r exceptionsrrrrrr4rrextensions.permessage_deflaterrPrrrrrrrhttp11rrr r!r"rr#r$r&r'rr(r)httpr*rr+__all__r.rr,r-r:rFrDr!s" >>&&31;L EE)<4- A[5[|bbJ  < < <<