:\c@sdZddlmZddlmZddlZddlZddlZddlZddl m Z m Z m Z m Z ddlZddlZddlmZddlmZmZddlmZdd lmZdd lmZdd lmZdd lmZmZdd l m!Z!de fdYZ"dfdYZ#de fdYZ$de%dZ&e'a(e'dZ)dZ*dZ+e,dkre+ndS(s1Worker threads for using the anaconda-client api.i(tdeque(t format_excN(tQObjecttQThreadtQTimertSignal(tCondaAPI(tCONFt DEFAULT_BRAND(t constants(t sort_versions(tlogger(tis_internet_available(tis_text_stringtto_text_string(tMessageBoxErrort ClientWorkercBsMeZdZeeeeZeeeeZdZdZdZ RS(s#Anaconda Client API process worker.cCs;tt|j||_||_||_t|_dS(s#Anaconda Client API process worker.N(tsuperRt__init__tmethodtargstkwargstFalset _is_finished(tselfRRR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyR(s    cCs|jS(s>Return wether or not the worker has finished running the task.(R(R((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt is_finished0scCsd\}}y)tjd|j|j|j}Wnktk r}tjt |jj |jj |ft |}|j dd}|j dd}nX|j j|||t|_dS(sStart the worker process.g?t(tt)N(NN(tNonettimetsleepRRRt ExceptionR tdebugtstrt __module__t__name__treplacet sig_finishedtemittTrueR(Rterrortoutputterr((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytstart4s  " ( R$R#t__doc__Rtobjecttsig_chain_finishedR&RRR,(((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyR"s   tArgscBseZdZRS(sDDummy class to pass to anaconda client on token loading and removal.(R$R#R-(((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyR0Fst _ClientAPIcBsdeZdZdZddZdZdZdZdZ e dddZ e ddZ dd Z d Zd Zd Zd ZdZdZdddZddZddZdZdZddddddZdZe dZe dZedZdZddZ dedZ!dedZ"RS( sAnaconda Client API wrapper.icCstt|jt|_d|_||_t|_ g|_ g|_ t |_ t|_|j jd|j jj|j|jdS(sAnaconda Client API wrapper.iN(RRRRt _conda_apiRt_anaconda_client_apit_configRt_queuet_threadst_workersRt_timerRtconfigt setIntervalttimeouttconnectt_cleantreload_binstar_client(RR9((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyROs        cCs|jr?x3|jD]%}|jr|jj|qqWn|jr~x@|jD]%}|jrR|jj|qRqRWn |jjdS(s7Check for inactive workers and remove their references.N(R7RtremoveR6t isFinishedR8tstop(Rtwtt((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyR=as    cCsBt|jdkr>|jj}|j|jjndS(s2Take avalaible worker from the queue and start it.iN(tlenR5tpopleftR,R8(Rtthread((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt_startos cOst}t|||}|j||jj|j|jj|j|jj|j|j j ||j j ||j j ||j|S(s?Create a worker for this client to be run in a separate thread.( RRt moveToThreadR&R<RGtquittstartedR,R5tappendR6R7(RRRRRFtworker((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt_create_workervs   cCs@|jr!|jjdd}nt}|r6t}nt}|S(sCheck initernet availability.tmaint offline_mode(R4tgetRR((Rt config_valuet connectivity((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt_is_internet_availables  cCs|r |ni}i}x|jD]\}}|jdi}x|D]}||}t|jdd\}} } ||kritd6id6id6id6id6||<s     cCs |jjS(s6Return the current token registered with authenticate.(R3R(R((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyRTscCs:d}ytjj|j}Wntk r5nX|S(s!Load current authenticated token.N(RRRRt get_api_urlR (RR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyRXs  cCsM|jj||||}t}d|_||_tjj|||S(sLogin callback.N( R3t authenticateR0RRRRRt store_token(Rtusernametpasswordt applicationtapplication_urlt new_tokenR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt_loginas    cCs>tjt|||f|j}|j|||||S(sLogin to anaconda server.(R R!R"RRM(RRRRRR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytloginls cCsd}t}d|_|j|_tjj||jry|jjWqtj j k r}|}t j dj |qtk r}|}t j dj |qXnt jd|S(sr Logout from anaconda.org. This method removes the authentication and removes the token. s;The token that you are trying to remove may not be valid {}s$The certificate might be invalid. {}slogout successfulN(RR0RRRRt remove_tokenR3tremove_authenticationterrorst UnauthorizedR R!tformatR tinfo(RR)Rte((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytlogoutts$      cCs2tjd|j}|j||d|d|S(s Load all the available packages information for downloaded repodata. For downloaded repodata files (repo.anaconda.com), additional data provided (anaconda cloud), and additional metadata and merge into a single set of packages and apps. If python_version is not none, exclude all package/versions which require an incompatible version of python. Parameters ---------- repodata: dict of dicts Data loaded from the conda cache directories. metadata: dict Metadata info form different sources. For now only from repo.anaconda.com python_version: str Python version used in preprocessing. RRjRk(R R!RxRM(RRiRjRkR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt load_repodatas  cCs/tjd|j}|j|||d|S(s=Prepare downloaded package info along with pip pacakges info.RR(R R!RRM(RRTRRR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytprepare_model_datas  shttps://api.anaconda.orgc Cstjdj|tjj}||d
This may result in Navigator not working properly.
R)s
s
treportt learn_moreRRN(R R!RRRRt set_configRt BinstarErrorR)RRRRtexec_RRRR3(RtdomainR9t tracebacktmsg_box((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt set_domains$     cCs|jddS(s'Return current logged user information.RN(t organizationsR(R((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytuserscCs |jjS(sReturn current domain.(R3R(R((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyRsc CsDtjd|jj}|j|d|d|d|d|d|S(s]Return all the available packages for a given user. Parameters ---------- type_: Optional[str] Only find packages that have this conda `type`, (i.e. 'app'). access : Optional[str] Only find packages that have this access level (e.g. 'private', 'authenticated', 'public'). RRtplatformt package_typeRtaccess(R R!R3t user_packagesRM(RRRRRRR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyRTs  cCs7y|jjd|}Wntk r2i}nX|S(s0List all the organizations a user has access to.R(R3RR (RRR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyRs   cCstjj}|jddS(s*Get the anaconda client url configuration.Rshttps://api.anaconda.org(RRRRP(t config_data((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyRsc Cstjj}||dThis may result in Navigator not working properly.
R)RRN( RRRRR R R)RRRR(RRRR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt set_api_urls   cCsStjj}|jd|jdt}|rO|jjd|jn|S(sV Get the anaconda client url configuration and set conda accordingly. t ssl_verifyt verify_ssl(RRRRPR(R2t config_sett communicate(Rt set_conda_sslR9tvalue((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytget_ssls c Cstjj}||d<||dThis may result in Navigator not working properly.
R)RRN(RRRRR2RRR R R)RRRR(RRRRR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytset_ssl's    cCs/tjt||j}|j|d|S(s/Get user trial/paid licenses from anaconda.org.R(R R!R"RRM(RRR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytget_user_licenses;s c Cs|p i}i|d6dd6td6dd6dd6d d 6d d 6}|jrytj|d |d|d|j}t|jdd}tj|}xM|j D]?\}} t | r| ddkr| d n| ||RRRRRRRRRRRTRRRR(RRRRR(((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyR1JsH     JJ             !tpythonc Cst}ztjd}x|D]}|j|j\}}} |jdd}||krgqn|r~||| gGHnd| krttj| jdd|}n| p|dkr| |k}Pn|dkr|jd| jdk}n|d kr.|jd| jdk}n|d kr[|jd| jdk}n]|d kr|jd| jdk}n0|d kr|jd| jdk}nqPqWWd |SX(sACan this package dependency list be met given the pinned version.s([^ ><=]+)([ <>=]+)([\d.*]+)t Rt*s.*s==ts<=s>=s!=N(R(tretcompiletmatchtgroupsR%tbooltsplit( tdeplistR^tpackageR!tflagtstdeptpnametrelR((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pytis_dependency_metls8   '  ! ! ! ! ! cCs"tdkrtd|antS(sClient API threaded worker.R9N(t CLIENT_APIRR1(R9((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt ClientAPIs cCs||fGHdS(sTest helper print function.N((RLR*R)((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt print_outputscCs\ddlm}|}t}|jdddd|jdddd|jdS( sLocal main test.i(t qapplicationtgoanpecatasdasdtbabyRtbruceN(t"anaconda_navigator.utils.qthelpersR R RR(R tapptapi((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyt local_tests   t__main__(-R-t collectionsRRRRRRRt qtpy.QtCoreRRRRRRt anaconda_navigator.api.conda_apiRtanaconda_navigator.configRRtanaconda_navigator.utilsR RzR tanaconda_navigator.utils.logsR tanaconda_navigator.utils.miscR t"anaconda_navigator.utils.py3compatR Rt"anaconda_navigator.widgets.dialogsRRR0R1RRRRR R RR$(((s@lib/python2.7/site-packages/anaconda_navigator/api/client_api.pyts:    "  $$%