moldudp64.hpp

Go to the documentation of this file.

#pragma once
 
 
#include <array>
#include <cstddef>
#include <cstdint>
#include <optional>
#include <span>
#include <string_view>
 
#include "itch/parser.hpp"
#include "itch/transport/sequencing.hpp"
 
namespace itch::transport {
 
struct MoldUdp64Header {
    std::array<char, 10> session {};           
    std::uint64_t        sequence_number {0};  
    std::uint16_t        message_count {0};    
 
    static constexpr std::uint16_t END_OF_SESSION = 0xFFFF;
 
    [[nodiscard]] auto session_view() const -> std::string_view {
        std::size_t length = session.size();
        while (length > 0 && (session[length - 1] == ' ' || session[length - 1] == '\0')) {
            --length;
        }
        return std::string_view {session.data(), length};
    }
 
    [[nodiscard]] auto is_heartbeat() const noexcept -> bool { return message_count == 0; }
 
    [[nodiscard]] auto is_end_of_session() const noexcept -> bool {
        return message_count == END_OF_SESSION;
    }
};
 
class MoldUdp64Decoder {
   public:
    static constexpr std::size_t HEADER_SIZE = 20;
 
    explicit MoldUdp64Decoder(MessageCallback callback);
 
    auto decode_packet(std::span<const std::byte> packet) -> std::optional<MoldUdp64Header>;
 
    [[nodiscard]] auto tracker() noexcept -> SequenceTracker& { return m_tracker; }
    [[nodiscard]] auto tracker() const noexcept -> const SequenceTracker& { return m_tracker; }
 
    [[nodiscard]] auto packets_decoded() const noexcept -> std::uint64_t {
        return m_packets_decoded;
    }
 
    [[nodiscard]] auto messages_decoded() const noexcept -> std::uint64_t {
        return m_messages_decoded;
    }
 
   private:
    Parser          m_parser {};
    MessageCallback m_callback;
    SequenceTracker m_tracker {};
    std::uint64_t   m_packets_decoded {0};
    std::uint64_t   m_messages_decoded {0};
};
 
}  // namespace itch::transport