2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef IOT_MQTT_TYPES_STRING_H
43#define IOT_MQTT_TYPES_STRING_H
45#include "iot/mqtt/types/TypeBase.h"
46#include "iot/mqtt/types/UInt16.h"
48#ifndef DOXYGEN_SHOULD_SKIP_THIS
60 explicit String(
const std::string& value);
70 std::vector<
char>
serialize()
const override;
75 bool operator==(
const std::string& rhsValue)
const;
76 bool operator!=(
const std::string& rhsValue)
const;
78 void reset(std::size_t size = 0)
override;
84 extern template class TypeBase<std::string>;
std::size_t deserialize(iot::mqtt::MqttContext *mqttContext)
virtual ~ControlPacketDeserializer()
std::size_t getConsumed() const
virtual std::size_t deserializeVP(iot::mqtt::MqttContext *mqttContext)=0
uint32_t getRemainingLength() const
ControlPacketDeserializer()=default
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
MqttContext * mqttContext
static std::string toHexString(const std::string &data)
const std::string & getConnectionName() const
virtual void onConnected()
static std::string toHexString(const std::vector< char > &data)
virtual void onPubcomp(const iot::mqtt::packets::Pubcomp &pubcomp)
virtual void onPublish(const iot::mqtt::packets::Publish &publish)
core::timer::Timer keepAliveTimer
iot::mqtt::FixedHeader fixedHeader
const MqttContext * getMqttContext() const
std::size_t onReceivedFromPeer()
virtual void onDisconnected()
void send(const std::vector< char > &data) const
void setMqttContext(MqttContext *mqttContext)
void sendPuback(uint16_t packetIdentifier) const
virtual void onPuback(const iot::mqtt::packets::Puback &puback)
std::string connectionName
void _onPubrec(const iot::mqtt::packets::Pubrec &pubrec)
virtual void deliverPacket(iot::mqtt::ControlPacketDeserializer *controlPacketDeserializer)=0
Mqtt(const std::string &connectionName, const std::string &clientId)
void sendPubrel(uint16_t packetIdentifier) const
uint16_t getPacketIdentifier()
bool _onPublish(const iot::mqtt::packets::Publish &publish)
virtual iot::mqtt::ControlPacketDeserializer * createControlPacketDeserializer(iot::mqtt::FixedHeader &staticHeader)=0
Mqtt & operator=(Mqtt &&)=delete
void sendPublish(const std::string &topic, const std::string &message, uint8_t qoS, bool retain)
void printFixedHeader(const iot::mqtt::FixedHeader &fixedHeader) const
uint16_t _packetIdentifier
Mqtt(const Mqtt &)=delete
void _onPubrel(const iot::mqtt::packets::Pubrel &pubrel)
virtual void onPubrec(const iot::mqtt::packets::Pubrec &pubrec)
virtual void onPubrel(const iot::mqtt::packets::Pubrel &pubrel)
void send(const iot::mqtt::ControlPacket &controlPacket) const
virtual bool onSignal(int sig)=0
Mqtt(const std::string &connectionName)
void initSession(Session *session, utils::Timeval keepAlive)
Mqtt & operator=(const Mqtt &)=delete
void printVP(const iot::mqtt::ControlPacket &packet) const
iot::mqtt::ControlPacketDeserializer * controlPacketDeserializer
void sendPubcomp(uint16_t packetIdentifier) const
void sendPubrec(uint16_t packetIdentifier) const
void _onPubcomp(const iot::mqtt::packets::Pubcomp &pubcomp)
void _onPuback(const iot::mqtt::packets::Puback &puback)
Session & operator=(const Session &)=default
std::set< uint16_t > publishPacketIdentifierSet
virtual nlohmann::json toJson() const
std::map< uint16_t, iot::mqtt::packets::Publish > publishMap
Session(const nlohmann::json &json)
bool isCleanSession() const
Session(const Session &)=default
virtual ~Session()=default
void fromJson(const nlohmann::json &json)
std::set< uint16_t > pubrelPacketIdentifierSet
virtual void deliverPacket(iot::mqtt::client::Mqtt *mqtt)=0
~ControlPacketDeserializer() override
void _onPublish(const iot::mqtt::client::packets::Publish &publish)
void sendConnect(uint16_t keepAlive, const std::string &clientId, bool cleanSession, const std::string &willTopic, const std::string &willMessage, uint8_t willQoS, bool willRetain, const std::string &username, const std::string &password, bool loopPrevention=false)
iot::mqtt::Session session
std::string sessionStoreFileName
Mqtt(const std::string &connectionName, const std::string &clientId, const std::string &sessionStoreFileName)
void _onPingresp(const iot::mqtt::client::packets::Pingresp &pingresp)
virtual void onConnack(const iot::mqtt::packets::Connack &connack)
virtual void onPingresp(const iot::mqtt::packets::Pingresp &pingresp)
void sendSubscribe(const std::list< Topic > &topics)
iot::mqtt::ControlPacketDeserializer * createControlPacketDeserializer(iot::mqtt::FixedHeader &fixedHeader) final
void _onSuback(const iot::mqtt::client::packets::Suback &suback)
virtual void onUnsuback(const iot::mqtt::packets::Unsuback &unsuback)
void _onConnack(const iot::mqtt::client::packets::Connack &connack)
void _onUnsuback(const iot::mqtt::client::packets::Unsuback &unsuback)
void sendUnsubscribe(const std::list< std::string > &topics)
bool onSignal(int sig) override
virtual void onSuback(const iot::mqtt::packets::Suback &suback)
void deliverPacket(iot::mqtt::ControlPacketDeserializer *controlPacketDeserializer) override
void sendDisconnect() const
core::timer::Timer pingTimer
std::size_t deserializeVP(iot::mqtt::MqttContext *mqttContext) override
Connack(uint32_t remainingLength, uint8_t flags)
void deliverPacket(iot::mqtt::client::Mqtt *mqtt) override
uint8_t getReturnCode() const
std::vector< char > serializeVP() const override
Connack(uint8_t returncode, uint8_t acknowledgeFlags)
iot::mqtt::types::UInt8 acknowledgeFlags
bool getSessionPresent() const
uint8_t getAcknowledgeFlags() const
iot::mqtt::types::UInt8 returnCode
iot::mqtt::types::StringRaw message
std::string getTopic() const
std::string getMessage() const
Publish(uint16_t packetIdentifier, const std::string &topic, const std::string &message, uint8_t qoS, bool dup, bool retain)
iot::mqtt::types::UInt16 packetIdentifier
uint16_t getPacketIdentifier() const
iot::mqtt::types::String topic
std::vector< char > serializeVP() const override
operator std::string() const
bool operator==(const std::string &rhsValue) const
std::size_t deserialize(iot::mqtt::MqttContext *mqttContext) override
void reset(std::size_t size=0) override
bool operator!=(const std::string &rhsValue) const
String(const std::string &value)
String(const String &)=default
String(String &&) noexcept=default
std::vector< char > serialize() const override
String & operator=(String &&) noexcept=default
String & operator=(const std::string &newValue)
String & operator=(const String &)=default
std::vector< char > value
TypeBase(const TypeBase &)=default
void setSize(std::size_t size)
virtual std::vector< char > serialize() const
virtual std::size_t deserialize(iot::mqtt::MqttContext *mqttContext)
TypeBase & operator=(TypeBase &&) noexcept=default
TypeBase(std::size_t size=sizeof(ValueType))
virtual ~TypeBase()=default
TypeBase(TypeBase &&) noexcept=default
virtual void reset(std::size_t size=sizeof(ValueType))
TypeBase & operator=(const TypeBase &)=default
UInt8 & operator=(const uint8_t &newValue)
UInt8(UInt8 &&) noexcept=default
UInt8 & operator=(UInt8 &&) noexcept=default
UInt8 & operator=(const UInt8 &)=default
UInt8(const UInt8 &)=default
UIntV & operator=(UIntV &&) noexcept=default
std::size_t deserialize(iot::mqtt::MqttContext *mqttContext) override
UIntV & operator=(const uint32_t &newValue)
operator uint32_t() const
UIntV(UIntV &&) noexcept=default
UIntV(const UIntV &)=default
UIntV & operator=(const UIntV &)=default
void reset(std::size_t size=sizeof(ValueType)) override
#define MQTT_CONNACK_FLAGS
const std::vector< std::string > mqttPackageName