aswi2021vochomurka-gitlab/aswi2021vochomurka/service/message_parser.py @ 21e4cc2f

import logging

from paho.mqtt.client import MQTTMessage

from aswi2021vochomurka.model.Message import Message


class ParseException(Exception):
    pass


def parse_mqtt_message(message: MQTTMessage) -> Message:
    data = message.payload.decode("utf-8")
    parts = data.split(";")
    logging.debug('Parsing message: ' + data + ', parts: ' + str(len(parts)))
    if len(parts) != 4:
        raise ParseException

    try:
        return Message(
            message.topic,
            int(parts[2]),
            parts[0],
            parts[1],
            float(parts[3])
        )
    except Exception as error:
        raise ParseException from error