Ë
    Bü´j•>  ã                   óÐ  — d Z ddlZddlZddlZddlmZ ddlmZm	Z	 ddl
mZmZmZ ddlmZmZmZ ddlmZmZmZ dd	lmZmZ dd
lmZmZ g d¢Z	 ddlmZmZm Z  ddl!m"Z" ddl#m$Z$ dZ% G d„ d«      Z(de)dedede	ej                  e	e)e*e)f   f   fd„Z+de)deded ede	ej                  e	e)e*e)f   f   f
d!„Z,d"e)d#e*d$e-dede	e.e-ef   f
d%„Z/d&„ Z0d'ej                  d(e1d"e)d)e-def
d*„Z2d'ej                  d+e1d"e)defd,„Z3d'ej                  d-e)d#e*d.edej                  f
d/„Z4d'ej                  de5fd0„Z6y# e&$ r0 dZ% G d„ de'«      Z G d„ de'«      Z  G d„ de'«      Z G d„ d«      Z"Y Œüw xY w)1a_  
_http.py
websocket - WebSocket client library for Python

Copyright 2026 engn33r

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
é    N)Úencodebytes)ÚAnyÚTupleé   )ÚWebSocketAddressExceptionÚWebSocketExceptionÚWebSocketProxyException)ÚdebugÚdumpÚtrace)ÚDEFAULT_SOCKET_OPTIONÚ	recv_lineÚsend)ÚHAVE_SSLÚssl)Úget_proxy_infoÚ	parse_url)Ú
proxy_infoÚconnectÚread_headers)ÚProxyConnectionErrorÚ
ProxyErrorÚProxyTimeoutError)Ú	ProxyType)ÚProxyTFc                   ó   — e Zd Zy)r   N©Ú__name__Ú
__module__Ú__qualname__© ó    úM/root/workspace/ytshorts/venv/lib/python3.12/site-packages/websocket/_http.pyr   r   0   ó   „ Ør"   r   c                   ó   — e Zd Zy)r   Nr   r!   r"   r#   r   r   3   r$   r"   r   c                   ó   — e Zd Zy)r   Nr   r!   r"   r#   r   r   6   r$   r"   r   c                   ó   — e Zd Zy)r   Nr   r!   r"   r#   r   r   9   r$   r"   r   c                   ó   — e Zd Zd„ Zy)r   c                 óª  — |j                  dd «      | _        | j                  r�|j                  dd«      | _        |j                  dd «      | _        |j                  dd «      | _        |j                  dd«      | _        |j                  dd «      | _        | j
                  d	vrt        d
«      ‚y d| _        d | _        d | _        d| _        d | _        y )NÚhttp_proxy_hostÚhttp_proxy_portr   Úhttp_proxy_authÚhttp_no_proxyÚ
proxy_typeÚhttpÚhttp_proxy_timeout)r/   Úsocks4Úsocks4aÚsocks5Úsocks5hz7Only http, socks4, socks5 proxy protocols are supported)ÚgetÚ
proxy_hostÚ
proxy_portÚauthÚno_proxyÚproxy_protocolÚproxy_timeoutr   )ÚselfÚoptionss     r#   Ú__init__zproxy_info.__init__>   sÌ   € Ø!Ÿ+™+Ð&7¸Ó>ˆŒØ�?Š?Ø%Ÿk™kÐ*;¸QÓ?ˆDŒOØŸ™Ð$5°tÓ<ˆDŒIØ#ŸK™K¨¸Ó>ˆDŒMØ")§+¡+¨l¸FÓ"CˆDÔà!(§¡Ð-AÀ4Ó!HˆDÔØ×"Ñ"ð +ñ ô !ØMóð ðð  ˆDŒOØˆDŒIØ ˆDŒMØ"(ˆDÔØ!%ˆDÕr"   N)r   r   r    r>   r!   r"   r#   r   r   =   s   „ ó&r"   r   Úurlr=   ÚproxyÚreturnc                 ó  — |j                   r|j                  st        d«      ‚t        st	        d«      ‚t        | «      \  }}}}|j                  dk(  rd}t        j                  }ne|j                  dk(  rd}t        j                  }nC|j                  dk(  rd}t        j                  }n!|j                  dk(  rd}t        j                  }t        j                  |j                   t        |j                  «      |j                  r|j                  d	   nd |j                  r|j                  d
   nd ¬«      }	|	j                  |||j                  ¬«      }
