#include <Publish.h>

Inheritance diagram for iot::mqtt::client::packets::Publish:

Collaboration diagram for iot::mqtt::client::packets::Publish:

Public Member Functions
	Publish (uint32_t remainingLength, uint8_t flags)

Public Member Functions inherited from iot::mqtt::packets::Publish
	Publish ()

	Publish (uint16_t packetIdentifier, const std::string &topic, const std::string &message, uint8_t qoS, bool dup, bool retain)

bool	getDup () const

uint8_t	getQoS () const

uint16_t	getPacketIdentifier () const

std::string	getTopic () const

std::string	getMessage () const

bool	getRetain () const

Public Member Functions inherited from iot::mqtt::ControlPacket
	ControlPacket (uint8_t type, const std::string &name)

	ControlPacket (const ControlPacket &)=default

	ControlPacket (ControlPacket &&)=default

virtual	~ControlPacket ()

ControlPacket &	operator= (const ControlPacket &)=default

ControlPacket &	operator= (ControlPacket &&)=default

std::vector< char >	serialize () const

const std::string &	getName () const

uint8_t	getType () const

uint8_t	getFlags () const

Public Member Functions inherited from iot::mqtt::client::ControlPacketDeserializer
	~ControlPacketDeserializer () override

Public Member Functions inherited from iot::mqtt::ControlPacketDeserializer
	ControlPacketDeserializer ()=default

	ControlPacketDeserializer (uint32_t remainingLength, uint8_t flags, uint8_t mustFlags)

ControlPacketDeserializer &	operator= (const ControlPacketDeserializer &)=default

std::size_t	deserialize (iot::mqtt::MqttContext *mqttContext)

uint32_t	getRemainingLength () const

bool	isComplete () const

bool	isError () const

std::size_t	getConsumed () const

Private Member Functions
std::size_t	deserializeVP (iot::mqtt::MqttContext *mqttContext) override

void	deliverPacket (iot::mqtt::client::Mqtt *mqtt) override

Private Attributes
int	state = 0

Additional Inherited Members
Protected Attributes inherited from iot::mqtt::packets::Publish
iot::mqtt::types::UInt16	packetIdentifier

iot::mqtt::types::String	topic

iot::mqtt::types::StringRaw	message

bool	dup = false

uint8_t	qoS = 0

bool	retain = false

Protected Attributes inherited from iot::mqtt::ControlPacket
uint8_t	flags = 0

Protected Attributes inherited from iot::mqtt::ControlPacketDeserializer
bool	complete = false

bool	error = false

uint32_t	remainingLength = 0

std::size_t	consumed = 0

Detailed Description

Definition at line 57 of file Publish.h.

Constructor & Destructor Documentation

◆ Publish()

iot::mqtt::client::packets::Publish::Publish	(	uint32_t	remainingLength,
		uint8_t	flags
	)

Definition at line 52 of file Publish.cpp.

        : iot::mqtt::client::ControlPacketDeserializer(remainingLength, flags, flags) {
        this->flags = flags;
        this->qoS = flags >> 1 & 0x03;
        this->dup = (flags & 0x04) != 0;
        this->retain = (flags & 0x01) != 0;
 
        error = this->qoS > 2;
    }

References iot::mqtt::packets::Publish::dup, iot::mqtt::ControlPacketDeserializer::error, iot::mqtt::ControlPacket::flags, iot::mqtt::packets::Publish::qoS, and iot::mqtt::packets::Publish::retain.

Referenced by iot::mqtt::client::Mqtt::createControlPacketDeserializer().

Here is the caller graph for this function:

Member Function Documentation

◆ deliverPacket()

void iot::mqtt::client::packets::Publish::deliverPacket ( iot::mqtt::client::Mqtt * mqtt )

overrideprivatevirtual

Implements iot::mqtt::client::ControlPacketDeserializer.

Definition at line 99 of file Publish.cpp.

                                                       {
        mqtt->printVP(*this);
        mqtt->_onPublish(*this);
    }

References iot::mqtt::client::Mqtt::_onPublish(), and iot::mqtt::Mqtt::printVP().

Here is the call graph for this function:

◆ deserializeVP()

std::size_t iot::mqtt::client::packets::Publish::deserializeVP ( iot::mqtt::MqttContext * mqttContext )

overrideprivatevirtual

Implements iot::mqtt::ControlPacketDeserializer.

Definition at line 62 of file Publish.cpp.

                                                                    {
        std::size_t consumed = 0;
 
        switch (state) {
            case 0: // V-Header
                consumed += topic.deserialize(mqttContext);
                if (!topic.isComplete()) {
                    break;
                }
 
                state++;
                [[fallthrough]];
            case 1:
                if (qoS > 0) {
                    consumed += packetIdentifier.deserialize(mqttContext);
                    if (!packetIdentifier.isComplete()) {
                        break;
                    }
                }
 
                message.setSize(static_cast<uint16_t>(getRemainingLength() - getConsumed() - consumed));
 
                state++;
                [[fallthrough]];
            case 2: // Payload
                consumed += message.deserialize(mqttContext);
                if (!message.isComplete()) {
                    break;
                }
 
                complete = true;
                break;
        }
 
        return consumed;
    }

References iot::mqtt::ControlPacketDeserializer::complete, iot::mqtt::types::TypeBase< ValueTypeT >::deserialize(), iot::mqtt::types::String::deserialize(), iot::mqtt::ControlPacketDeserializer::getConsumed(), iot::mqtt::ControlPacketDeserializer::getRemainingLength(), iot::mqtt::types::TypeBase< ValueTypeT >::isComplete(), iot::mqtt::packets::Publish::message, iot::mqtt::packets::Publish::packetIdentifier, iot::mqtt::packets::Publish::qoS, iot::mqtt::types::TypeBase< ValueTypeT >::setSize(), state, and iot::mqtt::packets::Publish::topic.

Here is the call graph for this function:

Member Data Documentation

◆ state

int iot::mqtt::client::packets::Publish::state = 0

private

Definition at line 67 of file Publish.h.

Referenced by deserializeVP().

The documentation for this class was generated from the following files:

iot/mqtt/client/packets/Publish.h
iot/mqtt/client/packets/Publish.cpp

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members