v0.1.1 (Builtin server)

* refac(rpc): Use `v.servername` instead of creating pipe

* refac: Remove host.lua as it's no longer needed

lua/flatten/core.lua

@@ -1,12 +1,9 @@
 local M = {}
 
-M.response_sock = nil
-
-local function unblock_client(pipe, othercmds)
-	M.response_sock = vim.fn.sockconnect("pipe", pipe, { rpc = true })
-	vim.fn.rpcnotify(M.response_sock, "nvim_exec_lua", "vim.cmd('qa!')", {})
-	vim.fn.chanclose(M.response_sock)
-	M.response_sock = nil
+local function unblock_guest(guest_pipe, othercmds)
+	local response_sock = vim.fn.sockconnect("pipe", guest_pipe, { rpc = true })
+	vim.fn.rpcnotify(response_sock, "nvim_exec_lua", "vim.cmd('qa!')", {})
+	vim.fn.chanclose(response_sock)
 
 	for _, cmd in ipairs(othercmds) do
 		vim.api.nvim_del_autocmd(cmd)
@@ -22,23 +19,23 @@ local function notify_when_done(pipe, bufnr, callback, ft)
 		buffer = bufnr,
 		once = true,
 		callback = function()
-			unblock_client(pipe, { bufunload, bufdelete })
+			unblock_guest(pipe, { bufunload, bufdelete })
 			callback(ft)
 		end
 	})
 	bufunload = vim.api.nvim_create_autocmd("BufUnload", {
 		buffer = bufnr,
 		once = true,
 		callback = function()
-			unblock_client(pipe, { quitpre, bufdelete })
+			unblock_guest(pipe, { quitpre, bufdelete })
 			callback(ft)
 		end
 	})
 	bufdelete = vim.api.nvim_create_autocmd("BufDelete", {
 		buffer = bufnr,
 		once = true,
 		callback = function()
-			unblock_client(pipe, { quitpre, bufunload })
+			unblock_guest(pipe, { quitpre, bufunload })
 			callback(ft)
 		end
 	})

lua/flatten/guest.lua

@@ -1,26 +1,25 @@
 local M = {}
 
-M.init = function()
+M.init = function(host_pipe)
 	local args = vim.call("argv")
 
-	local sock = vim.fn.sockconnect("pipe", require('flatten').pipe_path, { rpc = true })
-	local response_pipe = vim.call("serverstart")
+	local host = vim.fn.sockconnect("pipe", host_pipe, { rpc = true })
 
 	local call =
 		"return require('flatten.core').edit_files("
 		.. vim.inspect(args) .. ','
-		.. vim.inspect(response_pipe) .. ','
+		.. "'" .. vim.v.servername .. "',"
 		.. "'" .. vim.fn.getcwd() .. "'" ..
 		")"
 
 	if #args < 1 then return end
 
-	local block = vim.fn.rpcrequest(sock, "nvim_exec_lua", call, {})
+	local block = vim.fn.rpcrequest(host, "nvim_exec_lua", call, {})
 	if not block then
 		vim.cmd("qa!")
 	end
-	vim.fn.chanclose(sock)
-	while block do
+	vim.fn.chanclose(host)
+	while true do
 		vim.cmd("sleep 1")
 	end
 end

lua/flatten/init.lua

@@ -14,15 +14,10 @@ M.config = {
 	}
 }
 
-M.pipe_var = "NVIM_FLATTEN_PIPE_PATH"
-M.pipe_path = nil
-
 local function flatten_init()
-	M.pipe_path = os.getenv(M.pipe_var)
-	if M.pipe_path ~= nil then
-		require('flatten.guest').init()
-	else
-		require('flatten.host').init()
+	local pipe_path = os.getenv("NVIM")
+	if pipe_path ~= nil then
+		require('flatten.guest').init(pipe_path)
 	end
 end