def on_publish_received()

in tools/cloud/lks-subscribe.py [0:0]

• 13 lines of code
• 2 McCabe index (conditional complexity)

def on_publish_received(message):
    import last_known_state_message_pb2

    global received_data
    packet = message.publish_packet
    print(f"Received message on topic: {packet.topic}")
    try:
        msg = last_known_state_message_pb2.LastKnownState()
        msg.ParseFromString(packet.payload)
        json_msg = MessageToJson(msg)
        print(f"Received message: {json_msg}")
        received_data += [json.loads(json_msg)]
    except Exception as e:
        print(f"Error parsing message: {e}")