Merge pull request #1 from MO-RISE/pyais-version-bump

Using field-consistent pyais version

Author: freol35241

main.py

@@ -7,7 +7,7 @@
 
 from streamz import Stream
 
-from pyais.messages import ANY_MESSAGE, NMEAMessage
+from pyais.messages import ANY_MESSAGE, NMEAMessage, JSONEncoder as BytesJSONEncoder
 from pyais.exceptions import InvalidNMEAMessageException
 from environs import Env
 
@@ -125,7 +125,7 @@ def to_mqtt(envelope: Envelope, mmsi: int, message_type: int):
     """Publish an envelope to a mqtt topic"""
 
     topic = f"{MQTT_OUTPUT_BASE_TOPIC}/{mmsi}/{message_type}"
-    payload = envelope.json()
+    payload = envelope.json(cls=BytesJSONEncoder)
 
     LOGGER.debug("Publishing on %s with payload: %s", topic, payload)
     try:
@@ -159,5 +159,5 @@ def to_mqtt(envelope: Envelope, mmsi: int, message_type: int):
     LOGGER.info("Connecting to MQTT broker...")
     mq.connect(MQTT_BROKER_HOST, MQTT_BROKER_PORT)
 
-    # Lets fire this baby up!
+    # Data driven, lets just make sure to stay connected!
     mq.loop_forever()