mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

changed localhost to 127.0.0.1 to fix Travis CI test

pull/8/head
mi3z 2017-11-17 10:11:26 +01:00
rodzic 05b86e2f1e
commit 465b2cfc42
2 zmienionych plików z 31 dodań i 31 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

38
tests/test_broker.py
Wyświetl plik

@ -39,7 +39,7 @@ test_config = {
'listeners': { 'listeners': {
'default': { 'default': {
'type': 'tcp', 'type': 'tcp',
'bind': 'localhost:1883', 'bind': '127.0.0.1:1883',
'max_connections': 10 'max_connections': 10
}, },
}, },
@ -102,7 +102,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
client = MQTTClient() client = MQTTClient()
ret = yield from client.connect('mqtt://localhost/') ret = yield from client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
self.assertIn(client.session.client_id, broker._sessions) self.assertIn(client.session.client_id, broker._sessions)
yield from client.disconnect() yield from client.disconnect()
@ -133,7 +133,7 @@ class BrokerTest(unittest.TestCase):
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
conn_reader, conn_writer = \ conn_reader, conn_writer = \
yield from asyncio.open_connection('localhost', 1883, loop=self.loop) yield from asyncio.open_connection('127.0.0.1', 1883, loop=self.loop)
reader = StreamReaderAdapter(conn_reader) reader = StreamReaderAdapter(conn_reader)
writer = StreamWriterAdapter(conn_writer) writer = StreamWriterAdapter(conn_writer)
@ -181,7 +181,7 @@ class BrokerTest(unittest.TestCase):
client = MQTTClient(client_id="", config={'auto_reconnect': False}) client = MQTTClient(client_id="", config={'auto_reconnect': False})
return_code = None return_code = None
try: try:
yield from client.connect('mqtt://localhost/', cleansession=False) yield from client.connect('mqtt://127.0.0.1/', cleansession=False)
except ConnectException as ce: except ConnectException as ce:
return_code = ce.return_code return_code = ce.return_code
self.assertEqual(return_code, 0x02) self.assertEqual(return_code, 0x02)
@ -207,7 +207,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
client = MQTTClient() client = MQTTClient()
ret = yield from client.connect('mqtt://localhost/') ret = yield from client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
yield from client.subscribe([('/topic', QOS_0)]) yield from client.subscribe([('/topic', QOS_0)])
@ -245,7 +245,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
client = MQTTClient() client = MQTTClient()
ret = yield from client.connect('mqtt://localhost/') ret = yield from client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
yield from client.subscribe([('/topic', QOS_0)]) yield from client.subscribe([('/topic', QOS_0)])
@ -289,7 +289,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
client = MQTTClient() client = MQTTClient()
ret = yield from client.connect('mqtt://localhost/') ret = yield from client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
yield from client.subscribe([('/topic', QOS_0)]) yield from client.subscribe([('/topic', QOS_0)])
@ -335,7 +335,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
pub_client = MQTTClient() pub_client = MQTTClient()
ret = yield from pub_client.connect('mqtt://localhost/') ret = yield from pub_client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
ret_message = yield from pub_client.publish('/topic', b'data', QOS_0) ret_message = yield from pub_client.publish('/topic', b'data', QOS_0)
@ -370,7 +370,7 @@ class BrokerTest(unittest.TestCase):
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
conn_reader, conn_writer = \ conn_reader, conn_writer = \
yield from asyncio.open_connection('localhost', 1883, loop=self.loop) yield from asyncio.open_connection('127.0.0.1', 1883, loop=self.loop)
reader = StreamReaderAdapter(conn_reader) reader = StreamReaderAdapter(conn_reader)
writer = StreamWriterAdapter(conn_writer) writer = StreamWriterAdapter(conn_writer)
@ -421,7 +421,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
pub_client = MQTTClient() pub_client = MQTTClient()
ret = yield from pub_client.connect('mqtt://localhost/') ret = yield from pub_client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
yield from pub_client.publish('/+', b'data', QOS_0) yield from pub_client.publish('/+', b'data', QOS_0)
@ -449,7 +449,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
pub_client = MQTTClient() pub_client = MQTTClient()
ret = yield from pub_client.connect('mqtt://localhost/') ret = yield from pub_client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
ret_message = yield from pub_client.publish('/topic', bytearray(b'\x99' * 256 * 1024), QOS_2) ret_message = yield from pub_client.publish('/topic', bytearray(b'\x99' * 256 * 1024), QOS_2)
@ -484,7 +484,7 @@ class BrokerTest(unittest.TestCase):
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
pub_client = MQTTClient() pub_client = MQTTClient()
ret = yield from pub_client.connect('mqtt://localhost/') ret = yield from pub_client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
yield from pub_client.publish('/topic', b'data', QOS_0, retain=True) yield from pub_client.publish('/topic', b'data', QOS_0, retain=True)
yield from pub_client.disconnect() yield from pub_client.disconnect()
@ -516,7 +516,7 @@ class BrokerTest(unittest.TestCase):
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
pub_client = MQTTClient() pub_client = MQTTClient()
ret = yield from pub_client.connect('mqtt://localhost/') ret = yield from pub_client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
yield from pub_client.publish('/topic', b'', QOS_0, retain=True) yield from pub_client.publish('/topic', b'', QOS_0, retain=True)
yield from pub_client.disconnect() yield from pub_client.disconnect()
@ -542,7 +542,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
sub_client = MQTTClient() sub_client = MQTTClient()
yield from sub_client.connect('mqtt://localhost') yield from sub_client.connect('mqtt://127.0.0.1')
ret = yield from sub_client.subscribe([('/qos0', QOS_0), ('/qos1', QOS_1), ('/qos2', QOS_2)]) ret = yield from sub_client.subscribe([('/qos0', QOS_0), ('/qos1', QOS_1), ('/qos2', QOS_2)])
self.assertEqual(ret, [QOS_0, QOS_1, QOS_2]) self.assertEqual(ret, [QOS_0, QOS_1, QOS_2])
@ -578,7 +578,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
sub_client = MQTTClient() sub_client = MQTTClient()
yield from sub_client.connect('mqtt://localhost') yield from sub_client.connect('mqtt://127.0.0.1')
ret = yield from sub_client.subscribe( ret = yield from sub_client.subscribe(
[('+', QOS_0), ('+/tennis/#', QOS_0), ('sport+', QOS_0), ('sport/+/player1', QOS_0)]) [('+', QOS_0), ('+/tennis/#', QOS_0), ('sport+', QOS_0), ('sport/+/player1', QOS_0)])
self.assertEqual(ret, [QOS_0, QOS_0, 0x80, QOS_0]) self.assertEqual(ret, [QOS_0, QOS_0, 0x80, QOS_0])
@ -606,7 +606,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
sub_client = MQTTClient() sub_client = MQTTClient()
yield from sub_client.connect('mqtt://localhost') yield from sub_client.connect('mqtt://127.0.0.1')
ret = yield from sub_client.subscribe([('#', QOS_0)]) ret = yield from sub_client.subscribe([('#', QOS_0)])
self.assertEqual(ret, [QOS_0]) self.assertEqual(ret, [QOS_0])
@ -644,7 +644,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
sub_client = MQTTClient() sub_client = MQTTClient()
yield from sub_client.connect('mqtt://localhost') yield from sub_client.connect('mqtt://127.0.0.1')
ret = yield from sub_client.subscribe([('+/monitor/Clients', QOS_0)]) ret = yield from sub_client.subscribe([('+/monitor/Clients', QOS_0)])
self.assertEqual(ret, [QOS_0]) self.assertEqual(ret, [QOS_0])
@ -682,7 +682,7 @@ class BrokerTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
self.assertTrue(broker.transitions.is_started()) self.assertTrue(broker.transitions.is_started())
sub_client = MQTTClient() sub_client = MQTTClient()
yield from sub_client.connect('mqtt://localhost', cleansession=False) yield from sub_client.connect('mqtt://127.0.0.1', cleansession=False)
ret = yield from sub_client.subscribe([('/qos0', QOS_0), ('/qos1', QOS_1), ('/qos2', QOS_2)]) ret = yield from sub_client.subscribe([('/qos0', QOS_0), ('/qos1', QOS_1), ('/qos2', QOS_2)])
self.assertEqual(ret, [QOS_0, QOS_1, QOS_2]) self.assertEqual(ret, [QOS_0, QOS_1, QOS_2])
yield from sub_client.disconnect() yield from sub_client.disconnect()
@ -716,7 +716,7 @@ class BrokerTest(unittest.TestCase):
@asyncio.coroutine @asyncio.coroutine
def _client_publish(self, topic, data, qos, retain=False): def _client_publish(self, topic, data, qos, retain=False):
pub_client = MQTTClient() pub_client = MQTTClient()
ret = yield from pub_client.connect('mqtt://localhost/') ret = yield from pub_client.connect('mqtt://127.0.0.1/')
self.assertEqual(ret, 0) self.assertEqual(ret, 0)
ret = yield from pub_client.publish(topic, data, qos, retain) ret = yield from pub_client.publish(topic, data, qos, retain)
yield from pub_client.disconnect() yield from pub_client.disconnect()

24
tests/test_client.py
Wyświetl plik

@ -17,17 +17,17 @@ broker_config = {
'listeners': { 'listeners': {
'default': { 'default': {
'type': 'tcp', 'type': 'tcp',
'bind': 'localhost:1883', 'bind': '127.0.0.1:1883',
'max_connections': 10 'max_connections': 10
}, },
'ws': { 'ws': {
'type': 'ws', 'type': 'ws',
'bind': 'localhost:8080', 'bind': '127.0.0.1:8080',
'max_connections': 10 'max_connections': 10
}, },
'wss': { 'wss': {
'type': 'ws', 'type': 'ws',
'bind': 'localhost:8081', 'bind': '127.0.0.1:8081',
'max_connections': 10 'max_connections': 10
}, },
}, },
@ -87,7 +87,7 @@ class MQTTClientTest(unittest.TestCase):
try: try:
config = {'auto_reconnect': False} config = {'auto_reconnect': False}
client = MQTTClient(config=config) client = MQTTClient(config=config)
yield from client.connect('mqtt://localhost/') yield from client.connect('mqtt://127.0.0.1/')
except ConnectException as e: except ConnectException as e:
future.set_result(True) future.set_result(True)
@ -103,7 +103,7 @@ class MQTTClientTest(unittest.TestCase):
broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins")
yield from broker.start() yield from broker.start()
client = MQTTClient() client = MQTTClient()
yield from client.connect('ws://localhost:8080/') yield from client.connect('ws://127.0.0.1:8080/')
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
yield from client.disconnect() yield from client.disconnect()
yield from broker.shutdown() yield from broker.shutdown()
@ -124,7 +124,7 @@ class MQTTClientTest(unittest.TestCase):
yield from broker.start() yield from broker.start()
client = MQTTClient() client = MQTTClient()
ca = os.path.join(os.path.dirname(os.path.realpath(__file__)), 'mosquitto.org.crt') ca = os.path.join(os.path.dirname(os.path.realpath(__file__)), 'mosquitto.org.crt')
yield from client.connect('ws://localhost:8081/', cafile=ca) yield from client.connect('ws://127.0.0.1:8081/', cafile=ca)
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
yield from client.disconnect() yield from client.disconnect()
yield from broker.shutdown() yield from broker.shutdown()
@ -144,7 +144,7 @@ class MQTTClientTest(unittest.TestCase):
broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins")
yield from broker.start() yield from broker.start()
client = MQTTClient() client = MQTTClient()
yield from client.connect('mqtt://localhost/') yield from client.connect('mqtt://127.0.0.1/')
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
yield from client.ping() yield from client.ping()
yield from client.disconnect() yield from client.disconnect()
@ -165,7 +165,7 @@ class MQTTClientTest(unittest.TestCase):
broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins")
yield from broker.start() yield from broker.start()
client = MQTTClient() client = MQTTClient()
yield from client.connect('mqtt://localhost/') yield from client.connect('mqtt://127.0.0.1/')
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
ret = yield from client.subscribe([ ret = yield from client.subscribe([
('$SYS/broker/uptime', QOS_0), ('$SYS/broker/uptime', QOS_0),
@ -193,7 +193,7 @@ class MQTTClientTest(unittest.TestCase):
broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins")
yield from broker.start() yield from broker.start()
client = MQTTClient() client = MQTTClient()
yield from client.connect('mqtt://localhost/') yield from client.connect('mqtt://127.0.0.1/')
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
ret = yield from client.subscribe([ ret = yield from client.subscribe([
('$SYS/broker/uptime', QOS_0), ('$SYS/broker/uptime', QOS_0),
@ -220,14 +220,14 @@ class MQTTClientTest(unittest.TestCase):
broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins")
yield from broker.start() yield from broker.start()
client = MQTTClient() client = MQTTClient()
yield from client.connect('mqtt://localhost/') yield from client.connect('mqtt://127.0.0.1/')
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
ret = yield from client.subscribe([ ret = yield from client.subscribe([
('test_topic', QOS_0), ('test_topic', QOS_0),
]) ])
self.assertEqual(ret[0], QOS_0) self.assertEqual(ret[0], QOS_0)
client_pub = MQTTClient() client_pub = MQTTClient()
yield from client_pub.connect('mqtt://localhost/') yield from client_pub.connect('mqtt://127.0.0.1/')
yield from client_pub.publish('test_topic', data, QOS_0) yield from client_pub.publish('test_topic', data, QOS_0)
yield from client_pub.disconnect() yield from client_pub.disconnect()
message = yield from client.deliver_message() message = yield from client.deliver_message()
@ -253,7 +253,7 @@ class MQTTClientTest(unittest.TestCase):
broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins")
yield from broker.start() yield from broker.start()
client = MQTTClient() client = MQTTClient()
yield from client.connect('mqtt://localhost/') yield from client.connect('mqtt://127.0.0.1/')
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
ret = yield from client.subscribe([ ret = yield from client.subscribe([
('test_topic', QOS_0), ('test_topic', QOS_0),