|r)t         rt#        |
|j$                  |«      }
nt	        d«      ‚|
|||ffS )Nz+Cannot use port 0 when proxy_host specifiedz>Python Socks is needed for SOCKS proxying but is not availabler1   Fr2   Tr3   r4   r   r   )r.   ÚhostÚportÚusernameÚpasswordÚrdns)ÚtimeoutúSSL not available.)r6   r7   r	   ÚHAVE_PYTHON_SOCKSr   r   r:   r   ÚSOCKS4ÚSOCKS5r   ÚcreateÚintr8   r   r;   r   Ú_ssl_socketÚsslopt)r?   r=   r@   ÚhostnamerD   ÚresourceÚ	is_securerG   r.   Úws_proxyÚsocks              r#   Ú_start_proxied_socketrV   Y   sf  € ð ×Ò × 0Ò 0Ü%Ð&SÓTÐTÝÜ ØLó
ð 	
ô +4°C«.Ñ'€Hˆd�H˜ià×Ñ˜xÒ'ØˆÜ×%Ñ%‰
à	×	Ñ	 Ò	*ØˆÜ×%Ñ%‰
Ø	×	Ñ	 Ò	)ØˆÜ×%Ñ%‰
à	×	Ñ	 Ò	*ØˆÜ×%Ñ%ˆ
ä�|‰|ØØ×ÑÜ�×!Ñ!Ó"Ø"'§*¢*�—‘˜A’°$Ø"'§*¢*�—‘˜A’°$Øô€Hð ×Ñ˜H d°E×4GÑ4GÐÓH€DáÝÜ˜t W§^¡^°XÓ>‰Dä$Ð%9Ó:Ð:à�(˜D (Ð+Ð+Ð+r"   Úsocketc                 óÎ  — |j                   r|s|j                  dk7  rt        | ||«      S t        | «      \  }}}}|r||||ffS t	        ||||«      \  }}	}
|st        d|› d|› �«      ‚d }	 t        ||j                  |j                  «      }|	rt        ||||
«      }|r)t        rt        ||j                  |«      }nt        d«      ‚||||ffS #  |r|j                  «        ‚ xY w)Nr/   zHost not found.: ú:rI   )r6   r:   rV   r   Ú_get_addrinfo_listr   Ú_open_socketÚsockoptrH   Ú_tunnelr   rO   rP   Úclose)r?   r=   r@   rW   rQ   Úport_from_urlrR   rS   Úaddrinfo_listÚneed_tunnelr8   rU   s               r#   r   r   ˆ   s	  € ð ×Ò¡¨5×+?Ñ+?À6Ò+IÜ$ S¨'°5Ó9Ð9ä3<¸S³>Ñ0€Hˆm˜X yáØ˜ -°Ð:Ð:Ð:ä'9Ø�- ¨Eó(Ñ$€M�; ñ Ü Ð#4°X°J¸aÀ¸Ð!OÓPÐPà€DðÜ˜M¨7¯?©?¸G¿O¹OÓLˆÙÜ˜4 ¨=¸$Ó?ˆDáÝÜ" 4¨¯©¸ÓB‘ä(Ð)=Ó>Ð>à�h ¨xÐ8Ð8Ð8øðÙØ�J‰JŒLØús   Á,A"C ÃC$rQ   rD   rS   c                 ó  — 	 t        | ||j                  |j                  |j                  |j                  «      \  }}}	 |s:t        j                  | |dt        j                  t        j                  «      }|dd fS |xr |xs d}t        j                  ||dt        j                  t        j                  «      }|d|fS # t
        $ r}t        |«      ‚d }~ww xY w# t        j                  t
        f$ r}t        |«      ‚d }~ww xY w)Nr   FéP   T)r   r6   r7   r8   r9   Ú	TypeErrorr   rW   ÚgetaddrinfoÚSOCK_STREAMÚSOL_TCPÚgaierror)	rQ   rD   rS   r@   ÚphostÚpportÚpauthÚer`   s	            r#   rZ   rZ   ¯   s  € ð
+Ü,ØØØ×ÑØ×ÑØ�J‰JØ�N‰Nó
Ñˆˆu�eð+ñ Ü"×.Ñ.Ø˜$ ¤6×#5Ñ#5´v·~±~óˆMð ! %¨Ð-Ð-à’O˜eÒ) rˆEô
 #×.Ñ.Ø�u˜a¤×!3Ñ!3´V·^±^óˆMð ! $¨Ð-Ð-øô) ò +Ü'¨Ó*Ð*ûð+ûô* �O‰OœYÐ'ò +Ü'¨Ó*Ð*ûð+ús5   ‚<B? ¿;C Á;AC Â?	CÃCÃCÃDÃ4C?Ã?Dc                 óF  — d }| D ]‚  }|d d \  }}}t        j                   |||«      }|j                  |«       t        D ]  }	 |j                  |	Ž  Œ |D ]  }	 |j                  |	Ž  Œ |d   }
d }|s	 |j	                  |
«       	  |S Œ„ |r|‚S # t         j
                  $ r}}|j                  «        t        |
d   «      |_        t        j                  t        t        dt        j                  «      t        j                  f}|j                  |vr|‚|}Y d }~Œ«d }~ww xY w)Né   é   r   ÚWSAECONNREFUSED)rW   Ú
settimeoutr   Ú
setsockoptr   Úerrorr^   ÚstrÚ	remote_ipÚerrnoÚECONNREFUSEDÚgetattrÚENETUNREACH)r`   r\   rH   ÚerrÚaddrinfoÚfamilyÚsocktypeÚprotorU   ÚoptsÚaddressrs   ÚeConnRefuseds                r#   r[   r[   Ô   s?  € Ø
€CØ!ò !ˆØ"*¨2¨A ,Ñˆ�˜%Ü�}‰}˜V X¨uÓ5ˆØ�‰˜Ô Ü)ò 	#ˆDØˆD�O‰O˜TÒ"ð	#àò 	#ˆDØˆD�O‰O˜TÒ"ð	#ð ˜1‘+ˆØˆÙðØ—‘˜WÔ%ð ð 	ð
 €Kð ð;!ñ@ ØˆIà€Køô+ —<‘<ò Ø—
