diff options
Diffstat (limited to 'test/plum/test_connection.rb')
| -rw-r--r-- | test/plum/test_connection.rb | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/test/plum/test_connection.rb b/test/plum/test_connection.rb index fad70b4..a28672b 100644 --- a/test/plum/test_connection.rb +++ b/test/plum/test_connection.rb @@ -4,7 +4,7 @@ using Plum::BinaryString class ConnectionTest < Minitest::Test def test_server_must_raise_frame_size_error_when_exeeeded_max_size - _settings = "".push_uint16(Frame::SETTINGS_TYPE[:max_frame_size]).push_uint32(2**14) + _settings = "".push_uint16(Frame::Settings::SETTINGS_TYPE[:max_frame_size]).push_uint32(2**14) limit = 2 ** 14 new_con = -> (&blk) { @@ -15,23 +15,23 @@ class ConnectionTest < Minitest::Test new_con.call { |con| assert_no_error { - con << Frame.new(type: :settings, stream_id: 0, payload: _settings * (limit / 6)).assemble + con << Frame.craft(type: :settings, stream_id: 0, payload: _settings * (limit / 6)).assemble } } new_con.call { |con| assert_connection_error(:frame_size_error) { - con << Frame.new(type: :settings, stream_id: 0, payload: _settings * (limit / 6 + 1)).assemble + con << Frame.craft(type: :settings, stream_id: 0, payload: _settings * (limit / 6 + 1)).assemble } } new_con.call { |con| assert_connection_error(:frame_size_error) { - con << Frame.new(type: :headers, stream_id: 3, payload: "\x00" * (limit + 1)).assemble + con << Frame.craft(type: :headers, stream_id: 3, payload: "\x00" * (limit + 1)).assemble } } new_con.call { |con| assert_stream_error(:frame_size_error) { - con << Frame.new(type: :headers, stream_id: 3, flags: [:end_headers], payload: "").assemble - con << Frame.new(type: :data, stream_id: 3, payload: "\x00" * (limit + 1)).assemble + con << Frame.craft(type: :headers, stream_id: 3, flags: [:end_headers], payload: "").assemble + con << Frame.craft(type: :data, stream_id: 3, payload: "\x00" * (limit + 1)).assemble } } end @@ -40,7 +40,7 @@ class ConnectionTest < Minitest::Test [:data, :headers, :priority, :rst_stream, :push_promise, :continuation].each do |type| con = open_server_connection assert_connection_error(:protocol_error) { - con << Frame.new(type: type, stream_id: 0).assemble + con << Frame.craft(type: type, stream_id: 0).assemble } end end @@ -56,39 +56,39 @@ class ConnectionTest < Minitest::Test def test_server_raise_cprotocol_error_client_start_even_stream_id con = open_server_connection assert_connection_error(:protocol_error) { - con << Frame.new(type: :headers, flags: [:end_headers], stream_id: 2).assemble + con << Frame.craft(type: :headers, flags: [:end_headers], stream_id: 2).assemble } end def test_server_raise_cprotocol_error_client_start_small_stream_id con = open_server_connection - con << Frame.new(type: :headers, flags: [:end_headers], stream_id: 51).assemble + con << Frame.craft(type: :headers, flags: [:end_headers], stream_id: 51).assemble assert_connection_error(:protocol_error) { - con << Frame.new(type: :headers, flags: [:end_headers], stream_id: 31).assemble + con << Frame.craft(type: :headers, flags: [:end_headers], stream_id: 31).assemble } end def test_server_raise_cprotocol_error_invalid_continuation_state prepare = -> &blk { con = open_server_connection - con << Frame.new(type: :headers, flags: [:end_headers], stream_id: 1).assemble - con << Frame.new(type: :headers, flags: [:end_stream], stream_id: 3).assemble + con << Frame.craft(type: :headers, flags: [:end_headers], stream_id: 1).assemble + con << Frame.craft(type: :headers, flags: [:end_stream], stream_id: 3).assemble blk.call(con) } prepare.call { |con| assert_connection_error(:protocol_error) { - con << Frame.new(type: :data, stream_id: 1, payload: "hello").assemble + con << Frame.craft(type: :data, stream_id: 1, payload: "hello").assemble } } prepare.call { |con| assert_connection_error(:protocol_error) { - con << Frame.new(type: :data, stream_id: 3, payload: "hello").assemble + con << Frame.craft(type: :data, stream_id: 3, payload: "hello").assemble } } prepare.call { |con| assert_equal(:waiting_continuation, con.state) - con << Frame.new(type: :continuation, flags: [:end_headers], stream_id: 3, payload: "").assemble + con << Frame.craft(type: :continuation, flags: [:end_headers], stream_id: 3, payload: "").assemble assert_equal(:open, con.state) } end @@ -96,7 +96,7 @@ class ConnectionTest < Minitest::Test def test_connection_local_error open_server_connection { |con| assert_raises(LocalConnectionError) { - con << Frame.goaway(0, :frame_size_error).assemble + con << Frame::Goaway.new(0, :frame_size_error).assemble } } end @@ -105,7 +105,7 @@ class ConnectionTest < Minitest::Test io = StringIO.new con = Connection.new(io.method(:write)) fs = parse_frames(io) { - con.__send__(:send_immediately, Frame.new(type: :data, stream_id: 1, payload: "a"*16385)) + con.__send__(:send_immediately, Frame.craft(type: :data, stream_id: 1, payload: "a"*16385)) } assert_equal(2, fs.size) assert_equal(16384, fs.first.length) |