Diff: cyclone_tcp/mqtt/mqtt_client_packet.h

Revision:

0:8918a71cdbe9

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/cyclone_tcp/mqtt/mqtt_client_packet.h	Sat Feb 04 18:15:49 2017 +0000
@@ -0,0 +1,88 @@
+/**
+ * @file mqtt_client_packet.h
+ * @brief MQTT packet parsing and formatting
+ *
+ * @section License
+ *
+ * Copyright (C) 2010-2017 Oryx Embedded SARL. All rights reserved.
+ *
+ * This file is part of CycloneTCP Open.
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU General Public License
+ * as published by the Free Software Foundation; either version 2
+ * of the License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ *
+ * @author Oryx Embedded SARL (www.oryx-embedded.com)
+ * @version 1.7.6
+ **/
+
+#ifndef _MQTT_CLIENT_PACKET_H
+#define _MQTT_CLIENT_PACKET_H
+
+//Dependencies
+#include "core/net.h"
+#include "mqtt/mqtt_client.h"
+
+//MQTT client related functions
+error_t mqttClientReceivePacket(MqttClientContext *context);
+error_t mqttClientProcessPacket(MqttClientContext *context);
+
+error_t mqttClientProcessConnAck(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientProcessPubAck(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientProcessPublish(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientProcessPubRec(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientProcessPubRel(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientProcessPubComp(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientProcessSubAck(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientProcessUnsubAck(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientProcessPingResp(MqttClientContext *context,
+   bool_t dup, MqttQosLevel qos, bool_t retain, size_t remainingLen);
+
+error_t mqttClientFormatConnect(MqttClientContext *context,
+   bool_t cleanSession);
+
+error_t mqttClientFormatPublish(MqttClientContext *context, const char_t *topic,
+   const void *message, size_t length, MqttQosLevel qos, bool_t retain);
+
+error_t mqttClientFormatPubAck(MqttClientContext *context, uint16_t packetId);
+error_t mqttClientFormatPubRec(MqttClientContext *context, uint16_t packetId);
+error_t mqttClientFormatPubRel(MqttClientContext *context, uint16_t packetId);
+error_t mqttClientFormatPubComp(MqttClientContext *context, uint16_t packetId);
+
+error_t mqttClientFormatSubscribe(MqttClientContext *context,
+   const char_t *topic, MqttQosLevel qos);
+
+error_t mqttClientFormatUnsubscribe(MqttClientContext *context,
+   const char_t *topic);
+
+error_t mqttClientFormatPingReq(MqttClientContext *context);
+error_t mqttClientFormatDisconnect(MqttClientContext *context);
+
+#endif
+