forked from mirror/codesnap.nvim
60 lines
1.2 KiB
Lua
60 lines
1.2 KiB
Lua
local logger = require("codesnap.utils.logger")
|
|
local path_utils = require("codesnap.utils.path")
|
|
|
|
local client = {
|
|
job_id = 0,
|
|
}
|
|
|
|
function client:connect()
|
|
return vim.fn.jobstart({
|
|
path_utils.back(path_utils.back(debug.getinfo(1, "S").source:sub(2):match("(.*[/\\])")))
|
|
.. "/snap-server/target/debug/snap-server",
|
|
}, {
|
|
stderr_buffered = true,
|
|
rpc = true,
|
|
on_stderr = function(_, err)
|
|
vim.fn.jobstop(self.job_id)
|
|
logger.error(err)
|
|
end,
|
|
on_exit = function()
|
|
vim.fn.chanclose(self.job_id)
|
|
self.job_id = 0
|
|
end,
|
|
})
|
|
end
|
|
|
|
function client:init()
|
|
return self.job_id == 0 and client:connect() or self.job_id
|
|
end
|
|
|
|
function client:start()
|
|
self.job_id = client:init()
|
|
|
|
if self.job_id == 0 then
|
|
logger.error("cannot start rpc process")
|
|
return
|
|
end
|
|
|
|
if self.job_id == -1 then
|
|
logger.error("rpc process is not executable")
|
|
vim.fn.jobstop(self.job_id)
|
|
return
|
|
end
|
|
|
|
return self
|
|
end
|
|
|
|
function client:send(event, message)
|
|
vim.fn.rpcnotify(self.job_id, event, message)
|
|
end
|
|
|
|
function client:stop()
|
|
if self.job_id == 0 or self.job_id == -1 then
|
|
return
|
|
end
|
|
|
|
vim.fn.jobstop(self.job_id)
|
|
end
|
|
|
|
return client
|