Method buildStreamingResponse

tests/utils/mock_anthropic_client.cpp:222–256

}

std::vector<std::string> AnthropicResponseBuilder::buildStreamingResponse(
    const std::string& content) {
  std::vector<std::string> events;

  // Message start event
  events.push_back(
      "data: "
      "{\"type\":\"message_start\",\"message\":{\"id\":\"msg_stream\",\"type\":"
      "\"message\",\"role\":\"assistant\",\"content\":[]}}\n\n");

  // Content block start
  events.push_back(
      "data: "
      "{\"type\":\"content_block_start\",\"index\":0,\"content_block\":{"
      "\"type\":\"text\",\"text\":\"\"}}\n\n");

  // Split content into chunks
  const size_t chunk_size = 5;
  for (size_t i = 0; i < content.length(); i += chunk_size) {
    std::string chunk = content.substr(i, chunk_size);
    nlohmann::json event = {
        {"type", "content_block_delta"},
        {"index", 0},
        {"delta", {{"type", "text_delta"}, {"text", chunk}}}};
    events.push_back("data: " + event.dump() + "\n\n");
  }

  // Content block stop
  events.push_back("data: {\"type\":\"content_block_stop\",\"index\":0}\n\n");

  // Message stop event
  events.push_back("data: {\"type\":\"message_stop\"}\n\n");

  return events;
}

std::string AnthropicResponseBuilder::buildRateLimitResponse() {
  return buildErrorResponse(429, "rate_limit_error", "Rate limit exceeded");