edL dZddlmZmZddlZddlmZddlmZm Z m Z m Z m Z ddl mZmZmZmZdd lmZd Zd d d dddddddd ZGddeZdS)z+ Manage your Anaconda repository channels. )print_functionunicode_literalsN)errors)AllMirrorFormatterMirrorFormatterSyncStateFormattercomma_string_to_liststring_to_bool)check_cve_scorecheck_date_formatcheck_proxy_url check_url)SubCommandBasez 0 0 * * * mirror_id mirror_name source_root mirror_mode mirror_typecronproxy last_run_at created_at updated_at) idnamesourcemodetyperrrrrcteZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZddZdZdZdS) SubCommandmirrorc|j}|js|js|jr7|js0d}|j|tj||jr| |j|j |j|j |j |j |j|j|j|j|j|j|j|j|j|j|j|j|jdS|jr||j|j |j|j|j |j |j |j|j|j|j|j|j|j|j|j|j|j|j|jdS|jr"||j|jdS|jr||jdS|jr| dS|j!r|!|j!dS|j"r"|"|j"|jdS|j#r|#|j#dS|j$r|$|j$dStK)NzdChannel name not specified. Please use -c or --channel to specify your channel. Use --help for help.)&argscreateupdatedeletechannelloginfor RepoCLIError create_mirrorrrr licensessubdirsprojects only_spec exclude_spec include_spec cve_scoreexclude_uncurated_cve_packages only_signed date_fromdate_torrun_nowr update_mirrorrlist show_listlist_all show_all_list sync_stateshowstoprestartNotImplementedError)selfr%msgs 8lib/python3.11/site-packages/repo_cli/commands/mirror.pymainzSubCommand.main,sy K +4; +$+ +t| +'  HMM#   %c** * ;< (           !!3     '     *[& (            !!3     )     ,[ ( KK dk 2 2 2 2 2 Y ( NN49 % % % % % ] (    _ ( OODO , , , , , Y ( IIdi . . . . . Y ( IIdi \ ( LL & & & & &%'' 'c |||}|r|jd|dSi}|rt||d<|rt||d<|ryg|d<g|d<t|D]_}d}|dr d}|dd}|dr |dd}|||`| r| |d <| r| |d <| r| |d <|r||d <|r||d <| | |d<| r| |d<|r||d<|||j||||||||| |jd||dS)Nz)Mirror with the name '%s' already exists.r/r0include_licensesexclude_licenses-r+ only_specs exclude_specs include_specsr7r8cve_score_thresholdexclude_non_curated_cver6z,Mirror %s successfully created on channel %s) _get_by_namer*r+r startswithappendvalidate_mirror_filtersapir-)rDr)rrrtype_filter_licensesfilter_subdirsfilter_projectsfilter_only_specsfilter_exclude_specsfilter_include_specsr4exclude_uncurrated_cve_packagesfilter_only_signedfilter_date_fromfilter_date_torr9rr#filterslicensegroups rFr-zSubCommand.create_mirrorts ,""411   HMMEt L L L F  F!5n!E!EGI   H"6"G"GGJ   /*,G& '*,G& '/@@ / /*%%c***.E%abbkG%%c***%abbkG%%g....  6$5GL !  <';GO $  <';GO $  4#3GK  0!/GI   -6G) * * Q1PG- .  8%7GM " $$W---  VT4%w     DdGTTTTTrHc |||}|s|jddS|d}|t||d<| t| |d<|yg|d<g|d<t|D]_}d}|dr d}|dd}|d r |dd}|||`| | |d <| | |d <| | |d <|||d <|||d<| | |d<|||d<|||d<|||r||d<|r||d<| |r|nd|d<||tkr||d<|j |d||d|d|d||d|d||d |jd||dS)NMirror not foundrcr/r0rJrKrLrrMrNrOrPr7r8rQrRr6rrrrrrrz+Mirror %s successfully update on channel %s) rSr*r+r rTrUrVDEFAULT_MIRROR_CRONrWr:)rDr)rrnew_namerrXrYrZr[r\r]r^r4r_r`rarbrr9rr#rcrdres rFr:zSubCommand.update_mirrorsy.""411  HMM, - - - F#  %!5n!E!EGI   &"6"G"GGJ   &*,G& '*,G& '/@@ / /*%%c***.E%abbkG%%c***%abbkG%%g....  ($5GL !  +';GO $  +';GO $  '#3GK  %!/GI   -6G) * * 61PG- .  )%7GM " $$W---  +$*F= !  -$,F= !  ',6ee$F7O  (; ; ;!F6N  ;   = ! = ! = !  = ! 6N  7O   CT7SSSSSrHc|dr>|ds|drtjddSdS)NrNrOrPz=Can't combine only_specs with exclude_specs and include_specs)getrr,)rDrcs rFrVz"SubCommand.validate_mirror_filterssl ;;| $ $  KK ( ( ,3KK,H,H %O     rHc|j|}|jt j|d|jddSNitems)rW get_mirrorsr*r+r format_list)rDr)datas rFr<zSubCommand.show_listsTx##G,,  o1$w-@@AAA  brHc|j}|jt j|d|jddSrm)rWget_all_mirrorsr*r+rformat_list_all)rDrrs rFr>zSubCommand.show_all_listsSx''))  (8gGGHHH  brHc|j}|jt j|d||jddSrm)rWrtr*r+r format_sync_state)rDr#rrs rFr?zSubCommand.sync_state#sUx''))  (:4=&QQRRR  brHc||d|}|s|jddSt|dkrH|jt j||jddS||||dS)Nrrgrro)rSr*r+lenr format_detail show_detailconvert_show_args)rD show_argsr)r#s rFr@zSubCommand.show(s""9Q<99  HMM, - - - F y>>Q   HMM/7?? @ @ @ HMM"        VT%;%;I%F%F G G G G GrHcbt|D]\}}|tvrt|||<|SN) enumerateMIRROR_ARGS_MAPPING)rDr}indexargs rFr|zSubCommand.convert_show_args4s?#I.. < >Q  |v%% fYq\233333 o.....C } 0 0&==6F3K//C3xx1}} .////#2#h HMM$ $ $ $ $ $rHc||}|s|jddS|j||d||jd||dS)Nrgrz+Mirror %s successfully delete on channel %s)rSr*r+rW delete_mirror)rDr)rr#s rFr(zSubCommand.deleteNsu""4((  HMM, - - - F w{(;TBBB  CT7SSSSSrHc|j}|dD]}|d|kr|ddvrP|jd||j|||dn"|jd||ddS|jd|dS) Nrnrstate)runningpendingzStopping mirror %srz4Mirror %s cannot be stopped in its current state: %sMirror %s not found)rWrtr*r+ stop_mirror_get_channel_string)rDrrrr#s rFrAzSubCommand.stopVsx''))7m  Ff~,,'?&<<<HMM"6 DDDH(()A)A&)I)I6RV<XXXXHMMN#w -  +[99999rHc|j}|dD]}|d|kr|jd||j|d|||d|d|dd|vr|dni|dd |vr|d nt d d |vr|d nd dS|jd |dS) NrnrzRestarting mirror %srrrrcr rTrr)rWrtr*r+r:rrh)rDrrrr#s rFrBzSubCommand.restartfsx''))7m  Ff~%% 4d;;;&&4L,,V44=)6N6N)2f)<)dd?@|dAd>ddB@|dCd>ddD@|dEtddFG|dHdddFI|dJtddKG|dLtddMG|dNtdOdddPQ|dRddS||jTdS)UNz#Manage your Anaconda repository {}s)helpformatter_class descriptionz --channelz-czChannel to mirror to.)rT)requiredz--createzCreate a new {})metavarrz--updatez Update a {}z--deletez Delete a {}z--stopz Stop a {}z --restartz Restart a {}z--listz-lzlist all {}s for a userz--showzShow all of properties of {} or specify a property. Possible values: id, name, source, type, mode, state, proxy, cron, last_run_at, created_at, updated_at*)rrnargsz --list-all store_truezlist all mirrors)actionrz --sync-statezshow sync state of mirrorz--sourcez-szQPath to the source channel to mirror. I.e.: https://conda.anaconda.org/conda-test)r rz--namez-nzName of the mirrorz--modepassivezMirror mode. If "active", will download all the files from the source channel immediately else, if "passive", download JSON immediately and files on demand later. Default is "passive")defaultrz--typecondaz@Mirror type. Possible types: "conda", "python_simple" and "CRAN"z--cronz(Cron string to configure the mirror job.z--proxyzaProxy to use for the mirroring in format "http://" or "http://:@")rr rzmirror filtersz}Filters are used to filter specific subset of packages from the original index. Some filters are specific to artifact family.)rz --subdirsza[conda] List of conda subdirs, I.e.: linux-64, osx-64, linux-32, etc. Use comma-separated string.z --projectszE[python] List of pypi projects to mirror. Use comma-separated string.z --licenseszList of licenses to filter for. Use comma-separated string, prepent with "-" to exclude, or just a license to include. The allowed license values are: agpl, gpl2, gpl3, lgpl, bsd, mit, apache, psf, public_domain, proprietary, other, nonez --only_specrUzJMatchSpec to only spec. Use multiple times the option for multiple entries)rrrz--exclude_speczHMatchSpec to exclude. Use multiple times the option for multiple entriesz--include_speczHMatchSpec to include. Use multiple times the option for multiple entriesz --cve_scorezGOnly mirror files with CVE score less or equal to this value. I.e.: 9.5)r rrz --exclude_uncurated_cve_packages)rrrz --date_fromz9[conda] bottom date YYYY-mm-dd when package was publishedz --date_toz8[conda] upper date YYYY-mm-dd when package was publishedz --only_signed?zOnly mirror signed packages)r rconstrrz --run_nowzZDetermines whether the mirror job should run immediately or according to the cron schedule)rG) add_parserrformatargparseRawDescriptionHelpFormatter__doc__ add_argumentadd_mutually_exclusive_groupupperrrhradd_argument_groupr r r set_defaultsrG)rD subparsers subparserre filters_groups rFrzSubCommand.add_parsers)) I6==diHH$@ *   {D7NOOO666EE  IOO%%"))$)44       1 1 8L8LTY8W8W        1 1 8L8LTY8W8W      dioo//k6H6H6S6S      IOO%%&&ty11      IOO%%*11$)<<     IOO%%LLRF MM     < CUVVV >0KLLL  :     x4HIII *      S     ';      t    "44 C5  "" * #   "" X #   "" M #    "" ] #   "" [ #   "" [ #   ""  Z #   "" .Z #   "" "L #   "" "K #   "" . #     -     DI.....rHr)__name__ __module__ __qualname__rrGr-r:rVr<r>r?r@r|r{r(rArBrSrrrrHrFr"r")s+ DE(E(E(PAUAUAUFXTXTXTt   H H H%%%&TTT:::    *&&&&*--- h/h/h/h/h/rHr")r __future__rrrror utils.formatrrr r r utils.validatorsr r rrbaserrhrr"rrHrFrsK87777777 ! !         U/U/U/U/U/U/U/U/U/U/rH