‘
”Ü"% g¨a¡j£/�”ä×&Ñ&ÜœEÐ#4´e×6HÑ6HÓIÜ×%Ñ%ð �ð
 —;‘; lÑ2Ø�KØ�Üûðús   Á3BÂD Â#A3DÄD rU   rP   Úcheck_hostnamec                 óú  — |j                  dd «      }|�sŒt        j                  |j                  dt        j                  «      «      }t        j
                  j                  d«      }|�||_        |j                  dt        j                  «      t        j                  k7  rs|j                  dd «      }|j                  dd «      }|s|r	 |j                  ||¬«       n6t        |d	«      r*	 |j                  t        j                  j                   «       |j                  dd «      r7	 |j#                  |d   |j                  dd «      |j                  dd «      «       |j                  dt        j                  «      t        j                  k(  r/|j                  dd«      sd|_        t        j                  |_        n`|j                  dd«      }|j                  dt        j(                  «      }	|r|	t        j                  k(  rt        d«      ‚||_        |	|_        d|v r	 |j+                  |d   «       d|v rN	 |d   }
t-        |
t.        t0        f«      rt3        |
«      dk7  rt        d«      ‚|
\  }}}|j#                  |||«       d|v r	 |j5                  |d   «       |j7                  | |j                  dd«      |j                  dd«      |¬«      S # t        t        j                  t        f$ r}t        d|› �«      ‚d }~ww xY w# t        j                  $ r}t        d
|› �«      ‚d }~ww xY w# t        t        f$ r}t        d|› �«      ‚d }~wt        j                  $ r}t        d|› �«      ‚d }~ww xY w# t        j                  $ r}t        d|› �«      ‚d }~ww xY w# t        $ r ‚ t        t        j                  f$ r}t        d|› �«      ‚d }~ww xY w# t        $ r}t        d|› �«      ‚d }~ww xY w)NÚcontextÚssl_versionÚSSLKEYLOGFILEÚ	cert_reqsÚca_certsÚca_cert_path)ÚcafileÚcapathz#SSL CA certificate loading failed: Úload_default_certsz(SSL default certificate loading failed: ÚcertfileÚkeyfilerF   z'SSL client certificate loading failed: r‚   FTzoSSL certificate verification configuration failed: check_hostname cannot be enabled when cert_reqs is CERT_NONEÚciphersz!SSL cipher configuration failed: Ú
cert_chainrn   z@cert_chain must be a tuple/list of (certfile, keyfile, password)z-SSL client certificate configuration failed: Ú
ecdh_curvez%SSL ECDH curve configuration failed: Údo_handshake_on_connectÚsuppress_ragged_eofs)r’   r“   Úserver_hostname)r5   r   Ú
SSLContextÚPROTOCOL_TLS_CLIENTÚosÚenvironÚkeylog_filenameÚ	CERT_NONEÚload_verify_locationsÚFileNotFoundErrorÚSSLErrorÚ
ValueErrorr   ÚhasattrrŒ   ÚPurposeÚSERVER_AUTHÚload_cert_chainr‚   Úverify_modeÚCERT_REQUIREDÚset_ciphersÚ
isinstanceÚtupleÚlistÚlenÚset_ecdh_curveÚwrap_socket)rU   rP   rQ   r‚   r„   Úkeylog_filerŠ   r‹   rl   r‡   r�   r�   rŽ   rF   s                 r#   Ú_wrap_sni_socketr­   ü   så  € ð �j‰j˜ DÓ)€GÚÜ—.‘. §¡¨M¼3×;RÑ;RÓ!SÓTˆô
 —j‘j—n‘n _Ó5ˆØÐ"Ø&1ˆGÔ#à�:‰:�k¤3§=¡=Ó1´S·]±]ÒBØ—Z‘Z 
