diff options
Diffstat (limited to 'test/plum/stream/test_handle_frame.rb')
| -rw-r--r-- | test/plum/stream/test_handle_frame.rb | 44 |
1 files changed, 22 insertions, 22 deletions
diff --git a/test/plum/stream/test_handle_frame.rb b/test/plum/stream/test_handle_frame.rb index 2c14c26..6defb82 100644 --- a/test/plum/stream/test_handle_frame.rb +++ b/test/plum/stream/test_handle_frame.rb @@ -9,7 +9,7 @@ class StreamHandleFrameTest < Minitest::Test open_new_stream(state: :open) { |stream| data = nil stream.connection.on(:data) { |_, _data| data = _data } - stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, + stream.receive_frame(Frame.craft(type: :data, stream_id: stream.id, flags: [], payload: payload)) assert_equal(payload, data) } @@ -20,7 +20,7 @@ class StreamHandleFrameTest < Minitest::Test open_new_stream(state: :open) { |stream| data = nil stream.connection.on(:data) { |_, _data| data = _data } - stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, + stream.receive_frame(Frame.craft(type: :data, stream_id: stream.id, flags: [:padded], payload: "".push_uint8(6).push(payload).push("\x00"*6))) assert_equal(payload, data) } @@ -30,7 +30,7 @@ class StreamHandleFrameTest < Minitest::Test payload = "ABC" * 5 open_new_stream(state: :open) { |stream| assert_connection_error(:protocol_error) { - stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, + stream.receive_frame(Frame.craft(type: :data, stream_id: stream.id, flags: [:padded], payload: "".push_uint8(100).push(payload).push("\x00"*6))) } } @@ -39,7 +39,7 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_data_end_stream payload = "ABC" * 5 open_new_stream(state: :open) { |stream| - stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, + stream.receive_frame(Frame.craft(type: :data, stream_id: stream.id, flags: [:end_stream], payload: payload)) assert_equal(:half_closed_remote, stream.state) } @@ -49,7 +49,7 @@ class StreamHandleFrameTest < Minitest::Test payload = "ABC" * 5 open_new_stream(state: :half_closed_remote) { |stream| assert_stream_error(:stream_closed) { - stream.receive_frame(Frame.new(type: :data, stream_id: stream.id, + stream.receive_frame(Frame.craft(type: :data, stream_id: stream.id, flags: [:end_stream], payload: payload)) } } @@ -62,7 +62,7 @@ class StreamHandleFrameTest < Minitest::Test stream.connection.on(:headers) { |_, _headers| headers = _headers } - stream.receive_frame(Frame.new(type: :headers, + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_headers], payload: HPACK::Encoder.new(0).encode([[":path", "/"]]))) @@ -78,12 +78,12 @@ class StreamHandleFrameTest < Minitest::Test stream.connection.on(:headers) { |_, _headers| headers = _headers } - stream.receive_frame(Frame.new(type: :headers, + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_stream], payload: payload[0..4])) assert_equal(nil, headers) # wait CONTINUATION - stream.receive_frame(Frame.new(type: :continuation, + stream.receive_frame(Frame.craft(type: :continuation, stream_id: stream.id, flags: [:end_headers], payload: payload[5..-1])) @@ -99,7 +99,7 @@ class StreamHandleFrameTest < Minitest::Test stream.connection.on(:headers) { |_, _headers| headers = _headers } - stream.receive_frame(Frame.new(type: :headers, + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_headers, :padded], payload: "".push_uint8(payload.bytesize).push(payload).push("\x00"*payload.bytesize))) @@ -111,7 +111,7 @@ class StreamHandleFrameTest < Minitest::Test open_new_stream { |stream| payload = HPACK::Encoder.new(0).encode([[":path", "/"]]) assert_connection_error(:protocol_error) { - stream.receive_frame(Frame.new(type: :headers, + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_headers, :padded], payload: "".push_uint8(payload.bytesize+1).push(payload).push("\x00"*(payload.bytesize+1)))) @@ -123,7 +123,7 @@ class StreamHandleFrameTest < Minitest::Test open_new_stream { |stream| payload = "\x00\x01\x02" assert_connection_error(:compression_error) { - stream.receive_frame(Frame.new(type: :headers, + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_headers], payload: payload)) @@ -135,17 +135,17 @@ class StreamHandleFrameTest < Minitest::Test _payload = HPACK::Encoder.new(0).encode([[":path", "/"]]) open_new_stream(state: :reserved_local) { |stream| assert_connection_error(:protocol_error) { - stream.receive_frame(Frame.new(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) } } open_new_stream(state: :closed) { |stream| assert_connection_error(:stream_closed) { - stream.receive_frame(Frame.new(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) } } open_new_stream(state: :half_closed_remote) { |stream| assert_stream_error(:stream_closed) { - stream.receive_frame(Frame.new(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_headers, :end_stream], payload: _payload)) } } end @@ -161,7 +161,7 @@ class StreamHandleFrameTest < Minitest::Test payload = "".push_uint32((1 << 31) | parent.id) .push_uint8(50) .push(header_block) - stream.receive_frame(Frame.new(type: :headers, + stream.receive_frame(Frame.craft(type: :headers, stream_id: stream.id, flags: [:end_headers, :priority], payload: payload)) @@ -180,7 +180,7 @@ class StreamHandleFrameTest < Minitest::Test payload = "".push_uint32((1 << 31) | parent.id) .push_uint8(50) - stream.receive_frame(Frame.new(type: :priority, + stream.receive_frame(Frame.craft(type: :priority, stream_id: stream.id, payload: payload)) assert_equal(true, stream.exclusive) @@ -193,7 +193,7 @@ class StreamHandleFrameTest < Minitest::Test open_server_connection { |con| stream = open_new_stream(con) payload = "".push_uint32((0 << 31) | stream.id).push_uint8(6) - stream.receive_frame(Frame.new(type: :priority, + stream.receive_frame(Frame.craft(type: :priority, stream_id: stream.id, payload: payload)) last = sent_frames.last @@ -210,7 +210,7 @@ class StreamHandleFrameTest < Minitest::Test stream2 = open_new_stream(con, parent: parent) payload = "".push_uint32((1 << 31) | parent.id).push_uint8(6) - stream0.receive_frame(Frame.new(type: :priority, + stream0.receive_frame(Frame.craft(type: :priority, stream_id: stream0.id, payload: payload)) assert_equal(parent, stream0.parent) @@ -222,7 +222,7 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_frame_size_error open_new_stream { |stream| assert_stream_error(:frame_size_error) { - stream.receive_frame(Frame.new(type: :priority, + stream.receive_frame(Frame.craft(type: :priority, stream_id: stream.id, payload: "\x00")) } @@ -232,7 +232,7 @@ class StreamHandleFrameTest < Minitest::Test ## RST_STREAM def test_stream_handle_rst_stream open_new_stream(state: :reserved_local) { |stream| - stream.receive_frame(Frame.new(type: :rst_stream, + stream.receive_frame(Frame.craft(type: :rst_stream, stream_id: stream.id, payload: "\x00\x00\x00\x00")) assert_equal(:closed, stream.state) @@ -242,7 +242,7 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_rst_stream_idle open_new_stream(state: :idle) { |stream| assert_connection_error(:protocol_error) { - stream.receive_frame(Frame.new(type: :rst_stream, + stream.receive_frame(Frame.craft(type: :rst_stream, stream_id: stream.id, payload: "\x00\x00\x00\x00")) } @@ -252,7 +252,7 @@ class StreamHandleFrameTest < Minitest::Test def test_stream_handle_rst_stream_frame_size open_new_stream(state: :reserved_local) { |stream| assert_connection_error(:frame_size_error) { - stream.receive_frame(Frame.new(type: :rst_stream, + stream.receive_frame(Frame.craft(type: :rst_stream, stream_id: stream.id, payload: "\x00\x00\x00")) } |