Function proxyToCloud

mcp/src/server/http.ts:233–308

* Proxy a request to the cloud API.

(
  req: IncomingMessage,
  res: ServerResponse,
  pathname: string
)

 * Proxy a request to the cloud API.
 */
async function proxyToCloud(
  req: IncomingMessage,
  res: ServerResponse,
  pathname: string
): Promise<void> {
  const method = req.method || "GET";
  const cloudUrl = `${CLOUD_API_URL}${pathname}`;

  const headers: Record<string, string> = {
    "x-api-key": cloudApiKey!,
  };

  // Forward content-type for requests with body
  if (req.headers["content-type"]) {
    headers["Content-Type"] = req.headers["content-type"];
  }

  let body: string | undefined;
  if (method !== "GET" && method !== "HEAD") {
    body = await new Promise<string>((resolve, reject) => {
      let data = "";
      req.on("data", (chunk) => (data += chunk));
      req.on("end", () => resolve(data));
      req.on("error", reject);
    });
  }

  try {
    const cloudRes = await fetch(cloudUrl, {
      method,
      headers,
      body,
    });

    // Handle SSE responses
    if (cloudRes.headers.get("content-type")?.includes("text/event-stream")) {
      res.writeHead(cloudRes.status, {
        "Content-Type": "text/event-stream",
        "Cache-Control": "no-cache",
        Connection: "keep-alive",
        "Access-Control-Allow-Origin": "*",
      });

      const reader = cloudRes.body?.getReader();
      if (reader) {
        const pump = async () => {
          while (true) {
            const { done, value } = await reader.read();
            if (done) break;
            res.write(value);
          }
          res.end();
        };
        pump().catch(() => res.end());

        req.on("close", () => {
          reader.cancel();
        });