¨DÓ1ˆFØ—Z‘Z °Ó5ˆFÙ™ðXØ×1Ñ1¸ÈÐ1ÕOô ˜Ð"6Ô7ðØ×.Ñ.¬s¯{©{×/FÑ/FÔGð
 �:‰:�j $Ô'ð	XØ×'Ñ'Ø˜:Ñ&Ø—J‘J˜y¨$Ó/Ø—J‘J˜z¨4Ó0ôð �:‰:�k¤3§=¡=Ó1´S·]±]ÒBÈ6Ï:É:Ø˜eôL
ð &+ˆGÔ"Ü"%§-¡-ˆGÕà#ŸZ™ZÐ(8¸$Ó?ˆNØŸ
™
 ;´×0AÑ0AÓBˆIÙ )¬s¯}©}Ò"<Ü(ðSóð ð &4ˆGÔ"Ø"+ˆGÔà˜ÑðRØ×#Ñ# F¨9Ñ$5Ô6ð ˜6Ñ!ðØ# LÑ1�
Ü! *¬u´d¨mÔ<ÄÀJÃÐSTÒ@TÜ$ØZóð ð /9Ñ+�˜' 8Ø×'Ñ'¨°'¸8ÔDð ˜6Ñ!ðVØ×&Ñ& v¨lÑ';Ô<ð ×ÑØØ &§
¡
Ð+DÀdÓ KØ#ŸZ™ZÐ(>ÀÓEØ ð	 ó ð øôE *¬3¯<©<¼ÐDò XÜ,Ð/RÐSTÐRUÐ-VÓWÐWûðXûô
 —|‘|ò Ü,ØBÀ1À#ÐFóð ûðûô &¤zÐ2ò XÜ(Ð+RÐSTÐRUÐ)VÓWÐWûÜ—<‘<ò XÜ(Ð+RÐSTÐRUÐ)VÓWÐWûðXûô2 —<‘<ò RÜ(Ð+LÈQÈCÐ)PÓQÐQûðRûô ò ØÜ%¤s§|¡|Ð4ò Ü(ØCÀAÀ3ÐGóð ûðûô ò VÜ(Ð+PÐQRÐPSÐ)TÓUÐUûðVús�   ÃK Ã,)L Ä(6L4 È#M= È<AN& ÊO ËLË5LÌLÌL1ÌL,Ì,L1Ì4M:ÍMÍM:Í'M5Í5M:Í=N#ÎNÎN#Î&"OÏOÏOÏ	O:Ï'O5Ï5O:Úuser_ssloptc                 óÚ  — dt         j                  i}|j                  |«       t        j                  j                  d«      }|r7t        j                  j                  |«      r|j                  dd «      €||d<   n8|r6t        j                  j                  |«      r|j                  dd «      €||d<   |j                  dd «      r|d   }|j                  dd«      }t        | |||«      } | S )Nr‡   ÚWEBSOCKET_CLIENT_CA_BUNDLErˆ   r‰   r”   r‚   T)
