Je d Z ddlZddlmZ ddlmZmZmZmZ ddl Z ddl
m Z m Z ddl
mZmZ ddlmZ ddlmZ dd lmZ dd
lmZ ej0 e Ze G d d ee Zy)
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 y
)
KiteClientc B t j | | d | _ i | _ g | _ t | _ i | _ i | _ d| _ || _
t d | _ | j | j | j j j | j | j j | j" | j$ j | j& | j( j | j* y )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 Q/usr/lib/python3/dist-packages/spyder/plugins/completion/providers/kite/client.pyr zKiteClient.__init__+ s v&
X
#% #$8! dm $++& ##DLL1 (()=)=> ''//@ ++33D4L4LM c | j s| j j t j d t j | _ | j | _ | j j | j y )Nz Starting Kite HTTP session...) r r startloggerdebugr Sessionr
get_languagesr sig_client_startedemitr& s r( r+ zKiteClient.start< s` "" KK 45 ((*
++- $$T^^4r) c d| _ y )NT)r r2 s r( r zKiteClient.startedD s
"r) c | j rJt j d | j j | j
j
y y )Nz Closing Kite HTTP session...)r r, r- r closer quitr2 s r( stopzKiteClient.stopG s= LL7 8 MM ! KK r) c t j \ }}| j || \ }}|sg S |t |t rdg}|S )Npython)r
LANGUAGES_ENDPOINTperform_http_request
isinstancer r& verburlsuccessresponses r( r/ zKiteClient.get_languagesM sK "55 c 5 5dC @I z(J ? zHr) c V t j \ }}| 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- "66 c 5 5dC @r) c Z | j }| j j | y)zGet onboarding file.N)rD sig_onboarding_response_readyr1 )r& onboarding_files r( r% z KiteClient.get_onboarding_file] s$ 335 **//@r) c t t j \ }}|rd|i}nddi}| j ||| \ }}||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 sT "22 c $h/J$h/J 5 5 #* 6 . r) c | j | \ }}|r|-t }| j t j | yt |t rPt d }t d j | }|||d}| j t j | y| j t j | y)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&@# ;. (K * *3 / 4 4[ A
Z
0 ^ r? rK r] rA http_method
http_responser@ s r( r; z KiteClient.perform_http_request s dmmT2 'JV LM ++s2
@(--/ w
@(--#+r>4x
@s" A A AA BBc X d }| j ~|t v rvt | \ }}|j D ci c]# \ }}|t |t r t | n|% } }} |j di | } | j ||| \ }
}|S |S c c}}w # t t f$ r |cY S w xY w)N)r] )
r r itemsr< r r rU r; ConnectionRefusedErrorConnectionError) r& methodr] rK rA http_verbpathkeyvalueencoded_url_paramsr@ s r( sendzKiteClient.send s == $3G)G 26 :OIt %/$4$4$6"8 S% Zz%BU5\M"8 "8 4;;4!34D
$($=$= tF %> %4! x"8 +O<
s (B4B B)(B)c d }|| j v r{t j dj || | j | }t | | } || }|| j
v r%| j
| }t | | }| || }t
|t t d f s(t s | j j || y y | j j ||xs i y )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_idrl r] rA handler_namehandlerconverter_name converters r( r! zKiteClient.perform_request s T)) ) LL:AA
! //7L dL1G vH...!%!6!6v!> #D. 9 ' ( 2H(T4:$67')..33FHE *
# # ( ( R @r) )T)NN) __name__
__module__ __qualname__r intrV rx listr0 sig_client_not_respondingrT objectr r" rS r$ rF rw r r+ r r7 r/ rD r% rM r# r; rr r! rh r) r( r r s T* & c62!' &vw 7 %+X"$*3K! &sF 3 N"5# A
!C*!
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 rh r) r( r sm $ 9 8 7* N H '
8 $ RA1 RA RAr)