b8c386ac6b
Rather than using branch names we are using the hashes provided directly in the Gitlab API response, to compare the point at which the branch diverged from the target to the head commit. We are additionally flashing a warning if the MR contains a merge conflict.
67 lines
2.4 KiB
Lua
67 lines
2.4 KiB
Lua
-- This module is responsible for making API calls to the Go server and
|
|
-- running the callbacks associated with those jobs when the JSON is returned
|
|
local Job = require("plenary.job")
|
|
local u = require("gitlab.utils")
|
|
local M = {}
|
|
|
|
M.run_job = function(endpoint, method, body, callback)
|
|
local state = require("gitlab.state")
|
|
local args = { "-s", "-X", (method or "POST"), string.format("localhost:%s", state.settings.port) .. endpoint }
|
|
|
|
if body ~= nil then
|
|
local encoded_body = vim.json.encode(body)
|
|
table.insert(args, 1, "-d")
|
|
table.insert(args, 2, encoded_body)
|
|
end
|
|
|
|
-- This handler will handle all responses from the Go server. Anything with a successful
|
|
-- status will call the callback (if it is supplied for the job). Otherwise, it will print out the
|
|
-- success message or error message and details from the Go server.
|
|
Job:new({
|
|
command = "curl",
|
|
args = args,
|
|
on_stdout = function(_, output)
|
|
vim.defer_fn(function()
|
|
if output == nil then
|
|
return
|
|
end
|
|
local data_ok, data = pcall(vim.json.decode, output)
|
|
if not data_ok then
|
|
local msg = string.format("Failed to parse JSON from %s endpoint", endpoint)
|
|
if type(output) == "string" then
|
|
msg = string.format(msg .. ", got: '%s'", output)
|
|
end
|
|
u.notify(string.format(msg, endpoint, output), vim.log.levels.WARN)
|
|
return
|
|
end
|
|
if data ~= nil then
|
|
local status = (tonumber(data.status) >= 200 and tonumber(data.status) < 300) and "success" or "error"
|
|
if status == "success" and callback ~= nil then
|
|
callback(data)
|
|
elseif status == "success" then
|
|
local message = string.format("%s", data.message)
|
|
u.notify(message, vim.log.levels.INFO)
|
|
else
|
|
local message = string.format("%s: %s", data.message, data.details)
|
|
u.notify(message, vim.log.levels.ERROR)
|
|
end
|
|
end
|
|
end, 0)
|
|
end,
|
|
on_stderr = function()
|
|
vim.defer_fn(function()
|
|
u.notify("Could not run command!", vim.log.levels.ERROR)
|
|
end, 0)
|
|
end,
|
|
on_exit = function(_, status)
|
|
vim.defer_fn(function()
|
|
if status ~= 0 then
|
|
u.notify(string.format("Go server exited with non-zero code: %d", status), vim.log.levels.ERROR)
|
|
end
|
|
end, 0)
|
|
end,
|
|
}):start()
|
|
end
|
|
|
|
return M
|