packetdatatypes.h

/*
This file is part of FlashMQ (https://www.flashmq.org)
Copyright (C) 2021-2023 Wiebe Cazemier

FlashMQ is free software: you can redistribute it and/or modify
it under the terms of The Open Software License 3.0 (OSL-3.0).

See LICENSE for license details.
*/

#ifndef PACKETDATATYPES_H
#define PACKETDATATYPES_H

#include <optional>

#include "mqtt5properties.h"


struct ConnectData
{
    uint8_t protocol_level_byte = 0;
    bool bridge = false;

    // Flags
    bool password_flag = false;
    bool will_retain = false;
    uint8_t will_qos = false;
    bool will_flag = false;
    bool clean_start = false;

    uint16_t keep_alive = 0;

    // Content from properties
    uint16_t client_receive_max;
    uint32_t session_expire;
    uint32_t max_outgoing_packet_size;
    uint16_t max_outgoing_topic_aliases = 0; // Default MUST BE 0, meaning server won't initiate aliases;
    bool request_response_information = false;
    bool request_problem_information = false;
    std::string authenticationMethod;
    std::string authenticationData;

    // Content from Payload
    std::string client_id;
    WillPublish willpublish;
    std::optional<std::string> username;
    std::string password;

    Mqtt5PropertyBuilder builder;

    ConnectData();
};

struct ConnAckData
{
    // Flags
    bool sessionPresent = false;

    uint32_t session_expire = 0;
    uint16_t client_receive_max;
    uint8_t max_qos = 2;
    uint32_t max_outgoing_packet_size;
    uint16_t max_outgoing_topic_aliases = 0; // Default MUST BE 0, meaning we won't initiate aliases unless the other side says we can.
    std::string assigned_client_id;
    uint16_t keep_alive = 0;
    std::string response_information;
    std::string server_reference;
    bool shared_subscriptions_available = true;
    bool retained_available = true;

    ReasonCodes reasonCode = ReasonCodes::ImplementationSpecificError; // default something that is never a parse result;

    std::string authMethod;
    std::string authData;

    ConnAckData();
};

struct AuthPacketData
{
    std::string method;
    std::string data;
    ReasonCodes reasonCode = ReasonCodes::ImplementationSpecificError; // default something that is never a parse result;
};

struct DisconnectData
{
    ReasonCodes reasonCode = ReasonCodes::Success;
    std::string reasonString;

    bool session_expiry_interval_set = false;
    uint32_t session_expiry_interval = 0;
};

struct SubAckData
{
    uint16_t packet_id;
    std::string reasonString;
    std::vector<uint8_t> subAckCodes;
};

struct PubRecData
{
    ReasonCodes reasonCode = ReasonCodes::Success; // Default when not specified, or MQTT3;
};

#endif // PACKETDATATYPES_H