r   r¤   Úupdater—   r˜   r5   ÚpathÚisfileÚisdirr­   )rU   r®   rQ   rP   Ú	cert_pathr‚   s         r#   rO   rO   Z  sÍ   € Ø¤×!2Ñ!2Ð3€FØ
‡M�M�+Ôä—
‘
—‘Ð;Ó<€IáÜ�G‰G�N‰N˜9Ô%Ø�O‰O˜J¨Ó-Ð5à&ˆˆzÒáÜ�G‰G�M‰M˜)Ô$Ø�O‰O˜N¨DÓ1Ð9à!*ˆˆ~Ñà‡z�zÐ# TÔ*ØÐ+Ñ,ˆà—Z‘ZÐ 0°$Ó7€NÜ˜D &¨(°NÓC€Dà€Kr"   rC   r8   c                 ó  — t        d«       d|› d|› d�}|d|› d|› d�z  }|rh|d   rc|d   }|d   r|d|d   › �z  }t        |j                  «       «      j                  «       j	                  «       j                  d	d
«      }|d|› d�z  }|dz  }t        d|«       t        | |«       	 t        | «      \  }}}|dk7  rt        d|› �«      ‚| S # t        j                  t        f$ r}	t        t        |	«      «      ‚d }	~	ww xY w)NzConnecting proxy...zCONNECT rY   z HTTP/1.1
zHost: z
r   r   ú
Ú zProxy-Authorization: Basic zrequest headeréÈ   z!failed CONNECT via proxy status: )r
   Úbase64encodeÚencodeÚstripÚdecodeÚreplacer   r   r   rW   rs   r   r	   rt   )
rU   rC   rD   r8   Úconnect_headerÚauth_strÚencoded_strÚstatusÚ_rl   s
             r#   r]   r]   u  s,  € Ü	Ð
