mirror of https://github.com/folke/lazy.nvim.git
98 lines
2.5 KiB
Lua
98 lines
2.5 KiB
Lua
local Config = require("lazy.core.config")
|
|
local Git = require("lazy.manage.git")
|
|
local Manage = require("lazy.manage")
|
|
local Plugin = require("lazy.core.plugin")
|
|
local State = require("lazy.state")
|
|
local Util = require("lazy.util")
|
|
|
|
local M = {}
|
|
|
|
M.running = false
|
|
M.updated = {}
|
|
M.reported = {}
|
|
|
|
function M.start()
|
|
M.fast_check()
|
|
if M.schedule() > 0 and not M.has_errors() then
|
|
Manage.log({
|
|
clear = false,
|
|
show = false,
|
|
check = true,
|
|
concurrency = Config.options.checker.concurrency,
|
|
})
|
|
end
|
|
end
|
|
|
|
function M.schedule()
|
|
State.read() -- update state
|
|
local next_check = State.checker.last_check + Config.options.checker.frequency - os.time()
|
|
next_check = math.max(next_check, 0)
|
|
vim.defer_fn(M.check, next_check * 1000)
|
|
return next_check
|
|
end
|
|
|
|
---@param opts? {report:boolean} report defaults to true
|
|
function M.fast_check(opts)
|
|
opts = opts or {}
|
|
for _, plugin in pairs(Config.plugins) do
|
|
-- don't check local plugins here, since we mark them as needing updates
|
|
-- only if local is behind upstream (if the git log task gives no output)
|
|
if plugin._.installed and not (plugin.pin or plugin._.is_local) then
|
|
plugin._.updates = nil
|
|
local info = Git.info(plugin.dir)
|
|
local ok, target = pcall(Git.get_target, plugin)
|
|
if ok and info and target and not Git.eq(info, target) then
|
|
plugin._.updates = { from = info, to = target }
|
|
end
|
|
end
|
|
end
|
|
M.report(opts.report ~= false)
|
|
end
|
|
|
|
function M.has_errors()
|
|
for _, plugin in pairs(Config.plugins) do
|
|
if Plugin.has_errors(plugin) then
|
|
return true
|
|
end
|
|
end
|
|
return false
|
|
end
|
|
|
|
function M.check()
|
|
State.checker.last_check = os.time()
|
|
State.write() -- update state
|
|
if M.has_errors() then
|
|
M.schedule()
|
|
else
|
|
Manage.check({
|
|
clear = false,
|
|
show = false,
|
|
concurrency = Config.options.checker.concurrency,
|
|
}):wait(function()
|
|
M.report()
|
|
M.schedule()
|
|
end)
|
|
end
|
|
end
|
|
|
|
---@param notify? boolean
|
|
function M.report(notify)
|
|
local lines = {}
|
|
M.updated = {}
|
|
for _, plugin in pairs(Config.plugins) do
|
|
if plugin._.updates then
|
|
table.insert(M.updated, plugin.name)
|
|
if not vim.tbl_contains(M.reported, plugin.name) then
|
|
table.insert(lines, "- **" .. plugin.name .. "**")
|
|
table.insert(M.reported, plugin.name)
|
|
end
|
|
end
|
|
end
|
|
if #lines > 0 and notify and Config.options.checker.notify and not Config.headless() then
|
|
table.insert(lines, 1, "# Plugin Updates")
|
|
Util.info(lines)
|
|
end
|
|
end
|
|
|
|
return M
|