Function buildFetchRequest

nodejs/src/copilotRequestHandler.ts:646–674

(exchange: CopilotRequestExchange)

]);

async function buildFetchRequest(exchange: CopilotRequestExchange): Promise<Request> {
    const headers = new Headers();
    for (const [name, values] of Object.entries(exchange.headers)) {
        if (!values) {
            continue;
        }
        if (FORBIDDEN_REQUEST_HEADERS.has(name.toLowerCase())) {
            continue;
        }
        for (const value of values) {
            headers.append(name, value);
        }
    }

    const method = exchange.method.toUpperCase();
    const hasBody = method !== "GET" && method !== "HEAD";

    let body: Uint8Array | undefined;
    if (hasBody) {
        const buffered = await drainAsync(exchange.requestBody);
        if (buffered.length > 0) {
            body = buffered;
        }
    } else {
        await drainAsync(exchange.requestBody);
    }

    return new Request(exchange.url, { method, headers, body });
}

async function drainAsync(stream: AsyncIterable<Uint8Array>): Promise<Uint8Array> {
    const parts: Uint8Array[] = [];