Ô Ø ˜v Q t f¨MÐ:€NØ˜˜t˜f A d V¨4Ð0Ñ0€Nñ ��Q’Ø˜‘7ˆØ�Š7Ø˜!˜D ™G˜9˜Ñ%ˆHÜ" 8§?¡?Ó#4Ó5×;Ñ;Ó=×DÑDÓF×NÑNÈtÐUWÓXˆØÐ7¸°}ÀDÐIÑIˆØ�fÑ€NÜÐ	˜>Ô*äˆˆ~Ôð.Ü# DÓ)‰ˆ��1ð �‚}Ü%Ð(IÈ&ÈÐ&RÓSÐSà€Køô �L‰LÔ,Ð-ò .Ü%¤c¨!£fÓ-Ð-ûð.ús   Â)C ÃC?Ã&C:Ã:C?c                 ó0  — d }d }i }t        d«       	 t        | «      }	 |j                  d«      j                  «       }|snút        |«       |s5|j                  dd«      }	 t        |d   «      }t        |«      dkD  r¼|d   }n¶|j                  d	d«      }t        |«      dk7  rt        d
«      ‚|\  }}	|j                  «       dk(  rR|j                  d«      rA|j                  d«      }
|
�|
dz   |	j                  «       z   |d<   n5|	j                  «       |d<   n!|	j                  «       ||j                  «       <   �Œ(t        d«       |||fS # t        $ r }t        d|j                  › d|›�«      ‚d }~ww xY w# t        t        f$ r t        d|›�«      ‚w xY w)Nz--- response header ---zutf-8z-Invalid header line, not valid UTF-8 at byte z: ú é   r   zInvalid status line: rY   zInvalid headerz
set-cookiez; z-----------------------)r   r   r½   r¼   ÚUnicodeDecodeErrorr   ÚstartÚsplitrN   Ú
IndexErrorrž   r©   Úlowerr5   )rU   rÂ   Ústatus_messageÚheadersÚlinerl   Ústatus_infoÚkvÚkeyÚvalueÚexisting_cookies              r#   r   r   ‘  s¨  € Ø€FØ€NØ€GÜ	Ð
#Ô$à
Ü˜‹ˆð	Ø—;‘;˜wÓ'×-Ñ-Ó/ˆDñ
 ØÜˆdŒÙØŸ*™* S¨!Ó,ˆKðKÜ˜[¨™^Ó,�ô �;Ó !Ò#Ø!,¨Q¡‘à—‘˜C Ó#ˆBÜ�2‹w˜!Š|Ü(Ð)9Ó:Ð:Ø‰JˆC�Ø�y‰y‹{˜lÒ*¨w¯{©{¸<Ô/HØ")§+¡+¨lÓ";�Ø"Ð.Ø,;¸dÑ,BÀUÇ[Á[Ã]Ñ,R�G˜LÒ)à,1¯K©K«M�G˜LÒ)à',§{¡{£}�˜Ÿ	™	›Ñ$ñ? ôB 
Ð
#Ô$à�7˜NÐ*Ð*øô? "ò 	Ü$Ø?ÀÇÁ¸yÈÈ4È(ÐSóð ûð	ûô ¤
Ð+ò KÜ(Ð+@ÀÀÐ)IÓJÐJðKús#   ŸE Á!E7 Å	E4ÅE/Å/E4Å7F)7Ú__doc__rv   r—   rW   Úbase64r   rº   Útypingr   r   Ú_exceptionsr   r   r	   Ú_loggingr
   r   r   Ú_socketr   r   r   Ú_ssl_compatr   r   Ú_urlr   r   Ú__all__Úpython_socks._errorsr   r   r   Úpython_socks._typesr   Úpython_socks.syncr   rJ   ÚImportErrorÚ	Exceptionr   rt   rN   rV   r   Úboolr¨   rZ   r[   Údictr­   rO   r]   r§   r   r!   r"   r#   ú<module>rä      s  ðñó& Û 	Û Ý .ß ÷ñ ÷
 )Ñ (ß ;Ñ ;ß &ß +â
3€ðßXÑXÝ-Ý'àÐ÷"&ñ &ð8,,Ø	ð,,Øð,,Ø#&ð,,à
ˆ6�=‰=˜%  S¨# Ñ.Ð.Ñ/ó,,ð^$Ø	ð$Øð$Ø#&ð$Ø03ð$à
ˆ6�=‰=˜%  S¨# Ñ.Ð.Ñ/ó$ðN"+Øð"+Øð"+Ø)-ð"+Ø69ð"+à
ˆ4��sˆ?Ñó"+òJ%ðP[Ø
�-‰-ð[Ø!%ð[Ø14ð[ØFJð[àó[ð|�f—m‘mð °$ð À#ð È#ó ð6�&—-‘-ð  sð °#ð ¸Sð ÀVÇ]Á]ó ð8)+�v—}‘}ð )+¨ô )+øðI ò ØÐô�Yô ô˜Iô ô˜yô ÷ó ðús   ÁD0 Ä02E%Å$E%