frame.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2024, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "kcenon/network/detail/utils/result_types.h"
#include <cstdint>
#include <span>
#include <vector>
 
namespace kcenon::network::protocols::grpc
{
    constexpr size_t grpc_header_size = 5;
 
    constexpr size_t default_max_message_size = 4 * 1024 * 1024;
 
    struct grpc_message
    {
        bool compressed = false;      
        std::vector<uint8_t> data;    
 
        grpc_message() = default;
 
        explicit grpc_message(std::vector<uint8_t> payload, bool is_compressed = false)
            : compressed(is_compressed), data(std::move(payload)) {}
 
        static auto parse(std::span<const uint8_t> input) -> Result<grpc_message>;
 
        auto serialize() const -> std::vector<uint8_t>;
 
        auto serialized_size() const -> size_t
        {
            return grpc_header_size + data.size();
        }
 
        auto empty() const -> bool { return data.empty(); }
 
        auto size() const -> size_t { return data.size(); }
    };
 
    constexpr const char* grpc_content_type = "application/grpc";
 
    constexpr const char* grpc_content_type_proto = "application/grpc+proto";
 
    namespace trailer_names
    {
        constexpr const char* grpc_status = "grpc-status";
        constexpr const char* grpc_message = "grpc-message";
        constexpr const char* grpc_status_details = "grpc-status-details-bin";
    }
 
    namespace header_names
    {
        constexpr const char* te = "te";
        constexpr const char* content_type = "content-type";
        constexpr const char* grpc_encoding = "grpc-encoding";
        constexpr const char* grpc_accept_encoding = "grpc-accept-encoding";
        constexpr const char* grpc_timeout = "grpc-timeout";
        constexpr const char* user_agent = "user-agent";
    }
 
    namespace compression
    {
        constexpr const char* identity = "identity";
        constexpr const char* deflate = "deflate";
        constexpr const char* gzip = "gzip";
    }
 
    auto parse_timeout(std::string_view timeout_str) -> uint64_t;
 
    auto format_timeout(uint64_t timeout_ms) -> std::string;
 
} // namespace kcenon::network::protocols::grpc