371 lines
10 KiB
Lua
371 lines
10 KiB
Lua
local log = require("log")
|
|
|
|
local Util = {}
|
|
|
|
Util.os_name = vim.uv.os_uname().sysname
|
|
|
|
---@alias OutputStream "stdout" | "stderr" | "in_place"
|
|
|
|
---@class ow.FormatOptions
|
|
---@field buf? integer Buffer to apply formatting to
|
|
---@field cmd string[] Command to run. The following keywords get replaces by the specified values:
|
|
--- * %file% - path to the file for `buf`
|
|
--- * %filename% - name of the file for `buf`
|
|
--- * %row_start% - first row of selection
|
|
--- * %row_end% - last row of selection
|
|
--- * %col_start% - first column position of selection
|
|
--- * %col_end% - last column position of selection
|
|
--- * %byte_start% - byte count of first cell in selection
|
|
--- * %byte_end% - byte count of last cell in selection
|
|
---@field output? OutputStream What stream to use as the result. May be one of `stdout`, `stderr` or `in_place`.
|
|
---@field auto_indent? boolean Perform auto indent on formatted range
|
|
---@field only_selection? boolean Only send the selected lines to `stdin`
|
|
---@field ignore_ret? boolean Ignore non-zero return codes
|
|
---@field ignore_stderr? boolean Ignore stderr output when not using stderr for output
|
|
---@field env? table<string, string> Map of environment variables
|
|
|
|
--- Format buffer
|
|
---@param opts ow.FormatOptions
|
|
function Util.format(opts)
|
|
opts = {
|
|
buf = opts.buf or vim.api.nvim_get_current_buf(),
|
|
cmd = opts.cmd,
|
|
output = opts.output or "stdout",
|
|
auto_indent = opts.auto_indent,
|
|
only_selection = opts.only_selection,
|
|
ignore_ret = opts.ignore_ret,
|
|
ignore_stderr = opts.ignore_stderr,
|
|
env = opts.env,
|
|
}
|
|
|
|
local file = vim.api.nvim_buf_get_name(opts.buf)
|
|
local filename = vim.fn.fnamemodify(file, ":t")
|
|
|
|
local mode = vim.fn.mode()
|
|
local is_visual = mode == "v" or mode == "V" or mode == ""
|
|
|
|
-- All 1-indexed, inclusive
|
|
local row_start, row_end
|
|
local col_start, col_end
|
|
if is_visual then
|
|
row_start, col_start = unpack(vim.fn.getpos("v"), 2, 3)
|
|
row_end, col_end = unpack(vim.fn.getpos("."), 2, 3)
|
|
|
|
if
|
|
row_start > row_end
|
|
or (row_start == row_end and col_start > col_end)
|
|
then
|
|
row_start, row_end, col_start, col_end =
|
|
row_end, row_start, col_end, col_start
|
|
end
|
|
|
|
if mode == "V" then
|
|
col_start = 1
|
|
col_end = #vim.api.nvim_buf_get_lines(
|
|
opts.buf,
|
|
row_end - 1,
|
|
row_end,
|
|
false
|
|
)[1]
|
|
end
|
|
else
|
|
row_start = 1
|
|
col_start = 1
|
|
row_end = vim.api.nvim_buf_line_count(opts.buf)
|
|
col_end = #vim.api.nvim_buf_get_lines(
|
|
opts.buf,
|
|
row_end - 1,
|
|
row_end,
|
|
false
|
|
)[1]
|
|
end
|
|
|
|
local function get_byte_offset(buf, row, col)
|
|
local lines = vim.api.nvim_buf_get_text(buf, 0, 0, row - 1, col - 1, {})
|
|
return #table.concat(lines, "\n")
|
|
end
|
|
|
|
local byte_start = get_byte_offset(opts.buf, row_start, col_start)
|
|
local byte_end = get_byte_offset(opts.buf, row_end, col_end) + 1
|
|
|
|
local input
|
|
if is_visual and opts.only_selection then
|
|
input = vim.api.nvim_buf_get_text(
|
|
opts.buf,
|
|
row_start - 1,
|
|
col_start - 1,
|
|
row_end - 1,
|
|
col_end,
|
|
{}
|
|
)
|
|
else
|
|
input = vim.api.nvim_buf_get_lines(opts.buf, 0, -1, false)
|
|
end
|
|
|
|
local tmp
|
|
if opts.output == "in_place" then
|
|
tmp = os.tmpname()
|
|
vim.fn.writefile(input, tmp, "s")
|
|
file = tmp
|
|
end
|
|
|
|
for i, arg in ipairs(opts.cmd) do
|
|
arg = arg:gsub("%%file%%", file)
|
|
arg = arg:gsub("%%filename%%", filename)
|
|
if is_visual then
|
|
arg = arg:gsub("%%row_start%%", row_start)
|
|
arg = arg:gsub("%%row_end%%", row_end)
|
|
arg = arg:gsub("%%col_start%%", col_start)
|
|
arg = arg:gsub("%%col_end%%", col_end)
|
|
arg = arg:gsub("%%byte_start%%", byte_start)
|
|
arg = arg:gsub("%%byte_end%%", byte_end)
|
|
end
|
|
opts.cmd[i] = arg
|
|
end
|
|
|
|
local resp = vim.system(opts.cmd, {
|
|
stdin = input,
|
|
env = opts.env,
|
|
}):wait()
|
|
local stdout = resp.stdout or ""
|
|
local stderr = resp.stderr or ""
|
|
|
|
local tmp_out
|
|
if tmp then
|
|
local f = io.open(tmp, "r")
|
|
if not f then
|
|
return
|
|
end
|
|
tmp_out = f:read("*a")
|
|
f:close()
|
|
os.remove(tmp)
|
|
end
|
|
|
|
if
|
|
(not opts.ignore_ret and resp.code ~= 0)
|
|
or (opts.output ~= "stderr" and not opts.ignore_stderr and stderr ~= "")
|
|
then
|
|
local msg = ""
|
|
if stderr ~= "" then
|
|
msg = ":\n" .. stderr
|
|
end
|
|
|
|
log.error("Failed to format (%d)%s", resp.code, msg)
|
|
return
|
|
end
|
|
|
|
local output = ""
|
|
if opts.output == "stdout" then
|
|
output = stdout
|
|
elseif opts.output == "stderr" then
|
|
output = stderr
|
|
elseif opts.output == "in_place" then
|
|
output = tmp_out or ""
|
|
end
|
|
output = output:gsub("%s+$", "")
|
|
|
|
local old_lines = input
|
|
local new_lines =
|
|
vim.split(output:gsub("\r\n", "\n"), "\n", { plain = true })
|
|
|
|
local diff = vim.text.diff(
|
|
table.concat(old_lines, "\n"),
|
|
table.concat(new_lines, "\n"),
|
|
{ result_type = "indices", algorithm = "histogram" }
|
|
)
|
|
|
|
if not diff or #diff == 0 then
|
|
return
|
|
end
|
|
|
|
---@type lsp.TextEdit[]
|
|
local text_edits = {}
|
|
|
|
---@diagnostic disable-next-line: param-type-mismatch
|
|
for _, hunk in ipairs(diff) do
|
|
local old_start, old_count, new_start, new_count = unpack(hunk)
|
|
|
|
local lines = {}
|
|
for j = new_start, new_start + new_count - 1 do
|
|
table.insert(lines, new_lines[j])
|
|
end
|
|
|
|
local new_text = table.concat(lines, "\n") .. "\n"
|
|
if new_count == 0 then
|
|
new_text = ""
|
|
end
|
|
|
|
local start_line = row_start - 1 + old_start - 1
|
|
local end_line = row_start - 1 + old_start - 1 + old_count
|
|
if old_count == 0 then
|
|
-- Insertion: old_start means "after line N" (where N is 1-indexed),
|
|
-- which equals the 0-indexed position old_start
|
|
start_line = start_line + 1
|
|
end_line = end_line + 1
|
|
end
|
|
|
|
table.insert(text_edits, {
|
|
range = {
|
|
start = {
|
|
line = start_line,
|
|
character = 0,
|
|
},
|
|
["end"] = {
|
|
line = end_line,
|
|
character = 0,
|
|
},
|
|
},
|
|
newText = new_text,
|
|
})
|
|
end
|
|
|
|
local view = vim.fn.winsaveview()
|
|
|
|
vim.lsp.util.apply_text_edits(text_edits, opts.buf, "utf-16")
|
|
|
|
if opts.auto_indent then
|
|
vim.api.nvim_cmd({
|
|
cmd = "normal",
|
|
args = { "==" },
|
|
bang = true,
|
|
range = {
|
|
row_start,
|
|
math.min(row_end, vim.api.nvim_buf_line_count(opts.buf)),
|
|
},
|
|
}, { output = false })
|
|
end
|
|
|
|
vim.fn.winrestview(view)
|
|
end
|
|
|
|
--- Check if `val` is a list of type `t` (if given)
|
|
---@param val any
|
|
---@param kt type
|
|
---@param vt type
|
|
---@return boolean
|
|
function Util.is_map(val, kt, vt)
|
|
if type(val) ~= "table" then
|
|
return false
|
|
end
|
|
|
|
for k, v in pairs(val) do
|
|
if type(k) ~= kt then
|
|
return false
|
|
end
|
|
|
|
if type(v) ~= vt then
|
|
return false
|
|
end
|
|
end
|
|
|
|
return true
|
|
end
|
|
|
|
--- Check if `val` is a list of type `t` (if given)
|
|
---@param val any
|
|
---@param t? type
|
|
---@return boolean
|
|
function Util.is_list(val, t)
|
|
if not vim.islist(val) then
|
|
return false
|
|
end
|
|
|
|
for k, v in pairs(val) do
|
|
if type(k) ~= "number" then
|
|
return false
|
|
end
|
|
|
|
if t and type(v) ~= t then
|
|
return false
|
|
end
|
|
end
|
|
|
|
return true
|
|
end
|
|
|
|
--- Check if `val` is a list of type `t` (if given), or nil
|
|
---@param val? any
|
|
---@param t? type
|
|
---@return boolean
|
|
function Util.is_list_or_nil(val, t)
|
|
if val == nil then
|
|
return true
|
|
else
|
|
return Util.is_list(val, t)
|
|
end
|
|
end
|
|
|
|
local NIL_KEY = {}
|
|
|
|
---@class ow.Util.Debouncer
|
|
---@field private _fn fun(id: any, ...)
|
|
---@field private _delay integer
|
|
---@field private _timers table<any, uv.uv_timer_t>
|
|
local Debouncer = {}
|
|
Debouncer.__index = Debouncer
|
|
|
|
---@param fn fun(id: any, ...)
|
|
---@param delay integer
|
|
---@return ow.Util.Debouncer
|
|
function Debouncer.new(fn, delay)
|
|
return setmetatable({ _fn = fn, _delay = delay, _timers = {} }, Debouncer)
|
|
end
|
|
|
|
---@param id? any
|
|
---@param ... any
|
|
function Debouncer:call(id, ...)
|
|
local key = id == nil and NIL_KEY or id
|
|
local args = vim.F.pack_len(...)
|
|
self:cancel(id)
|
|
self._timers[key] = vim.defer_fn(function()
|
|
self._timers[key] = nil
|
|
self._fn(id, vim.F.unpack_len(args))
|
|
end, self._delay)
|
|
end
|
|
|
|
---@param timer uv.uv_timer_t
|
|
local function dispose(timer)
|
|
timer:stop()
|
|
timer:close()
|
|
end
|
|
|
|
---@param id? any
|
|
function Debouncer:cancel(id)
|
|
local key = id == nil and NIL_KEY or id
|
|
local timer = self._timers[key]
|
|
if timer then
|
|
dispose(timer)
|
|
self._timers[key] = nil
|
|
end
|
|
end
|
|
|
|
function Debouncer:cancel_all()
|
|
for _, t in pairs(self._timers) do
|
|
dispose(t)
|
|
end
|
|
self._timers = {}
|
|
end
|
|
|
|
Util.Debouncer = Debouncer
|
|
|
|
--- Creates a debounced function that delays execution of `fn` until after `delay` milliseconds have
|
|
--- elapsed since the last time it was invoked. Use `d:call(id, ...)` to debounce per-id, or
|
|
--- `d:call(...)` for a single shared slot.
|
|
---@param fn fun(id: any, ...) Function to be debounced
|
|
---@param delay integer Debounce delay in milliseconds
|
|
---@return ow.Util.Debouncer
|
|
function Util.debounce(fn, delay)
|
|
return Debouncer.new(fn, delay)
|
|
end
|
|
|
|
function Util.get_hl_source(name)
|
|
local hl = vim.api.nvim_get_hl(0, { name = name })
|
|
while hl.link do
|
|
hl = vim.api.nvim_get_hl(0, { name = hl.link })
|
|
end
|
|
|
|
return hl
|
|
end
|
|
|
|
return Util
|