soupbintcp.hpp

Go to the documentation of this file.

#pragma once
 
 
#include <cstddef>
#include <cstdint>
#include <functional>
#include <span>
#include <string>
#include <string_view>
#include <vector>
 
#include "itch/parser.hpp"
#include "itch/transport/sequencing.hpp"
 
namespace itch::transport {
 
enum class SoupBinPacketType : char {
    debug            = '+',  
    login_accepted   = 'A',  
    login_rejected   = 'J',  
    sequenced_data   = 'S',  
    server_heartbeat = 'H',  
    end_of_session   = 'Z',  
    login_request    = 'L',  
    unsequenced_data = 'U',  
    client_heartbeat = 'R',  
    logout_request   = 'O',  
};
 
class SoupBinDecoder {
   public:
    using EventCallback =
        std::function<void(SoupBinPacketType type, std::span<const std::byte> payload)>;
 
    explicit SoupBinDecoder(MessageCallback callback);
 
    auto feed(std::span<const std::byte> bytes) -> void;
 
    auto set_event_callback(EventCallback callback) -> void;
 
    [[nodiscard]] auto tracker() noexcept -> SequenceTracker& { return m_tracker; }
    [[nodiscard]] auto tracker() const noexcept -> const SequenceTracker& { return m_tracker; }
 
    [[nodiscard]] auto current_session() const -> std::string_view { return m_session; }
 
    [[nodiscard]] auto next_sequence() const noexcept -> std::uint64_t { return m_next_sequence; }
 
    [[nodiscard]] auto messages_decoded() const noexcept -> std::uint64_t {
        return m_messages_decoded;
    }
 
   private:
    auto process_packet(SoupBinPacketType type, std::span<const std::byte> payload) -> void;
 
    auto decode_application_message(std::span<const std::byte> payload) -> void;
 
    Parser                 m_parser {};
    MessageCallback        m_callback;
    EventCallback          m_event_callback {};
    SequenceTracker        m_tracker {};
    std::vector<std::byte> m_buffer {};
    std::string            m_session {};
    std::uint64_t          m_next_sequence {1};
    std::uint64_t          m_messages_decoded {0};
};
 
}  // namespace itch::transport