1
0

plug.vim 70 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454
  1. " vim-plug: Vim plugin manager
  2. " ============================
  3. "
  4. " Download plug.vim and put it in ~/.vim/autoload
  5. "
  6. " curl -fLo ~/.vim/autoload/plug.vim --create-dirs \
  7. " https://raw.githubusercontent.com/junegunn/vim-plug/master/plug.vim
  8. "
  9. " Edit your .vimrc
  10. "
  11. " call plug#begin('~/.vim/plugged')
  12. "
  13. " " Make sure you use single quotes
  14. "
  15. " " Shorthand notation; fetches https://github.com/junegunn/vim-easy-align
  16. " Plug 'junegunn/vim-easy-align'
  17. "
  18. " " Any valid git URL is allowed
  19. " Plug 'https://github.com/junegunn/vim-github-dashboard.git'
  20. "
  21. " " Multiple Plug commands can be written in a single line using | separators
  22. " Plug 'SirVer/ultisnips' | Plug 'honza/vim-snippets'
  23. "
  24. " " On-demand loading
  25. " Plug 'scrooloose/nerdtree', { 'on': 'NERDTreeToggle' }
  26. " Plug 'tpope/vim-fireplace', { 'for': 'clojure' }
  27. "
  28. " " Using a non-master branch
  29. " Plug 'rdnetto/YCM-Generator', { 'branch': 'stable' }
  30. "
  31. " " Using a tagged release; wildcard allowed (requires git 1.9.2 or above)
  32. " Plug 'fatih/vim-go', { 'tag': '*' }
  33. "
  34. " " Plugin options
  35. " Plug 'nsf/gocode', { 'tag': 'v.20150303', 'rtp': 'vim' }
  36. "
  37. " " Plugin outside ~/.vim/plugged with post-update hook
  38. " Plug 'junegunn/fzf', { 'dir': '~/.fzf', 'do': './install --all' }
  39. "
  40. " " Unmanaged plugin (manually installed and updated)
  41. " Plug '~/my-prototype-plugin'
  42. "
  43. " " Initialize plugin system
  44. " call plug#end()
  45. "
  46. " Then reload .vimrc and :PlugInstall to install plugins.
  47. "
  48. " Plug options:
  49. "
  50. "| Option | Description |
  51. "| ----------------------- | ------------------------------------------------ |
  52. "| `branch`/`tag`/`commit` | Branch/tag/commit of the repository to use |
  53. "| `rtp` | Subdirectory that contains Vim plugin |
  54. "| `dir` | Custom directory for the plugin |
  55. "| `as` | Use different name for the plugin |
  56. "| `do` | Post-update hook (string or funcref) |
  57. "| `on` | On-demand loading: Commands or `<Plug>`-mappings |
  58. "| `for` | On-demand loading: File types |
  59. "| `frozen` | Do not update unless explicitly specified |
  60. "
  61. " More information: https://github.com/junegunn/vim-plug
  62. "
  63. "
  64. " Copyright (c) 2017 Junegunn Choi
  65. "
  66. " MIT License
  67. "
  68. " Permission is hereby granted, free of charge, to any person obtaining
  69. " a copy of this software and associated documentation files (the
  70. " "Software"), to deal in the Software without restriction, including
  71. " without limitation the rights to use, copy, modify, merge, publish,
  72. " distribute, sublicense, and/or sell copies of the Software, and to
  73. " permit persons to whom the Software is furnished to do so, subject to
  74. " the following conditions:
  75. "
  76. " The above copyright notice and this permission notice shall be
  77. " included in all copies or substantial portions of the Software.
  78. "
  79. " THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  80. " EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  81. " MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  82. " NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  83. " LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  84. " OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  85. " WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  86. if exists('g:loaded_plug')
  87. finish
  88. endif
  89. let g:loaded_plug = 1
  90. let s:cpo_save = &cpo
  91. set cpo&vim
  92. let s:plug_src = 'https://github.com/junegunn/vim-plug.git'
  93. let s:plug_tab = get(s:, 'plug_tab', -1)
  94. let s:plug_buf = get(s:, 'plug_buf', -1)
  95. let s:mac_gui = has('gui_macvim') && has('gui_running')
  96. let s:is_win = has('win32') || has('win64')
  97. let s:nvim = has('nvim-0.2') || (has('nvim') && exists('*jobwait') && !s:is_win)
  98. let s:vim8 = has('patch-8.0.0039') && exists('*job_start')
  99. let s:me = resolve(expand('<sfile>:p'))
  100. let s:base_spec = { 'branch': 'master', 'frozen': 0 }
  101. let s:TYPE = {
  102. \ 'string': type(''),
  103. \ 'list': type([]),
  104. \ 'dict': type({}),
  105. \ 'funcref': type(function('call'))
  106. \ }
  107. let s:loaded = get(s:, 'loaded', {})
  108. let s:triggers = get(s:, 'triggers', {})
  109. function! plug#begin(...)
  110. if a:0 > 0
  111. let s:plug_home_org = a:1
  112. let home = s:path(fnamemodify(expand(a:1), ':p'))
  113. elseif exists('g:plug_home')
  114. let home = s:path(g:plug_home)
  115. elseif !empty(&rtp)
  116. let home = s:path(split(&rtp, ',')[0]) . '/plugged'
  117. else
  118. return s:err('Unable to determine plug home. Try calling plug#begin() with a path argument.')
  119. endif
  120. let g:plug_home = home
  121. let g:plugs = {}
  122. let g:plugs_order = []
  123. let s:triggers = {}
  124. call s:define_commands()
  125. return 1
  126. endfunction
  127. function! s:define_commands()
  128. command! -nargs=+ -bar Plug call plug#(<args>)
  129. if !executable('git')
  130. return s:err('`git` executable not found. Most commands will not be available. To suppress this message, prepend `silent!` to `call plug#begin(...)`.')
  131. endif
  132. command! -nargs=* -bar -bang -complete=customlist,s:names PlugInstall call s:install(<bang>0, [<f-args>])
  133. command! -nargs=* -bar -bang -complete=customlist,s:names PlugUpdate call s:update(<bang>0, [<f-args>])
  134. command! -nargs=0 -bar -bang PlugClean call s:clean(<bang>0)
  135. command! -nargs=0 -bar PlugUpgrade if s:upgrade() | execute 'source' s:esc(s:me) | endif
  136. command! -nargs=0 -bar PlugStatus call s:status()
  137. command! -nargs=0 -bar PlugDiff call s:diff()
  138. command! -nargs=? -bar -bang -complete=file PlugSnapshot call s:snapshot(<bang>0, <f-args>)
  139. endfunction
  140. function! s:to_a(v)
  141. return type(a:v) == s:TYPE.list ? a:v : [a:v]
  142. endfunction
  143. function! s:to_s(v)
  144. return type(a:v) == s:TYPE.string ? a:v : join(a:v, "\n") . "\n"
  145. endfunction
  146. function! s:glob(from, pattern)
  147. return s:lines(globpath(a:from, a:pattern))
  148. endfunction
  149. function! s:source(from, ...)
  150. let found = 0
  151. for pattern in a:000
  152. for vim in s:glob(a:from, pattern)
  153. execute 'source' s:esc(vim)
  154. let found = 1
  155. endfor
  156. endfor
  157. return found
  158. endfunction
  159. function! s:assoc(dict, key, val)
  160. let a:dict[a:key] = add(get(a:dict, a:key, []), a:val)
  161. endfunction
  162. function! s:ask(message, ...)
  163. call inputsave()
  164. echohl WarningMsg
  165. let answer = input(a:message.(a:0 ? ' (y/N/a) ' : ' (y/N) '))
  166. echohl None
  167. call inputrestore()
  168. echo "\r"
  169. return (a:0 && answer =~? '^a') ? 2 : (answer =~? '^y') ? 1 : 0
  170. endfunction
  171. function! s:ask_no_interrupt(...)
  172. try
  173. return call('s:ask', a:000)
  174. catch
  175. return 0
  176. endtry
  177. endfunction
  178. function! plug#end()
  179. if !exists('g:plugs')
  180. return s:err('Call plug#begin() first')
  181. endif
  182. if exists('#PlugLOD')
  183. augroup PlugLOD
  184. autocmd!
  185. augroup END
  186. augroup! PlugLOD
  187. endif
  188. let lod = { 'ft': {}, 'map': {}, 'cmd': {} }
  189. if exists('g:did_load_filetypes')
  190. filetype off
  191. endif
  192. for name in g:plugs_order
  193. if !has_key(g:plugs, name)
  194. continue
  195. endif
  196. let plug = g:plugs[name]
  197. if get(s:loaded, name, 0) || !has_key(plug, 'on') && !has_key(plug, 'for')
  198. let s:loaded[name] = 1
  199. continue
  200. endif
  201. if has_key(plug, 'on')
  202. let s:triggers[name] = { 'map': [], 'cmd': [] }
  203. for cmd in s:to_a(plug.on)
  204. if cmd =~? '^<Plug>.\+'
  205. if empty(mapcheck(cmd)) && empty(mapcheck(cmd, 'i'))
  206. call s:assoc(lod.map, cmd, name)
  207. endif
  208. call add(s:triggers[name].map, cmd)
  209. elseif cmd =~# '^[A-Z]'
  210. let cmd = substitute(cmd, '!*$', '', '')
  211. if exists(':'.cmd) != 2
  212. call s:assoc(lod.cmd, cmd, name)
  213. endif
  214. call add(s:triggers[name].cmd, cmd)
  215. else
  216. call s:err('Invalid `on` option: '.cmd.
  217. \ '. Should start with an uppercase letter or `<Plug>`.')
  218. endif
  219. endfor
  220. endif
  221. if has_key(plug, 'for')
  222. let types = s:to_a(plug.for)
  223. if !empty(types)
  224. augroup filetypedetect
  225. call s:source(s:rtp(plug), 'ftdetect/**/*.vim', 'after/ftdetect/**/*.vim')
  226. augroup END
  227. endif
  228. for type in types
  229. call s:assoc(lod.ft, type, name)
  230. endfor
  231. endif
  232. endfor
  233. for [cmd, names] in items(lod.cmd)
  234. execute printf(
  235. \ 'command! -nargs=* -range -bang -complete=file %s call s:lod_cmd(%s, "<bang>", <line1>, <line2>, <q-args>, %s)',
  236. \ cmd, string(cmd), string(names))
  237. endfor
  238. for [map, names] in items(lod.map)
  239. for [mode, map_prefix, key_prefix] in
  240. \ [['i', '<C-O>', ''], ['n', '', ''], ['v', '', 'gv'], ['o', '', '']]
  241. execute printf(
  242. \ '%snoremap <silent> %s %s:<C-U>call <SID>lod_map(%s, %s, %s, "%s")<CR>',
  243. \ mode, map, map_prefix, string(map), string(names), mode != 'i', key_prefix)
  244. endfor
  245. endfor
  246. for [ft, names] in items(lod.ft)
  247. augroup PlugLOD
  248. execute printf('autocmd FileType %s call <SID>lod_ft(%s, %s)',
  249. \ ft, string(ft), string(names))
  250. augroup END
  251. endfor
  252. call s:reorg_rtp()
  253. filetype plugin indent on
  254. if has('vim_starting')
  255. if has('syntax') && !exists('g:syntax_on')
  256. syntax enable
  257. end
  258. else
  259. call s:reload_plugins()
  260. endif
  261. endfunction
  262. function! s:loaded_names()
  263. return filter(copy(g:plugs_order), 'get(s:loaded, v:val, 0)')
  264. endfunction
  265. function! s:load_plugin(spec)
  266. call s:source(s:rtp(a:spec), 'plugin/**/*.vim', 'after/plugin/**/*.vim')
  267. endfunction
  268. function! s:reload_plugins()
  269. for name in s:loaded_names()
  270. call s:load_plugin(g:plugs[name])
  271. endfor
  272. endfunction
  273. function! s:trim(str)
  274. return substitute(a:str, '[\/]\+$', '', '')
  275. endfunction
  276. function! s:version_requirement(val, min)
  277. for idx in range(0, len(a:min) - 1)
  278. let v = get(a:val, idx, 0)
  279. if v < a:min[idx] | return 0
  280. elseif v > a:min[idx] | return 1
  281. endif
  282. endfor
  283. return 1
  284. endfunction
  285. function! s:git_version_requirement(...)
  286. if !exists('s:git_version')
  287. let s:git_version = map(split(split(s:system('git --version'))[2], '\.'), 'str2nr(v:val)')
  288. endif
  289. return s:version_requirement(s:git_version, a:000)
  290. endfunction
  291. function! s:progress_opt(base)
  292. return a:base && !s:is_win &&
  293. \ s:git_version_requirement(1, 7, 1) ? '--progress' : ''
  294. endfunction
  295. if s:is_win
  296. function! s:rtp(spec)
  297. return s:path(a:spec.dir . get(a:spec, 'rtp', ''))
  298. endfunction
  299. function! s:path(path)
  300. return s:trim(substitute(a:path, '/', '\', 'g'))
  301. endfunction
  302. function! s:dirpath(path)
  303. return s:path(a:path) . '\'
  304. endfunction
  305. function! s:is_local_plug(repo)
  306. return a:repo =~? '^[a-z]:\|^[%~]'
  307. endfunction
  308. else
  309. function! s:rtp(spec)
  310. return s:dirpath(a:spec.dir . get(a:spec, 'rtp', ''))
  311. endfunction
  312. function! s:path(path)
  313. return s:trim(a:path)
  314. endfunction
  315. function! s:dirpath(path)
  316. return substitute(a:path, '[/\\]*$', '/', '')
  317. endfunction
  318. function! s:is_local_plug(repo)
  319. return a:repo[0] =~ '[/$~]'
  320. endfunction
  321. endif
  322. function! s:err(msg)
  323. echohl ErrorMsg
  324. echom '[vim-plug] '.a:msg
  325. echohl None
  326. endfunction
  327. function! s:warn(cmd, msg)
  328. echohl WarningMsg
  329. execute a:cmd 'a:msg'
  330. echohl None
  331. endfunction
  332. function! s:esc(path)
  333. return escape(a:path, ' ')
  334. endfunction
  335. function! s:escrtp(path)
  336. return escape(a:path, ' ,')
  337. endfunction
  338. function! s:remove_rtp()
  339. for name in s:loaded_names()
  340. let rtp = s:rtp(g:plugs[name])
  341. execute 'set rtp-='.s:escrtp(rtp)
  342. let after = globpath(rtp, 'after')
  343. if isdirectory(after)
  344. execute 'set rtp-='.s:escrtp(after)
  345. endif
  346. endfor
  347. endfunction
  348. function! s:reorg_rtp()
  349. if !empty(s:first_rtp)
  350. execute 'set rtp-='.s:first_rtp
  351. execute 'set rtp-='.s:last_rtp
  352. endif
  353. " &rtp is modified from outside
  354. if exists('s:prtp') && s:prtp !=# &rtp
  355. call s:remove_rtp()
  356. unlet! s:middle
  357. endif
  358. let s:middle = get(s:, 'middle', &rtp)
  359. let rtps = map(s:loaded_names(), 's:rtp(g:plugs[v:val])')
  360. let afters = filter(map(copy(rtps), 'globpath(v:val, "after")'), '!empty(v:val)')
  361. let rtp = join(map(rtps, 'escape(v:val, ",")'), ',')
  362. \ . ','.s:middle.','
  363. \ . join(map(afters, 'escape(v:val, ",")'), ',')
  364. let &rtp = substitute(substitute(rtp, ',,*', ',', 'g'), '^,\|,$', '', 'g')
  365. let s:prtp = &rtp
  366. if !empty(s:first_rtp)
  367. execute 'set rtp^='.s:first_rtp
  368. execute 'set rtp+='.s:last_rtp
  369. endif
  370. endfunction
  371. function! s:doautocmd(...)
  372. if exists('#'.join(a:000, '#'))
  373. execute 'doautocmd' ((v:version > 703 || has('patch442')) ? '<nomodeline>' : '') join(a:000)
  374. endif
  375. endfunction
  376. function! s:dobufread(names)
  377. for name in a:names
  378. let path = s:rtp(g:plugs[name]).'/**'
  379. for dir in ['ftdetect', 'ftplugin']
  380. if len(finddir(dir, path))
  381. if exists('#BufRead')
  382. doautocmd BufRead
  383. endif
  384. return
  385. endif
  386. endfor
  387. endfor
  388. endfunction
  389. function! plug#load(...)
  390. if a:0 == 0
  391. return s:err('Argument missing: plugin name(s) required')
  392. endif
  393. if !exists('g:plugs')
  394. return s:err('plug#begin was not called')
  395. endif
  396. let unknowns = filter(copy(a:000), '!has_key(g:plugs, v:val)')
  397. if !empty(unknowns)
  398. let s = len(unknowns) > 1 ? 's' : ''
  399. return s:err(printf('Unknown plugin%s: %s', s, join(unknowns, ', ')))
  400. end
  401. let unloaded = filter(copy(a:000), '!get(s:loaded, v:val, 0)')
  402. if !empty(unloaded)
  403. for name in unloaded
  404. call s:lod([name], ['ftdetect', 'after/ftdetect', 'plugin', 'after/plugin'])
  405. endfor
  406. call s:dobufread(unloaded)
  407. return 1
  408. end
  409. return 0
  410. endfunction
  411. function! s:remove_triggers(name)
  412. if !has_key(s:triggers, a:name)
  413. return
  414. endif
  415. for cmd in s:triggers[a:name].cmd
  416. execute 'silent! delc' cmd
  417. endfor
  418. for map in s:triggers[a:name].map
  419. execute 'silent! unmap' map
  420. execute 'silent! iunmap' map
  421. endfor
  422. call remove(s:triggers, a:name)
  423. endfunction
  424. function! s:lod(names, types, ...)
  425. for name in a:names
  426. call s:remove_triggers(name)
  427. let s:loaded[name] = 1
  428. endfor
  429. call s:reorg_rtp()
  430. for name in a:names
  431. let rtp = s:rtp(g:plugs[name])
  432. for dir in a:types
  433. call s:source(rtp, dir.'/**/*.vim')
  434. endfor
  435. if a:0
  436. if !s:source(rtp, a:1) && !empty(s:glob(rtp, a:2))
  437. execute 'runtime' a:1
  438. endif
  439. call s:source(rtp, a:2)
  440. endif
  441. call s:doautocmd('User', name)
  442. endfor
  443. endfunction
  444. function! s:lod_ft(pat, names)
  445. let syn = 'syntax/'.a:pat.'.vim'
  446. call s:lod(a:names, ['plugin', 'after/plugin'], syn, 'after/'.syn)
  447. execute 'autocmd! PlugLOD FileType' a:pat
  448. call s:doautocmd('filetypeplugin', 'FileType')
  449. call s:doautocmd('filetypeindent', 'FileType')
  450. endfunction
  451. function! s:lod_cmd(cmd, bang, l1, l2, args, names)
  452. call s:lod(a:names, ['ftdetect', 'after/ftdetect', 'plugin', 'after/plugin'])
  453. call s:dobufread(a:names)
  454. execute printf('%s%s%s %s', (a:l1 == a:l2 ? '' : (a:l1.','.a:l2)), a:cmd, a:bang, a:args)
  455. endfunction
  456. function! s:lod_map(map, names, with_prefix, prefix)
  457. call s:lod(a:names, ['ftdetect', 'after/ftdetect', 'plugin', 'after/plugin'])
  458. call s:dobufread(a:names)
  459. let extra = ''
  460. while 1
  461. let c = getchar(0)
  462. if c == 0
  463. break
  464. endif
  465. let extra .= nr2char(c)
  466. endwhile
  467. if a:with_prefix
  468. let prefix = v:count ? v:count : ''
  469. let prefix .= '"'.v:register.a:prefix
  470. if mode(1) == 'no'
  471. if v:operator == 'c'
  472. let prefix = "\<esc>" . prefix
  473. endif
  474. let prefix .= v:operator
  475. endif
  476. call feedkeys(prefix, 'n')
  477. endif
  478. call feedkeys(substitute(a:map, '^<Plug>', "\<Plug>", '') . extra)
  479. endfunction
  480. function! plug#(repo, ...)
  481. if a:0 > 1
  482. return s:err('Invalid number of arguments (1..2)')
  483. endif
  484. try
  485. let repo = s:trim(a:repo)
  486. let opts = a:0 == 1 ? s:parse_options(a:1) : s:base_spec
  487. let name = get(opts, 'as', fnamemodify(repo, ':t:s?\.git$??'))
  488. let spec = extend(s:infer_properties(name, repo), opts)
  489. if !has_key(g:plugs, name)
  490. call add(g:plugs_order, name)
  491. endif
  492. let g:plugs[name] = spec
  493. let s:loaded[name] = get(s:loaded, name, 0)
  494. catch
  495. return s:err(v:exception)
  496. endtry
  497. endfunction
  498. function! s:parse_options(arg)
  499. let opts = copy(s:base_spec)
  500. let type = type(a:arg)
  501. if type == s:TYPE.string
  502. let opts.tag = a:arg
  503. elseif type == s:TYPE.dict
  504. call extend(opts, a:arg)
  505. if has_key(opts, 'dir')
  506. let opts.dir = s:dirpath(expand(opts.dir))
  507. endif
  508. else
  509. throw 'Invalid argument type (expected: string or dictionary)'
  510. endif
  511. return opts
  512. endfunction
  513. function! s:infer_properties(name, repo)
  514. let repo = a:repo
  515. if s:is_local_plug(repo)
  516. return { 'dir': s:dirpath(expand(repo)) }
  517. else
  518. if repo =~ ':'
  519. let uri = repo
  520. else
  521. if repo !~ '/'
  522. throw printf('Invalid argument: %s (implicit `vim-scripts'' expansion is deprecated)', repo)
  523. endif
  524. let fmt = get(g:, 'plug_url_format', 'https://git::@github.com/%s.git')
  525. let uri = printf(fmt, repo)
  526. endif
  527. return { 'dir': s:dirpath(g:plug_home.'/'.a:name), 'uri': uri }
  528. endif
  529. endfunction
  530. function! s:install(force, names)
  531. call s:update_impl(0, a:force, a:names)
  532. endfunction
  533. function! s:update(force, names)
  534. call s:update_impl(1, a:force, a:names)
  535. endfunction
  536. function! plug#helptags()
  537. if !exists('g:plugs')
  538. return s:err('plug#begin was not called')
  539. endif
  540. for spec in values(g:plugs)
  541. let docd = join([spec.dir, 'doc'], '/')
  542. if isdirectory(docd)
  543. silent! execute 'helptags' s:esc(docd)
  544. endif
  545. endfor
  546. return 1
  547. endfunction
  548. function! s:syntax()
  549. syntax clear
  550. syntax region plug1 start=/\%1l/ end=/\%2l/ contains=plugNumber
  551. syntax region plug2 start=/\%2l/ end=/\%3l/ contains=plugBracket,plugX
  552. syn match plugNumber /[0-9]\+[0-9.]*/ contained
  553. syn match plugBracket /[[\]]/ contained
  554. syn match plugX /x/ contained
  555. syn match plugDash /^-/
  556. syn match plugPlus /^+/
  557. syn match plugStar /^*/
  558. syn match plugMessage /\(^- \)\@<=.*/
  559. syn match plugName /\(^- \)\@<=[^ ]*:/
  560. syn match plugSha /\%(: \)\@<=[0-9a-f]\{4,}$/
  561. syn match plugTag /(tag: [^)]\+)/
  562. syn match plugInstall /\(^+ \)\@<=[^:]*/
  563. syn match plugUpdate /\(^* \)\@<=[^:]*/
  564. syn match plugCommit /^ \X*[0-9a-f]\{7,9} .*/ contains=plugRelDate,plugEdge,plugTag
  565. syn match plugEdge /^ \X\+$/
  566. syn match plugEdge /^ \X*/ contained nextgroup=plugSha
  567. syn match plugSha /[0-9a-f]\{7,9}/ contained
  568. syn match plugRelDate /([^)]*)$/ contained
  569. syn match plugNotLoaded /(not loaded)$/
  570. syn match plugError /^x.*/
  571. syn region plugDeleted start=/^\~ .*/ end=/^\ze\S/
  572. syn match plugH2 /^.*:\n-\+$/
  573. syn keyword Function PlugInstall PlugStatus PlugUpdate PlugClean
  574. hi def link plug1 Title
  575. hi def link plug2 Repeat
  576. hi def link plugH2 Type
  577. hi def link plugX Exception
  578. hi def link plugBracket Structure
  579. hi def link plugNumber Number
  580. hi def link plugDash Special
  581. hi def link plugPlus Constant
  582. hi def link plugStar Boolean
  583. hi def link plugMessage Function
  584. hi def link plugName Label
  585. hi def link plugInstall Function
  586. hi def link plugUpdate Type
  587. hi def link plugError Error
  588. hi def link plugDeleted Ignore
  589. hi def link plugRelDate Comment
  590. hi def link plugEdge PreProc
  591. hi def link plugSha Identifier
  592. hi def link plugTag Constant
  593. hi def link plugNotLoaded Comment
  594. endfunction
  595. function! s:lpad(str, len)
  596. return a:str . repeat(' ', a:len - len(a:str))
  597. endfunction
  598. function! s:lines(msg)
  599. return split(a:msg, "[\r\n]")
  600. endfunction
  601. function! s:lastline(msg)
  602. return get(s:lines(a:msg), -1, '')
  603. endfunction
  604. function! s:new_window()
  605. execute get(g:, 'plug_window', 'vertical topleft new')
  606. endfunction
  607. function! s:plug_window_exists()
  608. let buflist = tabpagebuflist(s:plug_tab)
  609. return !empty(buflist) && index(buflist, s:plug_buf) >= 0
  610. endfunction
  611. function! s:switch_in()
  612. if !s:plug_window_exists()
  613. return 0
  614. endif
  615. if winbufnr(0) != s:plug_buf
  616. let s:pos = [tabpagenr(), winnr(), winsaveview()]
  617. execute 'normal!' s:plug_tab.'gt'
  618. let winnr = bufwinnr(s:plug_buf)
  619. execute winnr.'wincmd w'
  620. call add(s:pos, winsaveview())
  621. else
  622. let s:pos = [winsaveview()]
  623. endif
  624. setlocal modifiable
  625. return 1
  626. endfunction
  627. function! s:switch_out(...)
  628. call winrestview(s:pos[-1])
  629. setlocal nomodifiable
  630. if a:0 > 0
  631. execute a:1
  632. endif
  633. if len(s:pos) > 1
  634. execute 'normal!' s:pos[0].'gt'
  635. execute s:pos[1] 'wincmd w'
  636. call winrestview(s:pos[2])
  637. endif
  638. endfunction
  639. function! s:finish_bindings()
  640. nnoremap <silent> <buffer> R :call <SID>retry()<cr>
  641. nnoremap <silent> <buffer> D :PlugDiff<cr>
  642. nnoremap <silent> <buffer> S :PlugStatus<cr>
  643. nnoremap <silent> <buffer> U :call <SID>status_update()<cr>
  644. xnoremap <silent> <buffer> U :call <SID>status_update()<cr>
  645. nnoremap <silent> <buffer> ]] :silent! call <SID>section('')<cr>
  646. nnoremap <silent> <buffer> [[ :silent! call <SID>section('b')<cr>
  647. endfunction
  648. function! s:prepare(...)
  649. if empty(getcwd())
  650. throw 'Invalid current working directory. Cannot proceed.'
  651. endif
  652. for evar in ['$GIT_DIR', '$GIT_WORK_TREE']
  653. if exists(evar)
  654. throw evar.' detected. Cannot proceed.'
  655. endif
  656. endfor
  657. call s:job_abort()
  658. if s:switch_in()
  659. if b:plug_preview == 1
  660. pc
  661. endif
  662. enew
  663. else
  664. call s:new_window()
  665. endif
  666. nnoremap <silent> <buffer> q :if b:plug_preview==1<bar>pc<bar>endif<bar>bd<cr>
  667. if a:0 == 0
  668. call s:finish_bindings()
  669. endif
  670. let b:plug_preview = -1
  671. let s:plug_tab = tabpagenr()
  672. let s:plug_buf = winbufnr(0)
  673. call s:assign_name()
  674. for k in ['<cr>', 'L', 'o', 'X', 'd', 'dd']
  675. execute 'silent! unmap <buffer>' k
  676. endfor
  677. setlocal buftype=nofile bufhidden=wipe nobuflisted nolist noswapfile nowrap cursorline modifiable nospell
  678. setf vim-plug
  679. if exists('g:syntax_on')
  680. call s:syntax()
  681. endif
  682. endfunction
  683. function! s:assign_name()
  684. " Assign buffer name
  685. let prefix = '[Plugins]'
  686. let name = prefix
  687. let idx = 2
  688. while bufexists(name)
  689. let name = printf('%s (%s)', prefix, idx)
  690. let idx = idx + 1
  691. endwhile
  692. silent! execute 'f' fnameescape(name)
  693. endfunction
  694. function! s:chsh(swap)
  695. let prev = [&shell, &shellredir]
  696. if !s:is_win && a:swap
  697. set shell=sh shellredir=>%s\ 2>&1
  698. endif
  699. return prev
  700. endfunction
  701. function! s:bang(cmd, ...)
  702. try
  703. let [sh, shrd] = s:chsh(a:0)
  704. " FIXME: Escaping is incomplete. We could use shellescape with eval,
  705. " but it won't work on Windows.
  706. let cmd = a:0 ? s:with_cd(a:cmd, a:1) : a:cmd
  707. let g:_plug_bang = '!'.escape(cmd, '#!%')
  708. execute "normal! :execute g:_plug_bang\<cr>\<cr>"
  709. finally
  710. unlet g:_plug_bang
  711. let [&shell, &shellredir] = [sh, shrd]
  712. endtry
  713. return v:shell_error ? 'Exit status: ' . v:shell_error : ''
  714. endfunction
  715. function! s:regress_bar()
  716. let bar = substitute(getline(2)[1:-2], '.*\zs=', 'x', '')
  717. call s:progress_bar(2, bar, len(bar))
  718. endfunction
  719. function! s:is_updated(dir)
  720. return !empty(s:system_chomp('git log --pretty=format:"%h" "HEAD...HEAD@{1}"', a:dir))
  721. endfunction
  722. function! s:do(pull, force, todo)
  723. for [name, spec] in items(a:todo)
  724. if !isdirectory(spec.dir)
  725. continue
  726. endif
  727. let installed = has_key(s:update.new, name)
  728. let updated = installed ? 0 :
  729. \ (a:pull && index(s:update.errors, name) < 0 && s:is_updated(spec.dir))
  730. if a:force || installed || updated
  731. execute 'cd' s:esc(spec.dir)
  732. call append(3, '- Post-update hook for '. name .' ... ')
  733. let error = ''
  734. let type = type(spec.do)
  735. if type == s:TYPE.string
  736. if spec.do[0] == ':'
  737. if !get(s:loaded, name, 0)
  738. let s:loaded[name] = 1
  739. call s:reorg_rtp()
  740. endif
  741. call s:load_plugin(spec)
  742. try
  743. execute spec.do[1:]
  744. catch
  745. let error = v:exception
  746. endtry
  747. if !s:plug_window_exists()
  748. cd -
  749. throw 'Warning: vim-plug was terminated by the post-update hook of '.name
  750. endif
  751. else
  752. let error = s:bang(spec.do)
  753. endif
  754. elseif type == s:TYPE.funcref
  755. try
  756. let status = installed ? 'installed' : (updated ? 'updated' : 'unchanged')
  757. call spec.do({ 'name': name, 'status': status, 'force': a:force })
  758. catch
  759. let error = v:exception
  760. endtry
  761. else
  762. let error = 'Invalid hook type'
  763. endif
  764. call s:switch_in()
  765. call setline(4, empty(error) ? (getline(4) . 'OK')
  766. \ : ('x' . getline(4)[1:] . error))
  767. if !empty(error)
  768. call add(s:update.errors, name)
  769. call s:regress_bar()
  770. endif
  771. cd -
  772. endif
  773. endfor
  774. endfunction
  775. function! s:hash_match(a, b)
  776. return stridx(a:a, a:b) == 0 || stridx(a:b, a:a) == 0
  777. endfunction
  778. function! s:checkout(spec)
  779. let sha = a:spec.commit
  780. let output = s:system('git rev-parse HEAD', a:spec.dir)
  781. if !v:shell_error && !s:hash_match(sha, s:lines(output)[0])
  782. let output = s:system(
  783. \ 'git fetch --depth 999999 && git checkout '.s:esc(sha).' --', a:spec.dir)
  784. endif
  785. return output
  786. endfunction
  787. function! s:finish(pull)
  788. let new_frozen = len(filter(keys(s:update.new), 'g:plugs[v:val].frozen'))
  789. if new_frozen
  790. let s = new_frozen > 1 ? 's' : ''
  791. call append(3, printf('- Installed %d frozen plugin%s', new_frozen, s))
  792. endif
  793. call append(3, '- Finishing ... ') | 4
  794. redraw
  795. call plug#helptags()
  796. call plug#end()
  797. call setline(4, getline(4) . 'Done!')
  798. redraw
  799. let msgs = []
  800. if !empty(s:update.errors)
  801. call add(msgs, "Press 'R' to retry.")
  802. endif
  803. if a:pull && len(s:update.new) < len(filter(getline(5, '$'),
  804. \ "v:val =~ '^- ' && stridx(v:val, 'Already up-to-date') < 0"))
  805. call add(msgs, "Press 'D' to see the updated changes.")
  806. endif
  807. echo join(msgs, ' ')
  808. call s:finish_bindings()
  809. endfunction
  810. function! s:retry()
  811. if empty(s:update.errors)
  812. return
  813. endif
  814. echo
  815. call s:update_impl(s:update.pull, s:update.force,
  816. \ extend(copy(s:update.errors), [s:update.threads]))
  817. endfunction
  818. function! s:is_managed(name)
  819. return has_key(g:plugs[a:name], 'uri')
  820. endfunction
  821. function! s:names(...)
  822. return sort(filter(keys(g:plugs), 'stridx(v:val, a:1) == 0 && s:is_managed(v:val)'))
  823. endfunction
  824. function! s:check_ruby()
  825. silent! ruby require 'thread'; VIM::command("let g:plug_ruby = '#{RUBY_VERSION}'")
  826. if !exists('g:plug_ruby')
  827. redraw!
  828. return s:warn('echom', 'Warning: Ruby interface is broken')
  829. endif
  830. let ruby_version = split(g:plug_ruby, '\.')
  831. unlet g:plug_ruby
  832. return s:version_requirement(ruby_version, [1, 8, 7])
  833. endfunction
  834. function! s:update_impl(pull, force, args) abort
  835. let sync = index(a:args, '--sync') >= 0 || has('vim_starting')
  836. let args = filter(copy(a:args), 'v:val != "--sync"')
  837. let threads = (len(args) > 0 && args[-1] =~ '^[1-9][0-9]*$') ?
  838. \ remove(args, -1) : get(g:, 'plug_threads', 16)
  839. let managed = filter(copy(g:plugs), 's:is_managed(v:key)')
  840. let todo = empty(args) ? filter(managed, '!v:val.frozen || !isdirectory(v:val.dir)') :
  841. \ filter(managed, 'index(args, v:key) >= 0')
  842. if empty(todo)
  843. return s:warn('echo', 'No plugin to '. (a:pull ? 'update' : 'install'))
  844. endif
  845. if !s:is_win && s:git_version_requirement(2, 3)
  846. let s:git_terminal_prompt = exists('$GIT_TERMINAL_PROMPT') ? $GIT_TERMINAL_PROMPT : ''
  847. let $GIT_TERMINAL_PROMPT = 0
  848. for plug in values(todo)
  849. let plug.uri = substitute(plug.uri,
  850. \ '^https://git::@github\.com', 'https://github.com', '')
  851. endfor
  852. endif
  853. if !isdirectory(g:plug_home)
  854. try
  855. call mkdir(g:plug_home, 'p')
  856. catch
  857. return s:err(printf('Invalid plug directory: %s. '.
  858. \ 'Try to call plug#begin with a valid directory', g:plug_home))
  859. endtry
  860. endif
  861. if has('nvim') && !exists('*jobwait') && threads > 1
  862. call s:warn('echom', '[vim-plug] Update Neovim for parallel installer')
  863. endif
  864. let use_job = s:nvim || s:vim8
  865. let python = (has('python') || has('python3')) && !use_job
  866. 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()
  867. let s:update = {
  868. \ 'start': reltime(),
  869. \ 'all': todo,
  870. \ 'todo': copy(todo),
  871. \ 'errors': [],
  872. \ 'pull': a:pull,
  873. \ 'force': a:force,
  874. \ 'new': {},
  875. \ 'threads': (python || ruby || use_job) ? min([len(todo), threads]) : 1,
  876. \ 'bar': '',
  877. \ 'fin': 0
  878. \ }
  879. call s:prepare(1)
  880. call append(0, ['', ''])
  881. normal! 2G
  882. silent! redraw
  883. let s:clone_opt = get(g:, 'plug_shallow', 1) ?
  884. \ '--depth 1' . (s:git_version_requirement(1, 7, 10) ? ' --no-single-branch' : '') : ''
  885. if has('win32unix')
  886. let s:clone_opt .= ' -c core.eol=lf -c core.autocrlf=input'
  887. endif
  888. " Python version requirement (>= 2.7)
  889. if python && !has('python3') && !ruby && !use_job && s:update.threads > 1
  890. redir => pyv
  891. silent python import platform; print platform.python_version()
  892. redir END
  893. let python = s:version_requirement(
  894. \ map(split(split(pyv)[0], '\.'), 'str2nr(v:val)'), [2, 6])
  895. endif
  896. if (python || ruby) && s:update.threads > 1
  897. try
  898. let imd = &imd
  899. if s:mac_gui
  900. set noimd
  901. endif
  902. if ruby
  903. call s:update_ruby()
  904. else
  905. call s:update_python()
  906. endif
  907. catch
  908. let lines = getline(4, '$')
  909. let printed = {}
  910. silent! 4,$d _
  911. for line in lines
  912. let name = s:extract_name(line, '.', '')
  913. if empty(name) || !has_key(printed, name)
  914. call append('$', line)
  915. if !empty(name)
  916. let printed[name] = 1
  917. if line[0] == 'x' && index(s:update.errors, name) < 0
  918. call add(s:update.errors, name)
  919. end
  920. endif
  921. endif
  922. endfor
  923. finally
  924. let &imd = imd
  925. call s:update_finish()
  926. endtry
  927. else
  928. call s:update_vim()
  929. while use_job && sync
  930. sleep 100m
  931. if s:update.fin
  932. break
  933. endif
  934. endwhile
  935. endif
  936. endfunction
  937. function! s:log4(name, msg)
  938. call setline(4, printf('- %s (%s)', a:msg, a:name))
  939. redraw
  940. endfunction
  941. function! s:update_finish()
  942. if exists('s:git_terminal_prompt')
  943. let $GIT_TERMINAL_PROMPT = s:git_terminal_prompt
  944. endif
  945. if s:switch_in()
  946. call append(3, '- Updating ...') | 4
  947. 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))'))
  948. let [pos, _] = s:logpos(name)
  949. if !pos
  950. continue
  951. endif
  952. if has_key(spec, 'commit')
  953. call s:log4(name, 'Checking out '.spec.commit)
  954. let out = s:checkout(spec)
  955. elseif has_key(spec, 'tag')
  956. let tag = spec.tag
  957. if tag =~ '\*'
  958. let tags = s:lines(s:system('git tag --list '.s:shellesc(tag).' --sort -version:refname 2>&1', spec.dir))
  959. if !v:shell_error && !empty(tags)
  960. let tag = tags[0]
  961. call s:log4(name, printf('Latest tag for %s -> %s', spec.tag, tag))
  962. call append(3, '')
  963. endif
  964. endif
  965. call s:log4(name, 'Checking out '.tag)
  966. let out = s:system('git checkout -q '.s:esc(tag).' -- 2>&1', spec.dir)
  967. else
  968. let branch = s:esc(get(spec, 'branch', 'master'))
  969. call s:log4(name, 'Merging origin/'.branch)
  970. let out = s:system('git checkout -q '.branch.' -- 2>&1'
  971. \. (has_key(s:update.new, name) ? '' : ('&& git merge --ff-only origin/'.branch.' 2>&1')), spec.dir)
  972. endif
  973. if !v:shell_error && filereadable(spec.dir.'/.gitmodules') &&
  974. \ (s:update.force || has_key(s:update.new, name) || s:is_updated(spec.dir))
  975. call s:log4(name, 'Updating submodules. This may take a while.')
  976. let out .= s:bang('git submodule update --init --recursive 2>&1', spec.dir)
  977. endif
  978. let msg = s:format_message(v:shell_error ? 'x': '-', name, out)
  979. if v:shell_error
  980. call add(s:update.errors, name)
  981. call s:regress_bar()
  982. silent execute pos 'd _'
  983. call append(4, msg) | 4
  984. elseif !empty(out)
  985. call setline(pos, msg[0])
  986. endif
  987. redraw
  988. endfor
  989. silent 4 d _
  990. try
  991. 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")'))
  992. catch
  993. call s:warn('echom', v:exception)
  994. call s:warn('echo', '')
  995. return
  996. endtry
  997. call s:finish(s:update.pull)
  998. call setline(1, 'Updated. Elapsed time: ' . split(reltimestr(reltime(s:update.start)))[0] . ' sec.')
  999. call s:switch_out('normal! gg')
  1000. endif
  1001. endfunction
  1002. function! s:job_abort()
  1003. if (!s:nvim && !s:vim8) || !exists('s:jobs')
  1004. return
  1005. endif
  1006. for [name, j] in items(s:jobs)
  1007. if s:nvim
  1008. silent! call jobstop(j.jobid)
  1009. elseif s:vim8
  1010. silent! call job_stop(j.jobid)
  1011. endif
  1012. if j.new
  1013. call s:system('rm -rf ' . s:shellesc(g:plugs[name].dir))
  1014. endif
  1015. endfor
  1016. let s:jobs = {}
  1017. endfunction
  1018. function! s:last_non_empty_line(lines)
  1019. let len = len(a:lines)
  1020. for idx in range(len)
  1021. let line = a:lines[len-idx-1]
  1022. if !empty(line)
  1023. return line
  1024. endif
  1025. endfor
  1026. return ''
  1027. endfunction
  1028. function! s:job_out_cb(self, data) abort
  1029. let self = a:self
  1030. let data = remove(self.lines, -1) . a:data
  1031. let lines = map(split(data, "\n", 1), 'split(v:val, "\r", 1)[-1]')
  1032. call extend(self.lines, lines)
  1033. " To reduce the number of buffer updates
  1034. let self.tick = get(self, 'tick', -1) + 1
  1035. if !self.running || self.tick % len(s:jobs) == 0
  1036. let bullet = self.running ? (self.new ? '+' : '*') : (self.error ? 'x' : '-')
  1037. let result = self.error ? join(self.lines, "\n") : s:last_non_empty_line(self.lines)
  1038. call s:log(bullet, self.name, result)
  1039. endif
  1040. endfunction
  1041. function! s:job_exit_cb(self, data) abort
  1042. let a:self.running = 0
  1043. let a:self.error = a:data != 0
  1044. call s:reap(a:self.name)
  1045. call s:tick()
  1046. endfunction
  1047. function! s:job_cb(fn, job, ch, data)
  1048. if !s:plug_window_exists() " plug window closed
  1049. return s:job_abort()
  1050. endif
  1051. call call(a:fn, [a:job, a:data])
  1052. endfunction
  1053. function! s:nvim_cb(job_id, data, event) dict abort
  1054. return a:event == 'stdout' ?
  1055. \ s:job_cb('s:job_out_cb', self, 0, join(a:data, "\n")) :
  1056. \ s:job_cb('s:job_exit_cb', self, 0, a:data)
  1057. endfunction
  1058. function! s:spawn(name, cmd, opts)
  1059. let job = { 'name': a:name, 'running': 1, 'error': 0, 'lines': [''],
  1060. \ 'new': get(a:opts, 'new', 0) }
  1061. let s:jobs[a:name] = job
  1062. let argv = add(s:is_win ? ['cmd', '/c'] : ['sh', '-c'],
  1063. \ has_key(a:opts, 'dir') ? s:with_cd(a:cmd, a:opts.dir) : a:cmd)
  1064. if s:nvim
  1065. call extend(job, {
  1066. \ 'on_stdout': function('s:nvim_cb'),
  1067. \ 'on_exit': function('s:nvim_cb'),
  1068. \ })
  1069. let jid = jobstart(argv, job)
  1070. if jid > 0
  1071. let job.jobid = jid
  1072. else
  1073. let job.running = 0
  1074. let job.error = 1
  1075. let job.lines = [jid < 0 ? argv[0].' is not executable' :
  1076. \ 'Invalid arguments (or job table is full)']
  1077. endif
  1078. elseif s:vim8
  1079. let jid = job_start(s:is_win ? join(argv, ' ') : argv, {
  1080. \ 'out_cb': function('s:job_cb', ['s:job_out_cb', job]),
  1081. \ 'exit_cb': function('s:job_cb', ['s:job_exit_cb', job]),
  1082. \ 'out_mode': 'raw'
  1083. \})
  1084. if job_status(jid) == 'run'
  1085. let job.jobid = jid
  1086. else
  1087. let job.running = 0
  1088. let job.error = 1
  1089. let job.lines = ['Failed to start job']
  1090. endif
  1091. else
  1092. let params = has_key(a:opts, 'dir') ? [a:cmd, a:opts.dir] : [a:cmd]
  1093. let job.lines = s:lines(call('s:system', params))
  1094. let job.error = v:shell_error != 0
  1095. let job.running = 0
  1096. endif
  1097. endfunction
  1098. function! s:reap(name)
  1099. let job = s:jobs[a:name]
  1100. if job.error
  1101. call add(s:update.errors, a:name)
  1102. elseif get(job, 'new', 0)
  1103. let s:update.new[a:name] = 1
  1104. endif
  1105. let s:update.bar .= job.error ? 'x' : '='
  1106. let bullet = job.error ? 'x' : '-'
  1107. let result = job.error ? join(job.lines, "\n") : s:last_non_empty_line(job.lines)
  1108. call s:log(bullet, a:name, empty(result) ? 'OK' : result)
  1109. call s:bar()
  1110. call remove(s:jobs, a:name)
  1111. endfunction
  1112. function! s:bar()
  1113. if s:switch_in()
  1114. let total = len(s:update.all)
  1115. call setline(1, (s:update.pull ? 'Updating' : 'Installing').
  1116. \ ' plugins ('.len(s:update.bar).'/'.total.')')
  1117. call s:progress_bar(2, s:update.bar, total)
  1118. call s:switch_out()
  1119. endif
  1120. endfunction
  1121. function! s:logpos(name)
  1122. for i in range(4, line('$'))
  1123. if getline(i) =~# '^[-+x*] '.a:name.':'
  1124. for j in range(i + 1, line('$'))
  1125. if getline(j) !~ '^ '
  1126. return [i, j - 1]
  1127. endif
  1128. endfor
  1129. return [i, i]
  1130. endif
  1131. endfor
  1132. return [0, 0]
  1133. endfunction
  1134. function! s:log(bullet, name, lines)
  1135. if s:switch_in()
  1136. let [b, e] = s:logpos(a:name)
  1137. if b > 0
  1138. silent execute printf('%d,%d d _', b, e)
  1139. if b > winheight('.')
  1140. let b = 4
  1141. endif
  1142. else
  1143. let b = 4
  1144. endif
  1145. " FIXME For some reason, nomodifiable is set after :d in vim8
  1146. setlocal modifiable
  1147. call append(b - 1, s:format_message(a:bullet, a:name, a:lines))
  1148. call s:switch_out()
  1149. endif
  1150. endfunction
  1151. function! s:update_vim()
  1152. let s:jobs = {}
  1153. call s:bar()
  1154. call s:tick()
  1155. endfunction
  1156. function! s:tick()
  1157. let pull = s:update.pull
  1158. let prog = s:progress_opt(s:nvim || s:vim8)
  1159. while 1 " Without TCO, Vim stack is bound to explode
  1160. if empty(s:update.todo)
  1161. if empty(s:jobs) && !s:update.fin
  1162. call s:update_finish()
  1163. let s:update.fin = 1
  1164. endif
  1165. return
  1166. endif
  1167. let name = keys(s:update.todo)[0]
  1168. let spec = remove(s:update.todo, name)
  1169. let new = !isdirectory(spec.dir)
  1170. call s:log(new ? '+' : '*', name, pull ? 'Updating ...' : 'Installing ...')
  1171. redraw
  1172. let has_tag = has_key(spec, 'tag')
  1173. if !new
  1174. let [error, _] = s:git_validate(spec, 0)
  1175. if empty(error)
  1176. if pull
  1177. let fetch_opt = (has_tag && !empty(globpath(spec.dir, '.git/shallow'))) ? '--depth 99999999' : ''
  1178. call s:spawn(name, printf('git fetch %s %s 2>&1', fetch_opt, prog), { 'dir': spec.dir })
  1179. else
  1180. let s:jobs[name] = { 'running': 0, 'lines': ['Already installed'], 'error': 0 }
  1181. endif
  1182. else
  1183. let s:jobs[name] = { 'running': 0, 'lines': s:lines(error), 'error': 1 }
  1184. endif
  1185. else
  1186. call s:spawn(name,
  1187. \ printf('git clone %s %s %s %s 2>&1',
  1188. \ has_tag ? '' : s:clone_opt,
  1189. \ prog,
  1190. \ s:shellesc(spec.uri),
  1191. \ s:shellesc(s:trim(spec.dir))), { 'new': 1 })
  1192. endif
  1193. if !s:jobs[name].running
  1194. call s:reap(name)
  1195. endif
  1196. if len(s:jobs) >= s:update.threads
  1197. break
  1198. endif
  1199. endwhile
  1200. endfunction
  1201. function! s:update_python()
  1202. let py_exe = has('python') ? 'python' : 'python3'
  1203. execute py_exe "<< EOF"
  1204. import datetime
  1205. import functools
  1206. import os
  1207. try:
  1208. import queue
  1209. except ImportError:
  1210. import Queue as queue
  1211. import random
  1212. import re
  1213. import shutil
  1214. import signal
  1215. import subprocess
  1216. import tempfile
  1217. import threading as thr
  1218. import time
  1219. import traceback
  1220. import vim
  1221. G_NVIM = vim.eval("has('nvim')") == '1'
  1222. G_PULL = vim.eval('s:update.pull') == '1'
  1223. G_RETRIES = int(vim.eval('get(g:, "plug_retries", 2)')) + 1
  1224. G_TIMEOUT = int(vim.eval('get(g:, "plug_timeout", 60)'))
  1225. G_CLONE_OPT = vim.eval('s:clone_opt')
  1226. G_PROGRESS = vim.eval('s:progress_opt(1)')
  1227. G_LOG_PROB = 1.0 / int(vim.eval('s:update.threads'))
  1228. G_STOP = thr.Event()
  1229. G_IS_WIN = vim.eval('s:is_win') == '1'
  1230. class PlugError(Exception):
  1231. def __init__(self, msg):
  1232. self.msg = msg
  1233. class CmdTimedOut(PlugError):
  1234. pass
  1235. class CmdFailed(PlugError):
  1236. pass
  1237. class InvalidURI(PlugError):
  1238. pass
  1239. class Action(object):
  1240. INSTALL, UPDATE, ERROR, DONE = ['+', '*', 'x', '-']
  1241. class Buffer(object):
  1242. def __init__(self, lock, num_plugs, is_pull):
  1243. self.bar = ''
  1244. self.event = 'Updating' if is_pull else 'Installing'
  1245. self.lock = lock
  1246. self.maxy = int(vim.eval('winheight(".")'))
  1247. self.num_plugs = num_plugs
  1248. def __where(self, name):
  1249. """ Find first line with name in current buffer. Return line num. """
  1250. found, lnum = False, 0
  1251. matcher = re.compile('^[-+x*] {0}:'.format(name))
  1252. for line in vim.current.buffer:
  1253. if matcher.search(line) is not None:
  1254. found = True
  1255. break
  1256. lnum += 1
  1257. if not found:
  1258. lnum = -1
  1259. return lnum
  1260. def header(self):
  1261. curbuf = vim.current.buffer
  1262. curbuf[0] = self.event + ' plugins ({0}/{1})'.format(len(self.bar), self.num_plugs)
  1263. num_spaces = self.num_plugs - len(self.bar)
  1264. curbuf[1] = '[{0}{1}]'.format(self.bar, num_spaces * ' ')
  1265. with self.lock:
  1266. vim.command('normal! 2G')
  1267. vim.command('redraw')
  1268. def write(self, action, name, lines):
  1269. first, rest = lines[0], lines[1:]
  1270. msg = ['{0} {1}{2}{3}'.format(action, name, ': ' if first else '', first)]
  1271. msg.extend([' ' + line for line in rest])
  1272. try:
  1273. if action == Action.ERROR:
  1274. self.bar += 'x'
  1275. vim.command("call add(s:update.errors, '{0}')".format(name))
  1276. elif action == Action.DONE:
  1277. self.bar += '='
  1278. curbuf = vim.current.buffer
  1279. lnum = self.__where(name)
  1280. if lnum != -1: # Found matching line num
  1281. del curbuf[lnum]
  1282. if lnum > self.maxy and action in set([Action.INSTALL, Action.UPDATE]):
  1283. lnum = 3
  1284. else:
  1285. lnum = 3
  1286. curbuf.append(msg, lnum)
  1287. self.header()
  1288. except vim.error:
  1289. pass
  1290. class Command(object):
  1291. CD = 'cd /d' if G_IS_WIN else 'cd'
  1292. def __init__(self, cmd, cmd_dir=None, timeout=60, cb=None, clean=None):
  1293. self.cmd = cmd
  1294. if cmd_dir:
  1295. self.cmd = '{0} {1} && {2}'.format(Command.CD, cmd_dir, self.cmd)
  1296. self.timeout = timeout
  1297. self.callback = cb if cb else (lambda msg: None)
  1298. self.clean = clean if clean else (lambda: None)
  1299. self.proc = None
  1300. @property
  1301. def alive(self):
  1302. """ Returns true only if command still running. """
  1303. return self.proc and self.proc.poll() is None
  1304. def execute(self, ntries=3):
  1305. """ Execute the command with ntries if CmdTimedOut.
  1306. Returns the output of the command if no Exception.
  1307. """
  1308. attempt, finished, limit = 0, False, self.timeout
  1309. while not finished:
  1310. try:
  1311. attempt += 1
  1312. result = self.try_command()
  1313. finished = True
  1314. return result
  1315. except CmdTimedOut:
  1316. if attempt != ntries:
  1317. self.notify_retry()
  1318. self.timeout += limit
  1319. else:
  1320. raise
  1321. def notify_retry(self):
  1322. """ Retry required for command, notify user. """
  1323. for count in range(3, 0, -1):
  1324. if G_STOP.is_set():
  1325. raise KeyboardInterrupt
  1326. msg = 'Timeout. Will retry in {0} second{1} ...'.format(
  1327. count, 's' if count != 1 else '')
  1328. self.callback([msg])
  1329. time.sleep(1)
  1330. self.callback(['Retrying ...'])
  1331. def try_command(self):
  1332. """ Execute a cmd & poll for callback. Returns list of output.
  1333. Raises CmdFailed -> return code for Popen isn't 0
  1334. Raises CmdTimedOut -> command exceeded timeout without new output
  1335. """
  1336. first_line = True
  1337. try:
  1338. tfile = tempfile.NamedTemporaryFile(mode='w+b')
  1339. preexec_fn = not G_IS_WIN and os.setsid or None
  1340. self.proc = subprocess.Popen(self.cmd, stdout=tfile,
  1341. stderr=subprocess.STDOUT,
  1342. stdin=subprocess.PIPE, shell=True,
  1343. preexec_fn=preexec_fn)
  1344. thrd = thr.Thread(target=(lambda proc: proc.wait()), args=(self.proc,))
  1345. thrd.start()
  1346. thread_not_started = True
  1347. while thread_not_started:
  1348. try:
  1349. thrd.join(0.1)
  1350. thread_not_started = False
  1351. except RuntimeError:
  1352. pass
  1353. while self.alive:
  1354. if G_STOP.is_set():
  1355. raise KeyboardInterrupt
  1356. if first_line or random.random() < G_LOG_PROB:
  1357. first_line = False
  1358. line = '' if G_IS_WIN else nonblock_read(tfile.name)
  1359. if line:
  1360. self.callback([line])
  1361. time_diff = time.time() - os.path.getmtime(tfile.name)
  1362. if time_diff > self.timeout:
  1363. raise CmdTimedOut(['Timeout!'])
  1364. thrd.join(0.5)
  1365. tfile.seek(0)
  1366. result = [line.decode('utf-8', 'replace').rstrip() for line in tfile]
  1367. if self.proc.returncode != 0:
  1368. raise CmdFailed([''] + result)
  1369. return result
  1370. except:
  1371. self.terminate()
  1372. raise
  1373. def terminate(self):
  1374. """ Terminate process and cleanup. """
  1375. if self.alive:
  1376. if G_IS_WIN:
  1377. os.kill(self.proc.pid, signal.SIGINT)
  1378. else:
  1379. os.killpg(self.proc.pid, signal.SIGTERM)
  1380. self.clean()
  1381. class Plugin(object):
  1382. def __init__(self, name, args, buf_q, lock):
  1383. self.name = name
  1384. self.args = args
  1385. self.buf_q = buf_q
  1386. self.lock = lock
  1387. self.tag = args.get('tag', 0)
  1388. def manage(self):
  1389. try:
  1390. if os.path.exists(self.args['dir']):
  1391. self.update()
  1392. else:
  1393. self.install()
  1394. with self.lock:
  1395. thread_vim_command("let s:update.new['{0}'] = 1".format(self.name))
  1396. except PlugError as exc:
  1397. self.write(Action.ERROR, self.name, exc.msg)
  1398. except KeyboardInterrupt:
  1399. G_STOP.set()
  1400. self.write(Action.ERROR, self.name, ['Interrupted!'])
  1401. except:
  1402. # Any exception except those above print stack trace
  1403. msg = 'Trace:\n{0}'.format(traceback.format_exc().rstrip())
  1404. self.write(Action.ERROR, self.name, msg.split('\n'))
  1405. raise
  1406. def install(self):
  1407. target = self.args['dir']
  1408. if target[-1] == '\\':
  1409. target = target[0:-1]
  1410. def clean(target):
  1411. def _clean():
  1412. try:
  1413. shutil.rmtree(target)
  1414. except OSError:
  1415. pass
  1416. return _clean
  1417. self.write(Action.INSTALL, self.name, ['Installing ...'])
  1418. callback = functools.partial(self.write, Action.INSTALL, self.name)
  1419. cmd = 'git clone {0} {1} {2} {3} 2>&1'.format(
  1420. '' if self.tag else G_CLONE_OPT, G_PROGRESS, self.args['uri'],
  1421. esc(target))
  1422. com = Command(cmd, None, G_TIMEOUT, callback, clean(target))
  1423. result = com.execute(G_RETRIES)
  1424. self.write(Action.DONE, self.name, result[-1:])
  1425. def repo_uri(self):
  1426. cmd = 'git rev-parse --abbrev-ref HEAD 2>&1 && git config -f .git/config remote.origin.url'
  1427. command = Command(cmd, self.args['dir'], G_TIMEOUT,)
  1428. result = command.execute(G_RETRIES)
  1429. return result[-1]
  1430. def update(self):
  1431. actual_uri = self.repo_uri()
  1432. expect_uri = self.args['uri']
  1433. regex = re.compile(r'^(?:\w+://)?(?:[^@/]*@)?([^:/]*(?::[0-9]*)?)[:/](.*?)(?:\.git)?/?$')
  1434. ma = regex.match(actual_uri)
  1435. mb = regex.match(expect_uri)
  1436. if ma is None or mb is None or ma.groups() != mb.groups():
  1437. msg = ['',
  1438. 'Invalid URI: {0}'.format(actual_uri),
  1439. 'Expected {0}'.format(expect_uri),
  1440. 'PlugClean required.']
  1441. raise InvalidURI(msg)
  1442. if G_PULL:
  1443. self.write(Action.UPDATE, self.name, ['Updating ...'])
  1444. callback = functools.partial(self.write, Action.UPDATE, self.name)
  1445. fetch_opt = '--depth 99999999' if self.tag and os.path.isfile(os.path.join(self.args['dir'], '.git/shallow')) else ''
  1446. cmd = 'git fetch {0} {1} 2>&1'.format(fetch_opt, G_PROGRESS)
  1447. com = Command(cmd, self.args['dir'], G_TIMEOUT, callback)
  1448. result = com.execute(G_RETRIES)
  1449. self.write(Action.DONE, self.name, result[-1:])
  1450. else:
  1451. self.write(Action.DONE, self.name, ['Already installed'])
  1452. def write(self, action, name, msg):
  1453. self.buf_q.put((action, name, msg))
  1454. class PlugThread(thr.Thread):
  1455. def __init__(self, tname, args):
  1456. super(PlugThread, self).__init__()
  1457. self.tname = tname
  1458. self.args = args
  1459. def run(self):
  1460. thr.current_thread().name = self.tname
  1461. buf_q, work_q, lock = self.args
  1462. try:
  1463. while not G_STOP.is_set():
  1464. name, args = work_q.get_nowait()
  1465. plug = Plugin(name, args, buf_q, lock)
  1466. plug.manage()
  1467. work_q.task_done()
  1468. except queue.Empty:
  1469. pass
  1470. class RefreshThread(thr.Thread):
  1471. def __init__(self, lock):
  1472. super(RefreshThread, self).__init__()
  1473. self.lock = lock
  1474. self.running = True
  1475. def run(self):
  1476. while self.running:
  1477. with self.lock:
  1478. thread_vim_command('noautocmd normal! a')
  1479. time.sleep(0.33)
  1480. def stop(self):
  1481. self.running = False
  1482. if G_NVIM:
  1483. def thread_vim_command(cmd):
  1484. vim.session.threadsafe_call(lambda: vim.command(cmd))
  1485. else:
  1486. def thread_vim_command(cmd):
  1487. vim.command(cmd)
  1488. def esc(name):
  1489. return '"' + name.replace('"', '\"') + '"'
  1490. def nonblock_read(fname):
  1491. """ Read a file with nonblock flag. Return the last line. """
  1492. fread = os.open(fname, os.O_RDONLY | os.O_NONBLOCK)
  1493. buf = os.read(fread, 100000).decode('utf-8', 'replace')
  1494. os.close(fread)
  1495. line = buf.rstrip('\r\n')
  1496. left = max(line.rfind('\r'), line.rfind('\n'))
  1497. if left != -1:
  1498. left += 1
  1499. line = line[left:]
  1500. return line
  1501. def main():
  1502. thr.current_thread().name = 'main'
  1503. nthreads = int(vim.eval('s:update.threads'))
  1504. plugs = vim.eval('s:update.todo')
  1505. mac_gui = vim.eval('s:mac_gui') == '1'
  1506. lock = thr.Lock()
  1507. buf = Buffer(lock, len(plugs), G_PULL)
  1508. buf_q, work_q = queue.Queue(), queue.Queue()
  1509. for work in plugs.items():
  1510. work_q.put(work)
  1511. start_cnt = thr.active_count()
  1512. for num in range(nthreads):
  1513. tname = 'PlugT-{0:02}'.format(num)
  1514. thread = PlugThread(tname, (buf_q, work_q, lock))
  1515. thread.start()
  1516. if mac_gui:
  1517. rthread = RefreshThread(lock)
  1518. rthread.start()
  1519. while not buf_q.empty() or thr.active_count() != start_cnt:
  1520. try:
  1521. action, name, msg = buf_q.get(True, 0.25)
  1522. buf.write(action, name, ['OK'] if not msg else msg)
  1523. buf_q.task_done()
  1524. except queue.Empty:
  1525. pass
  1526. except KeyboardInterrupt:
  1527. G_STOP.set()
  1528. if mac_gui:
  1529. rthread.stop()
  1530. rthread.join()
  1531. main()
  1532. EOF
  1533. endfunction
  1534. function! s:update_ruby()
  1535. ruby << EOF
  1536. module PlugStream
  1537. SEP = ["\r", "\n", nil]
  1538. def get_line
  1539. buffer = ''
  1540. loop do
  1541. char = readchar rescue return
  1542. if SEP.include? char.chr
  1543. buffer << $/
  1544. break
  1545. else
  1546. buffer << char
  1547. end
  1548. end
  1549. buffer
  1550. end
  1551. end unless defined?(PlugStream)
  1552. def esc arg
  1553. %["#{arg.gsub('"', '\"')}"]
  1554. end
  1555. def killall pid
  1556. pids = [pid]
  1557. if /mswin|mingw|bccwin/ =~ RUBY_PLATFORM
  1558. pids.each { |pid| Process.kill 'INT', pid.to_i rescue nil }
  1559. else
  1560. unless `which pgrep 2> /dev/null`.empty?
  1561. children = pids
  1562. until children.empty?
  1563. children = children.map { |pid|
  1564. `pgrep -P #{pid}`.lines.map { |l| l.chomp }
  1565. }.flatten
  1566. pids += children
  1567. end
  1568. end
  1569. pids.each { |pid| Process.kill 'TERM', pid.to_i rescue nil }
  1570. end
  1571. end
  1572. def compare_git_uri a, b
  1573. regex = %r{^(?:\w+://)?(?:[^@/]*@)?([^:/]*(?::[0-9]*)?)[:/](.*?)(?:\.git)?/?$}
  1574. regex.match(a).to_a.drop(1) == regex.match(b).to_a.drop(1)
  1575. end
  1576. require 'thread'
  1577. require 'fileutils'
  1578. require 'timeout'
  1579. running = true
  1580. iswin = VIM::evaluate('s:is_win').to_i == 1
  1581. pull = VIM::evaluate('s:update.pull').to_i == 1
  1582. base = VIM::evaluate('g:plug_home')
  1583. all = VIM::evaluate('s:update.todo')
  1584. limit = VIM::evaluate('get(g:, "plug_timeout", 60)')
  1585. tries = VIM::evaluate('get(g:, "plug_retries", 2)') + 1
  1586. nthr = VIM::evaluate('s:update.threads').to_i
  1587. maxy = VIM::evaluate('winheight(".")').to_i
  1588. vim7 = VIM::evaluate('v:version').to_i <= 703 && RUBY_PLATFORM =~ /darwin/
  1589. cd = iswin ? 'cd /d' : 'cd'
  1590. tot = VIM::evaluate('len(s:update.todo)') || 0
  1591. bar = ''
  1592. skip = 'Already installed'
  1593. mtx = Mutex.new
  1594. take1 = proc { mtx.synchronize { running && all.shift } }
  1595. logh = proc {
  1596. cnt = bar.length
  1597. $curbuf[1] = "#{pull ? 'Updating' : 'Installing'} plugins (#{cnt}/#{tot})"
  1598. $curbuf[2] = '[' + bar.ljust(tot) + ']'
  1599. VIM::command('normal! 2G')
  1600. VIM::command('redraw')
  1601. }
  1602. where = proc { |name| (1..($curbuf.length)).find { |l| $curbuf[l] =~ /^[-+x*] #{name}:/ } }
  1603. log = proc { |name, result, type|
  1604. mtx.synchronize do
  1605. ing = ![true, false].include?(type)
  1606. bar += type ? '=' : 'x' unless ing
  1607. b = case type
  1608. when :install then '+' when :update then '*'
  1609. when true, nil then '-' else
  1610. VIM::command("call add(s:update.errors, '#{name}')")
  1611. 'x'
  1612. end
  1613. result =
  1614. if type || type.nil?
  1615. ["#{b} #{name}: #{result.lines.to_a.last || 'OK'}"]
  1616. elsif result =~ /^Interrupted|^Timeout/
  1617. ["#{b} #{name}: #{result}"]
  1618. else
  1619. ["#{b} #{name}"] + result.lines.map { |l| " " << l }
  1620. end
  1621. if lnum = where.call(name)
  1622. $curbuf.delete lnum
  1623. lnum = 4 if ing && lnum > maxy
  1624. end
  1625. result.each_with_index do |line, offset|
  1626. $curbuf.append((lnum || 4) - 1 + offset, line.gsub(/\e\[./, '').chomp)
  1627. end
  1628. logh.call
  1629. end
  1630. }
  1631. bt = proc { |cmd, name, type, cleanup|
  1632. tried = timeout = 0
  1633. begin
  1634. tried += 1
  1635. timeout += limit
  1636. fd = nil
  1637. data = ''
  1638. if iswin
  1639. Timeout::timeout(timeout) do
  1640. tmp = VIM::evaluate('tempname()')
  1641. system("(#{cmd}) > #{tmp}")
  1642. data = File.read(tmp).chomp
  1643. File.unlink tmp rescue nil
  1644. end
  1645. else
  1646. fd = IO.popen(cmd).extend(PlugStream)
  1647. first_line = true
  1648. log_prob = 1.0 / nthr
  1649. while line = Timeout::timeout(timeout) { fd.get_line }
  1650. data << line
  1651. log.call name, line.chomp, type if name && (first_line || rand < log_prob)
  1652. first_line = false
  1653. end
  1654. fd.close
  1655. end
  1656. [$? == 0, data.chomp]
  1657. rescue Timeout::Error, Interrupt => e
  1658. if fd && !fd.closed?
  1659. killall fd.pid
  1660. fd.close
  1661. end
  1662. cleanup.call if cleanup
  1663. if e.is_a?(Timeout::Error) && tried < tries
  1664. 3.downto(1) do |countdown|
  1665. s = countdown > 1 ? 's' : ''
  1666. log.call name, "Timeout. Will retry in #{countdown} second#{s} ...", type
  1667. sleep 1
  1668. end
  1669. log.call name, 'Retrying ...', type
  1670. retry
  1671. end
  1672. [false, e.is_a?(Interrupt) ? "Interrupted!" : "Timeout!"]
  1673. end
  1674. }
  1675. main = Thread.current
  1676. threads = []
  1677. watcher = Thread.new {
  1678. if vim7
  1679. while VIM::evaluate('getchar(1)')
  1680. sleep 0.1
  1681. end
  1682. else
  1683. require 'io/console' # >= Ruby 1.9
  1684. nil until IO.console.getch == 3.chr
  1685. end
  1686. mtx.synchronize do
  1687. running = false
  1688. threads.each { |t| t.raise Interrupt } unless vim7
  1689. end
  1690. threads.each { |t| t.join rescue nil }
  1691. main.kill
  1692. }
  1693. refresh = Thread.new {
  1694. while true
  1695. mtx.synchronize do
  1696. break unless running
  1697. VIM::command('noautocmd normal! a')
  1698. end
  1699. sleep 0.2
  1700. end
  1701. } if VIM::evaluate('s:mac_gui') == 1
  1702. clone_opt = VIM::evaluate('s:clone_opt')
  1703. progress = VIM::evaluate('s:progress_opt(1)')
  1704. nthr.times do
  1705. mtx.synchronize do
  1706. threads << Thread.new {
  1707. while pair = take1.call
  1708. name = pair.first
  1709. dir, uri, tag = pair.last.values_at *%w[dir uri tag]
  1710. exists = File.directory? dir
  1711. ok, result =
  1712. if exists
  1713. chdir = "#{cd} #{iswin ? dir : esc(dir)}"
  1714. ret, data = bt.call "#{chdir} && git rev-parse --abbrev-ref HEAD 2>&1 && git config -f .git/config remote.origin.url", nil, nil, nil
  1715. current_uri = data.lines.to_a.last
  1716. if !ret
  1717. if data =~ /^Interrupted|^Timeout/
  1718. [false, data]
  1719. else
  1720. [false, [data.chomp, "PlugClean required."].join($/)]
  1721. end
  1722. elsif !compare_git_uri(current_uri, uri)
  1723. [false, ["Invalid URI: #{current_uri}",
  1724. "Expected: #{uri}",
  1725. "PlugClean required."].join($/)]
  1726. else
  1727. if pull
  1728. log.call name, 'Updating ...', :update
  1729. fetch_opt = (tag && File.exist?(File.join(dir, '.git/shallow'))) ? '--depth 99999999' : ''
  1730. bt.call "#{chdir} && git fetch #{fetch_opt} #{progress} 2>&1", name, :update, nil
  1731. else
  1732. [true, skip]
  1733. end
  1734. end
  1735. else
  1736. d = esc dir.sub(%r{[\\/]+$}, '')
  1737. log.call name, 'Installing ...', :install
  1738. bt.call "git clone #{clone_opt unless tag} #{progress} #{uri} #{d} 2>&1", name, :install, proc {
  1739. FileUtils.rm_rf dir
  1740. }
  1741. end
  1742. mtx.synchronize { VIM::command("let s:update.new['#{name}'] = 1") } if !exists && ok
  1743. log.call name, result, ok
  1744. end
  1745. } if running
  1746. end
  1747. end
  1748. threads.each { |t| t.join rescue nil }
  1749. logh.call
  1750. refresh.kill if refresh
  1751. watcher.kill
  1752. EOF
  1753. endfunction
  1754. function! s:shellesc(arg)
  1755. return '"'.escape(a:arg, '"').'"'
  1756. endfunction
  1757. function! s:glob_dir(path)
  1758. return map(filter(s:glob(a:path, '**'), 'isdirectory(v:val)'), 's:dirpath(v:val)')
  1759. endfunction
  1760. function! s:progress_bar(line, bar, total)
  1761. call setline(a:line, '[' . s:lpad(a:bar, a:total) . ']')
  1762. endfunction
  1763. function! s:compare_git_uri(a, b)
  1764. " See `git help clone'
  1765. " https:// [user@] github.com[:port] / junegunn/vim-plug [.git]
  1766. " [git@] github.com[:port] : junegunn/vim-plug [.git]
  1767. " file:// / junegunn/vim-plug [/]
  1768. " / junegunn/vim-plug [/]
  1769. let pat = '^\%(\w\+://\)\='.'\%([^@/]*@\)\='.'\([^:/]*\%(:[0-9]*\)\=\)'.'[:/]'.'\(.\{-}\)'.'\%(\.git\)\=/\?$'
  1770. let ma = matchlist(a:a, pat)
  1771. let mb = matchlist(a:b, pat)
  1772. return ma[1:2] ==# mb[1:2]
  1773. endfunction
  1774. function! s:format_message(bullet, name, message)
  1775. if a:bullet != 'x'
  1776. return [printf('%s %s: %s', a:bullet, a:name, s:lastline(a:message))]
  1777. else
  1778. let lines = map(s:lines(a:message), '" ".v:val')
  1779. return extend([printf('x %s:', a:name)], lines)
  1780. endif
  1781. endfunction
  1782. function! s:with_cd(cmd, dir)
  1783. return printf('cd%s %s && %s', s:is_win ? ' /d' : '', s:shellesc(a:dir), a:cmd)
  1784. endfunction
  1785. function! s:system(cmd, ...)
  1786. try
  1787. let [sh, shrd] = s:chsh(1)
  1788. let cmd = a:0 > 0 ? s:with_cd(a:cmd, a:1) : a:cmd
  1789. return system(s:is_win ? '('.cmd.')' : cmd)
  1790. finally
  1791. let [&shell, &shellredir] = [sh, shrd]
  1792. endtry
  1793. endfunction
  1794. function! s:system_chomp(...)
  1795. let ret = call('s:system', a:000)
  1796. return v:shell_error ? '' : substitute(ret, '\n$', '', '')
  1797. endfunction
  1798. function! s:git_validate(spec, check_branch)
  1799. let err = ''
  1800. if isdirectory(a:spec.dir)
  1801. let result = s:lines(s:system('git rev-parse --abbrev-ref HEAD 2>&1 && git config -f .git/config remote.origin.url', a:spec.dir))
  1802. let remote = result[-1]
  1803. if v:shell_error
  1804. let err = join([remote, 'PlugClean required.'], "\n")
  1805. elseif !s:compare_git_uri(remote, a:spec.uri)
  1806. let err = join(['Invalid URI: '.remote,
  1807. \ 'Expected: '.a:spec.uri,
  1808. \ 'PlugClean required.'], "\n")
  1809. elseif a:check_branch && has_key(a:spec, 'commit')
  1810. let result = s:lines(s:system('git rev-parse HEAD 2>&1', a:spec.dir))
  1811. let sha = result[-1]
  1812. if v:shell_error
  1813. let err = join(add(result, 'PlugClean required.'), "\n")
  1814. elseif !s:hash_match(sha, a:spec.commit)
  1815. let err = join([printf('Invalid HEAD (expected: %s, actual: %s)',
  1816. \ a:spec.commit[:6], sha[:6]),
  1817. \ 'PlugUpdate required.'], "\n")
  1818. endif
  1819. elseif a:check_branch
  1820. let branch = result[0]
  1821. " Check tag
  1822. if has_key(a:spec, 'tag')
  1823. let tag = s:system_chomp('git describe --exact-match --tags HEAD 2>&1', a:spec.dir)
  1824. if a:spec.tag !=# tag && a:spec.tag !~ '\*'
  1825. let err = printf('Invalid tag: %s (expected: %s). Try PlugUpdate.',
  1826. \ (empty(tag) ? 'N/A' : tag), a:spec.tag)
  1827. endif
  1828. " Check branch
  1829. elseif a:spec.branch !=# branch
  1830. let err = printf('Invalid branch: %s (expected: %s). Try PlugUpdate.',
  1831. \ branch, a:spec.branch)
  1832. endif
  1833. if empty(err)
  1834. let [ahead, behind] = split(s:lastline(s:system(printf(
  1835. \ 'git rev-list --count --left-right HEAD...origin/%s',
  1836. \ a:spec.branch), a:spec.dir)), '\t')
  1837. if !v:shell_error && ahead
  1838. if behind
  1839. " Only mention PlugClean if diverged, otherwise it's likely to be
  1840. " pushable (and probably not that messed up).
  1841. let err = printf(
  1842. \ "Diverged from origin/%s (%d commit(s) ahead and %d commit(s) behind!\n"
  1843. \ .'Backup local changes and run PlugClean and PlugUpdate to reinstall it.', a:spec.branch, ahead, behind)
  1844. else
  1845. let err = printf("Ahead of origin/%s by %d commit(s).\n"
  1846. \ .'Cannot update until local changes are pushed.',
  1847. \ a:spec.branch, ahead)
  1848. endif
  1849. endif
  1850. endif
  1851. endif
  1852. else
  1853. let err = 'Not found'
  1854. endif
  1855. return [err, err =~# 'PlugClean']
  1856. endfunction
  1857. function! s:rm_rf(dir)
  1858. if isdirectory(a:dir)
  1859. call s:system((s:is_win ? 'rmdir /S /Q ' : 'rm -rf ') . s:shellesc(a:dir))
  1860. endif
  1861. endfunction
  1862. function! s:clean(force)
  1863. call s:prepare()
  1864. call append(0, 'Searching for invalid plugins in '.g:plug_home)
  1865. call append(1, '')
  1866. " List of valid directories
  1867. let dirs = []
  1868. let errs = {}
  1869. let [cnt, total] = [0, len(g:plugs)]
  1870. for [name, spec] in items(g:plugs)
  1871. if !s:is_managed(name)
  1872. call add(dirs, spec.dir)
  1873. else
  1874. let [err, clean] = s:git_validate(spec, 1)
  1875. if clean
  1876. let errs[spec.dir] = s:lines(err)[0]
  1877. else
  1878. call add(dirs, spec.dir)
  1879. endif
  1880. endif
  1881. let cnt += 1
  1882. call s:progress_bar(2, repeat('=', cnt), total)
  1883. normal! 2G
  1884. redraw
  1885. endfor
  1886. let allowed = {}
  1887. for dir in dirs
  1888. let allowed[s:dirpath(fnamemodify(dir, ':h:h'))] = 1
  1889. let allowed[dir] = 1
  1890. for child in s:glob_dir(dir)
  1891. let allowed[child] = 1
  1892. endfor
  1893. endfor
  1894. let todo = []
  1895. let found = sort(s:glob_dir(g:plug_home))
  1896. while !empty(found)
  1897. let f = remove(found, 0)
  1898. if !has_key(allowed, f) && isdirectory(f)
  1899. call add(todo, f)
  1900. call append(line('$'), '- ' . f)
  1901. if has_key(errs, f)
  1902. call append(line('$'), ' ' . errs[f])
  1903. endif
  1904. let found = filter(found, 'stridx(v:val, f) != 0')
  1905. end
  1906. endwhile
  1907. 4
  1908. redraw
  1909. if empty(todo)
  1910. call append(line('$'), 'Already clean.')
  1911. else
  1912. let s:clean_count = 0
  1913. call append(3, ['Directories to delete:', ''])
  1914. redraw!
  1915. if a:force || s:ask_no_interrupt('Delete all directories?')
  1916. call s:delete([6, line('$')], 1)
  1917. else
  1918. call setline(4, 'Cancelled.')
  1919. nnoremap <silent> <buffer> d :set opfunc=<sid>delete_op<cr>g@
  1920. nmap <silent> <buffer> dd d_
  1921. xnoremap <silent> <buffer> d :<c-u>call <sid>delete_op(visualmode(), 1)<cr>
  1922. echo 'Delete the lines (d{motion}) to delete the corresponding directories'
  1923. endif
  1924. endif
  1925. 4
  1926. setlocal nomodifiable
  1927. endfunction
  1928. function! s:delete_op(type, ...)
  1929. call s:delete(a:0 ? [line("'<"), line("'>")] : [line("'["), line("']")], 0)
  1930. endfunction
  1931. function! s:delete(range, force)
  1932. let [l1, l2] = a:range
  1933. let force = a:force
  1934. while l1 <= l2
  1935. let line = getline(l1)
  1936. if line =~ '^- ' && isdirectory(line[2:])
  1937. execute l1
  1938. redraw!
  1939. let answer = force ? 1 : s:ask('Delete '.line[2:].'?', 1)
  1940. let force = force || answer > 1
  1941. if answer
  1942. call s:rm_rf(line[2:])
  1943. setlocal modifiable
  1944. call setline(l1, '~'.line[1:])
  1945. let s:clean_count += 1
  1946. call setline(4, printf('Removed %d directories.', s:clean_count))
  1947. setlocal nomodifiable
  1948. endif
  1949. endif
  1950. let l1 += 1
  1951. endwhile
  1952. endfunction
  1953. function! s:upgrade()
  1954. echo 'Downloading the latest version of vim-plug'
  1955. redraw
  1956. let tmp = tempname()
  1957. let new = tmp . '/plug.vim'
  1958. try
  1959. let out = s:system(printf('git clone --depth 1 %s %s', s:plug_src, tmp))
  1960. if v:shell_error
  1961. return s:err('Error upgrading vim-plug: '. out)
  1962. endif
  1963. if readfile(s:me) ==# readfile(new)
  1964. echo 'vim-plug is already up-to-date'
  1965. return 0
  1966. else
  1967. call rename(s:me, s:me . '.old')
  1968. call rename(new, s:me)
  1969. unlet g:loaded_plug
  1970. echo 'vim-plug has been upgraded'
  1971. return 1
  1972. endif
  1973. finally
  1974. silent! call s:rm_rf(tmp)
  1975. endtry
  1976. endfunction
  1977. function! s:upgrade_specs()
  1978. for spec in values(g:plugs)
  1979. let spec.frozen = get(spec, 'frozen', 0)
  1980. endfor
  1981. endfunction
  1982. function! s:status()
  1983. call s:prepare()
  1984. call append(0, 'Checking plugins')
  1985. call append(1, '')
  1986. let ecnt = 0
  1987. let unloaded = 0
  1988. let [cnt, total] = [0, len(g:plugs)]
  1989. for [name, spec] in items(g:plugs)
  1990. if has_key(spec, 'uri')
  1991. if isdirectory(spec.dir)
  1992. let [err, _] = s:git_validate(spec, 1)
  1993. let [valid, msg] = [empty(err), empty(err) ? 'OK' : err]
  1994. else
  1995. let [valid, msg] = [0, 'Not found. Try PlugInstall.']
  1996. endif
  1997. else
  1998. if isdirectory(spec.dir)
  1999. let [valid, msg] = [1, 'OK']
  2000. else
  2001. let [valid, msg] = [0, 'Not found.']
  2002. endif
  2003. endif
  2004. let cnt += 1
  2005. let ecnt += !valid
  2006. " `s:loaded` entry can be missing if PlugUpgraded
  2007. if valid && get(s:loaded, name, -1) == 0
  2008. let unloaded = 1
  2009. let msg .= ' (not loaded)'
  2010. endif
  2011. call s:progress_bar(2, repeat('=', cnt), total)
  2012. call append(3, s:format_message(valid ? '-' : 'x', name, msg))
  2013. normal! 2G
  2014. redraw
  2015. endfor
  2016. call setline(1, 'Finished. '.ecnt.' error(s).')
  2017. normal! gg
  2018. setlocal nomodifiable
  2019. if unloaded
  2020. echo "Press 'L' on each line to load plugin, or 'U' to update"
  2021. nnoremap <silent> <buffer> L :call <SID>status_load(line('.'))<cr>
  2022. xnoremap <silent> <buffer> L :call <SID>status_load(line('.'))<cr>
  2023. end
  2024. endfunction
  2025. function! s:extract_name(str, prefix, suffix)
  2026. return matchstr(a:str, '^'.a:prefix.' \zs[^:]\+\ze:.*'.a:suffix.'$')
  2027. endfunction
  2028. function! s:status_load(lnum)
  2029. let line = getline(a:lnum)
  2030. let name = s:extract_name(line, '-', '(not loaded)')
  2031. if !empty(name)
  2032. call plug#load(name)
  2033. setlocal modifiable
  2034. call setline(a:lnum, substitute(line, ' (not loaded)$', '', ''))
  2035. setlocal nomodifiable
  2036. endif
  2037. endfunction
  2038. function! s:status_update() range
  2039. let lines = getline(a:firstline, a:lastline)
  2040. let names = filter(map(lines, 's:extract_name(v:val, "[x-]", "")'), '!empty(v:val)')
  2041. if !empty(names)
  2042. echo
  2043. execute 'PlugUpdate' join(names)
  2044. endif
  2045. endfunction
  2046. function! s:is_preview_window_open()
  2047. silent! wincmd P
  2048. if &previewwindow
  2049. wincmd p
  2050. return 1
  2051. endif
  2052. endfunction
  2053. function! s:find_name(lnum)
  2054. for lnum in reverse(range(1, a:lnum))
  2055. let line = getline(lnum)
  2056. if empty(line)
  2057. return ''
  2058. endif
  2059. let name = s:extract_name(line, '-', '')
  2060. if !empty(name)
  2061. return name
  2062. endif
  2063. endfor
  2064. return ''
  2065. endfunction
  2066. function! s:preview_commit()
  2067. if b:plug_preview < 0
  2068. let b:plug_preview = !s:is_preview_window_open()
  2069. endif
  2070. let sha = matchstr(getline('.'), '^ \X*\zs[0-9a-f]\{7,9}')
  2071. if empty(sha)
  2072. return
  2073. endif
  2074. let name = s:find_name(line('.'))
  2075. if empty(name) || !has_key(g:plugs, name) || !isdirectory(g:plugs[name].dir)
  2076. return
  2077. endif
  2078. if exists('g:plug_pwindow') && !s:is_preview_window_open()
  2079. execute g:plug_pwindow
  2080. execute 'e' sha
  2081. else
  2082. execute 'pedit' sha
  2083. wincmd P
  2084. endif
  2085. setlocal previewwindow filetype=git buftype=nofile nobuflisted modifiable
  2086. try
  2087. let [sh, shrd] = s:chsh(1)
  2088. execute 'silent %!cd' s:shellesc(g:plugs[name].dir) '&& git show --no-color --pretty=medium' sha
  2089. finally
  2090. let [&shell, &shellredir] = [sh, shrd]
  2091. endtry
  2092. setlocal nomodifiable
  2093. nnoremap <silent> <buffer> q :q<cr>
  2094. wincmd p
  2095. endfunction
  2096. function! s:section(flags)
  2097. call search('\(^[x-] \)\@<=[^:]\+:', a:flags)
  2098. endfunction
  2099. function! s:format_git_log(line)
  2100. let indent = ' '
  2101. let tokens = split(a:line, nr2char(1))
  2102. if len(tokens) != 5
  2103. return indent.substitute(a:line, '\s*$', '', '')
  2104. endif
  2105. let [graph, sha, refs, subject, date] = tokens
  2106. let tag = matchstr(refs, 'tag: [^,)]\+')
  2107. let tag = empty(tag) ? ' ' : ' ('.tag.') '
  2108. return printf('%s%s%s%s%s (%s)', indent, graph, sha, tag, subject, date)
  2109. endfunction
  2110. function! s:append_ul(lnum, text)
  2111. call append(a:lnum, ['', a:text, repeat('-', len(a:text))])
  2112. endfunction
  2113. function! s:diff()
  2114. call s:prepare()
  2115. call append(0, ['Collecting changes ...', ''])
  2116. let cnts = [0, 0]
  2117. let bar = ''
  2118. let total = filter(copy(g:plugs), 's:is_managed(v:key) && isdirectory(v:val.dir)')
  2119. call s:progress_bar(2, bar, len(total))
  2120. for origin in [1, 0]
  2121. let plugs = reverse(sort(items(filter(copy(total), (origin ? '' : '!').'(has_key(v:val, "commit") || has_key(v:val, "tag"))'))))
  2122. if empty(plugs)
  2123. continue
  2124. endif
  2125. call s:append_ul(2, origin ? 'Pending updates:' : 'Last update:')
  2126. for [k, v] in plugs
  2127. let range = origin ? '..origin/'.v.branch : 'HEAD@{1}..'
  2128. let diff = s:system_chomp('git log --graph --color=never --pretty=format:"%x01%h%x01%d%x01%s%x01%cr" '.s:shellesc(range), v.dir)
  2129. if !empty(diff)
  2130. let ref = has_key(v, 'tag') ? (' (tag: '.v.tag.')') : has_key(v, 'commit') ? (' '.v.commit) : ''
  2131. call append(5, extend(['', '- '.k.':'.ref], map(s:lines(diff), 's:format_git_log(v:val)')))
  2132. let cnts[origin] += 1
  2133. endif
  2134. let bar .= '='
  2135. call s:progress_bar(2, bar, len(total))
  2136. normal! 2G
  2137. redraw
  2138. endfor
  2139. if !cnts[origin]
  2140. call append(5, ['', 'N/A'])
  2141. endif
  2142. endfor
  2143. call setline(1, printf('%d plugin(s) updated.', cnts[0])
  2144. \ . (cnts[1] ? printf(' %d plugin(s) have pending updates.', cnts[1]) : ''))
  2145. if cnts[0] || cnts[1]
  2146. nnoremap <silent> <buffer> <cr> :silent! call <SID>preview_commit()<cr>
  2147. nnoremap <silent> <buffer> o :silent! call <SID>preview_commit()<cr>
  2148. endif
  2149. if cnts[0]
  2150. nnoremap <silent> <buffer> X :call <SID>revert()<cr>
  2151. echo "Press 'X' on each block to revert the update"
  2152. endif
  2153. normal! gg
  2154. setlocal nomodifiable
  2155. endfunction
  2156. function! s:revert()
  2157. if search('^Pending updates', 'bnW')
  2158. return
  2159. endif
  2160. let name = s:find_name(line('.'))
  2161. if empty(name) || !has_key(g:plugs, name) ||
  2162. \ input(printf('Revert the update of %s? (y/N) ', name)) !~? '^y'
  2163. return
  2164. endif
  2165. call s:system('git reset --hard HEAD@{1} && git checkout '.s:esc(g:plugs[name].branch).' --', g:plugs[name].dir)
  2166. setlocal modifiable
  2167. normal! "_dap
  2168. setlocal nomodifiable
  2169. echo 'Reverted'
  2170. endfunction
  2171. function! s:snapshot(force, ...) abort
  2172. call s:prepare()
  2173. setf vim
  2174. call append(0, ['" Generated by vim-plug',
  2175. \ '" '.strftime("%c"),
  2176. \ '" :source this file in vim to restore the snapshot',
  2177. \ '" or execute: vim -S snapshot.vim',
  2178. \ '', '', 'PlugUpdate!'])
  2179. 1
  2180. let anchor = line('$') - 3
  2181. let names = sort(keys(filter(copy(g:plugs),
  2182. \'has_key(v:val, "uri") && !has_key(v:val, "commit") && isdirectory(v:val.dir)')))
  2183. for name in reverse(names)
  2184. let sha = s:system_chomp('git rev-parse --short HEAD', g:plugs[name].dir)
  2185. if !empty(sha)
  2186. call append(anchor, printf("silent! let g:plugs['%s'].commit = '%s'", name, sha))
  2187. redraw
  2188. endif
  2189. endfor
  2190. if a:0 > 0
  2191. let fn = expand(a:1)
  2192. if filereadable(fn) && !(a:force || s:ask(a:1.' already exists. Overwrite?'))
  2193. return
  2194. endif
  2195. call writefile(getline(1, '$'), fn)
  2196. echo 'Saved as '.a:1
  2197. silent execute 'e' s:esc(fn)
  2198. setf vim
  2199. endif
  2200. endfunction
  2201. function! s:split_rtp()
  2202. return split(&rtp, '\\\@<!,')
  2203. endfunction
  2204. let s:first_rtp = s:escrtp(get(s:split_rtp(), 0, ''))
  2205. let s:last_rtp = s:escrtp(get(s:split_rtp(), -1, ''))
  2206. if exists('g:plugs')
  2207. let g:plugs_order = get(g:, 'plugs_order', keys(g:plugs))
  2208. call s:upgrade_specs()
  2209. call s:define_commands()
  2210. endif
  2211. let &cpo = s:cpo_save
  2212. unlet s:cpo_save