Function curl_forward

server/src/server/http_server.cpp:239–322

            choice["finish_reason"] = c.value("finish_reason", "stop");
            json msg = {{"role", "assistant"}, {"content", c.value("text", "")}};
            choice["message"] = msg;
            choices.push_back(choice);
        }
    }
    chat_resp["choices"] = choices;
    return chat_resp;
}

static bool curl_forward(SocketHandle client_fd, const std::string & url,
                         const std::string & api_key, const json & body,
                         bool streaming, bool rewrite_to_chat,
                         const std::string & response_id,
                         const std::string & model) {
    CURL * curl = curl_easy_init();
    if (!curl) return false;

    std::string body_str = body.dump();

    struct curl_slist * headers = nullptr;
    headers = curl_slist_append(headers, "Content-Type: application/json");
    if (!api_key.empty()) {
        std::string auth = "Authorization: Bearer " + api_key;
        headers = curl_slist_append(headers, auth.c_str());
    }

    CurlWriteCtx ctx;
    ctx.client_fd = client_fd;
    ctx.streaming = streaming;
    ctx.first_chunk = true;
    ctx.chat_rewrite = rewrite_to_chat;
    ctx.response_id = response_id;
    ctx.model = model;

    curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
    curl_easy_setopt(curl, CURLOPT_POSTFIELDS, body_str.c_str());
    curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, (long)body_str.size());
    curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
    curl_easy_setopt(curl, CURLOPT_TIMEOUT, 600L);
    curl_easy_setopt(curl, CURLOPT_WRITEDATA, &ctx);

    if (rewrite_to_chat) {
        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, curl_write_rewrite);
    } else {
        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, curl_write_passthrough);
    }

    if (streaming) {
        std::string sse_header =
            "HTTP/1.1 200 OK\r\n"
            "Content-Type: text/event-stream\r\n"
            "Cache-Control: no-cache\r\n"
            "Connection: keep-alive\r\n"
            "\r\n";
        ::send(client_fd, sse_header.data(), sse_header.size(), MSG_NOSIGNAL);
    }

    CURLcode res = curl_easy_perform(curl);