From b90d5ded4a8c0b7a24eafacf231b8a1af0758df7 Mon Sep 17 00:00:00 2001 From: Roger Light Date: Mon, 17 Jun 2013 00:00:52 +0100 Subject: [PATCH] Fix tests. --HG-- rename : test/mosq_test.py => test/paho_test.py --- test/lib/01-con-discon-success.py | 15 +++--- test/lib/01-keepalive-pingreq.py | 19 ++++---- test/lib/01-no-clean-session.py | 9 ++-- test/lib/01-unpwd-set.py | 9 ++-- test/lib/01-will-set.py | 9 ++-- test/lib/01-will-unpwd-set.py | 9 ++-- test/lib/02-subscribe-qos0.py | 21 ++++----- test/lib/02-subscribe-qos1.py | 21 ++++----- test/lib/02-subscribe-qos2.py | 21 ++++----- test/lib/02-unsubscribe.py | 21 ++++----- test/lib/03-publish-b2c-qos1.py | 19 ++++---- test/lib/03-publish-b2c-qos2.py | 27 +++++------ test/lib/03-publish-c2b-qos1-disconnect.py | 27 +++++------ test/lib/03-publish-c2b-qos1-timeout.py | 25 +++++----- test/lib/03-publish-c2b-qos2-disconnect.py | 41 ++++++++-------- test/lib/03-publish-c2b-qos2-timeout.py | 35 +++++++------- test/lib/03-publish-qos0-no-payload.py | 19 ++++---- test/lib/03-publish-qos0.py | 19 ++++---- test/lib/04-retain-qos0.py | 15 +++--- test/lib/08-ssl-bad-cacert.py | 5 +- test/lib/08-ssl-connect-cert-auth.py | 15 +++--- test/lib/08-ssl-connect-no-auth.py | 15 +++--- test/lib/09-util-topic-matching.py | 3 +- test/lib/python/01-con-discon-success.test | 20 ++++---- test/lib/python/01-keepalive-pingreq.test | 12 ++--- test/lib/python/01-no-clean-session.test | 8 ++-- test/lib/python/01-unpwd-set.test | 10 ++-- test/lib/python/01-will-set.test | 10 ++-- test/lib/python/01-will-unpwd-set.test | 12 ++--- test/lib/python/02-subscribe-qos0.test | 24 +++++----- test/lib/python/02-subscribe-qos1.test | 24 +++++----- test/lib/python/02-subscribe-qos2.test | 24 +++++----- test/lib/python/02-unsubscribe.test | 24 +++++----- test/lib/python/03-publish-b2c-qos1.test | 18 +++---- test/lib/python/03-publish-b2c-qos2.test | 18 +++---- .../03-publish-c2b-qos1-disconnect.test | 28 +++++------ .../python/03-publish-c2b-qos1-timeout.test | 26 +++++----- .../03-publish-c2b-qos2-disconnect.test | 28 +++++------ .../python/03-publish-c2b-qos2-timeout.test | 26 +++++----- .../python/03-publish-qos0-no-payload.test | 20 ++++---- test/lib/python/03-publish-qos0.test | 20 ++++---- test/lib/python/04-retain-qos0.test | 14 +++--- test/lib/python/08-ssl-bad-cacert.test | 6 +-- test/lib/python/08-ssl-connect-cert-auth.test | 22 ++++----- test/lib/python/08-ssl-connect-no-auth.test | 22 ++++----- test/lib/python/09-util-topic-matching.test | 47 ++++--------------- test/lib/python3/01-con-discon-success.test | 20 ++++---- test/lib/python3/01-keepalive-pingreq.test | 12 ++--- test/lib/python3/01-no-clean-session.test | 8 ++-- test/lib/python3/01-unpwd-set.test | 10 ++-- test/lib/python3/01-will-set.test | 10 ++-- test/lib/python3/01-will-unpwd-set.test | 12 ++--- test/lib/python3/02-subscribe-qos0.test | 24 +++++----- test/lib/python3/02-subscribe-qos1.test | 24 +++++----- test/lib/python3/02-subscribe-qos2.test | 24 +++++----- test/lib/python3/02-unsubscribe.test | 24 +++++----- test/lib/python3/03-publish-b2c-qos1.test | 18 +++---- test/lib/python3/03-publish-b2c-qos2.test | 18 +++---- .../03-publish-c2b-qos1-disconnect.test | 28 +++++------ .../python3/03-publish-c2b-qos1-timeout.test | 26 +++++----- .../03-publish-c2b-qos2-disconnect.test | 28 +++++------ .../python3/03-publish-c2b-qos2-timeout.test | 26 +++++----- .../python3/03-publish-qos0-no-payload.test | 20 ++++---- test/lib/python3/03-publish-qos0.test | 20 ++++---- test/lib/python3/04-retain-qos0.test | 14 +++--- test/lib/python3/08-ssl-bad-cacert.test | 6 +-- .../lib/python3/08-ssl-connect-cert-auth.test | 22 ++++----- test/lib/python3/08-ssl-connect-no-auth.test | 22 ++++----- test/lib/python3/09-util-topic-matching.test | 47 ++++--------------- test/{mosq_test.py => paho_test.py} | 0 70 files changed, 634 insertions(+), 711 deletions(-) rename test/{mosq_test.py => paho_test.py} (100%) diff --git a/test/lib/01-con-discon-success.py b/test/lib/01-con-discon-success.py index 51cec8f..5f7b304 100755 --- a/test/lib/01-con-discon-success.py +++ b/test/lib/01-con-discon-success.py @@ -20,14 +20,14 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("01-con-discon-success", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("01-con-discon-success", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -37,22 +37,21 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/01-keepalive-pingreq.py b/test/lib/01-keepalive-pingreq.py index 612a802..7faf229 100755 --- a/test/lib/01-keepalive-pingreq.py +++ b/test/lib/01-keepalive-pingreq.py @@ -19,15 +19,15 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 4 -connect_packet = mosq_test.gen_connect("01-keepalive-pingreq", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("01-keepalive-pingreq", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -pingreq_packet = mosq_test.gen_pingreq() -pingresp_packet = mosq_test.gen_pingresp() +pingreq_packet = paho_test.gen_pingreq() +pingresp_packet = paho_test.gen_pingresp() sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -37,26 +37,25 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(keepalive+10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "pingreq", pingreq_packet): + if paho_test.expect_packet(conn, "pingreq", pingreq_packet): time.sleep(1.0) conn.send(pingresp_packet) - if mosq_test.expect_packet(conn, "pingreq", pingreq_packet): + if paho_test.expect_packet(conn, "pingreq", pingreq_packet): rc = 0 conn.close() diff --git a/test/lib/01-no-clean-session.py b/test/lib/01-no-clean-session.py index b495e85..f4aa415 100755 --- a/test/lib/01-no-clean-session.py +++ b/test/lib/01-no-clean-session.py @@ -17,11 +17,11 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("01-no-clean-session", clean_session=False, keepalive=keepalive) +connect_packet = paho_test.gen_connect("01-no-clean-session", clean_session=False, keepalive=keepalive) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -31,19 +31,18 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): rc = 0 conn.close() diff --git a/test/lib/01-unpwd-set.py b/test/lib/01-unpwd-set.py index f5ae278..0a1bf88 100755 --- a/test/lib/01-unpwd-set.py +++ b/test/lib/01-unpwd-set.py @@ -17,11 +17,11 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("01-unpwd-set", keepalive=keepalive, username="uname", password=";'[08gn=#") +connect_packet = paho_test.gen_connect("01-unpwd-set", keepalive=keepalive, username="uname", password=";'[08gn=#") sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -31,19 +31,18 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): rc = 0 conn.close() diff --git a/test/lib/01-will-set.py b/test/lib/01-will-set.py index 586adf7..e576895 100755 --- a/test/lib/01-will-set.py +++ b/test/lib/01-will-set.py @@ -19,11 +19,11 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("01-will-set", keepalive=keepalive, will_topic="topic/on/unexpected/disconnect", will_qos=1, will_retain=True, will_payload="will message") +connect_packet = paho_test.gen_connect("01-will-set", keepalive=keepalive, will_topic="topic/on/unexpected/disconnect", will_qos=1, will_retain=True, will_payload="will message") sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -33,19 +33,18 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): rc = 0 conn.close() diff --git a/test/lib/01-will-unpwd-set.py b/test/lib/01-will-unpwd-set.py index 77eb0aa..fb82836 100755 --- a/test/lib/01-will-unpwd-set.py +++ b/test/lib/01-will-unpwd-set.py @@ -19,11 +19,11 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("01-will-unpwd-set", +connect_packet = paho_test.gen_connect("01-will-unpwd-set", keepalive=keepalive, username="oibvvwqw", password="#'^2hg9a&nm38*us", will_topic="will-topic", will_qos=2, will_payload="will message") @@ -35,19 +35,18 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): rc = 0 conn.close() diff --git a/test/lib/02-subscribe-qos0.py b/test/lib/02-subscribe-qos0.py index 8e24440..d526d76 100755 --- a/test/lib/02-subscribe-qos0.py +++ b/test/lib/02-subscribe-qos0.py @@ -24,18 +24,18 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("subscribe-qos0-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("subscribe-qos0-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 1 -subscribe_packet = mosq_test.gen_subscribe(mid, "qos0/test", 0) -suback_packet = mosq_test.gen_suback(mid, 0) +subscribe_packet = paho_test.gen_subscribe(mid, "qos0/test", 0) +suback_packet = paho_test.gen_suback(mid, 0) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -45,25 +45,24 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "subscribe", subscribe_packet): + if paho_test.expect_packet(conn, "subscribe", subscribe_packet): conn.send(suback_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/02-subscribe-qos1.py b/test/lib/02-subscribe-qos1.py index eeac5df..afa5b5b 100755 --- a/test/lib/02-subscribe-qos1.py +++ b/test/lib/02-subscribe-qos1.py @@ -24,18 +24,18 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("subscribe-qos1-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("subscribe-qos1-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 1 -subscribe_packet = mosq_test.gen_subscribe(mid, "qos1/test", 1) -suback_packet = mosq_test.gen_suback(mid, 1) +subscribe_packet = paho_test.gen_subscribe(mid, "qos1/test", 1) +suback_packet = paho_test.gen_suback(mid, 1) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -45,25 +45,24 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "subscribe", subscribe_packet): + if paho_test.expect_packet(conn, "subscribe", subscribe_packet): conn.send(suback_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/02-subscribe-qos2.py b/test/lib/02-subscribe-qos2.py index 580fece..ab29fd4 100755 --- a/test/lib/02-subscribe-qos2.py +++ b/test/lib/02-subscribe-qos2.py @@ -24,18 +24,18 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("subscribe-qos2-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("subscribe-qos2-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 1 -subscribe_packet = mosq_test.gen_subscribe(mid, "qos2/test", 2) -suback_packet = mosq_test.gen_suback(mid, 2) +subscribe_packet = paho_test.gen_subscribe(mid, "qos2/test", 2) +suback_packet = paho_test.gen_suback(mid, 2) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -45,25 +45,24 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "subscribe", subscribe_packet): + if paho_test.expect_packet(conn, "subscribe", subscribe_packet): conn.send(suback_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/02-unsubscribe.py b/test/lib/02-unsubscribe.py index 1d107b4..f3f6422 100755 --- a/test/lib/02-unsubscribe.py +++ b/test/lib/02-unsubscribe.py @@ -14,18 +14,18 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("unsubscribe-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("unsubscribe-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 1 -unsubscribe_packet = mosq_test.gen_unsubscribe(mid, "unsubscribe/test") -unsuback_packet = mosq_test.gen_unsuback(mid) +unsubscribe_packet = paho_test.gen_unsubscribe(mid, "unsubscribe/test") +unsuback_packet = paho_test.gen_unsuback(mid) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -35,25 +35,24 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "unsubscribe", unsubscribe_packet): + if paho_test.expect_packet(conn, "unsubscribe", unsubscribe_packet): conn.send(unsuback_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/03-publish-b2c-qos1.py b/test/lib/03-publish-b2c-qos1.py index 8f47f07..0b5af94 100755 --- a/test/lib/03-publish-b2c-qos1.py +++ b/test/lib/03-publish-b2c-qos1.py @@ -23,18 +23,18 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("publish-qos1-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("publish-qos1-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 123 -publish_packet = mosq_test.gen_publish("pub/qos1/receive", qos=1, mid=mid, payload="message") -puback_packet = mosq_test.gen_puback(mid) +publish_packet = paho_test.gen_publish("pub/qos1/receive", qos=1, mid=mid, payload="message") +puback_packet = paho_test.gen_puback(mid) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -44,23 +44,22 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) conn.send(publish_packet) - if mosq_test.expect_packet(conn, "puback", puback_packet): + if paho_test.expect_packet(conn, "puback", puback_packet): rc = 0 conn.close() diff --git a/test/lib/03-publish-b2c-qos2.py b/test/lib/03-publish-b2c-qos2.py index caee360..86c820b 100755 --- a/test/lib/03-publish-b2c-qos2.py +++ b/test/lib/03-publish-b2c-qos2.py @@ -28,20 +28,20 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("publish-qos2-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("publish-qos2-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 13423 -publish_packet = mosq_test.gen_publish("pub/qos2/receive", qos=2, mid=mid, payload="message") -pubrec_packet = mosq_test.gen_pubrec(mid) -pubrel_packet = mosq_test.gen_pubrel(mid) -pubcomp_packet = mosq_test.gen_pubcomp(mid) +publish_packet = paho_test.gen_publish("pub/qos2/receive", qos=2, mid=mid, payload="message") +pubrec_packet = paho_test.gen_pubrec(mid) +pubrel_packet = paho_test.gen_pubrel(mid) +pubcomp_packet = paho_test.gen_pubcomp(mid) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -51,28 +51,27 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) conn.send(publish_packet) - if mosq_test.expect_packet(conn, "pubrec", pubrec_packet): + if paho_test.expect_packet(conn, "pubrec", pubrec_packet): # Should be repeated due to timeout - if mosq_test.expect_packet(conn, "pubrec", pubrec_packet): + if paho_test.expect_packet(conn, "pubrec", pubrec_packet): conn.send(pubrel_packet) - if mosq_test.expect_packet(conn, "pubcomp", pubcomp_packet): + if paho_test.expect_packet(conn, "pubcomp", pubcomp_packet): rc = 0 conn.close() diff --git a/test/lib/03-publish-c2b-qos1-disconnect.py b/test/lib/03-publish-c2b-qos1-disconnect.py index 33db504..a2f6789 100755 --- a/test/lib/03-publish-c2b-qos1-disconnect.py +++ b/test/lib/03-publish-c2b-qos1-disconnect.py @@ -14,19 +14,19 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("publish-qos1-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("publish-qos1-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 1 -publish_packet = mosq_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message") -publish_packet_dup = mosq_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message", dup=True) -puback_packet = mosq_test.gen_puback(mid) +publish_packet = paho_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message") +publish_packet_dup = paho_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message", dup=True) +puback_packet = paho_test.gen_puback(mid) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -36,12 +36,11 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) @@ -49,23 +48,23 @@ try: (conn, address) = sock.accept() conn.settimeout(15) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "publish", publish_packet): + if paho_test.expect_packet(conn, "publish", publish_packet): # Disconnect client. It should reconnect. conn.close() (conn, address) = sock.accept() conn.settimeout(15) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "retried publish", publish_packet_dup): + if paho_test.expect_packet(conn, "retried publish", publish_packet_dup): conn.send(puback_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/03-publish-c2b-qos1-timeout.py b/test/lib/03-publish-c2b-qos1-timeout.py index 59765b0..a61c447 100755 --- a/test/lib/03-publish-c2b-qos1-timeout.py +++ b/test/lib/03-publish-c2b-qos1-timeout.py @@ -28,19 +28,19 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("publish-qos1-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("publish-qos1-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 1 -publish_packet = mosq_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message") -publish_packet_dup = mosq_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message", dup=True) -puback_packet = mosq_test.gen_puback(mid) +publish_packet = paho_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message") +publish_packet_dup = paho_test.gen_publish("pub/qos1/test", qos=1, mid=mid, payload="message", dup=True) +puback_packet = paho_test.gen_puback(mid) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -50,28 +50,27 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(5) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "publish", publish_packet): + if paho_test.expect_packet(conn, "publish", publish_packet): # Delay for > 3 seconds (message retry time) - if mosq_test.expect_packet(conn, "dup publish", publish_packet_dup): + if paho_test.expect_packet(conn, "dup publish", publish_packet_dup): conn.send(puback_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/03-publish-c2b-qos2-disconnect.py b/test/lib/03-publish-c2b-qos2-disconnect.py index b26178c..acc1a3f 100755 --- a/test/lib/03-publish-c2b-qos2-disconnect.py +++ b/test/lib/03-publish-c2b-qos2-disconnect.py @@ -14,22 +14,22 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("publish-qos2-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("publish-qos2-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 1 -publish_packet = mosq_test.gen_publish("pub/qos2/test", qos=2, mid=mid, payload="message") -publish_dup_packet = mosq_test.gen_publish("pub/qos2/test", qos=2, mid=mid, payload="message", dup=True) -pubrec_packet = mosq_test.gen_pubrec(mid) -pubrel_packet = mosq_test.gen_pubrel(mid) -pubrel_dup_packet = mosq_test.gen_pubrel(mid, dup=True) -pubcomp_packet = mosq_test.gen_pubcomp(mid) +publish_packet = paho_test.gen_publish("pub/qos2/test", qos=2, mid=mid, payload="message") +publish_dup_packet = paho_test.gen_publish("pub/qos2/test", qos=2, mid=mid, payload="message", dup=True) +pubrec_packet = paho_test.gen_pubrec(mid) +pubrel_packet = paho_test.gen_pubrel(mid) +pubrel_dup_packet = paho_test.gen_pubrel(mid, dup=True) +pubcomp_packet = paho_test.gen_pubcomp(mid) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -39,35 +39,34 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(5) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "publish", publish_packet): + if paho_test.expect_packet(conn, "publish", publish_packet): # Disconnect client. It should reconnect. conn.close() (conn, address) = sock.accept() conn.settimeout(15) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "retried publish", publish_dup_packet): + if paho_test.expect_packet(conn, "retried publish", publish_dup_packet): conn.send(pubrec_packet) - if mosq_test.expect_packet(conn, "pubrel", pubrel_packet): + if paho_test.expect_packet(conn, "pubrel", pubrel_packet): # Disconnect client. It should reconnect. conn.close() @@ -75,16 +74,16 @@ try: conn.settimeout(15) # Complete connection and message flow. - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "2nd retried publish", publish_dup_packet): + if paho_test.expect_packet(conn, "2nd retried publish", publish_dup_packet): conn.send(pubrec_packet) - if mosq_test.expect_packet(conn, "pubrel", pubrel_packet): + if paho_test.expect_packet(conn, "pubrel", pubrel_packet): conn.send(pubcomp_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/03-publish-c2b-qos2-timeout.py b/test/lib/03-publish-c2b-qos2-timeout.py index 7705f1a..a4c7003 100755 --- a/test/lib/03-publish-c2b-qos2-timeout.py +++ b/test/lib/03-publish-c2b-qos2-timeout.py @@ -32,22 +32,22 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("publish-qos2-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("publish-qos2-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() mid = 1 -publish_packet = mosq_test.gen_publish("pub/qos2/test", qos=2, mid=mid, payload="message") -publish_dup_packet = mosq_test.gen_publish("pub/qos2/test", qos=2, mid=mid, payload="message", dup=True) -pubrec_packet = mosq_test.gen_pubrec(mid) -pubrel_packet = mosq_test.gen_pubrel(mid) -pubrel_dup_packet = mosq_test.gen_pubrel(mid, dup=True) -pubcomp_packet = mosq_test.gen_pubcomp(mid) +publish_packet = paho_test.gen_publish("pub/qos2/test", qos=2, mid=mid, payload="message") +publish_dup_packet = paho_test.gen_publish("pub/qos2/test", qos=2, mid=mid, payload="message", dup=True) +pubrec_packet = paho_test.gen_pubrec(mid) +pubrel_packet = paho_test.gen_pubrel(mid) +pubrel_dup_packet = paho_test.gen_pubrel(mid, dup=True) +pubcomp_packet = paho_test.gen_pubcomp(mid) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -57,32 +57,31 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(5) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "publish", publish_packet): + if paho_test.expect_packet(conn, "publish", publish_packet): # Delay for > 3 seconds (message retry time) - if mosq_test.expect_packet(conn, "dup publish", publish_dup_packet): + if paho_test.expect_packet(conn, "dup publish", publish_dup_packet): conn.send(pubrec_packet) - if mosq_test.expect_packet(conn, "pubrel", pubrel_packet): - if mosq_test.expect_packet(conn, "dup pubrel", pubrel_dup_packet): + if paho_test.expect_packet(conn, "pubrel", pubrel_packet): + if paho_test.expect_packet(conn, "dup pubrel", pubrel_dup_packet): conn.send(pubcomp_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/03-publish-qos0-no-payload.py b/test/lib/03-publish-qos0-no-payload.py index 6b16663..1324768 100755 --- a/test/lib/03-publish-qos0-no-payload.py +++ b/test/lib/03-publish-qos0-no-payload.py @@ -22,16 +22,16 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("publish-qos0-test-np", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("publish-qos0-test-np", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -publish_packet = mosq_test.gen_publish("pub/qos0/no-payload/test", qos=0) +publish_packet = paho_test.gen_publish("pub/qos0/no-payload/test", qos=0) -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -41,23 +41,22 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "publish", publish_packet): - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "publish", publish_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/03-publish-qos0.py b/test/lib/03-publish-qos0.py index db7e578..17d8b53 100755 --- a/test/lib/03-publish-qos0.py +++ b/test/lib/03-publish-qos0.py @@ -22,16 +22,16 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("publish-qos0-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("publish-qos0-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -publish_packet = mosq_test.gen_publish("pub/qos0/test", qos=0, payload="message") +publish_packet = paho_test.gen_publish("pub/qos0/test", qos=0, payload="message") -disconnect_packet = mosq_test.gen_disconnect() +disconnect_packet = paho_test.gen_disconnect() sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -41,23 +41,22 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "publish", publish_packet): - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "publish", publish_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/04-retain-qos0.py b/test/lib/04-retain-qos0.py index b0c6e24..859b612 100755 --- a/test/lib/04-retain-qos0.py +++ b/test/lib/04-retain-qos0.py @@ -14,15 +14,15 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test rc = 1 keepalive = 60 mid = 16 -connect_packet = mosq_test.gen_connect("retain-qos0-test", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) +connect_packet = paho_test.gen_connect("retain-qos0-test", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) -publish_packet = mosq_test.gen_publish("retain/qos0/test", qos=0, payload="retained message", retain=True) +publish_packet = paho_test.gen_publish("retain/qos0/test", qos=0, payload="retained message", retain=True) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -32,22 +32,21 @@ sock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = sock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "publish", publish_packet): + if paho_test.expect_packet(conn, "publish", publish_packet): rc = 0 conn.close() diff --git a/test/lib/08-ssl-bad-cacert.py b/test/lib/08-ssl-bad-cacert.py index 13fed1c..221e2ff 100755 --- a/test/lib/08-ssl-bad-cacert.py +++ b/test/lib/08-ssl-bad-cacert.py @@ -13,7 +13,7 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test if sys.version < '2.7': print("WARNING: SSL not supported on Python 2.6") @@ -23,12 +23,11 @@ rc = 1 client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) client.wait() diff --git a/test/lib/08-ssl-connect-cert-auth.py b/test/lib/08-ssl-connect-cert-auth.py index 8554713..4ec1dd7 100755 --- a/test/lib/08-ssl-connect-cert-auth.py +++ b/test/lib/08-ssl-connect-cert-auth.py @@ -23,7 +23,7 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test if sys.version < '2.7': print("WARNING: SSL not supported on Python 2.6") @@ -31,9 +31,9 @@ if sys.version < '2.7': rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("08-ssl-connect-crt-auth", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +connect_packet = paho_test.gen_connect("08-ssl-connect-crt-auth", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) +disconnect_packet = paho_test.gen_disconnect() sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -46,22 +46,21 @@ ssock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = ssock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/08-ssl-connect-no-auth.py b/test/lib/08-ssl-connect-no-auth.py index 716c59d..15c6f2d 100755 --- a/test/lib/08-ssl-connect-no-auth.py +++ b/test/lib/08-ssl-connect-no-auth.py @@ -22,7 +22,7 @@ cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(insp if cmd_subfolder not in sys.path: sys.path.insert(0, cmd_subfolder) -import mosq_test +import paho_test if sys.version < '2.7': print("WARNING: SSL not supported on Python 2.6") @@ -30,9 +30,9 @@ if sys.version < '2.7': rc = 1 keepalive = 60 -connect_packet = mosq_test.gen_connect("08-ssl-connect-no-auth", keepalive=keepalive) -connack_packet = mosq_test.gen_connack(rc=0) -disconnect_packet = mosq_test.gen_disconnect() +connect_packet = paho_test.gen_connect("08-ssl-connect-no-auth", keepalive=keepalive) +connack_packet = paho_test.gen_connack(rc=0) +disconnect_packet = paho_test.gen_disconnect() sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) @@ -43,22 +43,21 @@ ssock.listen(5) client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) try: (conn, address) = ssock.accept() conn.settimeout(10) - if mosq_test.expect_packet(conn, "connect", connect_packet): + if paho_test.expect_packet(conn, "connect", connect_packet): conn.send(connack_packet) - if mosq_test.expect_packet(conn, "disconnect", disconnect_packet): + if paho_test.expect_packet(conn, "disconnect", disconnect_packet): rc = 0 conn.close() diff --git a/test/lib/09-util-topic-matching.py b/test/lib/09-util-topic-matching.py index 57c989e..050acfc 100755 --- a/test/lib/09-util-topic-matching.py +++ b/test/lib/09-util-topic-matching.py @@ -15,12 +15,11 @@ rc = 1 client_args = sys.argv[1:] env = dict(os.environ) -env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp' try: pp = env['PYTHONPATH'] except KeyError: pp = '' -env['PYTHONPATH'] = '../../lib/python:'+pp +env['PYTHONPATH'] = '../../src:'+pp client = subprocess.Popen(client_args, env=env) client.wait() diff --git a/test/lib/python/01-con-discon-success.test b/test/lib/python/01-con-discon-success.test index 50a45f3..b6ccc1e 100755 --- a/test/lib/python/01-con-discon-success.test +++ b/test/lib/python/01-con-discon-success.test @@ -7,27 +7,27 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.disconnect() + mqttc.disconnect() -def on_disconnect(mosq, obj, rc): - mosq.loop() +def on_disconnect(mqttc, obj, rc): + mqttc.loop() obj = rc run = -1 -mosq = mosquitto.Mosquitto("01-con-discon-success", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect +mqttc = mqtt.Client("01-con-discon-success", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/01-keepalive-pingreq.test b/test/lib/python/01-keepalive-pingreq.test index 9aa289b..bf9565d 100755 --- a/test/lib/python/01-keepalive-pingreq.test +++ b/test/lib/python/01-keepalive-pingreq.test @@ -7,19 +7,19 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) run = -1 -mosq = mosquitto.Mosquitto("01-keepalive-pingreq") -mosq.on_connect = on_connect +mqttc = mqtt.Client("01-keepalive-pingreq") +mqttc.on_connect = on_connect -mosq.connect("localhost", 1888, 4) +mqttc.connect("localhost", 1888, 4) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/01-no-clean-session.test b/test/lib/python/01-no-clean-session.test index b006dc7..06387bf 100755 --- a/test/lib/python/01-no-clean-session.test +++ b/test/lib/python/01-no-clean-session.test @@ -1,12 +1,12 @@ #!/usr/bin/python -import mosquitto +import paho.mqtt.client as mqtt -mosq = mosquitto.Mosquitto("01-no-clean-session", False) +mqttc = mqtt.Client("01-no-clean-session", False) run = -1 -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/01-unpwd-set.test b/test/lib/python/01-unpwd-set.test index b55dab8..cbbd992 100755 --- a/test/lib/python/01-unpwd-set.test +++ b/test/lib/python/01-unpwd-set.test @@ -1,13 +1,13 @@ #!/usr/bin/python -import mosquitto +import paho.mqtt.client as mqtt -mosq = mosquitto.Mosquitto("01-unpwd-set") +mqttc = mqtt.Client("01-unpwd-set") run = -1 -mosq.username_pw_set("uname", ";'[08gn=#") -mosq.connect("localhost", 1888) +mqttc.username_pw_set("uname", ";'[08gn=#") +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/01-will-set.test b/test/lib/python/01-will-set.test index 75803a3..8502e7c 100755 --- a/test/lib/python/01-will-set.test +++ b/test/lib/python/01-will-set.test @@ -1,13 +1,13 @@ #!/usr/bin/python -import mosquitto +import paho.mqtt.client as mqtt -mosq = mosquitto.Mosquitto("01-will-set") +mqttc = mqtt.Client("01-will-set") run = -1 -mosq.will_set("topic/on/unexpected/disconnect", "will message", 1, True) -mosq.connect("localhost", 1888) +mqttc.will_set("topic/on/unexpected/disconnect", "will message", 1, True) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/01-will-unpwd-set.test b/test/lib/python/01-will-unpwd-set.test index 0379b36..61b631e 100755 --- a/test/lib/python/01-will-unpwd-set.test +++ b/test/lib/python/01-will-unpwd-set.test @@ -1,14 +1,14 @@ #!/usr/bin/python -import mosquitto +import paho.mqtt.client as mqtt -mosq = mosquitto.Mosquitto("01-will-unpwd-set") +mqttc = mqtt.Client("01-will-unpwd-set") run = -1 -mosq.username_pw_set("oibvvwqw", "#'^2hg9a&nm38*us") -mosq.will_set("will-topic", "will message", 2, False) -mosq.connect("localhost", 1888) +mqttc.username_pw_set("oibvvwqw", "#'^2hg9a&nm38*us") +mqttc.will_set("will-topic", "will message", 2, False) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/02-subscribe-qos0.test b/test/lib/python/02-subscribe-qos0.test index 2f65055..a49f110 100755 --- a/test/lib/python/02-subscribe-qos0.test +++ b/test/lib/python/02-subscribe-qos0.test @@ -7,29 +7,29 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.subscribe("qos0/test", 0) + mqttc.subscribe("qos0/test", 0) -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): obj = rc -def on_subscribe(mosq, obj, mid, granted_qos): - mosq.disconnect() +def on_subscribe(mqttc, obj, mid, granted_qos): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("subscribe-qos0-test", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_subscribe = on_subscribe +mqttc = mqtt.Client("subscribe-qos0-test", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_subscribe = on_subscribe -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/02-subscribe-qos1.test b/test/lib/python/02-subscribe-qos1.test index d00cc13..1060a1e 100755 --- a/test/lib/python/02-subscribe-qos1.test +++ b/test/lib/python/02-subscribe-qos1.test @@ -7,29 +7,29 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.subscribe("qos1/test", 1) + mqttc.subscribe("qos1/test", 1) -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): obj = rc -def on_subscribe(mosq, obj, mid, granted_qos): - mosq.disconnect() +def on_subscribe(mqttc, obj, mid, granted_qos): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("subscribe-qos1-test", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_subscribe = on_subscribe +mqttc = mqtt.Client("subscribe-qos1-test", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_subscribe = on_subscribe -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/02-subscribe-qos2.test b/test/lib/python/02-subscribe-qos2.test index 83a60b9..f09c887 100755 --- a/test/lib/python/02-subscribe-qos2.test +++ b/test/lib/python/02-subscribe-qos2.test @@ -7,29 +7,29 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.subscribe("qos2/test", 2) + mqttc.subscribe("qos2/test", 2) -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): obj = rc -def on_subscribe(mosq, obj, mid, granted_qos): - mosq.disconnect() +def on_subscribe(mqttc, obj, mid, granted_qos): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("subscribe-qos2-test", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_subscribe = on_subscribe +mqttc = mqtt.Client("subscribe-qos2-test", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_subscribe = on_subscribe -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/02-unsubscribe.test b/test/lib/python/02-unsubscribe.test index e3b5ecc..3e2c2c4 100755 --- a/test/lib/python/02-unsubscribe.test +++ b/test/lib/python/02-unsubscribe.test @@ -7,29 +7,29 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.unsubscribe("unsubscribe/test") + mqttc.unsubscribe("unsubscribe/test") -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): obj = rc -def on_unsubscribe(mosq, obj, mid): - mosq.disconnect() +def on_unsubscribe(mqttc, obj, mid): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("unsubscribe-test", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_unsubscribe = on_unsubscribe +mqttc = mqtt.Client("unsubscribe-test", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_unsubscribe = on_unsubscribe -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/03-publish-b2c-qos1.test b/test/lib/python/03-publish-b2c-qos1.test index 3b93c3a..cf2b58a 100755 --- a/test/lib/python/03-publish-b2c-qos1.test +++ b/test/lib/python/03-publish-b2c-qos1.test @@ -7,9 +7,9 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_message(mosq, obj, msg): +def on_message(mqttc, obj, msg): if msg.mid != 123: print("Invalid mid: ("+str(msg.mid)+")") exit(1) @@ -27,19 +27,19 @@ def on_message(mosq, obj, msg): exit(1) exit(0) -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: print("Connect failed ("+str(rc)+")") exit(rc) -mosq = mosquitto.Mosquitto("publish-qos1-test") -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_message = on_message +mqttc = mqtt.Client("publish-qos1-test") +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_message = on_message -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while rc == 0: - rc = mosq.loop() + rc = mqttc.loop() print("rc: "+str(rc)) exit(1) diff --git a/test/lib/python/03-publish-b2c-qos2.test b/test/lib/python/03-publish-b2c-qos2.test index 74e9df0..b88cc9c 100755 --- a/test/lib/python/03-publish-b2c-qos2.test +++ b/test/lib/python/03-publish-b2c-qos2.test @@ -7,10 +7,10 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_message(mosq, obj, msg): +def on_message(mqttc, obj, msg): global run if msg.mid != 13423: print("Invalid mid ("+str(msg.mid)+")") @@ -30,19 +30,19 @@ def on_message(mosq, obj, msg): run = 0 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) run = -1 -mosq = mosquitto.Mosquitto("publish-qos2-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_message = on_message +mqttc = mqtt.Client("publish-qos2-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_message = on_message -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1 and rc == 0: - rc = mosq.loop(0.3) + rc = mqttc.loop(0.3) exit(run) diff --git a/test/lib/python/03-publish-c2b-qos1-disconnect.test b/test/lib/python/03-publish-c2b-qos1-disconnect.test index 5da5623..812aa1e 100755 --- a/test/lib/python/03-publish-c2b-qos1-disconnect.test +++ b/test/lib/python/03-publish-c2b-qos1-disconnect.test @@ -7,42 +7,42 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt sent_mid = -1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global sent_mid if rc != 0: exit(rc) else: if sent_mid == -1: - res = mosq.publish("pub/qos1/test", "message", 1) + res = mqttc.publish("pub/qos1/test", "message", 1) sent_mid = res[1] -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): if rc == 1: - mosq.reconnect() + mqttc.reconnect() else: run = 0 -def on_publish(mosq, obj, mid): +def on_publish(mqttc, obj, mid): global sent_mid if mid == sent_mid: - mosq.disconnect() + mqttc.disconnect() else: exit(1) run = -1 -mosq = mosquitto.Mosquitto("publish-qos1-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos1-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1: - rc = mosq.loop() + rc = mqttc.loop() exit(run) diff --git a/test/lib/python/03-publish-c2b-qos1-timeout.test b/test/lib/python/03-publish-c2b-qos1-timeout.test index 30f1b33..c12957a 100755 --- a/test/lib/python/03-publish-c2b-qos1-timeout.test +++ b/test/lib/python/03-publish-c2b-qos1-timeout.test @@ -7,38 +7,38 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt sent_mid = -1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global sent_mid if rc != 0: exit(rc) else: - res = mosq.publish("pub/qos1/test", "message", 1) + res = mqttc.publish("pub/qos1/test", "message", 1) sent_mid = res[1] -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): run = 0 -def on_publish(mosq, obj, mid): +def on_publish(mqttc, obj, mid): global sent_mid if mid == sent_mid: - mosq.disconnect() + mqttc.disconnect() else: exit(1) run = -1 -mosq = mosquitto.Mosquitto("publish-qos1-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos1-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1 and rc == 0: - rc = mosq.loop() + rc = mqttc.loop() exit(run) diff --git a/test/lib/python/03-publish-c2b-qos2-disconnect.test b/test/lib/python/03-publish-c2b-qos2-disconnect.test index f394c61..ad6d2fd 100755 --- a/test/lib/python/03-publish-c2b-qos2-disconnect.test +++ b/test/lib/python/03-publish-c2b-qos2-disconnect.test @@ -7,38 +7,38 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt first_connection = 1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global first_connection if rc != 0: exit(rc) else: if first_connection == 1: - mosq.publish("pub/qos2/test", "message", 2) + mqttc.publish("pub/qos2/test", "message", 2) first_connection = 0 -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): if rc == 1: - mosq.reconnect() + mqttc.reconnect() else: run = 0 -def on_publish(mosq, obj, mid): - mosq.disconnect() +def on_publish(mqttc, obj, mid): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("publish-qos2-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos2-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1: - rc = mosq.loop() + rc = mqttc.loop() exit(run) diff --git a/test/lib/python/03-publish-c2b-qos2-timeout.test b/test/lib/python/03-publish-c2b-qos2-timeout.test index 940c594..e7a40e4 100755 --- a/test/lib/python/03-publish-c2b-qos2-timeout.test +++ b/test/lib/python/03-publish-c2b-qos2-timeout.test @@ -7,31 +7,31 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.publish("pub/qos2/test", "message", 2) + mqttc.publish("pub/qos2/test", "message", 2) -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): run = 0 -def on_publish(mosq, obj, mid): - mosq.disconnect() +def on_publish(mqttc, obj, mid): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("publish-qos2-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos2-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1 and rc == 0: - rc = mosq.loop() + rc = mqttc.loop() exit(run) diff --git a/test/lib/python/03-publish-qos0-no-payload.test b/test/lib/python/03-publish-qos0-no-payload.test index 7730e52..0cbf894 100755 --- a/test/lib/python/03-publish-qos0-no-payload.test +++ b/test/lib/python/03-publish-qos0-no-payload.test @@ -7,30 +7,30 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt sent_mid = -1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global sent_mid if rc != 0: exit(rc) else: - (res, sent_mid) = mosq.publish("pub/qos0/no-payload/test") + (res, sent_mid) = mqttc.publish("pub/qos0/no-payload/test") -def on_publish(mosq, obj, mid): +def on_publish(mqttc, obj, mid): global sent_mid, run if sent_mid == mid: - mosq.disconnect() + mqttc.disconnect() run = 0 run = -1 -mosq = mosquitto.Mosquitto("publish-qos0-test-np", run) -mosq.on_connect = on_connect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos0-test-np", run) +mqttc.on_connect = on_connect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/03-publish-qos0.test b/test/lib/python/03-publish-qos0.test index c446a08..88e6e5f 100755 --- a/test/lib/python/03-publish-qos0.test +++ b/test/lib/python/03-publish-qos0.test @@ -7,30 +7,30 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt sent_mid = -1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global sent_mid if rc != 0: exit(rc) else: - res = mosq.publish("pub/qos0/test", "message") + res = mqttc.publish("pub/qos0/test", "message") sent_mid = res[1] -def on_publish(mosq, obj, mid): +def on_publish(mqttc, obj, mid): global sent_mid, run if sent_mid == mid: - mosq.disconnect() + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("publish-qos0-test", run) -mosq.on_connect = on_connect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos0-test", run) +mqttc.on_connect = on_connect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/04-retain-qos0.test b/test/lib/python/04-retain-qos0.test index 516538d..eb950b8 100755 --- a/test/lib/python/04-retain-qos0.test +++ b/test/lib/python/04-retain-qos0.test @@ -7,21 +7,21 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.publish("retain/qos0/test", "retained message", 0, True) + mqttc.publish("retain/qos0/test", "retained message", 0, True) run = -1 -mosq = mosquitto.Mosquitto("retain-qos0-test", run) -mosq.on_connect = on_connect +mqttc = mqtt.Client("retain-qos0-test", run) +mqttc.on_connect = on_connect -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/08-ssl-bad-cacert.test b/test/lib/python/08-ssl-bad-cacert.test index 5b8bfb2..404030a 100755 --- a/test/lib/python/08-ssl-bad-cacert.test +++ b/test/lib/python/08-ssl-bad-cacert.test @@ -7,16 +7,16 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt if sys.version < '2.7': print("WARNING: SSL/TLS not supported on Python 2.6") exit(0) rc = 1 -mosq = mosquitto.Mosquitto("08-ssl-bad-cacert") +mqttc = mqtt.Client("08-ssl-bad-cacert") try: - mosq.tls_set("this/file/doesnt/exist") + mqttc.tls_set("this/file/doesnt/exist") except IOError as err: rc = 0 diff --git a/test/lib/python/08-ssl-connect-cert-auth.test b/test/lib/python/08-ssl-connect-cert-auth.test index d2c59c6..95ec548 100755 --- a/test/lib/python/08-ssl-connect-cert-auth.test +++ b/test/lib/python/08-ssl-connect-cert-auth.test @@ -7,31 +7,31 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt if sys.version < '2.7': print("WARNING: SSL/TLS not supported on Python 2.6") exit(0) -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.disconnect() + mqttc.disconnect() -def on_disconnect(mosq, obj, rc): - mosq.loop() +def on_disconnect(mqttc, obj, rc): + mqttc.loop() obj = rc run = -1 -mosq = mosquitto.Mosquitto("08-ssl-connect-crt-auth", run) -mosq.tls_set("../ssl/test-ca.crt", "../ssl/client.crt", "../ssl/client.key") -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect +mqttc = mqtt.Client("08-ssl-connect-crt-auth", run) +mqttc.tls_set("../ssl/test-ca.crt", "../ssl/client.crt", "../ssl/client.key") +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/08-ssl-connect-no-auth.test b/test/lib/python/08-ssl-connect-no-auth.test index 6baea37..4ce73e3 100755 --- a/test/lib/python/08-ssl-connect-no-auth.test +++ b/test/lib/python/08-ssl-connect-no-auth.test @@ -7,31 +7,31 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt if sys.version < '2.7': print("WARNING: SSL/TLS not supported on Python 2.6") exit(0) -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.disconnect() + mqttc.disconnect() -def on_disconnect(mosq, obj, rc): - mosq.loop() +def on_disconnect(mqttc, obj, rc): + mqttc.loop() obj = rc run = -1 -mosq = mosquitto.Mosquitto("08-ssl-connect-no-auth", run) -mosq.tls_set("../ssl/test-ca.crt") -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect +mqttc = mqtt.Client("08-ssl-connect-no-auth", run) +mqttc.tls_set("../ssl/test-ca.crt") +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python/09-util-topic-matching.test b/test/lib/python/09-util-topic-matching.test index 11fd81b..c546e20 100755 --- a/test/lib/python/09-util-topic-matching.test +++ b/test/lib/python/09-util-topic-matching.test @@ -1,61 +1,34 @@ #!/usr/bin/python -# Copyright (c) 2012 Roger Light -# All rights reserved. -# -# Redistribution and use in source and binary forms, with or without -# modification, are permitted provided that the following conditions are met: -# -# 1. Redistributions of source code must retain the above copyright notice, -# this list of conditions and the following disclaimer. -# 2. Redistributions in binary form must reproduce the above copyright -# notice, this list of conditions and the following disclaimer in the -# documentation and/or other materials provided with the distribution. -# 3. Neither the name of mosquitto nor the names of its -# contributors may be used to endorse or promote products derived from -# this software without specific prior written permission. -# -# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" -# AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE -# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE -# ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE -# LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR -# CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF -# SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS -# INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN -# CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) -# ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE -# POSSIBILITY OF SUCH DAMAGE. - -import mosquitto +import paho.mqtt.client as mqtt import sys -if mosquitto.topic_matches_sub("foo/bar", "foo/bar") == False: +if mqtt.topic_matches_sub("foo/bar", "foo/bar") == False: print("ERROR: foo/bar : foo/bar") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+", "foo/bar") == False: +if mqtt.topic_matches_sub("foo/+", "foo/bar") == False: print("ERROR: foo/+ : foo/bar") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+/baz", "foo/bar/baz") == False: +if mqtt.topic_matches_sub("foo/+/baz", "foo/bar/baz") == False: print("ERROR: foo/+/baz : foo/bar/baz") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+/#", "foo/bar/baz") == False: +if mqtt.topic_matches_sub("foo/+/#", "foo/bar/baz") == False: print("ERROR: foo/+/# : foo/bar/baz") sys.exit(1) -if mosquitto.topic_matches_sub("#", "foo/bar/baz") == False: +if mqtt.topic_matches_sub("#", "foo/bar/baz") == False: print("ERROR: # : foo/bar/baz") sys.exit(1) -if mosquitto.topic_matches_sub("foo/bar", "foo") == True: +if mqtt.topic_matches_sub("foo/bar", "foo") == True: print("ERROR: foo/bar : foo") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+", "foo/bar/baz") == True: +if mqtt.topic_matches_sub("foo/+", "foo/bar/baz") == True: print("ERROR: foo/+ : foo/bar/baz") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+/baz", "foo/bar/bar") == True: +if mqtt.topic_matches_sub("foo/+/baz", "foo/bar/bar") == True: print("ERROR: foo/+/baz : foo/bar/bar") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+/#", "fo2/bar/baz") == True: +if mqtt.topic_matches_sub("foo/+/#", "fo2/bar/baz") == True: print("ERROR: foo/+/# : foo/bar/baz") sys.exit(1) diff --git a/test/lib/python3/01-con-discon-success.test b/test/lib/python3/01-con-discon-success.test index e517856..188aa66 100755 --- a/test/lib/python3/01-con-discon-success.test +++ b/test/lib/python3/01-con-discon-success.test @@ -7,27 +7,27 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.disconnect() + mqttc.disconnect() -def on_disconnect(mosq, obj, rc): - mosq.loop() +def on_disconnect(mqttc, obj, rc): + mqttc.loop() obj = rc run = -1 -mosq = mosquitto.Mosquitto("01-con-discon-success", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect +mqttc = mqtt.Client("01-con-discon-success", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/01-keepalive-pingreq.test b/test/lib/python3/01-keepalive-pingreq.test index f7b0f30..4148df7 100755 --- a/test/lib/python3/01-keepalive-pingreq.test +++ b/test/lib/python3/01-keepalive-pingreq.test @@ -7,19 +7,19 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) run = -1 -mosq = mosquitto.Mosquitto("01-keepalive-pingreq") -mosq.on_connect = on_connect +mqttc = mqtt.Client("01-keepalive-pingreq") +mqttc.on_connect = on_connect -mosq.connect("localhost", 1888, 4) +mqttc.connect("localhost", 1888, 4) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/01-no-clean-session.test b/test/lib/python3/01-no-clean-session.test index 17d1aad..d1c9a21 100755 --- a/test/lib/python3/01-no-clean-session.test +++ b/test/lib/python3/01-no-clean-session.test @@ -1,12 +1,12 @@ #!/usr/bin/python3 -import mosquitto +import paho.mqtt.client as mqtt -mosq = mosquitto.Mosquitto("01-no-clean-session", False) +mqttc = mqtt.Client("01-no-clean-session", False) run = -1 -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/01-unpwd-set.test b/test/lib/python3/01-unpwd-set.test index 593636f..2ae97c7 100755 --- a/test/lib/python3/01-unpwd-set.test +++ b/test/lib/python3/01-unpwd-set.test @@ -1,13 +1,13 @@ #!/usr/bin/python3 -import mosquitto +import paho.mqtt.client as mqtt -mosq = mosquitto.Mosquitto("01-unpwd-set") +mqttc = mqtt.Client("01-unpwd-set") run = -1 -mosq.username_pw_set("uname", ";'[08gn=#") -mosq.connect("localhost", 1888) +mqttc.username_pw_set("uname", ";'[08gn=#") +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/01-will-set.test b/test/lib/python3/01-will-set.test index 2aae62f..6b0b76e 100755 --- a/test/lib/python3/01-will-set.test +++ b/test/lib/python3/01-will-set.test @@ -1,13 +1,13 @@ #!/usr/bin/python3 -import mosquitto +import paho.mqtt.client as mqtt -mosq = mosquitto.Mosquitto("01-will-set") +mqttc = mqtt.Client("01-will-set") run = -1 -mosq.will_set("topic/on/unexpected/disconnect", "will message", 1, True) -mosq.connect("localhost", 1888) +mqttc.will_set("topic/on/unexpected/disconnect", "will message", 1, True) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/01-will-unpwd-set.test b/test/lib/python3/01-will-unpwd-set.test index 290fe77..370bb80 100755 --- a/test/lib/python3/01-will-unpwd-set.test +++ b/test/lib/python3/01-will-unpwd-set.test @@ -1,14 +1,14 @@ #!/usr/bin/python3 -import mosquitto +import paho.mqtt.client as mqtt -mosq = mosquitto.Mosquitto("01-will-unpwd-set") +mqttc = mqtt.Client("01-will-unpwd-set") run = -1 -mosq.username_pw_set("oibvvwqw", "#'^2hg9a&nm38*us") -mosq.will_set("will-topic", "will message", 2, False) -mosq.connect("localhost", 1888) +mqttc.username_pw_set("oibvvwqw", "#'^2hg9a&nm38*us") +mqttc.will_set("will-topic", "will message", 2, False) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/02-subscribe-qos0.test b/test/lib/python3/02-subscribe-qos0.test index 2d5b721..b976978 100755 --- a/test/lib/python3/02-subscribe-qos0.test +++ b/test/lib/python3/02-subscribe-qos0.test @@ -7,29 +7,29 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.subscribe("qos0/test", 0) + mqttc.subscribe("qos0/test", 0) -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): obj = rc -def on_subscribe(mosq, obj, mid, granted_qos): - mosq.disconnect() +def on_subscribe(mqttc, obj, mid, granted_qos): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("subscribe-qos0-test", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_subscribe = on_subscribe +mqttc = mqtt.Client("subscribe-qos0-test", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_subscribe = on_subscribe -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/02-subscribe-qos1.test b/test/lib/python3/02-subscribe-qos1.test index aebda7d..37c35b0 100755 --- a/test/lib/python3/02-subscribe-qos1.test +++ b/test/lib/python3/02-subscribe-qos1.test @@ -7,29 +7,29 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.subscribe("qos1/test", 1) + mqttc.subscribe("qos1/test", 1) -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): obj = rc -def on_subscribe(mosq, obj, mid, granted_qos): - mosq.disconnect() +def on_subscribe(mqttc, obj, mid, granted_qos): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("subscribe-qos1-test", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_subscribe = on_subscribe +mqttc = mqtt.Client("subscribe-qos1-test", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_subscribe = on_subscribe -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/02-subscribe-qos2.test b/test/lib/python3/02-subscribe-qos2.test index 1fb5e2c..4592d79 100755 --- a/test/lib/python3/02-subscribe-qos2.test +++ b/test/lib/python3/02-subscribe-qos2.test @@ -7,29 +7,29 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.subscribe("qos2/test", 2) + mqttc.subscribe("qos2/test", 2) -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): obj = rc -def on_subscribe(mosq, obj, mid, granted_qos): - mosq.disconnect() +def on_subscribe(mqttc, obj, mid, granted_qos): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("subscribe-qos2-test", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_subscribe = on_subscribe +mqttc = mqtt.Client("subscribe-qos2-test", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_subscribe = on_subscribe -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/02-unsubscribe.test b/test/lib/python3/02-unsubscribe.test index 12a85b6..f4eb457 100755 --- a/test/lib/python3/02-unsubscribe.test +++ b/test/lib/python3/02-unsubscribe.test @@ -7,29 +7,29 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.unsubscribe("unsubscribe/test") + mqttc.unsubscribe("unsubscribe/test") -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): obj = rc -def on_unsubscribe(mosq, obj, mid): - mosq.disconnect() +def on_unsubscribe(mqttc, obj, mid): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("unsubscribe-test", run) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_unsubscribe = on_unsubscribe +mqttc = mqtt.Client("unsubscribe-test", run) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_unsubscribe = on_unsubscribe -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/03-publish-b2c-qos1.test b/test/lib/python3/03-publish-b2c-qos1.test index 56252ed..09c7189 100755 --- a/test/lib/python3/03-publish-b2c-qos1.test +++ b/test/lib/python3/03-publish-b2c-qos1.test @@ -7,9 +7,9 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_message(mosq, obj, msg): +def on_message(mqttc, obj, msg): if msg.mid != 123: print("Invalid mid: ("+str(msg.mid)+")") exit(1) @@ -27,19 +27,19 @@ def on_message(mosq, obj, msg): exit(1) exit(0) -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: print("Connect failed ("+str(rc)+")") exit(rc) -mosq = mosquitto.Mosquitto("publish-qos1-test") -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_message = on_message +mqttc = mqtt.Client("publish-qos1-test") +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_message = on_message -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while rc == 0: - rc = mosq.loop() + rc = mqttc.loop() print("rc: "+str(rc)) exit(1) diff --git a/test/lib/python3/03-publish-b2c-qos2.test b/test/lib/python3/03-publish-b2c-qos2.test index be0ff08..a71e7c4 100755 --- a/test/lib/python3/03-publish-b2c-qos2.test +++ b/test/lib/python3/03-publish-b2c-qos2.test @@ -7,10 +7,10 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_message(mosq, obj, msg): +def on_message(mqttc, obj, msg): global run if msg.mid != 13423: print("Invalid mid ("+str(msg.mid)+")") @@ -30,19 +30,19 @@ def on_message(mosq, obj, msg): run = 0 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) run = -1 -mosq = mosquitto.Mosquitto("publish-qos2-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_message = on_message +mqttc = mqtt.Client("publish-qos2-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_message = on_message -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1 and rc == 0: - rc = mosq.loop(0.3) + rc = mqttc.loop(0.3) exit(run) diff --git a/test/lib/python3/03-publish-c2b-qos1-disconnect.test b/test/lib/python3/03-publish-c2b-qos1-disconnect.test index 5da5623..812aa1e 100755 --- a/test/lib/python3/03-publish-c2b-qos1-disconnect.test +++ b/test/lib/python3/03-publish-c2b-qos1-disconnect.test @@ -7,42 +7,42 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt sent_mid = -1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global sent_mid if rc != 0: exit(rc) else: if sent_mid == -1: - res = mosq.publish("pub/qos1/test", "message", 1) + res = mqttc.publish("pub/qos1/test", "message", 1) sent_mid = res[1] -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): if rc == 1: - mosq.reconnect() + mqttc.reconnect() else: run = 0 -def on_publish(mosq, obj, mid): +def on_publish(mqttc, obj, mid): global sent_mid if mid == sent_mid: - mosq.disconnect() + mqttc.disconnect() else: exit(1) run = -1 -mosq = mosquitto.Mosquitto("publish-qos1-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos1-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1: - rc = mosq.loop() + rc = mqttc.loop() exit(run) diff --git a/test/lib/python3/03-publish-c2b-qos1-timeout.test b/test/lib/python3/03-publish-c2b-qos1-timeout.test index 3283c74..9576f6d 100755 --- a/test/lib/python3/03-publish-c2b-qos1-timeout.test +++ b/test/lib/python3/03-publish-c2b-qos1-timeout.test @@ -7,38 +7,38 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt sent_mid = -1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global sent_mid if rc != 0: exit(rc) else: - res = mosq.publish("pub/qos1/test", "message", 1) + res = mqttc.publish("pub/qos1/test", "message", 1) sent_mid = res[1] -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): run = 0 -def on_publish(mosq, obj, mid): +def on_publish(mqttc, obj, mid): global sent_mid if mid == sent_mid: - mosq.disconnect() + mqttc.disconnect() else: exit(1) run = -1 -mosq = mosquitto.Mosquitto("publish-qos1-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos1-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1 and rc == 0: - rc = mosq.loop() + rc = mqttc.loop() exit(run) diff --git a/test/lib/python3/03-publish-c2b-qos2-disconnect.test b/test/lib/python3/03-publish-c2b-qos2-disconnect.test index 0d97ec5..09bc1e3 100755 --- a/test/lib/python3/03-publish-c2b-qos2-disconnect.test +++ b/test/lib/python3/03-publish-c2b-qos2-disconnect.test @@ -7,38 +7,38 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt first_connection = 1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global first_connection if rc != 0: exit(rc) else: if first_connection == 1: - mosq.publish("pub/qos2/test", "message", 2) + mqttc.publish("pub/qos2/test", "message", 2) first_connection = 0 -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): if rc == 1: - mosq.reconnect() + mqttc.reconnect() else: run = 0 -def on_publish(mosq, obj, mid): - mosq.disconnect() +def on_publish(mqttc, obj, mid): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("publish-qos2-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos2-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1: - rc = mosq.loop() + rc = mqttc.loop() exit(run) diff --git a/test/lib/python3/03-publish-c2b-qos2-timeout.test b/test/lib/python3/03-publish-c2b-qos2-timeout.test index 13c7baa..dc601dc 100755 --- a/test/lib/python3/03-publish-c2b-qos2-timeout.test +++ b/test/lib/python3/03-publish-c2b-qos2-timeout.test @@ -7,31 +7,31 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.publish("pub/qos2/test", "message", 2) + mqttc.publish("pub/qos2/test", "message", 2) -def on_disconnect(mosq, obj, rc): +def on_disconnect(mqttc, obj, rc): run = 0 -def on_publish(mosq, obj, mid): - mosq.disconnect() +def on_publish(mqttc, obj, mid): + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("publish-qos2-test", run) -mosq.message_retry_set(3) -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos2-test", run) +mqttc.message_retry_set(3) +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) rc = 0 while run == -1 and rc == 0: - rc = mosq.loop() + rc = mqttc.loop() exit(run) diff --git a/test/lib/python3/03-publish-qos0-no-payload.test b/test/lib/python3/03-publish-qos0-no-payload.test index 874988c..2440a5e 100755 --- a/test/lib/python3/03-publish-qos0-no-payload.test +++ b/test/lib/python3/03-publish-qos0-no-payload.test @@ -7,30 +7,30 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt sent_mid = -1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global sent_mid if rc != 0: exit(rc) else: - (res, sent_mid) = mosq.publish("pub/qos0/no-payload/test") + (res, sent_mid) = mqttc.publish("pub/qos0/no-payload/test") -def on_publish(mosq, obj, mid): +def on_publish(mqttc, obj, mid): global sent_mid, run if sent_mid == mid: - mosq.disconnect() + mqttc.disconnect() run = 0 run = -1 -mosq = mosquitto.Mosquitto("publish-qos0-test-np", run) -mosq.on_connect = on_connect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos0-test-np", run) +mqttc.on_connect = on_connect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/03-publish-qos0.test b/test/lib/python3/03-publish-qos0.test index f3474fd..e911da3 100755 --- a/test/lib/python3/03-publish-qos0.test +++ b/test/lib/python3/03-publish-qos0.test @@ -7,30 +7,30 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt sent_mid = -1 -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): global sent_mid if rc != 0: exit(rc) else: - res = mosq.publish("pub/qos0/test", "message") + res = mqttc.publish("pub/qos0/test", "message") sent_mid = res[1] -def on_publish(mosq, obj, mid): +def on_publish(mqttc, obj, mid): global sent_mid, run if sent_mid == mid: - mosq.disconnect() + mqttc.disconnect() run = -1 -mosq = mosquitto.Mosquitto("publish-qos0-test", run) -mosq.on_connect = on_connect -mosq.on_publish = on_publish +mqttc = mqtt.Client("publish-qos0-test", run) +mqttc.on_connect = on_connect +mqttc.on_publish = on_publish -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/04-retain-qos0.test b/test/lib/python3/04-retain-qos0.test index 7bf6c85..5a74ddc 100755 --- a/test/lib/python3/04-retain-qos0.test +++ b/test/lib/python3/04-retain-qos0.test @@ -7,21 +7,21 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.publish("retain/qos0/test", "retained message", 0, True) + mqttc.publish("retain/qos0/test", "retained message", 0, True) run = -1 -mosq = mosquitto.Mosquitto("retain-qos0-test", run) -mosq.on_connect = on_connect +mqttc = mqtt.Client("retain-qos0-test", run) +mqttc.on_connect = on_connect -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/08-ssl-bad-cacert.test b/test/lib/python3/08-ssl-bad-cacert.test index 5b8bfb2..404030a 100755 --- a/test/lib/python3/08-ssl-bad-cacert.test +++ b/test/lib/python3/08-ssl-bad-cacert.test @@ -7,16 +7,16 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt if sys.version < '2.7': print("WARNING: SSL/TLS not supported on Python 2.6") exit(0) rc = 1 -mosq = mosquitto.Mosquitto("08-ssl-bad-cacert") +mqttc = mqtt.Client("08-ssl-bad-cacert") try: - mosq.tls_set("this/file/doesnt/exist") + mqttc.tls_set("this/file/doesnt/exist") except IOError as err: rc = 0 diff --git a/test/lib/python3/08-ssl-connect-cert-auth.test b/test/lib/python3/08-ssl-connect-cert-auth.test index f7dbadf..605d1a6 100755 --- a/test/lib/python3/08-ssl-connect-cert-auth.test +++ b/test/lib/python3/08-ssl-connect-cert-auth.test @@ -7,28 +7,28 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.disconnect() + mqttc.disconnect() -def on_disconnect(mosq, obj, rc): - mosq.loop() +def on_disconnect(mqttc, obj, rc): + mqttc.loop() obj = rc run = -1 -mosq = mosquitto.Mosquitto("08-ssl-connect-crt-auth", run) -mosq.tls_set("../ssl/test-ca.crt", "../ssl/client.crt", "../ssl/client.key") -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect +mqttc = mqtt.Client("08-ssl-connect-crt-auth", run) +mqttc.tls_set("../ssl/test-ca.crt", "../ssl/client.crt", "../ssl/client.key") +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/08-ssl-connect-no-auth.test b/test/lib/python3/08-ssl-connect-no-auth.test index 1fd5aec..a46b4a0 100755 --- a/test/lib/python3/08-ssl-connect-no-auth.test +++ b/test/lib/python3/08-ssl-connect-no-auth.test @@ -7,28 +7,28 @@ import sys import time from struct import * -import mosquitto +import paho.mqtt.client as mqtt -def on_connect(mosq, obj, rc): +def on_connect(mqttc, obj, rc): if rc != 0: exit(rc) else: - mosq.disconnect() + mqttc.disconnect() -def on_disconnect(mosq, obj, rc): - mosq.loop() +def on_disconnect(mqttc, obj, rc): + mqttc.loop() obj = rc run = -1 -mosq = mosquitto.Mosquitto("08-ssl-connect-no-auth", run) -mosq.tls_set("../ssl/test-ca.crt") -mosq.on_connect = on_connect -mosq.on_disconnect = on_disconnect +mqttc = mqtt.Client("08-ssl-connect-no-auth", run) +mqttc.tls_set("../ssl/test-ca.crt") +mqttc.on_connect = on_connect +mqttc.on_disconnect = on_disconnect -mosq.connect("localhost", 1888) +mqttc.connect("localhost", 1888) while run == -1: - mosq.loop() + mqttc.loop() exit(run) diff --git a/test/lib/python3/09-util-topic-matching.test b/test/lib/python3/09-util-topic-matching.test index 11fd81b..c546e20 100755 --- a/test/lib/python3/09-util-topic-matching.test +++ b/test/lib/python3/09-util-topic-matching.test @@ -1,61 +1,34 @@ #!/usr/bin/python -# Copyright (c) 2012 Roger Light -# All rights reserved. -# -# Redistribution and use in source and binary forms, with or without -# modification, are permitted provided that the following conditions are met: -# -# 1. Redistributions of source code must retain the above copyright notice, -# this list of conditions and the following disclaimer. -# 2. Redistributions in binary form must reproduce the above copyright -# notice, this list of conditions and the following disclaimer in the -# documentation and/or other materials provided with the distribution. -# 3. Neither the name of mosquitto nor the names of its -# contributors may be used to endorse or promote products derived from -# this software without specific prior written permission. -# -# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" -# AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE -# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE -# ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE -# LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR -# CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF -# SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS -# INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN -# CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) -# ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE -# POSSIBILITY OF SUCH DAMAGE. - -import mosquitto +import paho.mqtt.client as mqtt import sys -if mosquitto.topic_matches_sub("foo/bar", "foo/bar") == False: +if mqtt.topic_matches_sub("foo/bar", "foo/bar") == False: print("ERROR: foo/bar : foo/bar") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+", "foo/bar") == False: +if mqtt.topic_matches_sub("foo/+", "foo/bar") == False: print("ERROR: foo/+ : foo/bar") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+/baz", "foo/bar/baz") == False: +if mqtt.topic_matches_sub("foo/+/baz", "foo/bar/baz") == False: print("ERROR: foo/+/baz : foo/bar/baz") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+/#", "foo/bar/baz") == False: +if mqtt.topic_matches_sub("foo/+/#", "foo/bar/baz") == False: print("ERROR: foo/+/# : foo/bar/baz") sys.exit(1) -if mosquitto.topic_matches_sub("#", "foo/bar/baz") == False: +if mqtt.topic_matches_sub("#", "foo/bar/baz") == False: print("ERROR: # : foo/bar/baz") sys.exit(1) -if mosquitto.topic_matches_sub("foo/bar", "foo") == True: +if mqtt.topic_matches_sub("foo/bar", "foo") == True: print("ERROR: foo/bar : foo") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+", "foo/bar/baz") == True: +if mqtt.topic_matches_sub("foo/+", "foo/bar/baz") == True: print("ERROR: foo/+ : foo/bar/baz") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+/baz", "foo/bar/bar") == True: +if mqtt.topic_matches_sub("foo/+/baz", "foo/bar/bar") == True: print("ERROR: foo/+/baz : foo/bar/bar") sys.exit(1) -if mosquitto.topic_matches_sub("foo/+/#", "fo2/bar/baz") == True: +if mqtt.topic_matches_sub("foo/+/#", "fo2/bar/baz") == True: print("ERROR: foo/+/# : foo/bar/baz") sys.exit(1) diff --git a/test/mosq_test.py b/test/paho_test.py similarity index 100% rename from test/mosq_test.py rename to test/paho_test.py -- 2.39.5