G@d d Z ddlZddlmZ ddlmZmZmZmZ ddl Z ddl
m Z m Z ddl
mZmZ ddlmZ ddlmZ dd lmZ dd
lmZ ej e Ze G d d ee ZdS )
z Kite completions HTTP client. N)quote)QObjectQThreadSignalQMutex)_running_under_pytest)KITE_ENDPOINTSKITE_REQUEST_MAPPING)class_register)KiteMethodProviderMixIn)status)
TEXT_TYPESc * e Zd Z eee Z ee Z e Z eee
e Z ee
Z
ee
fef Z e Z ee
Z ee
e ZddZd Zd Zd Zd Zd Zd Zd Zd
Zdd Zd
Z d Z d S )
KiteClientTc t j | | d | _ i | _ g | _ t | _ i | _ i | _ d| _ || _
t d | _ |
| j | j j | j | j | j | j | j | j | j d S )NF)r __init__endpointrequests languagesr mutex opened_filesopened_files_statusthread_startedenable_code_snippetsr thread moveToThreadstartedconnectsig_perform_requestperform_requestsig_perform_status_request
get_status sig_perform_onboarding_requestget_onboarding_file)selfparentr s Olib/python3.11/site-packages/spyder/plugins/completion/providers/kite/client.pyr zKiteClient.__init__+ s v&&&
XX
#% #$8! dmm $+&&& ##DL111 (()=>>> '//@@@ +33D4LMMMMM c | j s| j t d t j | _ | | _ | j
| j d S )Nz Starting Kite HTTP session...) r r startloggerdebugr Sessionr
get_languagesr sig_client_startedemitr& s r( r+ zKiteClient.start< sv " K 4555 (**
++-- $$T^44444r) c d| _ d S )NT)r r2 s r( r zKiteClient.startedD s "r) c | j rNt d | j | j d S d S )Nz Closing Kite HTTP session...)r r, r- r closer quitr2 s r( stopzKiteClient.stopG sX LL7 8 8 8 M ! ! ! K r) c t j \ }}| || \ }}|sg S |t |t rdg}|S )Npython)r
LANGUAGES_ENDPOINTperform_http_request
isinstancer r& verburlsuccessresponses r( r/ zKiteClient.get_languagesM sV "5 c 5 5dC @ @ I z(J ? ? zHr) c V t j \ }}| || \ }}|S )z0Perform a request to get kite's onboarding file.)r
ONBOARDING_ENDPOINTr; r= s r( _get_onboarding_filez KiteClient._get_onboarding_fileW s- "6 c 5 5dC @ @r) c b | }| j | dS )zGet onboarding file.N)rD sig_onboarding_response_readyr1 )r& onboarding_files r( r% z KiteClient.get_onboarding_file] s0 3355 *//@@@@@r) c t t j \ }}|rd|i}nddi}| ||| \ }}||fS )z0Perform a request to get kite status for a file.filenamefiletyper9 )
url_params)r
STATUS_ENDPOINTr; )r& rI r> r? rK r@ rA s r( _get_statuszKiteClient._get_statusb s] "2 c 0$h/JJ$h/J 5 5 #* 6 . . r) c | | \ }}|r|5t }| j t | dS t |t r`t d }t d | }|||d}| j t | dS | j t | dS )z%Get kite status for a given filename.Nz with errors) extra_statuszt{error}
Note: If you are using a VPN, please don't route requests to localhost/127.0.0.1 with it)error)r shortlong)
rM r sig_status_response_readystrr1 r< r r formatdict)r& rI success_status kite_status
status_strlong_strkite_status_dicts r( r# zKiteClient.get_statusm s &*&6&6x&@&@# C;. ((K *3 / 4 4[ A A A A A
Z
0
0
C ^<< r? rK r] rA http_method
http_responser@ s r( r; z KiteClient.perform_http_request s dmT22 'KJV L L LMM ;; +s2 @
@(--//
@
@
@(-#+r>>44x
@ s (
66A A:9A:c d }| j z|t v rqt | \ }}d | D } |j di |} | ||| \ }}n# t
t f$ r |cY S w xY w|S )Nc b i | ],\ }}|t |t rt | n|-S )r< r r ).0keyvalues r(
z#KiteClient.send.. sG "8 "8 "8 S% Zz%B%BMU5\\\"8 "8 "8r) )r] ri )r r itemsrU r; ConnectionRefusedErrorConnectionError) r& methodr] rK rA http_verbpathencoded_url_paramsr@ s r( sendzKiteClient.send s = $3G)G)G 26 :OIt"8 "8$.$4$4$6$6"8 "8 "8 4;44!344D
$($=$= tF %> %4 %4!*O<
s A+ +B Bc
d }|| j v rt d || | j | }t | | } || }|| j v r*| j | }t | | }| || }t
|t t d f s-t s | j
|| d S d S | j ||pi d S )Nz Perform request {0} with id {1})
sender_registryr, r- rU ra handler_registryr< rV typer sig_client_wrong_responser1 sig_response_ready) r& req_idrq r] rA handler_namehandlerconverter_name converters r( r! zKiteClient.perform_request s( T) ) ) LL:AA
!
!
! /7L dL11G wvH...!%!6v!> #D. 9 9 ' (y 2 2H(T4::$677 A'))
F.33FHEEEEE
F
F
# ( ( R @ @ @ @ @r) )T)NN) __name__
__module__ __qualname__r intrV r{ listr0 sig_client_not_respondingrT objectr r" rS r$ rF rz r r+ r r7 r/ rD r% rM r# r; ru r! ri r) r( r r sq T** & &c622!' &vw 7 7 %+VXX"$*F3KK! &sF 3 3 N N N N"5 5 5# # # A A A
! ! !C C C*! ! ! !
A A A A Ar) r ) __doc__logging urllib.parser qtpy.QtCorer r r r r spyder.config.baser r (spyder.plugins.completion.providers.kiter
r 3spyder.plugins.completion.providers.kite.decoratorsr 2spyder.plugins.completion.providers.kite.providersr
5spyder.plugins.completion.providers.kite.utils.statusr spyder.py3compatr getLoggerr r, r ri r) r( r sZ $ # 9 8 8 8 8 8 8 8 8 8 8 8 7 6 6 6 6 6 6 6* * * * * * * * N N N N N N H H H H H H ' ' ' ' ' '
8 $ $ RA RA RA RA RA1 RA RA RA RA RAr)