#include <Connect.h>

Inheritance diagram for iot::mqtt::server::packets::Connect:

Collaboration diagram for iot::mqtt::server::packets::Connect:

Public Member Functions
	Connect (uint32_t remainingLength, uint8_t flags)

bool	isFakedClientId () const

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

	Connect (const std::string &clientId, uint16_t keepAlive, 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)

std::string	getProtocol () const

uint8_t	getLevel () const

uint8_t	getConnectFlags () const

uint16_t	getKeepAlive () const

std::string	getClientId () const

bool	getUsernameFlag () const

bool	getPasswordFlag () const

bool	getWillRetain () const

uint8_t	getWillQoS () const

bool	getWillFlag () const

bool	getCleanSession () const

bool	getReflect () const

std::string	getWillTopic () const

std::string	getWillMessage () const

std::string	getUsername () const

std::string	getPassword () 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::server::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::server::Mqtt *mqtt) override

Private Attributes
int	state = 0

bool	fakedClientId = false

Additional Inherited Members
Protected Attributes inherited from iot::mqtt::packets::Connect
iot::mqtt::types::String	protocol

iot::mqtt::types::UInt8	level

iot::mqtt::types::UInt8	connectFlags

iot::mqtt::types::UInt16	keepAlive

iot::mqtt::types::String	clientId

iot::mqtt::types::String	willTopic

iot::mqtt::types::String	willMessage

iot::mqtt::types::String	username

iot::mqtt::types::String	password

bool	usernameFlag = false

bool	passwordFlag = false

bool	willRetain = false

uint8_t	willQoS = 0

bool	willFlag = false

bool	cleanSession = false

bool	reflect = true

bool	reserved = 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 34 of file Connect.h.

Constructor & Destructor Documentation

◆ Connect()

iot::mqtt::server::packets::Connect::Connect	(	uint32_t	remainingLength,
		uint8_t	flags )

Definition at line 34 of file Connect.cpp.

        : iot::mqtt::server::ControlPacketDeserializer(remainingLength, flags, MQTT_CONNECT_FLAGS) {
        this->flags = flags;
    }

Member Function Documentation

◆ deliverPacket()

void iot::mqtt::server::packets::Connect::deliverPacket ( iot::mqtt::server::Mqtt * mqtt )

overrideprivatevirtual

Implements iot::mqtt::server::ControlPacketDeserializer.

Definition at line 143 of file Connect.cpp.

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

◆ deserializeVP()

std::size_t iot::mqtt::server::packets::Connect::deserializeVP ( iot::mqtt::MqttContext * mqttContext )

overrideprivatevirtual

Implements iot::mqtt::ControlPacketDeserializer.

Definition at line 39 of file Connect.cpp.

                                                                    {
        std::size_t consumed = 0;
 
        switch (state) {
            case 0: // V-Header
                consumed += protocol.deserialize(mqttContext);
                if (!protocol.isComplete()) {
                    break;
                }
 
                state++;
                [[fallthrough]];
            case 1:
                consumed += level.deserialize(mqttContext);
                if (!level.isComplete()) {
                    break;
                }
                reflect = (level & 0x80) == 0; // msb in level == 1 -> do not reflect message to origin (try_private in mosquitto)
                level = level & ~0x80;
 
                state++;
                [[fallthrough]];
            case 2:
                consumed += connectFlags.deserialize(mqttContext);
                if (!connectFlags.isComplete()) {
                    break;
                }
 
                reserved = (connectFlags & 0x01) != 0;
                cleanSession = (connectFlags & 0x02) != 0;
                willFlag = (connectFlags & 0x04) != 0;
                willQoS = (connectFlags & 0x18) >> 3;
                willRetain = (connectFlags & 0x20) != 0;
                passwordFlag = (connectFlags & 0x40) != 0;
                usernameFlag = (connectFlags & 0x80) != 0;
 
                state++;
                [[fallthrough]];
            case 3:
                consumed += keepAlive.deserialize(mqttContext);
                if (!keepAlive.isComplete()) {
                    break;
                }
 
                state++;
                [[fallthrough]];
            case 4: // Payload
                consumed += clientId.deserialize(mqttContext);
                if (!clientId.isComplete()) {
                    break;
                }
 
                if (clientId.size() == 0) {
                    clientId = utils::Uuid::getUuid();
                    fakedClientId = true;
                }
 
                state++;
                [[fallthrough]];
            case 5:
                if (willFlag) {
                    consumed += willTopic.deserialize(mqttContext);
                    if (!willTopic.isComplete()) {
                        break;
                    }
                }
 
                state++;
                [[fallthrough]];
            case 6:
                if (willFlag) {
                    consumed += willMessage.deserialize(mqttContext);
                    if (!willMessage.isComplete()) {
                        break;
                    }
                }
 
                state++;
                [[fallthrough]];
            case 7:
                if (usernameFlag) {
                    consumed += username.deserialize(mqttContext);
                    if (!username.isComplete()) {
                        break;
                    }
                }
 
                state++;
                [[fallthrough]];
            case 8:
                if (passwordFlag) {
                    consumed += password.deserialize(mqttContext);
                    if (!password.isComplete()) {
                        break;
                    }
                }
 
                complete = true;
                break;
        }
 
        return consumed;
    }

◆ isFakedClientId()

bool iot::mqtt::server::packets::Connect::isFakedClientId ( ) const

Definition at line 148 of file Connect.cpp.

                                        {
        return fakedClientId;
    }

Member Data Documentation

◆ fakedClientId

bool iot::mqtt::server::packets::Connect::fakedClientId = false

private

Definition at line 48 of file Connect.h.

◆ state

int iot::mqtt::server::packets::Connect::state = 0

private

Definition at line 46 of file Connect.h.

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

iot/mqtt/server/packets/Connect.h
iot/mqtt/server/packets/Connect.cpp

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members