bet-mcp

// src/helper/proxy/index.ts import { HTTPException } from "../../http-exception.js"; var hopByHopHeaders = [ "connection", "keep-alive", "proxy-authenticate", "proxy-authorization", "te", "trailer", "transfer-encoding", "upgrade" ]; var ALLOWED_TOKEN_PATTERN = /^[!#$%&'*+\-.0-9A-Z^_`a-z|~]+$/; var buildRequestInitFromRequest = (request, strictConnectionProcessing) => { if (!request) { return {}; } const headers = new Headers(request.headers); if (strictConnectionProcessing) { const connectionValue = headers.get("connection"); if (connectionValue) { const headerNames = connectionValue.split(",").map((h) => h.trim()); const invalidHeaders = headerNames.filter((h) => !ALLOWED_TOKEN_PATTERN.test(h)); if (invalidHeaders.length > 0) { throw new HTTPException(400, { message: `Invalid Connection header value: ${invalidHeaders.join(", ")}` }); } headerNames.forEach((headerName) => { headers.delete(headerName); }); } } hopByHopHeaders.forEach((header) => { headers.delete(header); }); return { method: request.method, body: request.body, duplex: request.body ? "half" : void 0, headers, signal: request.signal }; }; var preprocessRequestInit = (requestInit) => { if (!requestInit.headers || Array.isArray(requestInit.headers) || requestInit.headers instanceof Headers) { return requestInit; } const headers = new Headers(); for (const [key, value] of Object.entries(requestInit.headers)) { if (value == null) { headers.delete(key); } else { headers.set(key, value); } } requestInit.headers = headers; return requestInit; }; var proxy = async (input, proxyInit) => { const { raw, customFetch, strictConnectionProcessing = false, ...requestInit } = proxyInit instanceof Request ? { raw: proxyInit } : proxyInit ?? {}; const req = new Request(input, { ...buildRequestInitFromRequest(raw, strictConnectionProcessing), ...preprocessRequestInit(requestInit) }); req.headers.delete("accept-encoding"); const res = await (customFetch || fetch)(req); const resHeaders = new Headers(res.headers); hopByHopHeaders.forEach((header) => { resHeaders.delete(header); }); if (resHeaders.has("content-encoding")) { resHeaders.delete("content-encoding"); resHeaders.delete("content-length"); } return new Response(res.body, { status: res.status, statusText: res.statusText, headers: resHeaders }); }; export { proxy };