chore: refactor remaining installers to async impl (#616)

1 files changed, 124 insertions, 0 deletions

diff --git a/lua/nvim-lsp-installer/core/managers/std/init.lua b/lua/nvim-lsp-installer/core/managers/std/init.lua
index 49a7f53d..05495573 100644
--- a/lua/nvim-lsp-installer/core/managers/std/init.lua
+++ b/lua/nvim-lsp-installer/core/managers/std/init.lua
@@ -1,5 +1,10 @@
 local a = require "nvim-lsp-installer.core.async"
 local installer = require "nvim-lsp-installer.core.installer"
+local fetch = require "nvim-lsp-installer.core.fetch"
+local platform = require "nvim-lsp-installer.platform"
+local powershell = require "nvim-lsp-installer.core.managers.powershell"
+local path = require "nvim-lsp-installer.path"
+local Result = require "nvim-lsp-installer.core.result"
 
 local M = {}
 
@@ -41,4 +46,123 @@ function M.ensure_executable(executable, opts)
     }
 end
 
+---@async
+---@param url string
+---@param out_file string
+function M.download_file(url, out_file)
+    local ctx = installer.context()
+    ctx.stdio_sink.stdout(("Downloading file %q...\n"):format(url))
+    fetch(url, {
+        out_file = path.concat { ctx.cwd:get(), out_file },
+    })
+        :map_err(function(err)
+            return ("Failed to download file %q.\n%s"):format(url, err)
+        end)
+        :get_or_throw()
+end
+
+---@async
+---@param file string
+---@param dest string
+function M.unzip(file, dest)
+    local ctx = installer.context()
+    platform.when {
+        unix = function()
+            ctx.spawn.unzip { "-d", dest, file }
+        end,
+        win = function()
+            powershell.command(
+                ("Microsoft.PowerShell.Archive\\Expand-Archive -Path %q -DestinationPath %q"):format(file, dest),
+                {},
+                ctx.spawn
+            )
+        end,
+    }
+    pcall(function()
+        -- make sure the .zip archive doesn't linger
+        ctx.fs:unlink(file)
+    end)
+end
+
+---@param file string
+local function win_extract(file)
+    local ctx = installer.context()
+    Result.run_catching(function()
+        ctx.spawn["7z"] { "x", "-y", "-r", file }
+    end)
+        :recover_catching(function()
+            ctx.spawn.peazip { "-ext2here", path.concat { ctx.cwd:get(), file } } -- peazip requires absolute paths
+        end)
+        :recover_catching(function()
+            ctx.spawn.wzunzip { file }
+        end)
+        :recover_catching(function()
+            ctx.spawn.winrar { "e", file }
+        end)
+        :get_or_throw(("Unable to unpack %s."):format(file))
+end
+
+---@async
+---@param file string
+---@param opts {strip_components:integer}
+function M.untar(file, opts)
+    opts = opts or {}
+    local ctx = installer.context()
+    ctx.spawn.tar {
+        opts.strip_components and { "--strip-components", opts.strip_components } or vim.NIL,
+        "-xvf",
+        file,
+    }
+    pcall(function()
+        ctx.fs:unlink(file)
+    end)
+end
+
+---@async
+---@param file string
+function M.untarxz(file)
+    local ctx = installer.context()
+    platform.when {
+        unix = function()
+            M.untar(file)
+        end,
+        win = function()
+            Result.run_catching(function()
+                win_extract(file) -- unpack .tar.xz to .tar
+                local uncompressed_tar = file:gsub(".xz$", "")
+                M.untar(uncompressed_tar)
+            end):recover(function()
+                ctx.spawn.arc { "unarchive", file }
+                pcall(function()
+                    ctx.fs:unlink(file)
+                end)
+            end)
+        end,
+    }
+end
+
+---@async
+---@param file string
+function M.gunzip(file)
+    platform.when {
+        unix = function()
+            local ctx = installer.context()
+            ctx.spawn.gzip { "-d", file }
+        end,
+        win = function()
+            win_extract(file)
+        end,
+    }
+end
+
+---@async
+---@param flags string @The chmod flag to apply.
+---@param files string[] @A list of relative paths to apply the chmod on.
+function M.chmod(flags, files)
+    if platform.is_unix then
+        local ctx = installer.context()
+        ctx.spawn.chmod { flags, files }
+    end
+end
+
 return M