03-publish-b2c-qos1.test

#!/usr/bin/env python3

import os
import socket
import subprocess
import sys
import time
from struct import *

import paho.mqtt.client as mqtt

if sys.version_info[0] < 3:
    expected_payload = "message"
else:
    expected_payload = b"message"


def on_message(mqttc, obj, msg):
    if msg.mid != 123:
        print("Invalid mid: ("+str(msg.mid)+")")
        exit(1)
    if msg.topic != "pub/qos1/receive":
        print("Invalid topic: ("+str(msg.topic)+")")
        exit(1)
    if msg.payload != expected_payload:
        print("Invalid payload: ("+str(msg.payload)+")")
        exit(1)
    if msg.qos != 1:
        print("Invalid qos: ("+str(msg.qos)+")")
        exit(1)
    if msg.retain != False:
        print("Invalid retain: ("+str(msg.retain)+")")
        exit(1)
    exit(0)

def on_connect(mqttc, obj, flags, rc):
    if rc != 0:
        print("Connect failed ("+str(rc)+")")
        exit(rc)

mqttc = mqtt.Client("publish-qos1-test")
mqttc.on_connect = on_connect
mqttc.on_message = on_message

mqttc.connect("localhost", 1888)
rc = 0
while rc == 0:
    rc = mqttc.loop()
print("rc: "+str(rc))
exit(1)