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
|
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 do
host_thread.kill while host_thread.alive?
host_thread.join
end
context "poll" do
it "initializes a client and responds 'ok'" do
nvim_wr.write([0, 1, :poll, []]).flush
type, reqid, method = nvim_rd.read
expect(type).to eq(0)
expect(reqid).to eq(2)
expect(method).to eq("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
_, reqid, = nvim_rd.read
session = Session.new(EventLoop.child(Support.child_argv))
api_info = session.request(:nvim_get_api_info)
session.shutdown
nvim_wr.write([1, reqid, nil, api_info]).flush
nvim_rd.read
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
|
