mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Encode fixed header by default

pull/8/head
Nicolas Jouanin 2015-05-31 17:22:39 +02:00
rodzic 520f991791
commit 4be588ec4e
2 zmienionych plików z 2 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

2
hbmqtt/codecs/connect.py
Wyświetl plik

@ -82,7 +82,7 @@ class ConnectCodec:
return message return message
@staticmethod @staticmethod
def encode(message: ConnectMessage, with_header=False) -> bytes: def encode(message: ConnectMessage, with_header=True) -> bytes:
out = b'' out = b''
# Write CONNECT variable header # Write CONNECT variable header

2
tests/codecs/test_connect.py
Wyświetl plik

@ -95,4 +95,4 @@ class TestConnectCodec(unittest.TestCase):
message.user_name = 'user' message.user_name = 'user'
message.password = 'password' message.password = 'password'
encoded = ConnectCodec.encode(message) encoded = ConnectCodec.encode(message)
self.assertEqual(encoded, b'\x00\x04MQTT\x04\xce\x00\x00\x00\x0a0123456789\x00\x09WillTopic\x00\x0bWillMessage\x00\x04user\x00\x08password') self.assertEqual(encoded, b'\x10\x3e\x00\x04MQTT\x04\xce\x00\x00\x00\x0a0123456789\x00\x09WillTopic\x00\x0bWillMessage\x00\x04user\x00\x08password')