-
Notifications
You must be signed in to change notification settings - Fork 242
Expand file tree
/
Copy pathhttp_server_native_request.ts
More file actions
133 lines (114 loc) · 3.44 KB
/
http_server_native_request.ts
File metadata and controls
133 lines (114 loc) · 3.44 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
// Copyright 2018-2025 the oak authors. All rights reserved. MIT license.
import type {
NetAddr,
ServerRequest,
Uint8ArrayArrayBuffer,
UpgradeWebSocketFn,
UpgradeWebSocketOptions,
} from "./types.ts";
import { createPromiseWithResolvers } from "./utils/create_promise_with_resolvers.ts";
// deno-lint-ignore no-explicit-any
export const DomResponse: typeof Response = (globalThis as any).Response ??
class MockResponse {};
const maybeUpgradeWebSocket: UpgradeWebSocketFn | undefined =
"Deno" in globalThis && "upgradeWebSocket" in globalThis.Deno
// deno-lint-ignore no-explicit-any
? (Deno as any).upgradeWebSocket.bind(Deno)
: undefined;
export function isNativeRequest(r: ServerRequest): r is NativeRequest {
return r instanceof NativeRequest;
}
export interface NativeRequestInfo {
remoteAddr?: NetAddr;
upgradeWebSocket?: UpgradeWebSocketFn;
}
/** An internal oak abstraction for handling a Deno native request. Most users
* of oak do not need to worry about this abstraction. */
export class NativeRequest implements ServerRequest {
#remoteAddr?: NetAddr;
// deno-lint-ignore no-explicit-any
#reject: (reason?: any) => void;
#request: Request;
#resolve: (value: Response) => void;
#resolved = false;
#response: Promise<Response>;
#upgradeWebSocket?: UpgradeWebSocketFn;
constructor(
request: Request,
info: NativeRequestInfo,
) {
this.#remoteAddr = info.remoteAddr;
// this allows for the value to be explicitly undefined in the options
this.#upgradeWebSocket = "upgradeWebSocket" in info
? info.upgradeWebSocket
: maybeUpgradeWebSocket;
this.#request = request;
const { resolve, reject, promise } = createPromiseWithResolvers<Response>();
this.#resolve = resolve;
this.#reject = reject;
this.#response = promise;
}
get body(): ReadableStream<Uint8ArrayArrayBuffer> | null {
return this.#request.body;
}
get headers(): Headers {
return this.#request.headers;
}
get method(): string {
return this.#request.method;
}
get remoteAddr(): string | undefined {
return this.#remoteAddr?.hostname;
}
get request(): Request {
return this.#request;
}
get response(): Promise<Response> {
return this.#response;
}
get url(): string {
try {
const url = new URL(this.#request.url);
return this.#request.url.replace(url.origin, "");
} catch {
// we don't care about errors, we just want to fall back
}
return this.#request.url;
}
get rawUrl(): string {
return this.#request.url;
}
// deno-lint-ignore no-explicit-any
error(reason?: any): void {
if (this.#resolved) {
throw new Error("Request already responded to.");
}
this.#reject(reason);
this.#resolved = true;
}
getBody(): ReadableStream<Uint8ArrayArrayBuffer> | null {
return this.#request.body;
}
respond(response: Response): void {
if (this.#resolved) {
throw new Error("Request already responded to.");
}
this.#resolved = true;
this.#resolve(response);
}
upgrade(options?: UpgradeWebSocketOptions): WebSocket {
if (this.#resolved) {
throw new Error("Request already responded to.");
}
if (!this.#upgradeWebSocket) {
throw new TypeError("Upgrading web sockets not supported.");
}
const { response, socket } = this.#upgradeWebSocket(
this.#request,
options,
);
this.#resolve(response);
this.#resolved = true;
return socket;
}
}