fix: roslyn restart command not working

lua/roslyn/commands.lua

@@ -1,3 +1,4 @@
+local roslyn_emitter = require("roslyn.roslyn_emitter")
 -- Huge credits to mrcjkb
 -- https://github.com/mrcjkb/rustaceanvim/blob/2fa45427c01ded4d3ecca72e357f8a60fd8e46d4/lua/rustaceanvim/commands/init.lua
 local M = {}
@@ -19,28 +20,18 @@ local subcommand_tbl = {
 
             local attached_buffers = vim.tbl_keys(client.attached_buffers)
 
-            -- TODO: Change this to `client:request` when minimal version is `0.11`
-            ---@diagnostic disable-next-line: missing-parameter
-            client.stop()
-
-            local timer = vim.uv.new_timer()
-            timer:start(
-                500,
-                100,
-                vim.schedule_wrap(function()
-                    -- TODO: Change this to `client:request` when minimal version is `0.11`
-                    ---@diagnostic disable-next-line: missing-parameter
-                    if client.is_stopped() then
-                        for _, buffer in ipairs(attached_buffers) do
-                            vim.api.nvim_exec_autocmds("FileType", { group = "Roslyn", buffer = buffer })
-                        end
+            local function restart_lsp(remove_listener)
+                for _, buffer in ipairs(attached_buffers) do
+                    if vim.api.nvim_buf_is_valid(buffer) then
+                        vim.api.nvim_exec_autocmds("FileType", { group = "Roslyn", buffer = buffer })
                     end
+                end
+                remove_listener()
+            end
 
-                    if not timer:is_closing() then
-                        timer:close()
-                    end
-                end)
-            )
+            roslyn_emitter:on_stopped(restart_lsp)
+
+            client.stop(true)
         end,
     },
     stop = {

lua/roslyn/lsp.lua

@@ -1,3 +1,4 @@
+local roslyn_emitter = require("roslyn.roslyn_emitter")
 local M = {}
 
 ---@param bufnr integer
@@ -108,6 +109,7 @@ function M.start(bufnr, root_dir, on_init)
     config.on_exit = function(code, signal, client_id)
         vim.g.roslyn_nvim_selected_solution = nil
         vim.schedule(function()
+            roslyn_emitter:emit_stopped()
             vim.notify("Roslyn server stopped", vim.log.levels.INFO, { title = "roslyn.nvim" })
         end)
         if roslyn_config.config.on_exit then

lua/roslyn/roslyn_emitter.lua

@@ -0,0 +1,64 @@
+local M = {
+    events = {},
+}
+
+local function on(event, callback)
+    if not M.events[event] then
+        M.events[event] = {}
+    end
+    table.insert(M.events[event], callback)
+    return function()
+        M:off(event, callback)
+    end
+end
+
+local function emit(event, ...)
+    if M.events[event] then
+        for _, callback in ipairs(M.events[event]) do
+            callback(...)
+        end
+    end
+end
+
+local function off(event, callback)
+    if not M.events[event] then
+        return
+    end
+    for i, cb in ipairs(M.events[event]) do
+        if cb == callback then
+            table.remove(M.events[event], i)
+            break
+        end
+    end
+end
+
+---@param callback fun(remove_listener: fun()) # Callback function that is invoked when the Roslyn server is stopped. Accepts a function parameter for removing the event listener.
+---@return fun() # Returns a cleanup function for removing the listener manually.
+---```lua
+--- local remove_listener = M:on_stopped(function(remove_listener2)
+---     --For oneshot jobs
+---     remove_listener2()
+--- end)
+---
+--- remove_listener()
+---```
+function M:on_stopped(callback)
+    local wrapped
+    wrapped = function()
+        callback(function()
+            off("stopped", wrapped)
+        end)
+    end
+
+    on("stopped", wrapped)
+    return function()
+        off("stopped", wrapped)
+    end
+end
+
+--- Emits a stop event notifying all the M:on_stopped subscribers
+function M:emit_stopped(...)
+    emit("stopped", ...)
+end
+
+return M