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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
require "helper"
require "neovim/host"
module Neovim
RSpec.describe Host do
describe ".run" do
let!(:push_pipe) { IO.pipe }
let!(:pull_pipe) { IO.pipe }
let(:host_rd) { push_pipe[0] }
let(:host_wr) { pull_pipe[1] }
let(:nvim_rd) { MessagePack::Unpacker.new(pull_pipe[0]) }
let(:nvim_wr) { MessagePack::Packer.new(push_pipe[1]) }
let(:plugin_path) do
Support.file_path("my_plugin").tap do |path|
File.write(path, <<-PLUGIN)
Neovim.plugin do |plug|
plug.command(:Echo, nargs: 1, sync: true) do |client, arg|
arg
end
plug.command(:Boom, sync: true) do |client|
raise "BOOM"
end
plug.command(:BoomAsync) do |client|
raise "BOOM ASYNC"
end
end
PLUGIN
end
end
let!(:host_thread) do
connection = Connection.new(host_rd, host_wr)
event_loop = EventLoop.new(connection)
Thread.new do
Host.run([plugin_path], event_loop)
end
end
after { host_thread.kill.join }
context "poll" do
it "initializes a client, sets client info, and responds 'ok'" do
nvim_wr.write([0, 1, :poll, []]).flush
expect(nvim_rd.read).to match([2, "nvim_set_client_info", duck_type(:to_ary)])
type, reqid, method = nvim_rd.read
expect([type, reqid, method]).to match([0, duck_type(:to_int), "nvim_get_api_info"])
api_info = [0, {"types" => {}, "functions" => {}}]
nvim_wr.write([1, reqid, nil, api_info]).flush
expect(nvim_rd.read).to eq([1, 1, nil, "ok"])
end
end
context "after poll" do
before do
nvim_wr.write([0, 1, :poll, []]).flush
expect(nvim_rd.read[1]).to eq("nvim_set_client_info")
_, reqid, method = nvim_rd.read
expect(method).to eq("nvim_get_api_info")
api_info = Support.persistent_client.get_api_info
nvim_wr.write([1, reqid, nil, api_info]).flush
expect(nvim_rd.read[3]).to eq("ok")
end
it "responds with specs to the 'specs' request" do
nvim_wr.write([0, 2, :specs, [plugin_path]]).flush
expect(nvim_rd.read).to eq(
[
1,
2,
nil,
[
{
"type" => "command",
"name" => "Echo",
"sync" => true,
"opts" => {"nargs" => 1}
},
{
"type" => "command",
"name" => "Boom",
"sync" => true,
"opts" => {}
},
{
"type" => "command",
"name" => "BoomAsync",
"sync" => false,
"opts" => {}
}
]
]
)
end
it "delegates to plugin handlers" do
nvim_wr.write([0, 0, "#{plugin_path}:command:Echo", ["hi"]]).flush
expect(nvim_rd.read).to eq([1, 0, nil, "hi"])
end
it "handles exceptions in sync plugin handlers" do
nvim_wr.write([0, 0, "#{plugin_path}:command:Boom", ["hi"]]).flush
expect(nvim_rd.read).to eq([1, 0, "BOOM", nil])
end
it "handles exceptions in async plugin handlers" do
nvim_wr.write([2, "#{plugin_path}:command:BoomAsync", ["hi"]]).flush
expect(nvim_rd.read).to match_array(
[
0, duck_type(:to_int), "nvim_err_writeln",
[/my_plugin:command:BoomAsync: \(RuntimeError\) BOOM ASYNC/]
]
)
end
it "handles unknown requests" do
nvim_wr.write([0, 0, "foobar", []]).flush
expect(nvim_rd.read).to eq([1, 0, "Unknown request foobar", nil])
end
end
end
end
end
|
