From c744169a7d085b5e7f2204d2a195ae229af61065 Mon Sep 17 00:00:00 2001 From: Nicolas Jouanin Date: Wed, 8 Jul 2015 22:42:29 +0200 Subject: [PATCH] Implement stupid connect handle --- hbmqtt/mqtt/protocol/broker_handler.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/hbmqtt/mqtt/protocol/broker_handler.py b/hbmqtt/mqtt/protocol/broker_handler.py index 5db2c2c..abfe78f 100644 --- a/hbmqtt/mqtt/protocol/broker_handler.py +++ b/hbmqtt/mqtt/protocol/broker_handler.py @@ -8,7 +8,7 @@ from hbmqtt.mqtt.protocol.handler import ProtocolHandler from hbmqtt.mqtt.packet import MQTTFixedHeader from hbmqtt.mqtt.packet import PacketType from hbmqtt.mqtt.connect import ConnectVariableHeader, ConnectPacket, ConnectPayload -from hbmqtt.mqtt.connack import ConnackPacket +from hbmqtt.mqtt.connack import ConnackPacket, ReturnCode from hbmqtt.mqtt.disconnect import DisconnectPacket from hbmqtt.mqtt.pingreq import PingReqPacket from hbmqtt.mqtt.pingresp import PingRespPacket @@ -41,3 +41,9 @@ class BrokerProtocolHandler(ProtocolHandler): def handle_disconnect(self, disconnect: DisconnectPacket): if self._disconnect_waiter is not None: self._disconnect_waiter.set_result(disconnect) + + @asyncio.coroutine + def handle_connect(self, connect: ConnectPacket): + # TODO : implements this correcly (manage authentication, cleansession, ...) + self.logger.debug("Connect received") + yield from self.outgoing_queue.put(ConnackPacket.build(0, ReturnCode.CONNECTION_ACCEPTED))