summaryrefslogtreecommitdiff
path: root/cli
diff options
context:
space:
mode:
authorLuca Casonato <hello@lcas.dev>2022-08-24 14:10:57 +0200
committerGitHub <noreply@github.com>2022-08-24 17:40:57 +0530
commitf3bde1d53b4710fb526286e27af29a55f5da18c7 (patch)
treee9ff07886e5cc7ac0535ece0c47fe2447b509e4d /cli
parent452df99222911c772657c39491469bd97935f23a (diff)
feat(ext/flash): split upgradeHttp into two APIs (#15557)
This commit splits `Deno.upgradeHttp` into two different APIs, because the same API is currently overloaded with two different functions. Flash requests upgrade immediately, with no need to return a `Response` object. Instead you have to manually write the response to the socket. Hyper requests only upgrade once a `Response` object has been sent. These two behaviours are now split into `Deno.upgradeHttp` and `Deno.upgradeHttpRaw`. The latter is flash only. The former only supports hyper requests at the moment, but can be updated to support flash in the future. Additionally this removes `void | Promise<void>` as valid return types for the handler function. If one wants to use `Deno.upgradeHttpRaw`, they will have to type cast the handler signature - the signature is meant for the 99.99%, and should not be complicated for the 0.01% that use `Deno.upgradeHttpRaw()`.
Diffstat (limited to 'cli')
-rw-r--r--cli/bench/testdata/deno_upgrade_http.js4
-rw-r--r--cli/dts/lib.deno.unstable.d.ts42
-rw-r--r--cli/tests/unit/flash_test.ts6
3 files changed, 40 insertions, 12 deletions
diff --git a/cli/bench/testdata/deno_upgrade_http.js b/cli/bench/testdata/deno_upgrade_http.js
index 7274459c9..db14f8589 100644
--- a/cli/bench/testdata/deno_upgrade_http.js
+++ b/cli/bench/testdata/deno_upgrade_http.js
@@ -1,8 +1,8 @@
-const { serve, upgradeHttp } = Deno;
+const { serve, upgradeHttpRaw } = Deno;
const u8 = Deno.core.encode("HTTP/1.1 101 Switching Protocols\r\n\r\n");
async function handler(req) {
- const [conn, _firstPacket] = upgradeHttp(req);
+ const [conn, _firstPacket] = upgradeHttpRaw(req);
await conn.write(u8);
await conn.close();
}
diff --git a/cli/dts/lib.deno.unstable.d.ts b/cli/dts/lib.deno.unstable.d.ts
index a1817deb0..2f6a197bc 100644
--- a/cli/dts/lib.deno.unstable.d.ts
+++ b/cli/dts/lib.deno.unstable.d.ts
@@ -1344,25 +1344,51 @@ declare namespace Deno {
options: ServeInit & (ServeOptions | ServeTlsOptions),
): Promise<void>;
- /** **UNSTABLE**: new API, yet to be vetter.
+ /** **UNSTABLE**: new API, yet to be vetted.
*
- * Allows to "hijack" a connection that the request is associated with.
- * Can be used to implement protocols that build on top of HTTP (eg.
+ * Allows "hijacking" the connection that the request is associated with.
+ * This can be used to implement protocols that build on top of HTTP (eg.
* WebSockets).
*
- * The return type depends if `request` is coming from `Deno.serve()` API
- * or `Deno.serveHttp()`; for former it returns the connection and first
- * packet, for latter it returns a promise.
- *
* The returned promise returns underlying connection and first packet
* received. The promise shouldn't be awaited before responding to the
* `request`, otherwise event loop might deadlock.
*
+ * ```ts
+ * function handler(req: Request): Response {
+ * Deno.upgradeHttp(req).then(([conn, firstPacket]) => {
+ * // ...
+ * });
+ * return new Response(null, { status: 101 });
+ * }
+ * ```
+ *
+ * This method can only be called on requests originating the `Deno.serveHttp`
+ * server.
+ *
* @category HTTP Server
*/
export function upgradeHttp(
request: Request,
- ): [Deno.Conn, Uint8Array] | Promise<[Deno.Conn, Uint8Array]>;
+ ): Promise<[Deno.Conn, Uint8Array]>;
+
+ /** **UNSTABLE**: new API, yet to be vetted.
+ *
+ * Allows "hijacking" the connection that the request is associated with.
+ * This can be used to implement protocols that build on top of HTTP (eg.
+ * WebSockets).
+
+ * Unlike `Deno.upgradeHttp` this function does not require that you respond
+ * to the request with a `Response` object. Instead this function returns
+ * the underlying connection and first packet received immediately, and then
+ * the caller is responsible for writing the response to the connection.
+ *
+ * This method can only be called on requests originating the `Deno.serve`
+ * server.
+ *
+ * @category HTTP Server
+ */
+ export function upgradeHttpRaw(request: Request): [Deno.Conn, Uint8Array];
/** @category Sub Process */
export interface SpawnOptions {
diff --git a/cli/tests/unit/flash_test.ts b/cli/tests/unit/flash_test.ts
index f59484291..c718c1b2e 100644
--- a/cli/tests/unit/flash_test.ts
+++ b/cli/tests/unit/flash_test.ts
@@ -1002,14 +1002,14 @@ Deno.test(
},
);
-Deno.test("upgradeHttp tcp", async () => {
+Deno.test("upgradeHttpRaw tcp", async () => {
const promise = deferred();
const listeningPromise = deferred();
const promise2 = deferred();
const ac = new AbortController();
const signal = ac.signal;
const handler = async (req: Request) => {
- const [conn, _] = await Deno.upgradeHttp(req);
+ const [conn, _] = Deno.upgradeHttpRaw(req);
await conn.write(
new TextEncoder().encode("HTTP/1.1 101 Switching Protocols\r\n\r\n"),
@@ -1028,6 +1028,8 @@ Deno.test("upgradeHttp tcp", async () => {
conn.close();
};
const server = Deno.serve({
+ // NOTE: `as any` is used to bypass type checking for the return value
+ // of the handler.
handler: handler as any,
port: 4501,
signal,