Skip to content
Snippets Groups Projects
Commit c574a760 authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

who needs tests

parent 21ce145f
No related branches found
No related tags found
No related merge requests found
# coding=UTF-8
from __future__ import absolute_import, division, print_function
# coding=UTF-8
from __future__ import absolute_import, division, print_function
import unittest
import struct
import io
from coolamqp.framing.definitions import BasicContentPropertyList
class TestBasicContentPropertyList(unittest.TestCase):
def test_bcpl1(self):
bcpl = BasicContentPropertyList(content_type='text/plain', content_encoding='utf8')
self.assertEquals(bcpl.content_type, 'text/plain')
self.assertEquals(bcpl.content_encoding, 'utf8')
buf = io.BytesIO()
bcpl.write_to(buf)
ser = buf.getvalue()
self.assertEquals(ser, '\xC0\x00' + chr(len('text/plain')) + b'text/plain\x04utf8')
def test_bcpl2(self):
bcpl = BasicContentPropertyList(content_type='text/plain')
self.assertEquals(bcpl.content_type, 'text/plain')
buf = io.BytesIO()
bcpl.write_to(buf)
ser = buf.getvalue()
self.assertEquals(ser, b'\x80\x00' + struct.pack('!B', len('text/plain')) + b'text/plain')
# coding=UTF-8
from __future__ import absolute_import, division, print_function
import unittest
import io
import struct
import six
from coolamqp.framing.frames import AMQPHeaderFrame
from coolamqp.framing.definitions import BasicContentPropertyList, FRAME_HEADER, FRAME_END, ConnectionStartOk
class TestShitSerializesRight(unittest.TestCase):
def test_unser_header_frame(self):
s = b'\x00\x3C\x00\x00' + \
b'\x00\x00\x00\x00\x00\x00\x00\x0A' + \
b'\xC0\x00\x0Atext/plain\x04utf8'
hf = AMQPHeaderFrame.unserialize(0, memoryview(s))
self.assertEquals(hf.class_id, 60)
self.assertEquals(hf.weight, 0)
self.assertEquals(hf.body_size, 10)
self.assertEquals(hf.properties.content_type, b'text/plain')
self.assertEquals(hf.properties.content_encoding, b'utf8')
def test_ser_header_frame(self):
a_cpl = BasicContentPropertyList(content_type='text/plain')
# content_type has len 10
buf = io.BytesIO()
hdr = AMQPHeaderFrame(0, 60, 0, 0, a_cpl)
hdr.write_to(buf)
s = b'\x00\x3C\x00\x00' + \
b'\x00\x00\x00\x00\x00\x00\x00\x00' + \
b'\x80\x00\x0Atext/plain'
s = chr(FRAME_HEADER) + b'\x00\x00' + \
struct.pack('!L', len(s)) + s + chr(FRAME_END)
self.assertEquals(buf.getvalue(), s)
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment