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
|
-- Copyright (c) 2023-2024 Florian Fischer. All rights reserved.
--
-- vis-inotify is free software: you can redistribute it and/or modify it under
-- the terms of the GNU General Public License as published by the Free Software
-- Foundation, either version 3 of the License, or (at your option) any later
-- version.
--
-- vis-inotify is distributed in the hope that it will be useful, but WITHOUT
-- ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
-- FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
--
-- You should have received a copy of the GNU General Public License along with
-- vis-inotify found in the LICENSE file.
-- If not, see <https://www.gnu.org/licenses/>.
if not vis.communicate then
vis:info('Error: vis-inotify requires vis communicate patch')
return {}
end
if not os.execute('type inotifywait >/dev/null 2>/dev/null') then
vis:info('Error: vis-inotify requires inotifywait')
return {}
end
-- We have to keep the handles to our communicate processes otherwise
-- vis will terminate them.
local watches = {} -- luacheck: ignore watches
local function _add_watch(file, func, mode, cmd_options)
local cmd = 'inotifywait '
if cmd_options then cmd = cmd .. ' ' .. cmd_options .. ' ' end
if mode == 'monitor' then cmd = cmd .. '-m ' end
cmd = cmd .. file
local watch_fd = vis:communicate(file, cmd)
watches[file] = watch_fd
vis.events.subscribe(vis.events.PROCESS_RESPONSE,
function(name, event, code, msg)
if name ~= file then return end
if event == 'EXIT' or event == 'SIGNAL' then
if event == 'EXIT' then
if mode == 'recreate' then
-- recreate the watch
watches[file] = nil
watches[file] = vis:communicate(file, cmd)
else
vis:info(file .. ' watch exited with: ' .. code)
end
else
vis:info(file .. ' watch received signal: ' .. code)
end
return
end
if event == 'STDOUT' then func(msg) end
end)
end
local M = {}
M.add_monitor_watch = function(file, func, cmd_options)
_add_watch(file, func, 'monitor', cmd_options)
end
M.add_single_shot_watch = function(file, func, cmd_options)
_add_watch(file, func, 'single_shot', cmd_options)
end
M.add_recreate_watch = function(file, func, cmd_options)
_add_watch(file, func, 'recreate', cmd_options)
end
return M
|
