Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
85 kB · 2877 lines
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878" vim-plug: Vim plugin manager" ============================"" 1. Download plug.vim and put it in 'autoload' directory"" # Vim" curl -fLo ~/.vim/autoload/plug.vim --create-dirs \" https://raw.githubusercontent.com/junegunn/vim-plug/master/plug.vim"" # Neovim" sh -c 'curl -fLo "${XDG_DATA_HOME:-$HOME/.local/share}"/nvim/site/autoload/plug.vim --create-dirs \" https://raw.githubusercontent.com/junegunn/vim-plug/master/plug.vim'"" 2. Add a vim-plug section to your ~/.vimrc (or ~/.config/nvim/init.vim for Neovim)"" call plug#begin()"" " List your plugins here" Plug 'tpope/vim-sensible'"" call plug#end()"" 3. Reload the file or restart Vim, then you can,"" :PlugInstall to install plugins" :PlugUpdate to update plugins" :PlugDiff to review the changes from the last update" :PlugClean to remove plugins no longer in the list"" For more information, see https://github.com/junegunn/vim-plug""" Copyright (c) 2024 Junegunn Choi"" MIT License"" Permission is hereby granted, free of charge, to any person obtaining" a copy of this software and associated documentation files (the" "Software"), to deal in the Software without restriction, including" without limitation the rights to use, copy, modify, merge, publish," distribute, sublicense, and/or sell copies of the Software, and to" permit persons to whom the Software is furnished to do so, subject to" the following conditions:"" The above copyright notice and this permission notice shall be" included in all copies or substantial portions of the Software."" THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND," EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF" MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND" NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE" LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION" OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION" WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
if exists('g:loaded_plug') finishendiflet g:loaded_plug = 1
let s:cpo_save = &cposet cpo&vim
let s:plug_src = 'https://github.com/junegunn/vim-plug.git'let s:plug_tab = get(s:, 'plug_tab', -1)let s:plug_buf = get(s:, 'plug_buf', -1)let s:mac_gui = has('gui_macvim') && has('gui_running')let s:is_win = has('win32')let s:nvim = has('nvim-0.2') || (has('nvim') && exists('*jobwait') && !s:is_win)let s:vim8 = has('patch-8.0.0039') && exists('*job_start')if s:is_win && &shellslash set noshellslash let s:me = resolve(expand('<sfile>:p')) set shellslashelse let s:me = resolve(expand('<sfile>:p'))endiflet s:base_spec = { 'branch': '', 'frozen': 0 }let s:TYPE = {\ 'string': type(''),\ 'list': type([]),\ 'dict': type({}),\ 'funcref': type(function('call'))\ }let s:loaded = get(s:, 'loaded', {})let s:triggers = get(s:, 'triggers', {})
function! s:is_powershell(shell) return a:shell =~# 'powershell\(\.exe\)\?$' || a:shell =~# 'pwsh\(\.exe\)\?$'endfunction
function! s:isabsolute(dir) abort return a:dir =~# '^/' || (has('win32') && a:dir =~? '^\%(\\\|[A-Z]:\)')endfunction
function! s:git_dir(dir) abort let gitdir = s:trim(a:dir) . '/.git' if isdirectory(gitdir) return gitdir endif if !filereadable(gitdir) return '' endif let gitdir = matchstr(get(readfile(gitdir), 0, ''), '^gitdir: \zs.*') if len(gitdir) && !s:isabsolute(gitdir) let gitdir = a:dir . '/' . gitdir endif return isdirectory(gitdir) ? gitdir : ''endfunction
function! s:git_origin_url(dir) abort let gitdir = s:git_dir(a:dir) let config = gitdir . '/config' if empty(gitdir) || !filereadable(config) return '' endif return matchstr(join(readfile(config)), '\[remote "origin"\].\{-}url\s*=\s*\zs\S*\ze')endfunction
function! s:git_revision(dir) abort let gitdir = s:git_dir(a:dir) let head = gitdir . '/HEAD' if empty(gitdir) || !filereadable(head) return '' endif
let line = get(readfile(head), 0, '') let ref = matchstr(line, '^ref: \zs.*') if empty(ref) return line endif
if filereadable(gitdir . '/' . ref) return get(readfile(gitdir . '/' . ref), 0, '') endif
if filereadable(gitdir . '/packed-refs') for line in readfile(gitdir . '/packed-refs') if line =~# ' ' . ref return matchstr(line, '^[0-9a-f]*') endif endfor endif
return ''endfunction
function! s:git_local_branch(dir) abort let gitdir = s:git_dir(a:dir) let head = gitdir . '/HEAD' if empty(gitdir) || !filereadable(head) return '' endif let branch = matchstr(get(readfile(head), 0, ''), '^ref: refs/heads/\zs.*') return len(branch) ? branch : 'HEAD'endfunction
function! s:git_origin_branch(spec) if len(a:spec.branch) return a:spec.branch endif
" The file may not be present if this is a local repository let gitdir = s:git_dir(a:spec.dir) let origin_head = gitdir.'/refs/remotes/origin/HEAD' if len(gitdir) && filereadable(origin_head) return matchstr(get(readfile(origin_head), 0, ''), \ '^ref: refs/remotes/origin/\zs.*') endif
" The command may not return the name of a branch in detached HEAD state let result = s:lines(s:system('git symbolic-ref --short HEAD', a:spec.dir)) return v:shell_error ? '' : result[-1]endfunction
if s:is_win function! s:plug_call(fn, ...) let shellslash = &shellslash try set noshellslash return call(a:fn, a:000) finally let &shellslash = shellslash endtry endfunctionelse function! s:plug_call(fn, ...) return call(a:fn, a:000) endfunctionendif
function! s:plug_getcwd() return s:plug_call('getcwd')endfunction
function! s:plug_fnamemodify(fname, mods) return s:plug_call('fnamemodify', a:fname, a:mods)endfunction
function! s:plug_expand(fmt) return s:plug_call('expand', a:fmt, 1)endfunction
function! s:plug_tempname() return s:plug_call('tempname')endfunction
function! plug#begin(...) if a:0 > 0 let home = s:path(s:plug_fnamemodify(s:plug_expand(a:1), ':p')) elseif exists('g:plug_home') let home = s:path(g:plug_home) elseif has('nvim') let home = stdpath('data') . '/plugged' elseif !empty(&rtp) let home = s:path(split(&rtp, ',')[0]) . '/plugged' else return s:err('Unable to determine plug home. Try calling plug#begin() with a path argument.') endif if s:plug_fnamemodify(home, ':t') ==# 'plugin' && s:plug_fnamemodify(home, ':h') ==# s:first_rtp return s:err('Invalid plug home. '.home.' is a standard Vim runtime path and is not allowed.') endif
let g:plug_home = home let g:plugs = {} let g:plugs_order = [] let s:triggers = {}
call s:define_commands() return 1endfunction
function! s:define_commands() command! -nargs=+ -bar Plug call plug#(<args>) if !executable('git') return s:err('`git` executable not found. Most commands will not be available. To suppress this message, prepend `silent!` to `call plug#begin(...)`.') endif if has('win32') \ && &shellslash \ && (&shell =~# 'cmd\(\.exe\)\?$' || s:is_powershell(&shell)) return s:err('vim-plug does not support shell, ' . &shell . ', when shellslash is set.') endif if !has('nvim') \ && (has('win32') || has('win32unix')) \ && !has('multi_byte') return s:err('Vim needs +multi_byte feature on Windows to run shell commands. Enable +iconv for best results.') endif command! -nargs=* -bar -bang -complete=customlist,s:names PlugInstall call s:install(<bang>0, [<f-args>]) command! -nargs=* -bar -bang -complete=customlist,s:names PlugUpdate call s:update(<bang>0, [<f-args>]) command! -nargs=0 -bar -bang PlugClean call s:clean(<bang>0) command! -nargs=0 -bar PlugUpgrade if s:upgrade() | execute 'source' s:esc(s:me) | endif command! -nargs=0 -bar PlugStatus call s:status() command! -nargs=0 -bar PlugDiff call s:diff() command! -nargs=? -bar -bang -complete=file PlugSnapshot call s:snapshot(<bang>0, <f-args>)endfunction
function! s:to_a(v) return type(a:v) == s:TYPE.list ? a:v : [a:v]endfunction
function! s:to_s(v) return type(a:v) == s:TYPE.string ? a:v : join(a:v, "\n") . "\n"endfunction
function! s:glob(from, pattern) return s:lines(globpath(a:from, a:pattern))endfunction
function! s:source(from, ...) let found = 0 for pattern in a:000 for vim in s:glob(a:from, pattern) execute 'source' s:esc(vim) let found = 1 endfor endfor return foundendfunction
function! s:assoc(dict, key, val) let a:dict[a:key] = add(get(a:dict, a:key, []), a:val)endfunction
function! s:ask(message, ...) call inputsave() echohl WarningMsg let answer = input(a:message.(a:0 ? ' (y/N/a) ' : ' (y/N) ')) echohl None call inputrestore() echo "\r" return (a:0 && answer =~? '^a') ? 2 : (answer =~? '^y') ? 1 : 0endfunction
function! s:ask_no_interrupt(...) try return call('s:ask', a:000) catch return 0 endtryendfunction
function! s:lazy(plug, opt) return has_key(a:plug, a:opt) && \ (empty(s:to_a(a:plug[a:opt])) || \ !isdirectory(a:plug.dir) || \ len(s:glob(s:rtp(a:plug), 'plugin')) || \ len(s:glob(s:rtp(a:plug), 'after/plugin')))endfunction
function! plug#end() if !exists('g:plugs') return s:err('plug#end() called without calling plug#begin() first') endif
if exists('#PlugLOD') augroup PlugLOD autocmd! augroup END augroup! PlugLOD endif let lod = { 'ft': {}, 'map': {}, 'cmd': {} }
if get(g:, 'did_load_filetypes', 0) filetype off endif for name in g:plugs_order if !has_key(g:plugs, name) continue endif let plug = g:plugs[name] if get(s:loaded, name, 0) || !s:lazy(plug, 'on') && !s:lazy(plug, 'for') let s:loaded[name] = 1 continue endif
if has_key(plug, 'on') let s:triggers[name] = { 'map': [], 'cmd': [] } for cmd in s:to_a(plug.on) if cmd =~? '^<Plug>.\+' if empty(mapcheck(cmd)) && empty(mapcheck(cmd, 'i')) call s:assoc(lod.map, cmd, name) endif call add(s:triggers[name].map, cmd) elseif cmd =~# '^[A-Z]' let cmd = substitute(cmd, '!*$', '', '') if exists(':'.cmd) != 2 call s:assoc(lod.cmd, cmd, name) endif call add(s:triggers[name].cmd, cmd) else call s:err('Invalid `on` option: '.cmd. \ '. Should start with an uppercase letter or `<Plug>`.') endif endfor endif
if has_key(plug, 'for') let types = s:to_a(plug.for) if !empty(types) augroup filetypedetect call s:source(s:rtp(plug), 'ftdetect/**/*.vim', 'after/ftdetect/**/*.vim') if has('nvim-0.5.0') call s:source(s:rtp(plug), 'ftdetect/**/*.lua', 'after/ftdetect/**/*.lua') endif augroup END endif for type in types call s:assoc(lod.ft, type, name) endfor endif endfor
for [cmd, names] in items(lod.cmd) execute printf( \ has('patch-7.4.1898') \ ? 'command! -nargs=* -range -bang -complete=file %s call s:lod_cmd(%s, "<bang>", <line1>, <line2>, <q-args>, <q-mods> ,%s)' \ : 'command! -nargs=* -range -bang -complete=file %s call s:lod_cmd(%s, "<bang>", <line1>, <line2>, <q-args>, %s)' \ , cmd, string(cmd), string(names)) endfor
for [map, names] in items(lod.map) for [mode, map_prefix, key_prefix] in \ [['i', '<C-\><C-O>', ''], ['n', '', ''], ['v', '', 'gv'], ['o', '', '']] execute printf( \ '%snoremap <silent> %s %s:<C-U>call <SID>lod_map(%s, %s, %s, "%s")<CR>', \ mode, map, map_prefix, string(map), string(names), mode != 'i', key_prefix) endfor endfor
for [ft, names] in items(lod.ft) augroup PlugLOD execute printf('autocmd FileType %s call <SID>lod_ft(%s, %s)', \ ft, string(ft), string(names)) augroup END endfor
call s:reorg_rtp() filetype plugin indent on if has('vim_starting') if has('syntax') && !exists('g:syntax_on') syntax enable end else call s:reload_plugins() endifendfunction
function! s:loaded_names() return filter(copy(g:plugs_order), 'get(s:loaded, v:val, 0)')endfunction
function! s:load_plugin(spec) call s:source(s:rtp(a:spec), 'plugin/**/*.vim', 'after/plugin/**/*.vim') if has('nvim-0.5.0') call s:source(s:rtp(a:spec), 'plugin/**/*.lua', 'after/plugin/**/*.lua') endifendfunction
function! s:reload_plugins() for name in s:loaded_names() call s:load_plugin(g:plugs[name]) endforendfunction
function! s:trim(str) return substitute(a:str, '[\/]\+$', '', '')endfunction
function! s:version_requirement(val, min) for idx in range(0, len(a:min) - 1) let v = get(a:val, idx, 0) if v < a:min[idx] | return 0 elseif v > a:min[idx] | return 1 endif endfor return 1endfunction
function! s:git_version_requirement(...) if !exists('s:git_version') let s:git_version = map(split(split(s:system(['git', '--version']))[2], '\.'), 'str2nr(v:val)') endif return s:version_requirement(s:git_version, a:000)endfunction
function! s:progress_opt(base) return a:base && !s:is_win && \ s:git_version_requirement(1, 7, 1) ? '--progress' : ''endfunction
function! s:rtp(spec) return s:path(a:spec.dir . get(a:spec, 'rtp', ''))endfunction
if s:is_win function! s:path(path) return s:trim(substitute(a:path, '/', '\', 'g')) endfunction
function! s:dirpath(path) return s:path(a:path) . '\' endfunction
function! s:is_local_plug(repo) return a:repo =~? '^[a-z]:\|^[%~]' endfunction
" Copied from fzf function! s:wrap_cmds(cmds) let cmds = [ \ '@echo off', \ 'setlocal enabledelayedexpansion'] \ + (type(a:cmds) == type([]) ? a:cmds : [a:cmds]) \ + ['endlocal'] if has('iconv') if !exists('s:codepage') let s:codepage = libcallnr('kernel32.dll', 'GetACP', 0) endif return map(cmds, printf('iconv(v:val."\r", "%s", "cp%d")', &encoding, s:codepage)) endif return map(cmds, 'v:val."\r"') endfunction
function! s:batchfile(cmd) let batchfile = s:plug_tempname().'.bat' call writefile(s:wrap_cmds(a:cmd), batchfile) let cmd = plug#shellescape(batchfile, {'shell': &shell, 'script': 0}) if s:is_powershell(&shell) let cmd = '& ' . cmd endif return [batchfile, cmd] endfunctionelse function! s:path(path) return s:trim(a:path) endfunction
function! s:dirpath(path) return substitute(a:path, '[/\\]*$', '/', '') endfunction
function! s:is_local_plug(repo) return a:repo[0] =~ '[/$~]' endfunctionendif
function! s:err(msg) echohl ErrorMsg echom '[vim-plug] '.a:msg echohl Noneendfunction
function! s:warn(cmd, msg) echohl WarningMsg execute a:cmd 'a:msg' echohl Noneendfunction
function! s:esc(path) return escape(a:path, ' ')endfunction
function! s:escrtp(path) return escape(a:path, ' ,')endfunction
function! s:remove_rtp() for name in s:loaded_names() let rtp = s:rtp(g:plugs[name]) execute 'set rtp-='.s:escrtp(rtp) let after = globpath(rtp, 'after') if isdirectory(after) execute 'set rtp-='.s:escrtp(after) endif endforendfunction
function! s:reorg_rtp() if !empty(s:first_rtp) execute 'set rtp-='.s:first_rtp execute 'set rtp-='.s:last_rtp endif
" &rtp is modified from outside if exists('s:prtp') && s:prtp !=# &rtp call s:remove_rtp() unlet! s:middle endif
let s:middle = get(s:, 'middle', &rtp) let rtps = map(s:loaded_names(), 's:rtp(g:plugs[v:val])') let afters = filter(map(copy(rtps), 'globpath(v:val, "after")'), '!empty(v:val)') let rtp = join(map(rtps, 'escape(v:val, ",")'), ',') \ . ','.s:middle.',' \ . join(map(afters, 'escape(v:val, ",")'), ',') let &rtp = substitute(substitute(rtp, ',,*', ',', 'g'), '^,\|,$', '', 'g') let s:prtp = &rtp
if !empty(s:first_rtp) execute 'set rtp^='.s:first_rtp execute 'set rtp+='.s:last_rtp endifendfunction
function! s:doautocmd(...) if exists('#'.join(a:000, '#')) execute 'doautocmd' ((v:version > 703 || has('patch442')) ? '<nomodeline>' : '') join(a:000) endifendfunction
function! s:dobufread(names) for name in a:names let path = s:rtp(g:plugs[name]) for dir in ['ftdetect', 'ftplugin', 'after/ftdetect', 'after/ftplugin'] if len(finddir(dir, path)) if exists('#BufRead') doautocmd BufRead endif return endif endfor endforendfunction
function! plug#load(...) if a:0 == 0 return s:err('Argument missing: plugin name(s) required') endif if !exists('g:plugs') return s:err('plug#begin was not called') endif let names = a:0 == 1 && type(a:1) == s:TYPE.list ? a:1 : a:000 let unknowns = filter(copy(names), '!has_key(g:plugs, v:val)') if !empty(unknowns) let s = len(unknowns) > 1 ? 's' : '' return s:err(printf('Unknown plugin%s: %s', s, join(unknowns, ', '))) end let unloaded = filter(copy(names), '!get(s:loaded, v:val, 0)') if !empty(unloaded) for name in unloaded call s:lod([name], ['ftdetect', 'after/ftdetect', 'plugin', 'after/plugin']) endfor call s:dobufread(unloaded) return 1 end return 0endfunction
function! s:remove_triggers(name) if !has_key(s:triggers, a:name) return endif for cmd in s:triggers[a:name].cmd execute 'silent! delc' cmd endfor for map in s:triggers[a:name].map execute 'silent! unmap' map execute 'silent! iunmap' map endfor call remove(s:triggers, a:name)endfunction
function! s:lod(names, types, ...) for name in a:names call s:remove_triggers(name) let s:loaded[name] = 1 endfor call s:reorg_rtp()
for name in a:names let rtp = s:rtp(g:plugs[name]) for dir in a:types call s:source(rtp, dir.'/**/*.vim') if has('nvim-0.5.0') " see neovim#14686 call s:source(rtp, dir.'/**/*.lua') endif endfor if a:0 if !s:source(rtp, a:1) && !empty(s:glob(rtp, a:2)) execute 'runtime' a:1 endif call s:source(rtp, a:2) endif call s:doautocmd('User', name) endforendfunction
function! s:lod_ft(pat, names) let syn = 'syntax/'.a:pat.'.vim' call s:lod(a:names, ['plugin', 'after/plugin'], syn, 'after/'.syn) execute 'autocmd! PlugLOD FileType' a:pat call s:doautocmd('filetypeplugin', 'FileType') call s:doautocmd('filetypeindent', 'FileType')endfunction
if has('patch-7.4.1898') function! s:lod_cmd(cmd, bang, l1, l2, args, mods, names) call s:lod(a:names, ['ftdetect', 'after/ftdetect', 'plugin', 'after/plugin']) call s:dobufread(a:names) execute printf('%s %s%s%s %s', a:mods, (a:l1 == a:l2 ? '' : (a:l1.','.a:l2)), a:cmd, a:bang, a:args) endfunctionelse function! s:lod_cmd(cmd, bang, l1, l2, args, names) call s:lod(a:names, ['ftdetect', 'after/ftdetect', 'plugin', 'after/plugin']) call s:dobufread(a:names) execute printf('%s%s%s %s', (a:l1 == a:l2 ? '' : (a:l1.','.a:l2)), a:cmd, a:bang, a:args) endfunctionendif
function! s:lod_map(map, names, with_prefix, prefix) call s:lod(a:names, ['ftdetect', 'after/ftdetect', 'plugin', 'after/plugin']) call s:dobufread(a:names) let extra = '' while 1 let c = getchar(0) if c == 0 break endif let extra .= nr2char(c) endwhile
if a:with_prefix let prefix = v:count ? v:count : '' let prefix .= '"'.v:register.a:prefix if mode(1) == 'no' if v:operator == 'c' let prefix = "\<esc>" . prefix endif let prefix .= v:operator endif call feedkeys(prefix, 'n') endif call feedkeys(substitute(a:map, '^<Plug>', "\<Plug>", '') . extra)endfunction
function! plug#(repo, ...) if a:0 > 1 return s:err('Invalid number of arguments (1..2)') endif
try let repo = s:trim(a:repo) let opts = a:0 == 1 ? s:parse_options(a:1) : s:base_spec let name = get(opts, 'as', s:plug_fnamemodify(repo, ':t:s?\.git$??')) let spec = extend(s:infer_properties(name, repo), opts) if !has_key(g:plugs, name) call add(g:plugs_order, name) endif let g:plugs[name] = spec let s:loaded[name] = get(s:loaded, name, 0) catch return s:err(repo . ' ' . v:exception) endtryendfunction
function! s:parse_options(arg) let opts = copy(s:base_spec) let type = type(a:arg) let opt_errfmt = 'Invalid argument for "%s" option of :Plug (expected: %s)' if type == s:TYPE.string if empty(a:arg) throw printf(opt_errfmt, 'tag', 'string') endif let opts.tag = a:arg elseif type == s:TYPE.dict for opt in ['branch', 'tag', 'commit', 'rtp', 'dir', 'as'] if has_key(a:arg, opt) \ && (type(a:arg[opt]) != s:TYPE.string || empty(a:arg[opt])) throw printf(opt_errfmt, opt, 'string') endif endfor for opt in ['on', 'for'] if has_key(a:arg, opt) \ && type(a:arg[opt]) != s:TYPE.list \ && (type(a:arg[opt]) != s:TYPE.string || empty(a:arg[opt])) throw printf(opt_errfmt, opt, 'string or list') endif endfor if has_key(a:arg, 'do') \ && type(a:arg.do) != s:TYPE.funcref \ && (type(a:arg.do) != s:TYPE.string || empty(a:arg.do)) throw printf(opt_errfmt, 'do', 'string or funcref') endif call extend(opts, a:arg) if has_key(opts, 'dir') let opts.dir = s:dirpath(s:plug_expand(opts.dir)) endif else throw 'Invalid argument type (expected: string or dictionary)' endif return optsendfunction
function! s:infer_properties(name, repo) let repo = a:repo if s:is_local_plug(repo) return { 'dir': s:dirpath(s:plug_expand(repo)) } else if repo =~ ':' let uri = repo else if repo !~ '/' throw printf('Invalid argument: %s (implicit `vim-scripts'' expansion is deprecated)', repo) endif let fmt = get(g:, 'plug_url_format', 'https://git::@github.com/%s.git') let uri = printf(fmt, repo) endif return { 'dir': s:dirpath(g:plug_home.'/'.a:name), 'uri': uri } endifendfunction
function! s:install(force, names) call s:update_impl(0, a:force, a:names)endfunction
function! s:update(force, names) call s:update_impl(1, a:force, a:names)endfunction
function! plug#helptags() if !exists('g:plugs') return s:err('plug#begin was not called') endif for spec in values(g:plugs) let docd = join([s:rtp(spec), 'doc'], '/') if isdirectory(docd) silent! execute 'helptags' s:esc(docd) endif endfor return 1endfunction
function! s:syntax() syntax clear syntax region plug1 start=/\%1l/ end=/\%2l/ contains=plugNumber syntax region plug2 start=/\%2l/ end=/\%3l/ contains=plugBracket,plugX,plugAbort syn match plugNumber /[0-9]\+[0-9.]*/ contained syn match plugBracket /[[\]]/ contained syn match plugX /x/ contained syn match plugAbort /\~/ contained syn match plugDash /^-\{1}\ / syn match plugPlus /^+/ syn match plugStar /^*/ syn match plugMessage /\(^- \)\@<=.*/ syn match plugName /\(^- \)\@<=[^ ]*:/ syn match plugSha /\%(: \)\@<=[0-9a-f]\{4,}$/ syn match plugTag /(tag: [^)]\+)/ syn match plugInstall /\(^+ \)\@<=[^:]*/ syn match plugUpdate /\(^* \)\@<=[^:]*/ syn match plugCommit /^ \X*[0-9a-f]\{7,9} .*/ contains=plugRelDate,plugEdge,plugTag syn match plugEdge /^ \X\+$/ syn match plugEdge /^ \X*/ contained nextgroup=plugSha syn match plugSha /[0-9a-f]\{7,9}/ contained syn match plugRelDate /([^)]*)$/ contained syn match plugNotLoaded /(not loaded)$/ syn match plugError /^x.*/ syn region plugDeleted start=/^\~ .*/ end=/^\ze\S/ syn match plugH2 /^.*:\n-\+$/ syn match plugH2 /^-\{2,}/ syn keyword Function PlugInstall PlugStatus PlugUpdate PlugClean hi def link plug1 Title hi def link plug2 Repeat hi def link plugH2 Type hi def link plugX Exception hi def link plugAbort Ignore hi def link plugBracket Structure hi def link plugNumber Number
hi def link plugDash Special hi def link plugPlus Constant hi def link plugStar Boolean
hi def link plugMessage Function hi def link plugName Label hi def link plugInstall Function hi def link plugUpdate Type
hi def link plugError Error hi def link plugDeleted Ignore hi def link plugRelDate Comment hi def link plugEdge PreProc hi def link plugSha Identifier hi def link plugTag Constant
hi def link plugNotLoaded Commentendfunction
function! s:lpad(str, len) return a:str . repeat(' ', a:len - len(a:str))endfunction
function! s:lines(msg) return split(a:msg, "[\r\n]")endfunction
function! s:lastline(msg) return get(s:lines(a:msg), -1, '')endfunction
function! s:new_window() execute get(g:, 'plug_window', '-tabnew')endfunction
function! s:plug_window_exists() let buflist = tabpagebuflist(s:plug_tab) return !empty(buflist) && index(buflist, s:plug_buf) >= 0endfunction
function! s:switch_in() if !s:plug_window_exists() return 0 endif
if winbufnr(0) != s:plug_buf let s:pos = [tabpagenr(), winnr(), winsaveview()] execute 'normal!' s:plug_tab.'gt' let winnr = bufwinnr(s:plug_buf) execute winnr.'wincmd w' call add(s:pos, winsaveview()) else let s:pos = [winsaveview()] endif
setlocal modifiable return 1endfunction
function! s:switch_out(...) call winrestview(s:pos[-1]) setlocal nomodifiable if a:0 > 0 execute a:1 endif
if len(s:pos) > 1 execute 'normal!' s:pos[0].'gt' execute s:pos[1] 'wincmd w' call winrestview(s:pos[2]) endifendfunction
function! s:finish_bindings() nnoremap <silent> <buffer> R :call <SID>retry()<cr> nnoremap <silent> <buffer> D :PlugDiff<cr> nnoremap <silent> <buffer> S :PlugStatus<cr> nnoremap <silent> <buffer> U :call <SID>status_update()<cr> xnoremap <silent> <buffer> U :call <SID>status_update()<cr> nnoremap <silent> <buffer> ]] :silent! call <SID>section('')<cr> nnoremap <silent> <buffer> [[ :silent! call <SID>section('b')<cr>endfunction
function! s:prepare(...) if empty(s:plug_getcwd()) throw 'Invalid current working directory. Cannot proceed.' endif
for evar in ['$GIT_DIR', '$GIT_WORK_TREE'] if exists(evar) throw evar.' detected. Cannot proceed.' endif endfor
call s:job_abort(0) if s:switch_in() if b:plug_preview == 1 pc endif enew else call s:new_window() endif
nnoremap <silent> <buffer> q :call <SID>close_pane()<cr> if a:0 == 0 call s:finish_bindings() endif let b:plug_preview = -1 let s:plug_tab = tabpagenr() let s:plug_buf = winbufnr(0) call s:assign_name()
for k in ['<cr>', 'L', 'o', 'X', 'd', 'dd'] execute 'silent! unmap <buffer>' k endfor setlocal buftype=nofile bufhidden=wipe nobuflisted nolist noswapfile nowrap cursorline modifiable nospell if exists('+colorcolumn') setlocal colorcolumn= endif setf vim-plug if exists('g:syntax_on') call s:syntax() endifendfunction
function! s:close_pane() if b:plug_preview == 1 pc let b:plug_preview = -1 elseif exists('s:jobs') && !empty(s:jobs) call s:job_abort(1) else bd endifendfunction
function! s:assign_name() " Assign buffer name let prefix = '[Plugins]' let name = prefix let idx = 2 while bufexists(name) let name = printf('%s (%s)', prefix, idx) let idx = idx + 1 endwhile silent! execute 'f' fnameescape(name)endfunction
function! s:chsh(swap) let prev = [&shell, &shellcmdflag, &shellredir] if !s:is_win set shell=sh endif if a:swap if s:is_powershell(&shell) let &shellredir = '2>&1 | Out-File -Encoding UTF8 %s' elseif &shell =~# 'sh' || &shell =~# 'cmd\(\.exe\)\?$' set shellredir=>%s\ 2>&1 endif endif return prevendfunction
function! s:bang(cmd, ...) let batchfile = '' try let [sh, shellcmdflag, shrd] = s:chsh(a:0) " FIXME: Escaping is incomplete. We could use shellescape with eval, " but it won't work on Windows. let cmd = a:0 ? s:with_cd(a:cmd, a:1) : a:cmd if s:is_win let [batchfile, cmd] = s:batchfile(cmd) endif let g:_plug_bang = (s:is_win && has('gui_running') ? 'silent ' : '').'!'.escape(cmd, '#!%') execute "normal! :execute g:_plug_bang\<cr>\<cr>" finally unlet g:_plug_bang let [&shell, &shellcmdflag, &shellredir] = [sh, shellcmdflag, shrd] if s:is_win && filereadable(batchfile) call delete(batchfile) endif endtry return v:shell_error ? 'Exit status: ' . v:shell_error : ''endfunction
function! s:regress_bar() let bar = substitute(getline(2)[1:-2], '.*\zs=', 'x', '') call s:progress_bar(2, bar, len(bar))endfunction
function! s:is_updated(dir) return !empty(s:system_chomp(['git', 'log', '--pretty=format:%h', 'HEAD...HEAD@{1}'], a:dir))endfunction
function! s:do(pull, force, todo) if has('nvim') " Reset &rtp to invalidate Neovim cache of loaded Lua modules " See https://github.com/junegunn/vim-plug/pull/1157#issuecomment-1809226110 let &rtp = &rtp endif for [name, spec] in items(a:todo) if !isdirectory(spec.dir) continue endif let installed = has_key(s:update.new, name) let updated = installed ? 0 : \ (a:pull && index(s:update.errors, name) < 0 && s:is_updated(spec.dir)) if a:force || installed || updated execute 'cd' s:esc(spec.dir) call append(3, '- Post-update hook for '. name .' ... ') let error = '' let type = type(spec.do) if type == s:TYPE.string if spec.do[0] == ':' if !get(s:loaded, name, 0) let s:loaded[name] = 1 call s:reorg_rtp() endif call s:load_plugin(spec) try execute spec.do[1:] catch let error = v:exception endtry if !s:plug_window_exists() cd - throw 'Warning: vim-plug was terminated by the post-update hook of '.name endif else let error = s:bang(spec.do) endif elseif type == s:TYPE.funcref try call s:load_plugin(spec) let status = installed ? 'installed' : (updated ? 'updated' : 'unchanged') call spec.do({ 'name': name, 'status': status, 'force': a:force }) catch let error = v:exception endtry else let error = 'Invalid hook type' endif call s:switch_in() call setline(4, empty(error) ? (getline(4) . 'OK') \ : ('x' . getline(4)[1:] . error)) if !empty(error) call add(s:update.errors, name) call s:regress_bar() endif cd - endif endforendfunction
function! s:hash_match(a, b) return stridx(a:a, a:b) == 0 || stridx(a:b, a:a) == 0endfunction
function! s:disable_credential_helper() return s:git_version_requirement(2) && get(g:, 'plug_disable_credential_helper', 1)endfunction
function! s:checkout(spec) let sha = a:spec.commit let output = s:git_revision(a:spec.dir) let error = 0 if !empty(output) && !s:hash_match(sha, s:lines(output)[0]) let credential_helper = s:disable_credential_helper() ? '-c credential.helper= ' : '' let output = s:system( \ 'git '.credential_helper.'fetch --depth 999999 && git checkout '.plug#shellescape(sha).' --', a:spec.dir) let error = v:shell_error endif return [output, error]endfunction
function! s:finish(pull) let new_frozen = len(filter(keys(s:update.new), 'g:plugs[v:val].frozen')) if new_frozen let s = new_frozen > 1 ? 's' : '' call append(3, printf('- Installed %d frozen plugin%s', new_frozen, s)) endif call append(3, '- Finishing ... ') | 4 redraw call plug#helptags() call plug#end() call setline(4, getline(4) . 'Done!') redraw let msgs = [] if !empty(s:update.errors) call add(msgs, "Press 'R' to retry.") endif if a:pull && len(s:update.new) < len(filter(getline(5, '$'), \ "v:val =~ '^- ' && v:val !~# 'Already up.to.date'")) call add(msgs, "Press 'D' to see the updated changes.") endif echo join(msgs, ' ') call s:finish_bindings()endfunction
function! s:retry() if empty(s:update.errors) return endif echo call s:update_impl(s:update.pull, s:update.force, \ extend(copy(s:update.errors), [s:update.threads]))endfunction
function! s:is_managed(name) return has_key(g:plugs[a:name], 'uri')endfunction
function! s:names(...) return sort(filter(keys(g:plugs), 'stridx(v:val, a:1) == 0 && s:is_managed(v:val)'))endfunction
function! s:check_ruby() silent! ruby require 'thread'; VIM::command("let g:plug_ruby = '#{RUBY_VERSION}'") if !exists('g:plug_ruby') redraw! return s:warn('echom', 'Warning: Ruby interface is broken') endif let ruby_version = split(g:plug_ruby, '\.') unlet g:plug_ruby return s:version_requirement(ruby_version, [1, 8, 7])endfunction
function! s:update_impl(pull, force, args) abort let sync = index(a:args, '--sync') >= 0 || has('vim_starting') let args = filter(copy(a:args), 'v:val != "--sync"') let threads = (len(args) > 0 && args[-1] =~ '^[1-9][0-9]*$') ? \ remove(args, -1) : get(g:, 'plug_threads', 16)
let managed = filter(deepcopy(g:plugs), 's:is_managed(v:key)') let todo = empty(args) ? filter(managed, '!v:val.frozen || !isdirectory(v:val.dir)') : \ filter(managed, 'index(args, v:key) >= 0')
if empty(todo) return s:warn('echo', 'No plugin to '. (a:pull ? 'update' : 'install')) endif
if !s:is_win && s:git_version_requirement(2, 3) let s:git_terminal_prompt = exists('$GIT_TERMINAL_PROMPT') ? $GIT_TERMINAL_PROMPT : '' let $GIT_TERMINAL_PROMPT = 0 for plug in values(todo) let plug.uri = substitute(plug.uri, \ '^https://git::@github\.com', 'https://github.com', '') endfor endif
if !isdirectory(g:plug_home) try call mkdir(g:plug_home, 'p') catch return s:err(printf('Invalid plug directory: %s. '. \ 'Try to call plug#begin with a valid directory', g:plug_home)) endtry endif
if has('nvim') && !exists('*jobwait') && threads > 1 call s:warn('echom', '[vim-plug] Update Neovim for parallel installer') endif
let use_job = s:nvim || s:vim8 let python = (has('python') || has('python3')) && !use_job let ruby = has('ruby') && !use_job && (v:version >= 703 || v:version == 702 && has('patch374')) && !(s:is_win && has('gui_running')) && threads > 1 && s:check_ruby()
let s:update = { \ 'start': reltime(), \ 'all': todo, \ 'todo': copy(todo), \ 'errors': [], \ 'pull': a:pull, \ 'force': a:force, \ 'new': {}, \ 'threads': (python || ruby || use_job) ? min([len(todo), threads]) : 1, \ 'bar': '', \ 'fin': 0 \ }
call s:prepare(1) call append(0, ['', '']) normal! 2G silent! redraw
" Set remote name, overriding a possible user git config's clone.defaultRemoteName let s:clone_opt = ['--origin', 'origin'] if get(g:, 'plug_shallow', 1) call extend(s:clone_opt, ['--depth', '1']) if s:git_version_requirement(1, 7, 10) call add(s:clone_opt, '--no-single-branch') endif endif
if has('win32unix') || has('wsl') call extend(s:clone_opt, ['-c', 'core.eol=lf', '-c', 'core.autocrlf=input']) endif
let s:submodule_opt = s:git_version_requirement(2, 8) ? ' --jobs='.threads : ''
" Python version requirement (>= 2.7) if python && !has('python3') && !ruby && !use_job && s:update.threads > 1 redir => pyv silent python import platform; print platform.python_version() redir END let python = s:version_requirement( \ map(split(split(pyv)[0], '\.'), 'str2nr(v:val)'), [2, 6]) endif
if (python || ruby) && s:update.threads > 1 try let imd = &imd if s:mac_gui set noimd endif if ruby call s:update_ruby() else call s:update_python() endif catch let lines = getline(4, '$') let printed = {} silent! 4,$d _ for line in lines let name = s:extract_name(line, '.', '') if empty(name) || !has_key(printed, name) call append('$', line) if !empty(name) let printed[name] = 1 if line[0] == 'x' && index(s:update.errors, name) < 0 call add(s:update.errors, name) end endif endif endfor finally let &imd = imd call s:update_finish() endtry else call s:update_vim() while use_job && sync sleep 100m if s:update.fin break endif endwhile endifendfunction
function! s:log4(name, msg) call setline(4, printf('- %s (%s)', a:msg, a:name)) redrawendfunction
function! s:update_finish() if exists('s:git_terminal_prompt') let $GIT_TERMINAL_PROMPT = s:git_terminal_prompt endif if s:switch_in() call append(3, '- Updating ...') | 4 for [name, spec] in items(filter(copy(s:update.all), 'index(s:update.errors, v:key) < 0 && (s:update.force || s:update.pull || has_key(s:update.new, v:key))')) let [pos, _] = s:logpos(name) if !pos continue endif let out = '' let error = 0 if has_key(spec, 'commit') call s:log4(name, 'Checking out '.spec.commit) let [out, error] = s:checkout(spec) elseif has_key(spec, 'tag') let tag = spec.tag if tag =~ '\*' let tags = s:lines(s:system('git tag --list '.plug#shellescape(tag).' --sort -version:refname 2>&1', spec.dir)) if !v:shell_error && !empty(tags) let tag = tags[0] call s:log4(name, printf('Latest tag for %s -> %s', spec.tag, tag)) call append(3, '') endif endif call s:log4(name, 'Checking out '.tag) let out = s:system('git checkout -q '.plug#shellescape(tag).' -- 2>&1', spec.dir) let error = v:shell_error endif if !error && filereadable(spec.dir.'/.gitmodules') && \ (s:update.force || has_key(s:update.new, name) || s:is_updated(spec.dir)) call s:log4(name, 'Updating submodules. This may take a while.') let out .= s:bang('git submodule update --init --recursive'.s:submodule_opt.' 2>&1', spec.dir) let error = v:shell_error endif let msg = s:format_message(v:shell_error ? 'x': '-', name, out) if error call add(s:update.errors, name) call s:regress_bar() silent execute pos 'd _' call append(4, msg) | 4 elseif !empty(out) call setline(pos, msg[0]) endif redraw endfor silent 4 d _ try call s:do(s:update.pull, s:update.force, filter(copy(s:update.all), 'index(s:update.errors, v:key) < 0 && has_key(v:val, "do")')) catch call s:warn('echom', v:exception) call s:warn('echo', '') return endtry call s:finish(s:update.pull) call setline(1, 'Updated. Elapsed time: ' . split(reltimestr(reltime(s:update.start)))[0] . ' sec.') call s:switch_out('normal! gg') endifendfunction
function! s:mark_aborted(name, message) let attrs = { 'running': 0, 'error': 1, 'abort': 1, 'lines': [a:message] } let s:jobs[a:name] = extend(get(s:jobs, a:name, {}), attrs)endfunction
function! s:job_abort(cancel) if (!s:nvim && !s:vim8) || !exists('s:jobs') return endif
for [name, j] in items(s:jobs) if s:nvim silent! call jobstop(j.jobid) elseif s:vim8 silent! call job_stop(j.jobid) endif if j.new call s:rm_rf(g:plugs[name].dir) endif if a:cancel call s:mark_aborted(name, 'Aborted') endif endfor
if a:cancel for todo in values(s:update.todo) let todo.abort = 1 endfor else let s:jobs = {} endifendfunction
function! s:last_non_empty_line(lines) let len = len(a:lines) for idx in range(len) let line = a:lines[len-idx-1] if !empty(line) return line endif endfor return ''endfunction
function! s:bullet_for(job, ...) if a:job.running return a:job.new ? '+' : '*' endif if get(a:job, 'abort', 0) return '~' endif return a:job.error ? 'x' : get(a:000, 0, '-')endfunction
function! s:job_out_cb(self, data) abort let self = a:self let data = remove(self.lines, -1) . a:data let lines = map(split(data, "\n", 1), 'split(v:val, "\r", 1)[-1]') call extend(self.lines, lines) " To reduce the number of buffer updates let self.tick = get(self, 'tick', -1) + 1 if !self.running || self.tick % len(s:jobs) == 0 let result = self.error ? join(self.lines, "\n") : s:last_non_empty_line(self.lines) if len(result) call s:log(s:bullet_for(self), self.name, result) endif endifendfunction
function! s:job_exit_cb(self, data) abort let a:self.running = 0 let a:self.error = a:data != 0 call s:reap(a:self.name) call s:tick()endfunction
function! s:job_cb(fn, job, ch, data) if !s:plug_window_exists() " plug window closed return s:job_abort(0) endif call call(a:fn, [a:job, a:data])endfunction
function! s:nvim_cb(job_id, data, event) dict abort return (a:event == 'stdout' || a:event == 'stderr') ? \ s:job_cb('s:job_out_cb', self, 0, join(a:data, "\n")) : \ s:job_cb('s:job_exit_cb', self, 0, a:data)endfunction
function! s:spawn(name, spec, queue, opts) let job = { 'name': a:name, 'spec': a:spec, 'running': 1, 'error': 0, 'lines': [''], \ 'new': get(a:opts, 'new', 0), 'queue': copy(a:queue) } let Item = remove(job.queue, 0) let argv = type(Item) == s:TYPE.funcref ? call(Item, [a:spec]) : Item let s:jobs[a:name] = job
if s:nvim if has_key(a:opts, 'dir') let job.cwd = a:opts.dir endif call extend(job, { \ 'on_stdout': function('s:nvim_cb'), \ 'on_stderr': function('s:nvim_cb'), \ 'on_exit': function('s:nvim_cb'), \ }) let jid = s:plug_call('jobstart', argv, job) if jid > 0 let job.jobid = jid else let job.running = 0 let job.error = 1 let job.lines = [jid < 0 ? argv[0].' is not executable' : \ 'Invalid arguments (or job table is full)'] endif elseif s:vim8 let cmd = join(map(copy(argv), 'plug#shellescape(v:val, {"script": 0})')) if has_key(a:opts, 'dir') let cmd = s:with_cd(cmd, a:opts.dir, 0) endif let argv = s:is_win ? ['cmd', '/s', '/c', '"'.cmd.'"'] : ['sh', '-c', cmd] let jid = job_start(s:is_win ? join(argv, ' ') : argv, { \ 'out_cb': function('s:job_cb', ['s:job_out_cb', job]), \ 'err_cb': function('s:job_cb', ['s:job_out_cb', job]), \ 'exit_cb': function('s:job_cb', ['s:job_exit_cb', job]), \ 'err_mode': 'raw', \ 'out_mode': 'raw' \}) if job_status(jid) == 'run' let job.jobid = jid else let job.running = 0 let job.error = 1 let job.lines = ['Failed to start job'] endif else let job.lines = s:lines(call('s:system', has_key(a:opts, 'dir') ? [argv, a:opts.dir] : [argv])) let job.error = v:shell_error != 0 let job.running = 0 endifendfunction
function! s:reap(name) let job = remove(s:jobs, a:name) if job.error call add(s:update.errors, a:name) elseif get(job, 'new', 0) let s:update.new[a:name] = 1 endif
let more = len(get(job, 'queue', [])) let result = job.error ? join(job.lines, "\n") : s:last_non_empty_line(job.lines) if len(result) call s:log(s:bullet_for(job), a:name, result) endif
if !job.error && more let job.spec.queue = job.queue let s:update.todo[a:name] = job.spec else let s:update.bar .= s:bullet_for(job, '=') call s:bar() endifendfunction
function! s:bar() if s:switch_in() let total = len(s:update.all) call setline(1, (s:update.pull ? 'Updating' : 'Installing'). \ ' plugins ('.len(s:update.bar).'/'.total.')') call s:progress_bar(2, s:update.bar, total) call s:switch_out() endifendfunction
function! s:logpos(name) let max = line('$') for i in range(4, max > 4 ? max : 4) if getline(i) =~# '^[-+x*] '.a:name.':' for j in range(i + 1, max > 5 ? max : 5) if getline(j) !~ '^ ' return [i, j - 1] endif endfor return [i, i] endif endfor return [0, 0]endfunction
function! s:log(bullet, name, lines) if s:switch_in() let [b, e] = s:logpos(a:name) if b > 0 silent execute printf('%d,%d d _', b, e) if b > winheight('.') let b = 4 endif else let b = 4 endif " FIXME For some reason, nomodifiable is set after :d in vim8 setlocal modifiable call append(b - 1, s:format_message(a:bullet, a:name, a:lines)) call s:switch_out() endifendfunction
function! s:update_vim() let s:jobs = {}
call s:bar() call s:tick()endfunction
function! s:checkout_command(spec) let a:spec.branch = s:git_origin_branch(a:spec) return ['git', 'checkout', '-q', a:spec.branch, '--']endfunction
function! s:merge_command(spec) let a:spec.branch = s:git_origin_branch(a:spec) return ['git', 'merge', '--ff-only', 'origin/'.a:spec.branch]endfunction
function! s:tick() let pull = s:update.pull let prog = s:progress_opt(s:nvim || s:vim8)while 1 " Without TCO, Vim stack is bound to explode if empty(s:update.todo) if empty(s:jobs) && !s:update.fin call s:update_finish() let s:update.fin = 1 endif return endif
let name = keys(s:update.todo)[0] let spec = remove(s:update.todo, name) if get(spec, 'abort', 0) call s:mark_aborted(name, 'Skipped') call s:reap(name) continue endif
let queue = get(spec, 'queue', []) let new = empty(globpath(spec.dir, '.git', 1))
if empty(queue) call s:log(new ? '+' : '*', name, pull ? 'Updating ...' : 'Installing ...') redraw endif
let has_tag = has_key(spec, 'tag') if len(queue) call s:spawn(name, spec, queue, { 'dir': spec.dir }) elseif !new let [error, _] = s:git_validate(spec, 0) if empty(error) if pull let cmd = s:disable_credential_helper() ? ['git', '-c', 'credential.helper=', 'fetch'] : ['git', 'fetch'] if has_tag && !empty(globpath(spec.dir, '.git/shallow')) call extend(cmd, ['--depth', '99999999']) endif if !empty(prog) call add(cmd, prog) endif let queue = [cmd, split('git remote set-head origin -a')] if !has_tag && !has_key(spec, 'commit') call extend(queue, [function('s:checkout_command'), function('s:merge_command')]) endif call s:spawn(name, spec, queue, { 'dir': spec.dir }) else let s:jobs[name] = { 'running': 0, 'lines': ['Already installed'], 'error': 0 } endif else let s:jobs[name] = { 'running': 0, 'lines': s:lines(error), 'error': 1 } endif else let cmd = ['git', 'clone'] if !has_tag call extend(cmd, s:clone_opt) endif if !empty(prog) call add(cmd, prog) endif call s:spawn(name, spec, [extend(cmd, [spec.uri, s:trim(spec.dir)]), function('s:checkout_command'), function('s:merge_command')], { 'new': 1 }) endif
if !s:jobs[name].running call s:reap(name) endif if len(s:jobs) >= s:update.threads break endifendwhileendfunction
function! s:update_python()let py_exe = has('python') ? 'python' : 'python3'execute py_exe "<< EOF"import datetimeimport functoolsimport ostry: import queueexcept ImportError: import Queue as queueimport randomimport reimport shutilimport signalimport subprocessimport tempfileimport threading as thrimport timeimport tracebackimport vim
G_NVIM = vim.eval("has('nvim')") == '1'G_PULL = vim.eval('s:update.pull') == '1'G_RETRIES = int(vim.eval('get(g:, "plug_retries", 2)')) + 1G_TIMEOUT = int(vim.eval('get(g:, "plug_timeout", 60)'))G_CLONE_OPT = ' '.join(vim.eval('s:clone_opt'))G_PROGRESS = vim.eval('s:progress_opt(1)')G_LOG_PROB = 1.0 / int(vim.eval('s:update.threads'))G_STOP = thr.Event()G_IS_WIN = vim.eval('s:is_win') == '1'
class PlugError(Exception): def __init__(self, msg): self.msg = msgclass CmdTimedOut(PlugError): passclass CmdFailed(PlugError): passclass InvalidURI(PlugError): passclass Action(object): INSTALL, UPDATE, ERROR, DONE = ['+', '*', 'x', '-']
class Buffer(object): def __init__(self, lock, num_plugs, is_pull): self.bar = '' self.event = 'Updating' if is_pull else 'Installing' self.lock = lock self.maxy = int(vim.eval('winheight(".")')) self.num_plugs = num_plugs
def __where(self, name): """ Find first line with name in current buffer. Return line num. """ found, lnum = False, 0 matcher = re.compile('^[-+x*] {0}:'.format(name)) for line in vim.current.buffer: if matcher.search(line) is not None: found = True break lnum += 1
if not found: lnum = -1 return lnum
def header(self): curbuf = vim.current.buffer curbuf[0] = self.event + ' plugins ({0}/{1})'.format(len(self.bar), self.num_plugs)
num_spaces = self.num_plugs - len(self.bar) curbuf[1] = '[{0}{1}]'.format(self.bar, num_spaces * ' ')
with self.lock: vim.command('normal! 2G') vim.command('redraw')
def write(self, action, name, lines): first, rest = lines[0], lines[1:] msg = ['{0} {1}{2}{3}'.format(action, name, ': ' if first else '', first)] msg.extend([' ' + line for line in rest])
try: if action == Action.ERROR: self.bar += 'x' vim.command("call add(s:update.errors, '{0}')".format(name)) elif action == Action.DONE: self.bar += '='
curbuf = vim.current.buffer lnum = self.__where(name) if lnum != -1: # Found matching line num del curbuf[lnum] if lnum > self.maxy and action in set([Action.INSTALL, Action.UPDATE]): lnum = 3 else: lnum = 3 curbuf.append(msg, lnum)
self.header() except vim.error: pass
class Command(object): CD = 'cd /d' if G_IS_WIN else 'cd'
def __init__(self, cmd, cmd_dir=None, timeout=60, cb=None, clean=None): self.cmd = cmd if cmd_dir: self.cmd = '{0} {1} && {2}'.format(Command.CD, cmd_dir, self.cmd) self.timeout = timeout self.callback = cb if cb else (lambda msg: None) self.clean = clean if clean else (lambda: None) self.proc = None
@property def alive(self): """ Returns true only if command still running. """ return self.proc and self.proc.poll() is None
def execute(self, ntries=3): """ Execute the command with ntries if CmdTimedOut. Returns the output of the command if no Exception. """ attempt, finished, limit = 0, False, self.timeout
while not finished: try: attempt += 1 result = self.try_command() finished = True return result except CmdTimedOut: if attempt != ntries: self.notify_retry() self.timeout += limit else: raise
def notify_retry(self): """ Retry required for command, notify user. """ for count in range(3, 0, -1): if G_STOP.is_set(): raise KeyboardInterrupt msg = 'Timeout. Will retry in {0} second{1} ...'.format( count, 's' if count != 1 else '') self.callback([msg]) time.sleep(1) self.callback(['Retrying ...'])
def try_command(self): """ Execute a cmd & poll for callback. Returns list of output. Raises CmdFailed -> return code for Popen isn't 0 Raises CmdTimedOut -> command exceeded timeout without new output """ first_line = True
try: tfile = tempfile.NamedTemporaryFile(mode='w+b') preexec_fn = not G_IS_WIN and os.setsid or None self.proc = subprocess.Popen(self.cmd, stdout=tfile, stderr=subprocess.STDOUT, stdin=subprocess.PIPE, shell=True, preexec_fn=preexec_fn) thrd = thr.Thread(target=(lambda proc: proc.wait()), args=(self.proc,)) thrd.start()
thread_not_started = True while thread_not_started: try: thrd.join(0.1) thread_not_started = False except RuntimeError: pass
while self.alive: if G_STOP.is_set(): raise KeyboardInterrupt
if first_line or random.random() < G_LOG_PROB: first_line = False line = '' if G_IS_WIN else nonblock_read(tfile.name) if line: self.callback([line])
time_diff = time.time() - os.path.getmtime(tfile.name) if time_diff > self.timeout: raise CmdTimedOut(['Timeout!'])
thrd.join(0.5)
tfile.seek(0) result = [line.decode('utf-8', 'replace').rstrip() for line in tfile]
if self.proc.returncode != 0: raise CmdFailed([''] + result)
return result except: self.terminate() raise
def terminate(self): """ Terminate process and cleanup. """ if self.alive: if G_IS_WIN: os.kill(self.proc.pid, signal.SIGINT) else: os.killpg(self.proc.pid, signal.SIGTERM) self.clean()
class Plugin(object): def __init__(self, name, args, buf_q, lock): self.name = name self.args = args self.buf_q = buf_q self.lock = lock self.tag = args.get('tag', 0)
def manage(self): try: if os.path.exists(self.args['dir']): self.update() else: self.install() with self.lock: thread_vim_command("let s:update.new['{0}'] = 1".format(self.name)) except PlugError as exc: self.write(Action.ERROR, self.name, exc.msg) except KeyboardInterrupt: G_STOP.set() self.write(Action.ERROR, self.name, ['Interrupted!']) except: # Any exception except those above print stack trace msg = 'Trace:\n{0}'.format(traceback.format_exc().rstrip()) self.write(Action.ERROR, self.name, msg.split('\n')) raise
def install(self): target = self.args['dir'] if target[-1] == '\\': target = target[0:-1]
def clean(target): def _clean(): try: shutil.rmtree(target) except OSError: pass return _clean
self.write(Action.INSTALL, self.name, ['Installing ...']) callback = functools.partial(self.write, Action.INSTALL, self.name) cmd = 'git clone {0} {1} {2} {3} 2>&1'.format( '' if self.tag else G_CLONE_OPT, G_PROGRESS, self.args['uri'], esc(target)) com = Command(cmd, None, G_TIMEOUT, callback, clean(target)) result = com.execute(G_RETRIES) self.write(Action.DONE, self.name, result[-1:])
def repo_uri(self): cmd = 'git rev-parse --abbrev-ref HEAD 2>&1 && git config -f .git/config remote.origin.url' command = Command(cmd, self.args['dir'], G_TIMEOUT,) result = command.execute(G_RETRIES) return result[-1]
def update(self): actual_uri = self.repo_uri() expect_uri = self.args['uri'] regex = re.compile(r'^(?:\w+://)?(?:[^@/]*@)?([^:/]*(?::[0-9]*)?)[:/](.*?)(?:\.git)?/?$') ma = regex.match(actual_uri) mb = regex.match(expect_uri) if ma is None or mb is None or ma.groups() != mb.groups(): msg = ['', 'Invalid URI: {0}'.format(actual_uri), 'Expected {0}'.format(expect_uri), 'PlugClean required.'] raise InvalidURI(msg)
if G_PULL: self.write(Action.UPDATE, self.name, ['Updating ...']) callback = functools.partial(self.write, Action.UPDATE, self.name) fetch_opt = '--depth 99999999' if self.tag and os.path.isfile(os.path.join(self.args['dir'], '.git/shallow')) else '' cmd = 'git fetch {0} {1} 2>&1'.format(fetch_opt, G_PROGRESS) com = Command(cmd, self.args['dir'], G_TIMEOUT, callback) result = com.execute(G_RETRIES) self.write(Action.DONE, self.name, result[-1:]) else: self.write(Action.DONE, self.name, ['Already installed'])
def write(self, action, name, msg): self.buf_q.put((action, name, msg))
class PlugThread(thr.Thread): def __init__(self, tname, args): super(PlugThread, self).__init__() self.tname = tname self.args = args
def run(self): thr.current_thread().name = self.tname buf_q, work_q, lock = self.args
try: while not G_STOP.is_set(): name, args = work_q.get_nowait() plug = Plugin(name, args, buf_q, lock) plug.manage() work_q.task_done() except queue.Empty: pass
class RefreshThread(thr.Thread): def __init__(self, lock): super(RefreshThread, self).__init__() self.lock = lock self.running = True
def run(self): while self.running: with self.lock: thread_vim_command('noautocmd normal! a') time.sleep(0.33)
def stop(self): self.running = False
if G_NVIM: def thread_vim_command(cmd): vim.session.threadsafe_call(lambda: vim.command(cmd))else: def thread_vim_command(cmd): vim.command(cmd)
def esc(name): return '"' + name.replace('"', '\"') + '"'
def nonblock_read(fname): """ Read a file with nonblock flag. Return the last line. """ fread = os.open(fname, os.O_RDONLY | os.O_NONBLOCK) buf = os.read(fread, 100000).decode('utf-8', 'replace') os.close(fread)
line = buf.rstrip('\r\n') left = max(line.rfind('\r'), line.rfind('\n')) if left != -1: left += 1 line = line[left:]
return line
def main(): thr.current_thread().name = 'main' nthreads = int(vim.eval('s:update.threads')) plugs = vim.eval('s:update.todo') mac_gui = vim.eval('s:mac_gui') == '1'
lock = thr.Lock() buf = Buffer(lock, len(plugs), G_PULL) buf_q, work_q = queue.Queue(), queue.Queue() for work in plugs.items(): work_q.put(work)
start_cnt = thr.active_count() for num in range(nthreads): tname = 'PlugT-{0:02}'.format(num) thread = PlugThread(tname, (buf_q, work_q, lock)) thread.start() if mac_gui: rthread = RefreshThread(lock) rthread.start()
while not buf_q.empty() or thr.active_count() != start_cnt: try: action, name, msg = buf_q.get(True, 0.25) buf.write(action, name, ['OK'] if not msg else msg) buf_q.task_done() except queue.Empty: pass except KeyboardInterrupt: G_STOP.set()
if mac_gui: rthread.stop() rthread.join()
main()EOFendfunction
function! s:update_ruby() ruby << EOF module PlugStream SEP = ["\r", "\n", nil] def get_line buffer = '' loop do char = readchar rescue return if SEP.include? char.chr buffer << $/ break else buffer << char end end buffer end end unless defined?(PlugStream)
def esc arg %["#{arg.gsub('"', '\"')}"] end
def killall pid pids = [pid] if /mswin|mingw|bccwin/ =~ RUBY_PLATFORM pids.each { |pid| Process.kill 'INT', pid.to_i rescue nil } else unless `which pgrep 2> /dev/null`.empty? children = pids until children.empty? children = children.map { |pid| `pgrep -P #{pid}`.lines.map { |l| l.chomp } }.flatten pids += children end end pids.each { |pid| Process.kill 'TERM', pid.to_i rescue nil } end end
def compare_git_uri a, b regex = %r{^(?:\w+://)?(?:[^@/]*@)?([^:/]*(?::[0-9]*)?)[:/](.*?)(?:\.git)?/?$} regex.match(a).to_a.drop(1) == regex.match(b).to_a.drop(1) end
require 'thread' require 'fileutils' require 'timeout' running = true iswin = VIM::evaluate('s:is_win').to_i == 1 pull = VIM::evaluate('s:update.pull').to_i == 1 base = VIM::evaluate('g:plug_home') all = VIM::evaluate('s:update.todo') limit = VIM::evaluate('get(g:, "plug_timeout", 60)') tries = VIM::evaluate('get(g:, "plug_retries", 2)') + 1 nthr = VIM::evaluate('s:update.threads').to_i maxy = VIM::evaluate('winheight(".")').to_i vim7 = VIM::evaluate('v:version').to_i <= 703 && RUBY_PLATFORM =~ /darwin/ cd = iswin ? 'cd /d' : 'cd' tot = VIM::evaluate('len(s:update.todo)') || 0 bar = '' skip = 'Already installed' mtx = Mutex.new take1 = proc { mtx.synchronize { running && all.shift } } logh = proc { cnt = bar.length $curbuf[1] = "#{pull ? 'Updating' : 'Installing'} plugins (#{cnt}/#{tot})" $curbuf[2] = '[' + bar.ljust(tot) + ']' VIM::command('normal! 2G') VIM::command('redraw') } where = proc { |name| (1..($curbuf.length)).find { |l| $curbuf[l] =~ /^[-+x*] #{name}:/ } } log = proc { |name, result, type| mtx.synchronize do ing = ![true, false].include?(type) bar += type ? '=' : 'x' unless ing b = case type when :install then '+' when :update then '*' when true, nil then '-' else VIM::command("call add(s:update.errors, '#{name}')") 'x' end result = if type || type.nil? ["#{b} #{name}: #{result.lines.to_a.last || 'OK'}"] elsif result =~ /^Interrupted|^Timeout/ ["#{b} #{name}: #{result}"] else ["#{b} #{name}"] + result.lines.map { |l| " " << l } end if lnum = where.call(name) $curbuf.delete lnum lnum = 4 if ing && lnum > maxy end result.each_with_index do |line, offset| $curbuf.append((lnum || 4) - 1 + offset, line.gsub(/\e\[./, '').chomp) end logh.call end } bt = proc { |cmd, name, type, cleanup| tried = timeout = 0 begin tried += 1 timeout += limit fd = nil data = '' if iswin Timeout::timeout(timeout) do tmp = VIM::evaluate('tempname()') system("(#{cmd}) > #{tmp}") data = File.read(tmp).chomp File.unlink tmp rescue nil end else fd = IO.popen(cmd).extend(PlugStream) first_line = true log_prob = 1.0 / nthr while line = Timeout::timeout(timeout) { fd.get_line } data << line log.call name, line.chomp, type if name && (first_line || rand < log_prob) first_line = false end fd.close end [$? == 0, data.chomp] rescue Timeout::Error, Interrupt => e if fd && !fd.closed? killall fd.pid fd.close end cleanup.call if cleanup if e.is_a?(Timeout::Error) && tried < tries 3.downto(1) do |countdown| s = countdown > 1 ? 's' : '' log.call name, "Timeout. Will retry in #{countdown} second#{s} ...", type sleep 1 end log.call name, 'Retrying ...', type retry end [false, e.is_a?(Interrupt) ? "Interrupted!" : "Timeout!"] end } main = Thread.current threads = [] watcher = Thread.new { if vim7 while VIM::evaluate('getchar(1)') sleep 0.1 end else require 'io/console' # >= Ruby 1.9 nil until IO.console.getch == 3.chr end mtx.synchronize do running = false threads.each { |t| t.raise Interrupt } unless vim7 end threads.each { |t| t.join rescue nil } main.kill } refresh = Thread.new { while true mtx.synchronize do break unless running VIM::command('noautocmd normal! a') end sleep 0.2 end } if VIM::evaluate('s:mac_gui') == 1
clone_opt = VIM::evaluate('s:clone_opt').join(' ') progress = VIM::evaluate('s:progress_opt(1)') nthr.times do mtx.synchronize do threads << Thread.new { while pair = take1.call name = pair.first dir, uri, tag = pair.last.values_at *%w[dir uri tag] exists = File.directory? dir ok, result = if exists chdir = "#{cd} #{iswin ? dir : esc(dir)}" ret, data = bt.call "#{chdir} && git rev-parse --abbrev-ref HEAD 2>&1 && git config -f .git/config remote.origin.url", nil, nil, nil current_uri = data.lines.to_a.last if !ret if data =~ /^Interrupted|^Timeout/ [false, data] else [false, [data.chomp, "PlugClean required."].join($/)] end elsif !compare_git_uri(current_uri, uri) [false, ["Invalid URI: #{current_uri}", "Expected: #{uri}", "PlugClean required."].join($/)] else if pull log.call name, 'Updating ...', :update fetch_opt = (tag && File.exist?(File.join(dir, '.git/shallow'))) ? '--depth 99999999' : '' bt.call "#{chdir} && git fetch #{fetch_opt} #{progress} 2>&1", name, :update, nil else [true, skip] end end else d = esc dir.sub(%r{[\\/]+$}, '') log.call name, 'Installing ...', :install bt.call "git clone #{clone_opt unless tag} #{progress} #{uri} #{d} 2>&1", name, :install, proc { FileUtils.rm_rf dir } end mtx.synchronize { VIM::command("let s:update.new['#{name}'] = 1") } if !exists && ok log.call name, result, ok end } if running end end threads.each { |t| t.join rescue nil } logh.call refresh.kill if refresh watcher.killEOFendfunction
function! s:shellesc_cmd(arg, script) let escaped = substitute('"'.a:arg.'"', '[&|<>()@^!"]', '^&', 'g') return substitute(escaped, '%', (a:script ? '%' : '^') . '&', 'g')endfunction
function! s:shellesc_ps1(arg) return "'".substitute(escape(a:arg, '\"'), "'", "''", 'g')."'"endfunction
function! s:shellesc_sh(arg) return "'".substitute(a:arg, "'", "'\\\\''", 'g')."'"endfunction
" Escape the shell argument based on the shell." Vim and Neovim's shellescape() are insufficient." 1. shellslash determines whether to use single/double quotes." Double-quote escaping is fragile for cmd.exe." 2. It does not work for powershell." 3. It does not work for *sh shells if the command is executed" via cmd.exe (ie. cmd.exe /c sh -c command command_args)" 4. It does not support batchfile syntax."" Accepts an optional dictionary with the following keys:" - shell: same as Vim/Neovim 'shell' option." If unset, fallback to 'cmd.exe' on Windows or 'sh'." - script: If truthy and shell is cmd.exe, escape for batchfile syntax.function! plug#shellescape(arg, ...) if a:arg =~# '^[A-Za-z0-9_/:.-]\+$' return a:arg endif let opts = a:0 > 0 && type(a:1) == s:TYPE.dict ? a:1 : {} let shell = get(opts, 'shell', s:is_win ? 'cmd.exe' : 'sh') let script = get(opts, 'script', 1) if shell =~# 'cmd\(\.exe\)\?$' return s:shellesc_cmd(a:arg, script) elseif s:is_powershell(shell) return s:shellesc_ps1(a:arg) endif return s:shellesc_sh(a:arg)endfunction
function! s:glob_dir(path) return map(filter(s:glob(a:path, '**'), 'isdirectory(v:val)'), 's:dirpath(v:val)')endfunction
function! s:progress_bar(line, bar, total) call setline(a:line, '[' . s:lpad(a:bar, a:total) . ']')endfunction
function! s:compare_git_uri(a, b) " See `git help clone' " https:// [user@] github.com[:port] / junegunn/vim-plug [.git] " [git@] github.com[:port] : junegunn/vim-plug [.git] " file:// / junegunn/vim-plug [/] " / junegunn/vim-plug [/] let pat = '^\%(\w\+://\)\='.'\%([^@/]*@\)\='.'\([^:/]*\%(:[0-9]*\)\=\)'.'[:/]'.'\(.\{-}\)'.'\%(\.git\)\=/\?$' let ma = matchlist(a:a, pat) let mb = matchlist(a:b, pat) return ma[1:2] ==# mb[1:2]endfunction
function! s:format_message(bullet, name, message) if a:bullet != 'x' return [printf('%s %s: %s', a:bullet, a:name, s:lastline(a:message))] else let lines = map(s:lines(a:message), '" ".v:val') return extend([printf('x %s:', a:name)], lines) endifendfunction
function! s:with_cd(cmd, dir, ...) let script = a:0 > 0 ? a:1 : 1 let pwsh = s:is_powershell(&shell) let cd = s:is_win && !pwsh ? 'cd /d' : 'cd' let sep = pwsh ? ';' : '&&' return printf('%s %s %s %s', cd, plug#shellescape(a:dir, {'script': script, 'shell': &shell}), sep, a:cmd)endfunction
function! s:system(cmd, ...) let batchfile = '' try let [sh, shellcmdflag, shrd] = s:chsh(1) if type(a:cmd) == s:TYPE.list " Neovim's system() supports list argument to bypass the shell " but it cannot set the working directory for the command. " Assume that the command does not rely on the shell. if has('nvim') && a:0 == 0 return system(a:cmd) endif let cmd = join(map(copy(a:cmd), 'plug#shellescape(v:val, {"shell": &shell, "script": 0})')) if s:is_powershell(&shell) let cmd = '& ' . cmd endif else let cmd = a:cmd endif if a:0 > 0 let cmd = s:with_cd(cmd, a:1, type(a:cmd) != s:TYPE.list) endif if s:is_win && type(a:cmd) != s:TYPE.list let [batchfile, cmd] = s:batchfile(cmd) endif return system(cmd) finally let [&shell, &shellcmdflag, &shellredir] = [sh, shellcmdflag, shrd] if s:is_win && filereadable(batchfile) call delete(batchfile) endif endtryendfunction
function! s:system_chomp(...) let ret = call('s:system', a:000) return v:shell_error ? '' : substitute(ret, '\n$', '', '')endfunction
function! s:git_validate(spec, check_branch) let err = '' if isdirectory(a:spec.dir) let result = [s:git_local_branch(a:spec.dir), s:git_origin_url(a:spec.dir)] let remote = result[-1] if empty(remote) let err = join([remote, 'PlugClean required.'], "\n") elseif !s:compare_git_uri(remote, a:spec.uri) let err = join(['Invalid URI: '.remote, \ 'Expected: '.a:spec.uri, \ 'PlugClean required.'], "\n") elseif a:check_branch && has_key(a:spec, 'commit') let sha = s:git_revision(a:spec.dir) if empty(sha) let err = join(add(result, 'PlugClean required.'), "\n") elseif !s:hash_match(sha, a:spec.commit) let err = join([printf('Invalid HEAD (expected: %s, actual: %s)', \ a:spec.commit[:6], sha[:6]), \ 'PlugUpdate required.'], "\n") endif elseif a:check_branch let current_branch = result[0] " Check tag let origin_branch = s:git_origin_branch(a:spec) if has_key(a:spec, 'tag') let tag = s:system_chomp('git describe --exact-match --tags HEAD 2>&1', a:spec.dir) if a:spec.tag !=# tag && a:spec.tag !~ '\*' let err = printf('Invalid tag: %s (expected: %s). Try PlugUpdate.', \ (empty(tag) ? 'N/A' : tag), a:spec.tag) endif " Check branch elseif origin_branch !=# current_branch let err = printf('Invalid branch: %s (expected: %s). Try PlugUpdate.', \ current_branch, origin_branch) endif if empty(err) let ahead_behind = split(s:lastline(s:system([ \ 'git', 'rev-list', '--count', '--left-right', \ printf('HEAD...origin/%s', origin_branch) \ ], a:spec.dir)), '\t') if v:shell_error || len(ahead_behind) != 2 let err = "Failed to compare with the origin. The default branch might have changed.\nPlugClean required." else let [ahead, behind] = ahead_behind if ahead && behind " Only mention PlugClean if diverged, otherwise it's likely to be " pushable (and probably not that messed up). let err = printf( \ "Diverged from origin/%s (%d commit(s) ahead and %d commit(s) behind!\n" \ .'Backup local changes and run PlugClean and PlugUpdate to reinstall it.', origin_branch, ahead, behind) elseif ahead let err = printf("Ahead of origin/%s by %d commit(s).\n" \ .'Cannot update until local changes are pushed.', \ origin_branch, ahead) endif endif endif endif else let err = 'Not found' endif return [err, err =~# 'PlugClean']endfunction
function! s:rm_rf(dir) if isdirectory(a:dir) return s:system(s:is_win \ ? 'rmdir /S /Q '.plug#shellescape(a:dir) \ : ['rm', '-rf', a:dir]) endifendfunction
function! s:clean(force) call s:prepare() call append(0, 'Searching for invalid plugins in '.g:plug_home) call append(1, '')
" List of valid directories let dirs = [] let errs = {} let [cnt, total] = [0, len(g:plugs)] for [name, spec] in items(g:plugs) if !s:is_managed(name) || get(spec, 'frozen', 0) call add(dirs, spec.dir) else let [err, clean] = s:git_validate(spec, 1) if clean let errs[spec.dir] = s:lines(err)[0] else call add(dirs, spec.dir) endif endif let cnt += 1 call s:progress_bar(2, repeat('=', cnt), total) normal! 2G redraw endfor
let allowed = {} for dir in dirs let allowed[s:dirpath(s:plug_fnamemodify(dir, ':h:h'))] = 1 let allowed[dir] = 1 for child in s:glob_dir(dir) let allowed[child] = 1 endfor endfor
let todo = [] let found = sort(s:glob_dir(g:plug_home)) while !empty(found) let f = remove(found, 0) if !has_key(allowed, f) && isdirectory(f) call add(todo, f) call append(line('$'), '- ' . f) if has_key(errs, f) call append(line('$'), ' ' . errs[f]) endif let found = filter(found, 'stridx(v:val, f) != 0') end endwhile
4 redraw if empty(todo) call append(line('$'), 'Already clean.') else let s:clean_count = 0 call append(3, ['Directories to delete:', '']) redraw! if a:force || s:ask_no_interrupt('Delete all directories?') call s:delete([6, line('$')], 1) else call setline(4, 'Cancelled.') nnoremap <silent> <buffer> d :set opfunc=<sid>delete_op<cr>g@ nmap <silent> <buffer> dd d_ xnoremap <silent> <buffer> d :<c-u>call <sid>delete_op(visualmode(), 1)<cr> echo 'Delete the lines (d{motion}) to delete the corresponding directories' endif endif 4 setlocal nomodifiableendfunction
function! s:delete_op(type, ...) call s:delete(a:0 ? [line("'<"), line("'>")] : [line("'["), line("']")], 0)endfunction
function! s:delete(range, force) let [l1, l2] = a:range let force = a:force let err_count = 0 while l1 <= l2 let line = getline(l1) if line =~ '^- ' && isdirectory(line[2:]) execute l1 redraw! let answer = force ? 1 : s:ask('Delete '.line[2:].'?', 1) let force = force || answer > 1 if answer let err = s:rm_rf(line[2:]) setlocal modifiable if empty(err) call setline(l1, '~'.line[1:]) let s:clean_count += 1 else delete _ call append(l1 - 1, s:format_message('x', line[1:], err)) let l2 += len(s:lines(err)) let err_count += 1 endif let msg = printf('Removed %d directories.', s:clean_count) if err_count > 0 let msg .= printf(' Failed to remove %d directories.', err_count) endif call setline(4, msg) setlocal nomodifiable endif endif let l1 += 1 endwhileendfunction
function! s:upgrade() echo 'Downloading the latest version of vim-plug' redraw let tmp = s:plug_tempname() let new = tmp . '/plug.vim'
try let out = s:system(['git', 'clone', '--depth', '1', s:plug_src, tmp]) if v:shell_error return s:err('Error upgrading vim-plug: '. out) endif
if readfile(s:me) ==# readfile(new) echo 'vim-plug is already up-to-date' return 0 else call rename(s:me, s:me . '.old') call rename(new, s:me) unlet g:loaded_plug echo 'vim-plug has been upgraded' return 1 endif finally silent! call s:rm_rf(tmp) endtryendfunction
function! s:upgrade_specs() for spec in values(g:plugs) let spec.frozen = get(spec, 'frozen', 0) endforendfunction
function! s:status() call s:prepare() call append(0, 'Checking plugins') call append(1, '')
let ecnt = 0 let unloaded = 0 let [cnt, total] = [0, len(g:plugs)] for [name, spec] in items(g:plugs) let is_dir = isdirectory(spec.dir) if has_key(spec, 'uri') if is_dir let [err, _] = s:git_validate(spec, 1) let [valid, msg] = [empty(err), empty(err) ? 'OK' : err] else let [valid, msg] = [0, 'Not found. Try PlugInstall.'] endif else if is_dir let [valid, msg] = [1, 'OK'] else let [valid, msg] = [0, 'Not found.'] endif endif let cnt += 1 let ecnt += !valid " `s:loaded` entry can be missing if PlugUpgraded if is_dir && get(s:loaded, name, -1) == 0 let unloaded = 1 let msg .= ' (not loaded)' endif call s:progress_bar(2, repeat('=', cnt), total) call append(3, s:format_message(valid ? '-' : 'x', name, msg)) normal! 2G redraw endfor call setline(1, 'Finished. '.ecnt.' error(s).') normal! gg setlocal nomodifiable if unloaded echo "Press 'L' on each line to load plugin, or 'U' to update" nnoremap <silent> <buffer> L :call <SID>status_load(line('.'))<cr> xnoremap <silent> <buffer> L :call <SID>status_load(line('.'))<cr> endendfunction
function! s:extract_name(str, prefix, suffix) return matchstr(a:str, '^'.a:prefix.' \zs[^:]\+\ze:.*'.a:suffix.'$')endfunction
function! s:status_load(lnum) let line = getline(a:lnum) let name = s:extract_name(line, '-', '(not loaded)') if !empty(name) call plug#load(name) setlocal modifiable call setline(a:lnum, substitute(line, ' (not loaded)$', '', '')) setlocal nomodifiable endifendfunction
function! s:status_update() range let lines = getline(a:firstline, a:lastline) let names = filter(map(lines, 's:extract_name(v:val, "[x-]", "")'), '!empty(v:val)') if !empty(names) echo execute 'PlugUpdate' join(names) endifendfunction
function! s:is_preview_window_open() silent! wincmd P if &previewwindow wincmd p return 1 endifendfunction
function! s:find_name(lnum) for lnum in reverse(range(1, a:lnum)) let line = getline(lnum) if empty(line) return '' endif let name = s:extract_name(line, '-', '') if !empty(name) return name endif endfor return ''endfunction
function! s:preview_commit() if b:plug_preview < 0 let b:plug_preview = !s:is_preview_window_open() endif
let sha = matchstr(getline('.'), '^ \X*\zs[0-9a-f]\{7,9}') if empty(sha) let name = matchstr(getline('.'), '^- \zs[^:]*\ze:$') if empty(name) return endif let title = 'HEAD@{1}..' let command = 'git diff --no-color HEAD@{1}' else let title = sha let command = 'git show --no-color --pretty=medium '.sha let name = s:find_name(line('.')) endif
if empty(name) || !has_key(g:plugs, name) || !isdirectory(g:plugs[name].dir) return endif
if !s:is_preview_window_open() execute get(g:, 'plug_pwindow', 'vertical rightbelow new') execute 'e' title else execute 'pedit' title wincmd P endif setlocal previewwindow filetype=git buftype=nofile bufhidden=wipe nobuflisted modifiable let batchfile = '' try let [sh, shellcmdflag, shrd] = s:chsh(1) let cmd = 'cd '.plug#shellescape(g:plugs[name].dir).' && '.command if s:is_win let [batchfile, cmd] = s:batchfile(cmd) endif execute 'silent %!' cmd finally let [&shell, &shellcmdflag, &shellredir] = [sh, shellcmdflag, shrd] if s:is_win && filereadable(batchfile) call delete(batchfile) endif endtry setlocal nomodifiable nnoremap <silent> <buffer> q :q<cr> wincmd pendfunction
function! s:section(flags) call search('\(^[x-] \)\@<=[^:]\+:', a:flags)endfunction
function! s:format_git_log(line) let indent = ' ' let tokens = split(a:line, nr2char(1)) if len(tokens) != 5 return indent.substitute(a:line, '\s*$', '', '') endif let [graph, sha, refs, subject, date] = tokens let tag = matchstr(refs, 'tag: [^,)]\+') let tag = empty(tag) ? ' ' : ' ('.tag.') ' return printf('%s%s%s%s%s (%s)', indent, graph, sha, tag, subject, date)endfunction
function! s:append_ul(lnum, text) call append(a:lnum, ['', a:text, repeat('-', len(a:text))])endfunction
function! s:diff() call s:prepare() call append(0, ['Collecting changes ...', '']) let cnts = [0, 0] let bar = '' let total = filter(copy(g:plugs), 's:is_managed(v:key) && isdirectory(v:val.dir)') call s:progress_bar(2, bar, len(total)) for origin in [1, 0] let plugs = reverse(sort(items(filter(copy(total), (origin ? '' : '!').'(has_key(v:val, "commit") || has_key(v:val, "tag"))')))) if empty(plugs) continue endif call s:append_ul(2, origin ? 'Pending updates:' : 'Last update:') for [k, v] in plugs let branch = s:git_origin_branch(v) if len(branch) let range = origin ? '..origin/'.branch : 'HEAD@{1}..' let cmd = ['git', 'log', '--graph', '--color=never'] if s:git_version_requirement(2, 10, 0) call add(cmd, '--no-show-signature') endif call extend(cmd, ['--pretty=format:%x01%h%x01%d%x01%s%x01%cr', range]) if has_key(v, 'rtp') call extend(cmd, ['--', v.rtp]) endif let diff = s:system_chomp(cmd, v.dir) if !empty(diff) let ref = has_key(v, 'tag') ? (' (tag: '.v.tag.')') : has_key(v, 'commit') ? (' '.v.commit) : '' call append(5, extend(['', '- '.k.':'.ref], map(s:lines(diff), 's:format_git_log(v:val)'))) let cnts[origin] += 1 endif endif let bar .= '=' call s:progress_bar(2, bar, len(total)) normal! 2G redraw endfor if !cnts[origin] call append(5, ['', 'N/A']) endif endfor call setline(1, printf('%d plugin(s) updated.', cnts[0]) \ . (cnts[1] ? printf(' %d plugin(s) have pending updates.', cnts[1]) : ''))
if cnts[0] || cnts[1] nnoremap <silent> <buffer> <plug>(plug-preview) :silent! call <SID>preview_commit()<cr> if empty(maparg("\<cr>", 'n')) nmap <buffer> <cr> <plug>(plug-preview) endif if empty(maparg('o', 'n')) nmap <buffer> o <plug>(plug-preview) endif endif if cnts[0] nnoremap <silent> <buffer> X :call <SID>revert()<cr> echo "Press 'X' on each block to revert the update" endif normal! gg setlocal nomodifiableendfunction
function! s:revert() if search('^Pending updates', 'bnW') return endif
let name = s:find_name(line('.')) if empty(name) || !has_key(g:plugs, name) || \ input(printf('Revert the update of %s? (y/N) ', name)) !~? '^y' return endif
call s:system('git reset --hard HEAD@{1} && git checkout '.plug#shellescape(g:plugs[name].branch).' --', g:plugs[name].dir) setlocal modifiable normal! "_dap setlocal nomodifiable echo 'Reverted'endfunction
function! s:snapshot(force, ...) abort call s:prepare() setf vim call append(0, ['" Generated by vim-plug', \ '" '.strftime("%c"), \ '" :source this file in vim to restore the snapshot', \ '" or execute: vim -S snapshot.vim', \ '', '', 'PlugUpdate!']) 1 let anchor = line('$') - 3 let names = sort(keys(filter(copy(g:plugs), \'has_key(v:val, "uri") && isdirectory(v:val.dir)'))) for name in reverse(names) let sha = has_key(g:plugs[name], 'commit') ? g:plugs[name].commit : s:git_revision(g:plugs[name].dir) if !empty(sha) call append(anchor, printf("silent! let g:plugs['%s'].commit = '%s'", name, sha)) redraw endif endfor
if a:0 > 0 let fn = s:plug_expand(a:1) if filereadable(fn) && !(a:force || s:ask(a:1.' already exists. Overwrite?')) return endif call writefile(getline(1, '$'), fn) echo 'Saved as '.a:1 silent execute 'e' s:esc(fn) setf vim endifendfunction
function! s:split_rtp() return split(&rtp, '\\\@<!,')endfunction
let s:first_rtp = s:escrtp(get(s:split_rtp(), 0, ''))let s:last_rtp = s:escrtp(get(s:split_rtp(), -1, ''))
if exists('g:plugs') let g:plugs_order = get(g:, 'plugs_order', keys(g:plugs)) call s:upgrade_specs() call s:define_commands()endif
let &cpo = s:cpo_saveunlet s:cpo_save