jsonrpc::transport::MessageFramer Class Reference

#include <message_framer.hpp>

Collaboration diagram for jsonrpc::transport::MessageFramer:

Classes
struct	DeframeResult

Public Member Functions
auto	TryDeframe (const std::string &buffer) -> DeframeResult

Static Public Member Functions
static auto	Frame (const std::string &message, const std::string &content_type="application/vscode-jsonrpc; charset=utf-8") -> std::string

Detailed Description

Definition at line 8 of file message_framer.hpp.

Member Function Documentation

Frame()

static auto jsonrpc::transport::MessageFramer::Frame ( const std::string & message, const std::string & content_type = "application/vscode-jsonrpc; charset=utf-8" ) -> std::string

inlinestatic

Definition at line 17 of file message_framer.hpp.

                                                                    {
    std::ostringstream out;
    out << "Content-Length: " << message.size() << "\r\n"
        << "Content-Type: " << content_type << "\r\n"
        << "\r\n"
        << message;
    return out.str();
  }

Referenced by jsonrpc::transport::FramedPipeTransport::SendMessage().

Here is the caller graph for this function:

TryDeframe()

auto jsonrpc::transport::MessageFramer::TryDeframe ( const std::string & buffer ) -> DeframeResult

inline

Definition at line 29 of file message_framer.hpp.

                                                            {
    if (!header_complete_) {
      auto header_end = buffer.find("\r\n\r\n");
      if (header_end == std::string::npos) {
        return {
            .complete = false,
            .message = "",
            .consumed_bytes = 0,
            .error = ""};  // Need more data
      }
 
      // Parse headers
      std::istringstream header_stream(buffer.substr(0, header_end));
      std::string header_line;
      bool found_length = false;
      while (std::getline(header_stream, header_line) && !header_line.empty()) {
        if (header_line.starts_with("Content-Length:")) {
          try {
            expected_length_ = std::stoi(header_line.substr(15));
            found_length = true;
          } catch (const std::exception&) {
            return {
                .complete = false,
                .message = "",
                .consumed_bytes = 0,
                .error = "Invalid Content-Length header"};
          }
        }
      }
 
      if (!found_length) {
        return {
            .complete = false,
            .message = "",
            .consumed_bytes = 0,
            .error = "Missing Content-Length header"};
      }
 
      header_complete_ = true;
      header_size_ = header_end + 4;  // Include \r\n\r\n
    }
 
    // Check if we have enough data for the content
    if (buffer.size() < header_size_ + expected_length_) {
      return {
          .complete = false,
          .message = "",
          .consumed_bytes = 0,
          .error = ""};  // Need more data
    }
 
    // Extract message
    std::string message = buffer.substr(header_size_, expected_length_);
    std::size_t total_consumed = header_size_ + expected_length_;
 
    // Reset state for next message
    header_complete_ = false;
    expected_length_ = 0;
    header_size_ = 0;
 
    return {
        .complete = true,
        .message = message,
        .consumed_bytes = total_consumed,
        .error = ""};
  }

References jsonrpc::transport::MessageFramer::DeframeResult::complete.

---

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

• include/jsonrpc/transport/message_framer.hpp