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

Add secure CA

pull/8/head
Nico 2015-09-27 21:39:43 +02:00
rodzic 5e889f5059
commit fec006d830
1 zmienionych plików z 6 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

8
tests/test_client.py
Wyświetl plik

@ -3,6 +3,7 @@
# See the file license.txt for copying permission. # See the file license.txt for copying permission.
import unittest import unittest
import asyncio import asyncio
import os
import logging import logging
from hbmqtt.plugins.manager import PluginManager from hbmqtt.plugins.manager import PluginManager
from hbmqtt.client import MQTTClient from hbmqtt.client import MQTTClient
@ -43,7 +44,9 @@ class MQTTClientTest(unittest.TestCase):
def test_coro(): def test_coro():
try: try:
client = MQTTClient() client = MQTTClient()
ret = yield from client.connect('mqtts://test.mosquitto.org/', cafile='mosquitto.org.crt') print(os.path.dirname(os.path.realpath(__file__)))
ca = os.path.join(os.path.dirname(os.path.realpath(__file__)), 'mosquitto.org.crt')
ret = yield from client.connect('mqtts://test.mosquitto.org/', cafile=ca)
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
yield from client.disconnect() yield from client.disconnect()
future.set_result(True) future.set_result(True)
@ -92,7 +95,8 @@ class MQTTClientTest(unittest.TestCase):
def test_coro(): def test_coro():
try: try:
client = MQTTClient() client = MQTTClient()
yield from client.connect('wss://test.mosquitto.org:8081/', cafile='mosquitto.org.crt') ca = os.path.join(os.path.dirname(os.path.realpath(__file__)), 'mosquitto.org.crt')
yield from client.connect('wss://test.mosquitto.org:8081/', cafile=ca)
self.assertIsNotNone(client.session) self.assertIsNotNone(client.session)
yield from client.disconnect() yield from client.disconnect()
future.set_result(True) future.set_result(True)