1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
local log = require "mason-core.log"
local a = require "mason-core.async"
local Path = require "mason-core.path"
local settings = require "mason.settings"
local function make_module(uv)
local M = {}
---@param path string
function M.fstat(path)
log.trace("fs: fstat", path)
local fd = uv.fs_open(path, "r", 438)
local fstat = uv.fs_fstat(fd)
uv.fs_close(fd)
return fstat
end
---@param path string
function M.file_exists(path)
log.trace("fs: file_exists", path)
local ok, fstat = pcall(M.fstat, path)
if not ok then
return false
end
return fstat.type == "file"
end
---@param path string
function M.dir_exists(path)
log.trace("fs: dir_exists", path)
local ok, fstat = pcall(M.fstat, path)
if not ok then
return false
end
return fstat.type == "directory"
end
---@param path string
function M.rmrf(path)
assert(
Path.is_subdirectory(settings.current.install_root_dir, path),
(
"Refusing to rmrf %q which is outside of the allowed boundary %q. Please report this error at https://github.com/williamboman/mason.nvim/issues/new"
):format(path, settings.current.install_root_dir)
)
log.debug("fs: rmrf", path)
if vim.in_fast_event() then
a.scheduler()
end
if vim.fn.delete(path, "rf") ~= 0 then
log.debug "fs: rmrf failed"
error(("rmrf: Could not remove directory %q."):format(path))
end
end
---@param path string
function M.unlink(path)
log.debug("fs: unlink", path)
uv.fs_unlink(path)
end
---@param path string
function M.mkdir(path)
log.debug("fs: mkdir", path)
uv.fs_mkdir(path, 493) -- 493(10) == 755(8)
end
---@param path string
function M.mkdirp(path)
log.debug("fs: mkdirp", path)
if vim.in_fast_event() then
a.scheduler()
end
if vim.fn.mkdir(path, "p") ~= 1 then
log.debug "fs: mkdirp failed"
error(("mkdirp: Could not create directory %q."):format(path))
end
end
---@param path string
---@param new_path string
function M.rename(path, new_path)
log.debug("fs: rename", path, new_path)
uv.fs_rename(path, new_path)
end
---@param path string
---@param contents string
---@param flags string|nil: Defaults to "w".
function M.write_file(path, contents, flags)
log.debug("fs: write_file", path)
local fd = uv.fs_open(path, flags or "w", 438)
uv.fs_write(fd, contents, -1)
uv.fs_close(fd)
end
---@param path string
---@param contents string
function M.append_file(path, contents)
M.write_file(path, contents, "a")
end
---@param path string
function M.read_file(path)
log.trace("fs: read_file", path)
local fd = uv.fs_open(path, "r", 438)
local fstat = uv.fs_fstat(fd)
local contents = uv.fs_read(fd, fstat.size, 0)
uv.fs_close(fd)
return contents
end
---@alias ReaddirEntry {name: string, type: string}
---@param path string: The full path to the directory to read.
---@return ReaddirEntry[]
function M.readdir(path)
log.trace("fs: fs_opendir", path)
local dir = assert(vim.loop.fs_opendir(path, nil, 25))
local all_entries = {}
local exhausted = false
repeat
local entries = uv.fs_readdir(dir)
log.trace("fs: fs_readdir", path, entries)
if entries and #entries > 0 then
for i = 1, #entries do
all_entries[#all_entries + 1] = entries[i]
end
else
log.trace("fs: fs_readdir exhausted scan", path)
exhausted = true
end
until exhausted
uv.fs_closedir(dir)
return all_entries
end
function M.symlink(path, new_path)
log.trace("fs: symlink", path, new_path)
uv.fs_symlink(path, new_path)
end
return M
end
return {
async = make_module(require "mason-core.async.uv"),
sync = make_module(vim.loop),
}
|
