aboutsummaryrefslogtreecommitdiffstats
path: root/test/http/http2/test_frames.py
diff options
context:
space:
mode:
authorThomas Kriechbaumer <thomas@kriechbaumer.name>2015-07-14 23:02:14 +0200
committerThomas Kriechbaumer <thomas@kriechbaumer.name>2015-07-22 15:30:51 +0200
commitf50deb7b763d093a22a4d331e16465a2fb0329cf (patch)
treea11e92fca2a0deffeb801cc6f931bd79aec0d669 /test/http/http2/test_frames.py
parentbd5ee212840e3be731ea93e14ef1375745383d88 (diff)
downloadmitmproxy-f50deb7b763d093a22a4d331e16465a2fb0329cf.tar.gz
mitmproxy-f50deb7b763d093a22a4d331e16465a2fb0329cf.tar.bz2
mitmproxy-f50deb7b763d093a22a4d331e16465a2fb0329cf.zip
move bits around
Diffstat (limited to 'test/http/http2/test_frames.py')
-rw-r--r--test/http/http2/test_frames.py704
1 files changed, 704 insertions, 0 deletions
diff --git a/test/http/http2/test_frames.py b/test/http/http2/test_frames.py
new file mode 100644
index 00000000..ee2edc39
--- /dev/null
+++ b/test/http/http2/test_frames.py
@@ -0,0 +1,704 @@
+import cStringIO
+from test import tutils
+from nose.tools import assert_equal
+from netlib import tcp
+from netlib.http.http2.frame import *
+
+
+def hex_to_file(data):
+ data = data.decode('hex')
+ return tcp.Reader(cStringIO.StringIO(data))
+
+
+def test_invalid_flags():
+ tutils.raises(
+ ValueError,
+ DataFrame,
+ flags=ContinuationFrame.FLAG_END_HEADERS,
+ stream_id=0x1234567,
+ payload='foobar')
+
+
+def test_frame_equality():
+ a = DataFrame(
+ length=6,
+ flags=Frame.FLAG_END_STREAM,
+ stream_id=0x1234567,
+ payload='foobar')
+ b = DataFrame(
+ length=6,
+ flags=Frame.FLAG_END_STREAM,
+ stream_id=0x1234567,
+ payload='foobar')
+ assert_equal(a, b)
+
+
+def test_too_large_frames():
+ f = DataFrame(
+ length=9000,
+ flags=Frame.FLAG_END_STREAM,
+ stream_id=0x1234567,
+ payload='foobar' * 3000)
+ tutils.raises(FrameSizeError, f.to_bytes)
+
+
+def test_data_frame_to_bytes():
+ f = DataFrame(
+ length=6,
+ flags=Frame.FLAG_END_STREAM,
+ stream_id=0x1234567,
+ payload='foobar')
+ assert_equal(f.to_bytes().encode('hex'), '000006000101234567666f6f626172')
+
+ f = DataFrame(
+ length=11,
+ flags=(Frame.FLAG_END_STREAM | Frame.FLAG_PADDED),
+ stream_id=0x1234567,
+ payload='foobar',
+ pad_length=3)
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00000a00090123456703666f6f626172000000')
+
+ f = DataFrame(
+ length=6,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ payload='foobar')
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_data_frame_from_bytes():
+ f = Frame.from_file(hex_to_file('000006000101234567666f6f626172'))
+ assert isinstance(f, DataFrame)
+ assert_equal(f.length, 6)
+ assert_equal(f.TYPE, DataFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_END_STREAM)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.payload, 'foobar')
+
+ f = Frame.from_file(hex_to_file('00000a00090123456703666f6f626172000000'))
+ assert isinstance(f, DataFrame)
+ assert_equal(f.length, 10)
+ assert_equal(f.TYPE, DataFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_END_STREAM | Frame.FLAG_PADDED)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.payload, 'foobar')
+
+
+def test_data_frame_human_readable():
+ f = DataFrame(
+ length=11,
+ flags=(Frame.FLAG_END_STREAM | Frame.FLAG_PADDED),
+ stream_id=0x1234567,
+ payload='foobar',
+ pad_length=3)
+ assert f.human_readable()
+
+
+def test_headers_frame_to_bytes():
+ f = HeadersFrame(
+ length=6,
+ flags=(Frame.FLAG_NO_FLAGS),
+ stream_id=0x1234567,
+ header_block_fragment='668594e75e31d9'.decode('hex'))
+ assert_equal(f.to_bytes().encode('hex'), '000007010001234567668594e75e31d9')
+
+ f = HeadersFrame(
+ length=10,
+ flags=(HeadersFrame.FLAG_PADDED),
+ stream_id=0x1234567,
+ header_block_fragment='668594e75e31d9'.decode('hex'),
+ pad_length=3)
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00000b01080123456703668594e75e31d9000000')
+
+ f = HeadersFrame(
+ length=10,
+ flags=(HeadersFrame.FLAG_PRIORITY),
+ stream_id=0x1234567,
+ header_block_fragment='668594e75e31d9'.decode('hex'),
+ exclusive=True,
+ stream_dependency=0x7654321,
+ weight=42)
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00000c012001234567876543212a668594e75e31d9')
+
+ f = HeadersFrame(
+ length=14,
+ flags=(HeadersFrame.FLAG_PADDED | HeadersFrame.FLAG_PRIORITY),
+ stream_id=0x1234567,
+ header_block_fragment='668594e75e31d9'.decode('hex'),
+ pad_length=3,
+ exclusive=True,
+ stream_dependency=0x7654321,
+ weight=42)
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00001001280123456703876543212a668594e75e31d9000000')
+
+ f = HeadersFrame(
+ length=14,
+ flags=(HeadersFrame.FLAG_PADDED | HeadersFrame.FLAG_PRIORITY),
+ stream_id=0x1234567,
+ header_block_fragment='668594e75e31d9'.decode('hex'),
+ pad_length=3,
+ exclusive=False,
+ stream_dependency=0x7654321,
+ weight=42)
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00001001280123456703076543212a668594e75e31d9000000')
+
+ f = HeadersFrame(
+ length=6,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ header_block_fragment='668594e75e31d9'.decode('hex'))
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_headers_frame_from_bytes():
+ f = Frame.from_file(hex_to_file(
+ '000007010001234567668594e75e31d9'))
+ assert isinstance(f, HeadersFrame)
+ assert_equal(f.length, 7)
+ assert_equal(f.TYPE, HeadersFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.header_block_fragment, '668594e75e31d9'.decode('hex'))
+
+ f = Frame.from_file(hex_to_file(
+ '00000b01080123456703668594e75e31d9000000'))
+ assert isinstance(f, HeadersFrame)
+ assert_equal(f.length, 11)
+ assert_equal(f.TYPE, HeadersFrame.TYPE)
+ assert_equal(f.flags, HeadersFrame.FLAG_PADDED)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.header_block_fragment, '668594e75e31d9'.decode('hex'))
+
+ f = Frame.from_file(hex_to_file(
+ '00000c012001234567876543212a668594e75e31d9'))
+ assert isinstance(f, HeadersFrame)
+ assert_equal(f.length, 12)
+ assert_equal(f.TYPE, HeadersFrame.TYPE)
+ assert_equal(f.flags, HeadersFrame.FLAG_PRIORITY)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.header_block_fragment, '668594e75e31d9'.decode('hex'))
+ assert_equal(f.exclusive, True)
+ assert_equal(f.stream_dependency, 0x7654321)
+ assert_equal(f.weight, 42)
+
+ f = Frame.from_file(hex_to_file(
+ '00001001280123456703876543212a668594e75e31d9000000'))
+ assert isinstance(f, HeadersFrame)
+ assert_equal(f.length, 16)
+ assert_equal(f.TYPE, HeadersFrame.TYPE)
+ assert_equal(f.flags, HeadersFrame.FLAG_PADDED | HeadersFrame.FLAG_PRIORITY)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.header_block_fragment, '668594e75e31d9'.decode('hex'))
+ assert_equal(f.exclusive, True)
+ assert_equal(f.stream_dependency, 0x7654321)
+ assert_equal(f.weight, 42)
+
+ f = Frame.from_file(hex_to_file(
+ '00001001280123456703076543212a668594e75e31d9000000'))
+ assert isinstance(f, HeadersFrame)
+ assert_equal(f.length, 16)
+ assert_equal(f.TYPE, HeadersFrame.TYPE)
+ assert_equal(f.flags, HeadersFrame.FLAG_PADDED | HeadersFrame.FLAG_PRIORITY)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.header_block_fragment, '668594e75e31d9'.decode('hex'))
+ assert_equal(f.exclusive, False)
+ assert_equal(f.stream_dependency, 0x7654321)
+ assert_equal(f.weight, 42)
+
+
+def test_headers_frame_human_readable():
+ f = HeadersFrame(
+ length=7,
+ flags=(HeadersFrame.FLAG_PADDED | HeadersFrame.FLAG_PRIORITY),
+ stream_id=0x1234567,
+ header_block_fragment=b'',
+ pad_length=3,
+ exclusive=False,
+ stream_dependency=0x7654321,
+ weight=42)
+ assert f.human_readable()
+
+ f = HeadersFrame(
+ length=14,
+ flags=(HeadersFrame.FLAG_PADDED | HeadersFrame.FLAG_PRIORITY),
+ stream_id=0x1234567,
+ header_block_fragment='668594e75e31d9'.decode('hex'),
+ pad_length=3,
+ exclusive=False,
+ stream_dependency=0x7654321,
+ weight=42)
+ assert f.human_readable()
+
+
+def test_priority_frame_to_bytes():
+ f = PriorityFrame(
+ length=5,
+ flags=(Frame.FLAG_NO_FLAGS),
+ stream_id=0x1234567,
+ exclusive=True,
+ stream_dependency=0x7654321,
+ weight=42)
+ assert_equal(f.to_bytes().encode('hex'), '000005020001234567876543212a')
+
+ f = PriorityFrame(
+ length=5,
+ flags=(Frame.FLAG_NO_FLAGS),
+ stream_id=0x1234567,
+ exclusive=False,
+ stream_dependency=0x7654321,
+ weight=21)
+ assert_equal(f.to_bytes().encode('hex'), '0000050200012345670765432115')
+
+ f = PriorityFrame(
+ length=5,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ stream_dependency=0x1234567)
+ tutils.raises(ValueError, f.to_bytes)
+
+ f = PriorityFrame(
+ length=5,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ stream_dependency=0x0)
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_priority_frame_from_bytes():
+ f = Frame.from_file(hex_to_file('000005020001234567876543212a'))
+ assert isinstance(f, PriorityFrame)
+ assert_equal(f.length, 5)
+ assert_equal(f.TYPE, PriorityFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.exclusive, True)
+ assert_equal(f.stream_dependency, 0x7654321)
+ assert_equal(f.weight, 42)
+
+ f = Frame.from_file(hex_to_file('0000050200012345670765432115'))
+ assert isinstance(f, PriorityFrame)
+ assert_equal(f.length, 5)
+ assert_equal(f.TYPE, PriorityFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.exclusive, False)
+ assert_equal(f.stream_dependency, 0x7654321)
+ assert_equal(f.weight, 21)
+
+
+def test_priority_frame_human_readable():
+ f = PriorityFrame(
+ length=5,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ exclusive=False,
+ stream_dependency=0x7654321,
+ weight=21)
+ assert f.human_readable()
+
+
+def test_rst_stream_frame_to_bytes():
+ f = RstStreamFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ error_code=0x7654321)
+ assert_equal(f.to_bytes().encode('hex'), '00000403000123456707654321')
+
+ f = RstStreamFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0)
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_rst_stream_frame_from_bytes():
+ f = Frame.from_file(hex_to_file('00000403000123456707654321'))
+ assert isinstance(f, RstStreamFrame)
+ assert_equal(f.length, 4)
+ assert_equal(f.TYPE, RstStreamFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.error_code, 0x07654321)
+
+
+def test_rst_stream_frame_human_readable():
+ f = RstStreamFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ error_code=0x7654321)
+ assert f.human_readable()
+
+
+def test_settings_frame_to_bytes():
+ f = SettingsFrame(
+ length=0,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0)
+ assert_equal(f.to_bytes().encode('hex'), '000000040000000000')
+
+ f = SettingsFrame(
+ length=0,
+ flags=SettingsFrame.FLAG_ACK,
+ stream_id=0x0)
+ assert_equal(f.to_bytes().encode('hex'), '000000040100000000')
+
+ f = SettingsFrame(
+ length=6,
+ flags=SettingsFrame.FLAG_ACK,
+ stream_id=0x0,
+ settings={
+ SettingsFrame.SETTINGS.SETTINGS_ENABLE_PUSH: 1})
+ assert_equal(f.to_bytes().encode('hex'), '000006040100000000000200000001')
+
+ f = SettingsFrame(
+ length=12,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ settings={
+ SettingsFrame.SETTINGS.SETTINGS_ENABLE_PUSH: 1,
+ SettingsFrame.SETTINGS.SETTINGS_MAX_CONCURRENT_STREAMS: 0x12345678})
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00000c040000000000000200000001000312345678')
+
+ f = SettingsFrame(
+ length=0,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567)
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_settings_frame_from_bytes():
+ f = Frame.from_file(hex_to_file('000000040000000000'))
+ assert isinstance(f, SettingsFrame)
+ assert_equal(f.length, 0)
+ assert_equal(f.TYPE, SettingsFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x0)
+
+ f = Frame.from_file(hex_to_file('000000040100000000'))
+ assert isinstance(f, SettingsFrame)
+ assert_equal(f.length, 0)
+ assert_equal(f.TYPE, SettingsFrame.TYPE)
+ assert_equal(f.flags, SettingsFrame.FLAG_ACK)
+ assert_equal(f.stream_id, 0x0)
+
+ f = Frame.from_file(hex_to_file('000006040100000000000200000001'))
+ assert isinstance(f, SettingsFrame)
+ assert_equal(f.length, 6)
+ assert_equal(f.TYPE, SettingsFrame.TYPE)
+ assert_equal(f.flags, SettingsFrame.FLAG_ACK, 0x0)
+ assert_equal(f.stream_id, 0x0)
+ assert_equal(len(f.settings), 1)
+ assert_equal(f.settings[SettingsFrame.SETTINGS.SETTINGS_ENABLE_PUSH], 1)
+
+ f = Frame.from_file(hex_to_file(
+ '00000c040000000000000200000001000312345678'))
+ assert isinstance(f, SettingsFrame)
+ assert_equal(f.length, 12)
+ assert_equal(f.TYPE, SettingsFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x0)
+ assert_equal(len(f.settings), 2)
+ assert_equal(f.settings[SettingsFrame.SETTINGS.SETTINGS_ENABLE_PUSH], 1)
+ assert_equal(
+ f.settings[
+ SettingsFrame.SETTINGS.SETTINGS_MAX_CONCURRENT_STREAMS],
+ 0x12345678)
+
+
+def test_settings_frame_human_readable():
+ f = SettingsFrame(
+ length=12,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ settings={})
+ assert f.human_readable()
+
+ f = SettingsFrame(
+ length=12,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ settings={
+ SettingsFrame.SETTINGS.SETTINGS_ENABLE_PUSH: 1,
+ SettingsFrame.SETTINGS.SETTINGS_MAX_CONCURRENT_STREAMS: 0x12345678})
+ assert f.human_readable()
+
+
+def test_push_promise_frame_to_bytes():
+ f = PushPromiseFrame(
+ length=10,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ promised_stream=0x7654321,
+ header_block_fragment='foobar')
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00000a05000123456707654321666f6f626172')
+
+ f = PushPromiseFrame(
+ length=14,
+ flags=HeadersFrame.FLAG_PADDED,
+ stream_id=0x1234567,
+ promised_stream=0x7654321,
+ header_block_fragment='foobar',
+ pad_length=3)
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00000e0508012345670307654321666f6f626172000000')
+
+ f = PushPromiseFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ promised_stream=0x1234567)
+ tutils.raises(ValueError, f.to_bytes)
+
+ f = PushPromiseFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ promised_stream=0x0)
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_push_promise_frame_from_bytes():
+ f = Frame.from_file(hex_to_file('00000a05000123456707654321666f6f626172'))
+ assert isinstance(f, PushPromiseFrame)
+ assert_equal(f.length, 10)
+ assert_equal(f.TYPE, PushPromiseFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.header_block_fragment, 'foobar')
+
+ f = Frame.from_file(hex_to_file(
+ '00000e0508012345670307654321666f6f626172000000'))
+ assert isinstance(f, PushPromiseFrame)
+ assert_equal(f.length, 14)
+ assert_equal(f.TYPE, PushPromiseFrame.TYPE)
+ assert_equal(f.flags, PushPromiseFrame.FLAG_PADDED)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.header_block_fragment, 'foobar')
+
+
+def test_push_promise_frame_human_readable():
+ f = PushPromiseFrame(
+ length=14,
+ flags=HeadersFrame.FLAG_PADDED,
+ stream_id=0x1234567,
+ promised_stream=0x7654321,
+ header_block_fragment='foobar',
+ pad_length=3)
+ assert f.human_readable()
+
+
+def test_ping_frame_to_bytes():
+ f = PingFrame(
+ length=8,
+ flags=PingFrame.FLAG_ACK,
+ stream_id=0x0,
+ payload=b'foobar')
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '000008060100000000666f6f6261720000')
+
+ f = PingFrame(
+ length=8,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ payload=b'foobardeadbeef')
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '000008060000000000666f6f6261726465')
+
+ f = PingFrame(
+ length=8,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567)
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_ping_frame_from_bytes():
+ f = Frame.from_file(hex_to_file('000008060100000000666f6f6261720000'))
+ assert isinstance(f, PingFrame)
+ assert_equal(f.length, 8)
+ assert_equal(f.TYPE, PingFrame.TYPE)
+ assert_equal(f.flags, PingFrame.FLAG_ACK)
+ assert_equal(f.stream_id, 0x0)
+ assert_equal(f.payload, b'foobar\0\0')
+
+ f = Frame.from_file(hex_to_file('000008060000000000666f6f6261726465'))
+ assert isinstance(f, PingFrame)
+ assert_equal(f.length, 8)
+ assert_equal(f.TYPE, PingFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x0)
+ assert_equal(f.payload, b'foobarde')
+
+
+def test_ping_frame_human_readable():
+ f = PingFrame(
+ length=8,
+ flags=PingFrame.FLAG_ACK,
+ stream_id=0x0,
+ payload=b'foobar')
+ assert f.human_readable()
+
+
+def test_goaway_frame_to_bytes():
+ f = GoAwayFrame(
+ length=8,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ last_stream=0x1234567,
+ error_code=0x87654321,
+ data=b'')
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '0000080700000000000123456787654321')
+
+ f = GoAwayFrame(
+ length=14,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ last_stream=0x1234567,
+ error_code=0x87654321,
+ data=b'foobar')
+ assert_equal(
+ f.to_bytes().encode('hex'),
+ '00000e0700000000000123456787654321666f6f626172')
+
+ f = GoAwayFrame(
+ length=8,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ last_stream=0x1234567,
+ error_code=0x87654321)
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_goaway_frame_from_bytes():
+ f = Frame.from_file(hex_to_file(
+ '0000080700000000000123456787654321'))
+ assert isinstance(f, GoAwayFrame)
+ assert_equal(f.length, 8)
+ assert_equal(f.TYPE, GoAwayFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x0)
+ assert_equal(f.last_stream, 0x1234567)
+ assert_equal(f.error_code, 0x87654321)
+ assert_equal(f.data, b'')
+
+ f = Frame.from_file(hex_to_file(
+ '00000e0700000000000123456787654321666f6f626172'))
+ assert isinstance(f, GoAwayFrame)
+ assert_equal(f.length, 14)
+ assert_equal(f.TYPE, GoAwayFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x0)
+ assert_equal(f.last_stream, 0x1234567)
+ assert_equal(f.error_code, 0x87654321)
+ assert_equal(f.data, b'foobar')
+
+
+def test_go_away_frame_human_readable():
+ f = GoAwayFrame(
+ length=14,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ last_stream=0x1234567,
+ error_code=0x87654321,
+ data=b'foobar')
+ assert f.human_readable()
+
+
+def test_window_update_frame_to_bytes():
+ f = WindowUpdateFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ window_size_increment=0x1234567)
+ assert_equal(f.to_bytes().encode('hex'), '00000408000000000001234567')
+
+ f = WindowUpdateFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ window_size_increment=0x7654321)
+ assert_equal(f.to_bytes().encode('hex'), '00000408000123456707654321')
+
+ f = WindowUpdateFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x0,
+ window_size_increment=0xdeadbeef)
+ tutils.raises(ValueError, f.to_bytes)
+
+ f = WindowUpdateFrame(4, Frame.FLAG_NO_FLAGS, 0x0, window_size_increment=0)
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_window_update_frame_from_bytes():
+ f = Frame.from_file(hex_to_file('00000408000000000001234567'))
+ assert isinstance(f, WindowUpdateFrame)
+ assert_equal(f.length, 4)
+ assert_equal(f.TYPE, WindowUpdateFrame.TYPE)
+ assert_equal(f.flags, Frame.FLAG_NO_FLAGS)
+ assert_equal(f.stream_id, 0x0)
+ assert_equal(f.window_size_increment, 0x1234567)
+
+
+def test_window_update_frame_human_readable():
+ f = WindowUpdateFrame(
+ length=4,
+ flags=Frame.FLAG_NO_FLAGS,
+ stream_id=0x1234567,
+ window_size_increment=0x7654321)
+ assert f.human_readable()
+
+
+def test_continuation_frame_to_bytes():
+ f = ContinuationFrame(
+ length=6,
+ flags=ContinuationFrame.FLAG_END_HEADERS,
+ stream_id=0x1234567,
+ header_block_fragment='foobar')
+ assert_equal(f.to_bytes().encode('hex'), '000006090401234567666f6f626172')
+
+ f = ContinuationFrame(
+ length=6,
+ flags=ContinuationFrame.FLAG_END_HEADERS,
+ stream_id=0x0,
+ header_block_fragment='foobar')
+ tutils.raises(ValueError, f.to_bytes)
+
+
+def test_continuation_frame_from_bytes():
+ f = Frame.from_file(hex_to_file('000006090401234567666f6f626172'))
+ assert isinstance(f, ContinuationFrame)
+ assert_equal(f.length, 6)
+ assert_equal(f.TYPE, ContinuationFrame.TYPE)
+ assert_equal(f.flags, ContinuationFrame.FLAG_END_HEADERS)
+ assert_equal(f.stream_id, 0x1234567)
+ assert_equal(f.header_block_fragment, 'foobar')
+
+
+def test_continuation_frame_human_readable():
+ f = ContinuationFrame(
+ length=6,
+ flags=ContinuationFrame.FLAG_END_HEADERS,
+ stream_id=0x1234567,
+ header_block_fragment='foobar')
+ assert f.human_readable()