B l‚z]:<ã@sÖddlmZmZmZmZddlmZddlZddlm Z m Z m Z ddl Z ddl mZddlZddlmZmZmZddlZddlZddlmZddlZddlZdd lmZdd lmZdd lm Z m!Z!dd l"m#Z#dd l$m%Z%ddl&m'Z'm(Z(m)Z)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7m8Z8ddl9m:Z:e  ;e<¡Z=Gdd„de>ƒZ?dd„Z@dd„ZAdd„ZBdd„ZCGd d!„d!eDƒZEe %s <== z%Y-%m-%d %H:%M:%Sz # cmd: %s ú css|]}t|ƒVqdS)N)r)Ú.0Úsr'r'r(ú *szwrite_head..z# conda version: %s Ú.é) ÚwriteÚtimeZstrftimer ÚsysÚargvrÚ CONDA_VERSIONÚsplit)Úfor'r'r(Ú write_head(s r6cCstdd„|DƒƒS)Ncss|]}| d¡VqdS))ú-ú+N)Ú startswith)r*r+r'r'r(r,/szis_diff..)Úany)Úcontentr'r'r(Úis_diff.sr<c cs i}i}xj|D]b}|dd…}t|ƒ\}}}}|tkrB|d|7}| d¡rZ||| ¡<q| d¡r||| ¡<qWt|ƒt|ƒ@} x(t| ƒD]}d|||||fVqŽWx*tt|ƒ| ƒD]}d|||fVqÀWx*tt|ƒ| ƒD]}d|||fVqìWdS)Nrz (%s)r7r8z %s {%s -> %s}z-%s-%sz+%s-%s)rrr9ÚlowerÚsetÚsorted) ZdiffÚaddedÚremovedr+ÚfnÚnameÚversionÚ_ÚchannelÚchangedr'r'r(Ú pretty_diff2s$     rHcCs t|ƒrt|ƒStt|ƒƒSdS)N)r<rHÚiterr?)r;r'r'r(Úpretty_contentGsrJc@s¾eZdZe d¡Ze d¡Ze d¡Zdd„Zdd„Z dd „Z d d „Z d d „Z dd„Z dd„Zedd„ƒZedd„ƒZdd„Zdd„Zdd„Zd)dd„Zdd „Zd!d"„Zd#d$„Zd*d&d'„Zd(S)+ÚHistoryz#\s*cmd:\s*(.+)z#\s*(\w+)\s*specs:\s*(.+)?z#\s*conda version:\s*(.+)cCs$||_t|dƒ|_t|jdƒ|_dS)Nz conda-metaÚhistory)Úprefixr Úmeta_dirÚpath)ÚselfrMr'r'r(Ú__init__Ts zHistory.__init__cCs | ¡|S)N)Ú init_log_file)rPr'r'r(Ú __enter__YszHistory.__enter__cCs | ¡dS)N)Úupdate)rPÚexc_typeÚ exc_valueÚ tracebackr'r'r(Ú__exit__]szHistory.__exit__cCst|jdƒdS)NT)rrO)rPr'r'r(rR`szHistory.init_log_filecCst |j¡jdkS)Nr)ÚosÚstatrOÚst_size)rPr'r'r(Ú file_is_emptycszHistory.file_is_emptyc CsÄyzyt| ¡ƒ}Wn8tk rJ}zt d|j|ft¡dSd}~XYnXt|jƒ}tdd„|  ¡Dƒƒ}|  ||¡WnDt k r¾}z&|j t ttfkr¬t|j|j ƒ‚n‚Wdd}~XYnXdS)zK update the history file (creating a new one if necessary) zError in %s: %sNcss|]}| ¡VqdS)N)Zdist_str)r*Z prefix_recr'r'r(r,rsz!History.update..)r>Ú get_staterÚwarningsÚwarnrOr#rrMÚ iter_recordsÚ write_changesÚEnvironmentErrorÚerrnorrr r)rPZlastÚeZpdZcurrr'r'r(rTfs zHistory.updatec CsÂg}t|jƒs|St d¡}t|jƒ}| ¡ ¡}WdQRXx~|D]v}| ¡}|sVqD| |¡}|r~|  |  d¡t ƒgf¡qD|  d¡rœ|dd  |¡qDt |ƒdkrD|dd |¡qDW|S)z„ parse the history file and return a list of tuples(datetime strings, set of distributions/diffs, comments) z==>\s*(.+?)\s*<==Nrú#éÿÿÿÿér)r rOÚreÚcompilerÚreadÚ splitlinesÚstripÚmatchÚappendÚgroupr>r9ÚlenÚadd)rPÚresZsep_patÚfÚlinesÚlineÚmr'r'r(Úparsezs$       z History.parsecCsLg}xB| d¡D]4}t |¡r:|r:d |d|g¡|d<q| |¡qW|S)zÖ Parse specifications string that use conda<4.5 syntax. Examples -------- - "param >=1.5.1,<2.0'" - "python>=3.5.1,jupyter >=1.0.0,<2.0,matplotlib >=1.5.1,<2.0" ú,rf)r4r!rmr rn)Ú specs_stringÚspecsÚspecr'r'r(Ú_parse_old_format_specs_string’s z&History._parse_old_format_specs_stringcCs i}|j |¡}|r@| d¡ ¡}|d d¡r8d|d<||d<|j |¡}|r^| d¡|d<|j |¡}|r| ¡\}}|p‚d}||d<| d¡r t |ƒ}nd|kr²t   |¡}d d „|Dƒ}|rÞ|d krÞ||d <|d <n>|rü|dkrü||d<|d <n |r|dkr||d<|d <|S)aH Parse comment lines in the history file. These lines can be of command type or action type. Examples -------- - "# cmd: /scratch/mc3/bin/conda install -c conda-forge param>=1.5.1,<2.0" - "# install specs: python>=3.5.1,jupyter >=1.0.0,<2.0,matplotlib >=1.5.1,<2.0" rrZcondaÚcmdÚ conda_versionÚÚactionú[cSsg|]}|r| d¡s|‘qS)ú@)Úendswith)r*r{r'r'r(ú Ész/History._parse_comment_line..)rTÚinstallZcreateÚ update_specsrz)ÚremoveZ uninstallÚ remove_specs)ZneuteredÚneutered_specs) Úcom_patrmror4rƒÚ conda_v_patÚspec_patÚgroupsr9rrKr|)ÚclsruÚitemrvr2r€ryrzr'r'r(Ú_parse_comment_line¦s6          zHistory._parse_comment_linecCsBg}x€| ¡D]t\}}}d|i}x |D]}| |¡}| |¡q&Wd|krT| |¡ttdƒ|ƒ}| dd¡|d<| dd¡|d<qWtd d „|Dƒƒ} | r>tj s>t | t d d } d   t d|  d ¡ƒ¡} d   t dt d ¡ƒ¡} t | ƒt | ƒkr>tdƒ|jt| dœ} t|jtjƒs2| tdƒtj| dœ7} | tdƒ7} |S)a4 return a list of user requested items. Each item is a dict with the following keys: 'date': the date and time running the command 'cmd': a list of argv of the actual command which was run 'action': install/remove/update 'specs': the specs being used Údater}rr7r'Z unlink_distsr8Z link_distscss|]}d|kr|dVqdS)r~Nr')r*Úxr'r'r(r,ësz,History.get_user_requests..)Úkeyrfr-rga† This environment has previously been operated on by a conda version that's newer than the conda currently being used. A newer version of conda is required. target environment location: %(target_prefix)s current conda version: %(conda_version)s minimum conda version: %(minimum_version)s )Z target_prefixr~Úminimum_versionzŸ Update conda and try again. $ conda install -p "%(base_prefix)s" "conda>=%(minimum_version)s" )Ú base_prefixr”z­ To work around this restriction, one can also set the config parameter 'allow_conda_downgrades' to False at their own risk. )rwrrTrnrr ÚgetÚtuplerZallow_conda_downgradesr?r r rr4r3rrMrZ root_prefixr)rPrrÚdtZ unused_contZcommentsrruZ comment_itemsZdistsZconda_versions_from_historyZminimum_conda_versionZminimum_major_minorZcurrent_major_minorÚmessager'r'r(Úget_user_requestsÔs<      zHistory.get_user_requestscsÒi}x–| ¡D]Š}dd„| dd¡Dƒ}x|D]}| |jd¡q.Wdd„| dd¡Dƒ}| dd„|Dƒ¡dd„| d d¡Dƒ}| d d„|Dƒ¡qWtd d„t|jƒ ¡Dƒƒ‰t ‡fd d„t |ƒDƒƒS) Ncss|]}t|ƒVqdS)N)r")r*r{r'r'r(r,sz2History.get_requested_specs_map..rˆr'css|]}t|ƒVqdS)N)r")r*r{r'r'r(r,sr†css|]}|j|fVqdS)N)rC)r*r+r'r'r(r,scss|]}t|ƒVqdS)N)r")r*r{r'r'r(r,sr‰css|]}|j|fVqdS)N)rC)r*r+r'r'r(r,scss|] }|jVqdS)N)rC)r*rEr'r'r(r,!sc3s"|]\}}|ˆkr||fVqdS)Nr')r*rCr{)Ú prefix_recsr'r(r,"s) ršr–ÚpoprCrTr>rrMr`Údictr)rPZspec_mapZrequestrˆr{r†r‰r')r›r(Úget_requested_specs_maps zHistory.get_requested_specs_mapcCsžg}tgƒ}xŒ| ¡D]€\}}}t|ƒs.|}nVxT|D]L}| d¡rV| |dd…¡q4| d¡rt| |dd…¡q4td|ƒ‚q4W| || ¡f¡qW|S)zQ return a list of tuples(datetime strings, set of distributions) r7rNr8zDid not expect: %s) r>rwr<r9ÚdiscardrqrrnÚcopy)rPrrZcurr˜ZcontÚ unused_comr+r'r'r(Úconstruct_states$s   zHistory.construct_statesrfcCs(| ¡}|stgƒSt|Ž\}}||S)zé return the state, i.e. the set of distributions, for a given revision, defaults to latest (which is the same as the current state when the log file is up-to-date) Returns a list of dist_strs )r¢r>Úzip)rPÚrevZstatesÚtimesZpkgsr'r'r(r]8s  zHistory.get_statecCsZxTt| ¡ƒD]D\}\}}}td||fƒxt|ƒD]}td|ƒq6WtdƒqWdS)Nz %s (rev %d)z %sr)Ú enumeraterwÚprintrJ)rPÚir‘r;r¡rur'r'r(Ú print_logFs zHistory.print_logc CsÎg}xÂt| ¡ƒD]°\}\}}}||ggggdœ}i}i}t|ƒršx^|D]V} t| dd…ƒ\} } } } |  d¡rˆ| | | f||  ¡<qN|  d¡rN| | | f||  ¡<qNWt|ƒt|ƒ@}xjt|ƒD]^} || }|| }d | f|¡d | f|¡dœ}||kr|d  |¡qÂ|d  |¡qÂWx8tt|ƒ|ƒD]$} |d  d | f|| ¡¡q6Wx\tt|ƒ|ƒD]$} |d   d | f|| ¡¡qpWn"x t|ƒD]} |d   | ¡q¤W|  |¡qW|S) N)r‘r¤r…r‡ÚupgradeÚ downgraderr8r7)ÚoldÚnewrªr«r‡r…) r¦rwr<rr9r=r>r?r rn)rPÚresultr¨r‘r;r¡Zeventr@rAÚpkgrCrDZbuildrFrGr¬r­Zdetailsr'r'r(Ú object_logMsD      $&zHistory.object_logc Csˆt|jƒst |j¡tj|jdddV}t|ƒx"t||ƒD]}|  d|¡q@Wx"t||ƒD]}|  d|¡qdWWdQRXdS)NÚabzutf-8)ÚmodeÚencodingz-%s z+%s ) r rNrYÚmakedirsÚcodecsrrOr6r?r/)rPZ last_stateZ current_stater5rBr'r'r(ra}s  zHistory.write_changesr'c Csdd„|Dƒ}dd„|Dƒ}dd„|Dƒ}t|||fƒrŒtj|jddd<}|r^| d|¡|rp| d |¡|r‚| d |¡WdQRXdS) NcSsg|]}tt|ƒƒ‘qSr')rr")r*r+r'r'r(r„ˆsz'History.write_specs..cSsg|]}tt|ƒƒ‘qSr')rr")r*r+r'r'r(r„‰scSsg|]}tt|ƒƒ‘qSr')rr")r*r+r'r'r(r„Šsr±zutf-8)r²r³z# remove specs: %s z# update specs: %s z# neutered specs: %s )r:rµrrOr/)rPrˆr†r‰Zfhr'r'r(Ú write_specs‡szHistory.write_specsN)rf)r'r'r')r$r%r&rhrirŠrŒr‹rQrSrXrRr\rTrwÚ staticmethodr|Ú classmethodrršržr¢r]r©r°rar¶r'r'r'r(rKNs(     .= 0 rKÚ__main__)Úpprint)LZ __future__rrrrZastrrµrcrrr ZloggingÚoperatorr rYÚos.pathr r r rhr1Útextwraprr0r^rrr3Z_vendor.auxlib.ishrZ _vendor.toolzrrZbase.constantsrZ base.contextrZ common.compatrrrrZ common.pathrZcore.prefix_datarÚ exceptionsrrZgateways.disk.updaterZ models.distrZmodels.versionr r!Zmodels.match_specr"Z getLoggerr$ÚlogÚWarningr#r6r<rHrJÚobjectrKrºrMÚhršr§ržr'r'r'r(ÚsN             I