SNode.C
Loading...
Searching...
No Matches
ControlPacket.h
Go to the documentation of this file.
1/*
2 * SNode.C - A Slim Toolkit for Network Communication
3 * Copyright (C) Volker Christian <me@vchrist.at>
4 * 2020, 2021, 2022, 2023, 2024, 2025
5 *
6 * This program is free software: you can redistribute it and/or modify
7 * it under the terms of the GNU Lesser General Public License as published
8 * by the Free Software Foundation, either version 3 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU Lesser General Public License for more details.
15 *
16 * You should have received a copy of the GNU Lesser General Public License
17 * along with this program. If not, see <http://www.gnu.org/licenses/>.
18 */
19
20/*
21 * MIT License
22 *
23 * Permission is hereby granted, free of charge, to any person obtaining a copy
24 * of this software and associated documentation files (the "Software"), to deal
25 * in the Software without restriction, including without limitation the rights
26 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
27 * copies of the Software, and to permit persons to whom the Software is
28 * furnished to do so, subject to the following conditions:
29 *
30 * The above copyright notice and this permission notice shall be included in
31 * all copies or substantial portions of the Software.
32 *
33 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
34 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
35 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
36 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
37 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
38 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
39 * THE SOFTWARE.
40 */
41
42#ifndef IOT_MQTT_CONTROLPACKET_H
43#define IOT_MQTT_CONTROLPACKET_H
44
45#ifndef DOXYGEN_SHOULD_SKIP_THIS
46
47#include <cstdint>
48#include <string>
49#include <vector>
50
51#endif // DOXYGEN_SHOULD_SKIP_THIS
52
53#define MQTT_RESERVED_00 0x00
54#define MQTT_CONNECT 0x01
55#define MQTT_CONNACK 0x02
56#define MQTT_PUBLISH 0x03
57#define MQTT_PUBACK 0x04
58#define MQTT_PUBREC 0x05
59#define MQTT_PUBREL 0x06
60#define MQTT_PUBCOMP 0x07
61#define MQTT_SUBSCRIBE 0x08
62#define MQTT_SUBACK 0x09
63#define MQTT_UNSUBSCRIBE 0x0A
64#define MQTT_UNSUBACK 0x0B
65#define MQTT_PINGREQ 0x0C
66#define MQTT_PINGRESP 0x0D
67#define MQTT_DISCONNECT 0x0E
68#define MQTT_RESERVED_0F 0x0F
69
70// no flags for MQTT_RESERVED_00
71#define MQTT_CONNECT_FLAGS 0x00
72#define MQTT_CONNACK_FLAGS 0x00
73// no flags for MQTT_PUBLISH_FLAGS
74#define MQTT_PUBACK_FLAGS 0x00
75#define MQTT_PUBREC_FLAGS 0x00
76#define MQTT_PUBREL_FLAGS 0x02
77#define MQTT_PUBCOMP_FLAGS 0x00
78#define MQTT_SUBSCRIBE_FLAGS 0x02
79#define MQTT_SUBACK_FLAGS 0x00
80#define MQTT_UNSUBSCRIBE_FLAGS 0x02
81#define MQTT_UNSUBACK_FLAGS 0x00
82#define MQTT_PINGREQ_FLAGS 0x00
83#define MQTT_PINGRESP_FLAGS 0x00
84#define MQTT_DISCONNECT_FLAGS 0x00
85// no flags for MQTT_RESERVED_0F
86
87namespace iot::mqtt {
88
89 extern const std::vector<std::string> mqttPackageName;
90
92 public:
93 ControlPacket(uint8_t type, const std::string& name);
94 ControlPacket(const ControlPacket&) = default;
96
97 virtual ~ControlPacket();
98
101
102 virtual std::vector<char> serializeVP() const = 0;
103 std::vector<char> serialize() const;
104
105 const std::string& getName() const;
106 uint8_t getType() const;
107 uint8_t getFlags() const;
108
109 private:
110 std::string name;
111 uint8_t type = 0;
112
113 protected:
114 uint8_t flags = 0;
115 };
116
117} // namespace iot::mqtt
118
119#endif // IOT_MQTT_CONTROLPACKET_H
std::size_t deserialize(iot::mqtt::MqttContext *mqttContext)
virtual std::size_t deserializeVP(iot::mqtt::MqttContext *mqttContext)=0
ControlPacketDeserializer & operator=(const ControlPacketDeserializer &)=default
ControlPacketDeserializer(uint32_t remainingLength, uint8_t flags, uint8_t mustFlags)
std::vector< char > serialize() const
const std::string & getName() const
ControlPacket & operator=(const ControlPacket &)=default
virtual std::vector< char > serializeVP() const =0
ControlPacket(const ControlPacket &)=default
ControlPacket(ControlPacket &&)=default
ControlPacket(uint8_t type, const std::string &name)
ControlPacket & operator=(ControlPacket &&)=default
void printVP(const iot::mqtt::ControlPacket &packet) const
Definition Mqtt.cpp:368
virtual void deliverPacket(iot::mqtt::client::Mqtt *mqtt)=0
void _onConnack(const iot::mqtt::client::packets::Connack &connack)
Definition Mqtt.cpp:193
std::size_t deserializeVP(iot::mqtt::MqttContext *mqttContext) override
Definition Connack.cpp:57
Connack(uint32_t remainingLength, uint8_t flags)
Definition Connack.cpp:52
void deliverPacket(iot::mqtt::client::Mqtt *mqtt) override
Definition Connack.cpp:87
uint8_t getReturnCode() const
Definition Connack.cpp:76
std::vector< char > serializeVP() const override
Definition Connack.cpp:63
Connack(uint8_t returncode, uint8_t acknowledgeFlags)
Definition Connack.cpp:57
iot::mqtt::types::UInt8 acknowledgeFlags
Definition Connack.h:81
bool getSessionPresent() const
Definition Connack.cpp:80
uint8_t getAcknowledgeFlags() const
Definition Connack.cpp:72
iot::mqtt::types::UInt8 returnCode
Definition Connack.h:82
virtual std::size_t deserialize(iot::mqtt::MqttContext *mqttContext)
Definition TypeBase.hpp:59
#define MQTT_CONNACK_FLAGS
const std::vector< std::string > mqttPackageName