Revert "Forward user headers (#24)"

This reverts commit 9c10ace.

Author: Wauplin

src/routes/responses.ts

@@ -35,23 +35,6 @@ class StreamingError extends Error {
 type IncompleteResponse = Omit<Response, "incomplete_details" | "output_text" | "parallel_tool_calls">;
 const SEQUENCE_NUMBER_PLACEHOLDER = -1;
 
-// All headers are forwarded by default, except these ones.
-const NOT_FORWARDED_HEADERS = new Set([
-	"accept",
-	"accept-encoding",
-	"authorization",
-	"connection",
-	"content-length",
-	"content-type",
-	"host",
-	"keep-alive",
-	"te",
-	"trailer",
-	"trailers",
-	"transfer-encoding",
-	"upgrade",
-]);
-
 export const postCreateResponse = async (
 	req: ValidatedRequest<CreateResponseParams>,
 	res: ExpressResponse
@@ -186,11 +169,6 @@ async function* innerRunStream(
 		return;
 	}
 
-	// Forward headers (except authorization handled separately)
-	const defaultHeaders = Object.fromEntries(
-		Object.entries(req.headers).filter(([key]) => !NOT_FORWARDED_HEADERS.has(key.toLowerCase()))
-	) as Record<string, string>;
-
 	// Return early if not supported param
 	if (req.body.reasoning?.summary && req.body.reasoning?.summary !== "auto") {
 		throw new Error(`Not implemented: only 'auto' summary is supported. Got '${req.body.reasoning?.summary}'`);
@@ -451,7 +429,7 @@ async function* innerRunStream(
 	do {
 		previousMessageCount = currentMessageCount;
 
-		for await (const event of handleOneTurnStream(apiKey, payload, responseObject, mcpToolsMapping, defaultHeaders)) {
+		for await (const event of handleOneTurnStream(apiKey, payload, responseObject, mcpToolsMapping)) {
 			yield event;
 		}
 
@@ -521,13 +499,11 @@ async function* handleOneTurnStream(
 	apiKey: string | undefined,
 	payload: ChatCompletionCreateParamsStreaming,
 	responseObject: IncompleteResponse,
-	mcpToolsMapping: Record<string, McpServerParams>,
-	defaultHeaders: Record<string, string>
+	mcpToolsMapping: Record<string, McpServerParams>
 ): AsyncGenerator<PatchedResponseStreamEvent> {
 	const client = new OpenAI({
 		baseURL: process.env.OPENAI_BASE_URL ?? "https://router.huggingface.co/v1",
 		apiKey: apiKey,
-		defaultHeaders,
 	});
 	const stream = await client.chat.completions.create(payload);
 	let previousInputTokens = responseObject.usage?.input_tokens ?? 0;