ce)8UdZddlmZgdZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl ZddlmZddlZddlmZddlmZdd lmZd d lmZe jr dd lmZd d lmZdZ Gdde!ej"Z#Gddej$Z%da&de'd<ddZ(dS)zClient for Cloud API) annotations)EnvironmentSort _CloudAPICloudAPIN)parse)QtCore)config)logger)workers) utilities)user)typesc tjdtjdS#t $rYdSwxYw)za Cancel login process. This should kill server started by :meth:`~_CloudAPI.login`. z shutting down cloud login serverN)r debuganaconda_cloud_authhandlersshutdown_all_servers Exception@lib/python3.11/site-packages/anaconda_navigator/api/cloud/api.py cancel_loginrsU   7888$99;;;;;      s26 AAc*eZdZdZdZdZdZdZdZdZ dS) rz Options for environment sorting.namez-name created_atz -created_at updated_atz -updated_atN) __name__ __module__ __qualname____doc__NAME_ASC NAME_DESC CREATED_ASC CREATED_DESC UPDATED_ASC UPDATED_DESCrrrrr,s2**HIK LK LLLrrceZdZdZejZd'd(fd Zd)d Zd*d Z d+d Z e d,dZ e d-dZ ejejed+dZejd*dZejd.dZejd+dZejddejfd/dZejd0d"Zejd'd1d$Zejd2d%Zejd0d&ZxZS)3rzE Anaconda Cloud API. :param: Navigator's config object. Nr 'typing.Optional[user_config.UserConfig]returnNonec t| tj}||_d|_i|_tj|j ddpddddddd d d d d d d d|_ tj |_ |j |j|dS)z+Initialize new :class:`~CloudAPI` instance.Nmaincloud_base_urlz api/iam/tokenzapi/iam/logout)loginlogoutz api/account)pingaccountzapi/environments/myzapi/environments/my/{name}zapi/environments/my/{name}.yml)list_environmentscreate_environmentupdate_environmentdelete_environmentdownload_environment)authenticationbasics environments)base_url endpoints)super__init__navigator_configCONF_CloudAPI__config_CloudAPI__token_CloudAPI__accountr EndpointCollectionget_CloudAPI__routesSession_CloudAPI__sessionsig_token_changedconnect_CloudAPI__refresh_session_CloudAPI__load_token)selfr __class__s rr?z_CloudAPI.__init__Bs  >%*F>D -1 CEDMD`]&&v/?@@FB-.## , *?*?*F*F,L !!E E E  *;D:K:M:M &&t'=>>> rtoken str | NonecF||_|jdS)zUpdate token value.N)rCrJemit)rNrPs r __set_tokenz_CloudAPI.__set_tokengs$  ##%%%%%rboolcZd} tjj|jddtjj}|}n#t$rYnwxYw| |t|S)z)Try to load exising token in the keyring.Nr- auth_domain)domain) rclient TokenInfoloadrBrF AuthConfigrXget_access_tokenr_CloudAPI__set_tokenrU)rN access_token token_infos r __load_tokenz_CloudAPI.__load_tokenls#'  M`MgMqMvMv}((@S@Z@e@e@g@g@nooNwNNJ&6688LL    D  &&&L!!!sA4A99 BBcjd|jpd|jjd<||_dS)z*Inject authorization details into session.zBearer r/ AuthorizationN)rPrIheadersr3rDrNs r__refresh_sessionz_CloudAPI.__refresh_sessionzs32NDJ)) $) % * C   '   55 s58A  A (collections.abc.Mapping[str, typing.Any]c|jd|jjjddS)rrrsFrtru)rIrxrGr:r3jsonres rr3z_CloudAPI.accountsB~%%  M (! &  $&&  rcVtj|ddS)z$Remove token data and clear session.N)rr1r^res rr1z_CloudAPI.logouts- "$$$ rdrlimitintoffsetsortr"'types.CloudEnvironmentCollection'c|jd|jjj|||ddS)a[ List available environments for current user. :param limit: Maximum number of environments to fetch in a single call. :param offset: Number of environments to skip from the start. :param sort: How environments in the result should be sorted. :return: Collection of environments available to user. rs)rrrT)paramsraise_for_status)rIrxrGr;r4r~)rNrrrs rr4z_CloudAPI.list_environmentssT~%%  M & 8  "&    $&& rrpathctj\}}tj|dd5}t j|}t |dd5}|||ddddn #1swxYwY|dd|j d|j j j |d dddn #1swxYwYtj|dS) z Create a new environment in Cloud. :param name: Name of the environment to create. :param path: Path to the exported environment (yaml file). wt+utf-8encodingrtryamlNrPOSTTdatar)tempfilemkstemposfdopenr JsonWriteropen serializeseekrIrxrGr;r5remove)rNrrfile_descriptor file_path file_stream file_writerstreams rr5z_CloudAPI.create_environments&.%5%7%7"Y @ @ @ K090D[0Q0QKdD7333 Fv%%tV&D&DEEE F F F F F F F F F F F F F F F   Q " " " N " " *= !% #                   )s6'CA:. C:A> >CA> ACCC rename_toc B||}tj\}}tj|dd5}t j|}t |dd5}|||ddddn #1swxYwY|dd|j d|j j j tj|d  |d dddn #1swxYwYtj|dS)z Update environment in Cloud. :param name: Name of the environment to update. :param path: Path to the exported environment (yaml file). :param rename_to: Optional name to change Cloud environment to. NrrrrrrPUTr/stringsaferTr)rrrrr rrrrrIrxrGr;r6formatrquoter) rNrrrrrrrrs rr6z_CloudAPI.update_environments  I&.%5%7%7"Y @ @ @ K090D[0Q0QKdD7333 Kv%%y&&I&IJJJ K K K K K K K K K K K K K K K   Q " " " N " " *=DDDr:::E!!% #                  $ )s6'DA>2 D>B DB A.DDDc |jd|jjjt j|dddS)zi Remove environment from Cloud. :param name: Name of the environment to remove. DELETEr/rrT)rN)rIrxrGr;r7rrr)rNrs rr7z_CloudAPI.delete_environmentsh   M & 9 @ @[2666 A  "      rc 6|jd|jjjt j|ddd}t|d5}tj |j |ddddS#1swxYwYdS) z Download environment description file from the Cloud. :param name: Name of the environment to download. :param path: Path to store downloaded environment to. rsr/rrT)rrwbN) rIrxrGr;r8rrrrshutil copyfileobjraw)rNrrresponsers rr8z_CloudAPI.download_environment s)-(>(>  M & ; B B[2666 C  " )?) ) $   5  x|V 4 4 4 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5s&BBB)N)r r)r*r+)rPrQr*r+)r*rU)r*r+)r*rg)r*rj)r*r|)rrrrrrr*r)rrjrrjr*r+)rrjrrjrrgr*r+)rrjr*r+)rrr r!rSignalrJr?r^rMrLpropertyrPrmr TaskAddCancelCallbackrr0r2r3r1rr"r4r5r6r7r8 __classcell__)rOs@rrr9sA & #######J&&&& " " " "(((( XLLLXL W\+'+L99::,,,;:, \   \  \\ \\ \$3$< \2 \\: \""""\"H \    \   \555\55555rrztyping.Optional[_CloudAPI]CLOUD_API_INSTANCEr*c:ttatS)z&Retrieve :class:`~_CloudAPI` instance.)rrrrrrr9s!&[[ r)r*r))r! __future__r__all__collections.abc collectionsenumrrrtypingurllibranaconda_cloud_auth.handlersrqtpyrrzanaconda_navigatorr r@anaconda_navigator.utils.logsr anaconda_navigator.utilsr r/r TYPE_CHECKINGanaconda_navigator.configr user_configrrrjEnumrQObjectrr__annotations__rrrrrs"""""" 6 6 6  ####999999000000,,,,,, ======     ! ! ! ! !c49 ! ! !z5z5z5z5z5z5z5z5z265555r