-
-
Notifications
You must be signed in to change notification settings - Fork 18
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
29 changed files
with
751 additions
and
332 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,144 @@ | ||
| /* eslint-disable @typescript-eslint/ban-ts-comment */ | ||
| import type { IncomingMessage } from "node:http"; | ||
| import type { Socket } from "node:net"; | ||
|
|
||
| // @ts-ignore | ||
| const deno = typeof Deno !== "undefined"; | ||
| // @ts-ignore | ||
| const bun = typeof Bun !== "undefined"; | ||
|
|
||
| interface PossiblyEncryptedSocket extends Socket { | ||
| encrypted?: boolean; | ||
| } | ||
|
|
||
| /** | ||
| * `IncomingMessage` possibly augmented with some environment-specific | ||
| * properties. | ||
| */ | ||
| export interface DecoratedRequest extends Omit<IncomingMessage, "socket"> { | ||
| ip?: string; | ||
| protocol?: string; | ||
| socket?: PossiblyEncryptedSocket; | ||
| rawBody?: Buffer | null; | ||
| } | ||
|
|
||
| /** Adapter options */ | ||
| export interface NodeRequestAdapterOptions { | ||
| /** | ||
| * Set the origin part of the URL to a constant value. | ||
| * It defaults to `process.env.ORIGIN`. If neither is set, | ||
| * the origin is computed from the protocol and hostname. | ||
| * To determine the protocol, `req.protocol` is tried first. | ||
| * If `trustProxy` is set, `X-Forwarded-Proto` header is used. | ||
| * Otherwise, `req.socket.encrypted` is used. | ||
| * To determine the hostname, `X-Forwarded-Host` | ||
| * (if `trustProxy` is set) or `Host` header is used. | ||
| */ | ||
| origin?: string; | ||
| /** | ||
| * Whether to trust `X-Forwarded-*` headers. `X-Forwarded-Proto` | ||
| * and `X-Forwarded-Host` are used to determine the origin when | ||
| * `origin` and `process.env.ORIGIN` are not set. `X-Forwarded-For` | ||
| * is used to determine the IP address. The leftmost values are used | ||
| * if multiple values are set. Defaults to true if `process.env.TRUST_PROXY` | ||
| * is set to `1`, otherwise false. | ||
| */ | ||
| trustProxy?: boolean; | ||
| /** | ||
| * Can the Request constructor accept a ReadableStream? | ||
| */ | ||
| // canUseReadableStream: boolean; | ||
| } | ||
|
|
||
| /** Create a function that converts a Node HTTP request into a fetch API `Request` object */ | ||
| export function createRequestAdapter( | ||
| options: NodeRequestAdapterOptions = {}, | ||
| ): (req: DecoratedRequest) => [request: Request, ip: string] { | ||
| const { | ||
| origin = process.env.ORIGIN, | ||
| trustProxy = process.env.TRUST_PROXY === "1", | ||
| } = options; | ||
|
|
||
| let { protocol, host } = origin | ||
| ? new URL(origin) | ||
| : ({} as Record<string, undefined>); | ||
|
|
||
| if (protocol) { | ||
| protocol = protocol.slice(0, -1); | ||
| } | ||
|
|
||
| let warned = false; | ||
|
|
||
| return function requestAdapter(req) { | ||
| // TODO: Support the newer `Forwarded` standard header | ||
| function parseForwardedHeader(name: string) { | ||
| return (headers["x-forwarded-" + name] || "").split(",", 1)[0].trim(); | ||
| } | ||
|
|
||
| let headers = req.headers as any; | ||
| if (headers[":method"]) { | ||
| headers = Object.fromEntries( | ||
| Object.entries(headers).filter(([key]) => !key.startsWith(":")), | ||
| ); | ||
| } | ||
|
|
||
| const ip = | ||
| req.ip || | ||
| (trustProxy && parseForwardedHeader("for")) || | ||
| req.socket?.remoteAddress || | ||
| ""; | ||
|
|
||
| protocol = | ||
| protocol || | ||
| req.protocol || | ||
| (trustProxy && parseForwardedHeader("proto")) || | ||
| (req.socket?.encrypted && "https") || | ||
| "http"; | ||
|
|
||
| host = host || (trustProxy && parseForwardedHeader("host")) || headers.host; | ||
|
|
||
| if (!host && !warned) { | ||
| console.warn( | ||
| "Could not automatically determine the origin host, using 'localhost'. " + | ||
| "Use the 'origin' option or the 'ORIGIN' environment variable to set the origin explicitly.", | ||
| ); | ||
| warned = true; | ||
| host = "localhost"; | ||
| } | ||
|
|
||
| const request = new Request(protocol + "://" + host + req.url, { | ||
| method: req.method, | ||
| headers, | ||
| body: convertBody(req), | ||
| // @ts-expect-error: Node requires this when the body is a ReadableStream | ||
| duplex: "half", | ||
| }); | ||
|
|
||
| return [request, ip]; | ||
| }; | ||
| } | ||
|
|
||
| function convertBody(req: DecoratedRequest): BodyInit | null | undefined { | ||
| if (req.method === "GET" || req.method === "HEAD") { | ||
| return; | ||
| } | ||
|
|
||
| // Needed for Google Cloud Functions and some other environments | ||
| // that pre-parse the body. | ||
| if (req.rawBody !== undefined) { | ||
| return req.rawBody; | ||
| } | ||
|
|
||
| if (!bun && !deno) { | ||
| // Real Node can handle ReadableStream | ||
| return req as any; | ||
| } | ||
|
|
||
| return new ReadableStream({ | ||
| start(controller) { | ||
| req.on("data", (chunk) => controller.enqueue(chunk)); | ||
| req.on("end", () => controller.close()); | ||
| req.on("error", (err) => controller.error(err)); | ||
| }, | ||
| }); | ||
| } |
Oops, something went wrong.