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
|
require "test_helper"
using Plum::BinaryString
class StreamTest < Minitest::Test
def test_stream_illegal_frame_type
open_new_stream { |stream|
assert_connection_error(:protocol_error) {
stream.receive_frame(Frame.new(type: :goaway, stream_id: stream.id, payload: "\x00\x00\x00\x00"))
}
}
end
def test_stream_unknown_frame_type
open_new_stream { |stream|
assert_no_error {
stream.receive_frame(Frame.new(type_value: 0x0f, stream_id: stream.id, payload: "\x00\x00\x00\x00"))
}
}
end
def test_stream_remote_error
open_server_connection { |con|
stream = nil
con.on(:headers) { |s|
stream = s
raise RemoteStreamError.new(:frame_size_error)
}
assert_stream_error(:frame_size_error) {
con << Frame.headers(1, "", end_headers: true).assemble
}
last = sent_frames.last
assert_equal(:rst_stream, last.type)
assert_equal(HTTPError::ERROR_CODES[:frame_size_error], last.payload.uint32)
assert_equal(:closed, stream.state)
}
end
def test_stream_local_error
open_server_connection { |con|
stream = type = nil
con.on(:rst_stream) { |s, t| stream = s; type = t }
con << Frame.headers(1, "", end_headers: true).assemble
con << Frame.rst_stream(1, :frame_size_error).assemble
assert_equal(1, stream.id)
assert_equal(:frame_size_error, type)
}
end
end
|
