1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
local spy = require "luassert.spy"
local match = require "luassert.match"
local spawn = require "nvim-lsp-installer.core.spawn"
local process = require "nvim-lsp-installer.process"
describe("async spawn", function()
it(
"should spawn commands and return stdout & stderr",
async_test(function()
local result = spawn.env {
env = { "FOO=bar" },
}
assert.is_true(result:is_success())
assert.equals("FOO=bar\n", result:get_or_nil().stdout)
assert.equals("", result:get_or_nil().stderr)
end)
)
it(
"should use provided stdio_sink",
async_test(function()
local stdio = process.in_memory_sink()
local result = spawn.env {
env = { "FOO=bar" },
stdio_sink = stdio.sink,
}
assert.is_true(result:is_success())
assert.equals(nil, result:get_or_nil().stdout)
assert.equals(nil, result:get_or_nil().stderr)
assert.equals("FOO=bar\n", table.concat(stdio.buffers.stdout, ""))
assert.equals("", table.concat(stdio.buffers.stderr, ""))
end)
)
it(
"should pass command arguments",
async_test(function()
local result = spawn.bash {
"-c",
'echo "Hello $VAR"',
env = { "VAR=world" },
}
assert.is_true(result:is_success())
assert.equals("Hello world\n", result:get_or_nil().stdout)
assert.equals("", result:get_or_nil().stderr)
end)
)
it(
"should ignore vim.NIL args",
async_test(function()
local result = spawn.bash {
vim.NIL,
spawn._when(true, "-c"),
spawn._when(false, "shouldnotbeincluded"),
vim.NIL,
'echo "Hello $VAR"',
env = { "VAR=world" },
}
assert.is_true(result:is_success())
assert.equals("Hello world\n", result:get_or_nil().stdout)
assert.equals("", result:get_or_nil().stderr)
end)
)
it(
"should flatten table args",
async_test(function()
local result = spawn.bash {
{ "-c", 'echo "Hello $VAR"' },
env = { "VAR=world" },
}
assert.is_true(result:is_success())
assert.equals("Hello world\n", result:get_or_nil().stdout)
assert.equals("", result:get_or_nil().stderr)
end)
)
it(
"should call on_spawn",
async_test(function()
local on_spawn = spy.new(function(_, stdio)
local stdin = stdio[1]
stdin:write "im so piped rn"
stdin:close()
end)
local result = spawn.cat {
{ "-" },
on_spawn = on_spawn,
}
assert.spy(on_spawn).was_called(1)
assert.spy(on_spawn).was_called_with(match.is_not.is_nil(), match.is_not.is_nil())
assert.is_true(result:is_success())
assert.equals("im so piped rn", result:get_or_nil().stdout)
end)
)
it(
"should not call on_spawn if spawning fails",
async_test(function()
local on_spawn = spy.new()
local result = spawn.this_cmd_doesnt_exist {
on_spawn = on_spawn,
}
assert.spy(on_spawn).was_called(0)
assert.is_true(result:is_failure())
end)
)
end)
|
