2023-01-13 02:51:32 -05:00
|
|
|
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
|
|
|
|
|
2022-07-02 10:09:25 -04:00
|
|
|
const addr = Deno.args[0] || "127.0.0.1:4500";
|
|
|
|
const [hostname, port] = addr.split(":");
|
|
|
|
const tcp = Deno.listen({ hostname, port: Number(port) });
|
|
|
|
console.log("Server listening on", addr);
|
|
|
|
|
|
|
|
class Http {
|
|
|
|
id;
|
|
|
|
constructor(id) {
|
|
|
|
this.id = id;
|
|
|
|
}
|
|
|
|
[Symbol.asyncIterator]() {
|
|
|
|
return {
|
|
|
|
next: async () => {
|
|
|
|
const reqEvt = await Deno.core.opAsync("op_http_accept", this.id);
|
|
|
|
return { value: reqEvt ?? undefined, done: reqEvt === null };
|
|
|
|
},
|
|
|
|
};
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
for await (const conn of tcp) {
|
2022-08-11 09:56:56 -04:00
|
|
|
const id = Deno.core.ops.op_http_start(conn.rid);
|
2022-07-02 10:09:25 -04:00
|
|
|
const http = new Http(id);
|
|
|
|
(async () => {
|
|
|
|
for await (const req of http) {
|
|
|
|
if (req == null) continue;
|
|
|
|
const { 0: stream } = req;
|
|
|
|
await Deno.core.opAsync(
|
|
|
|
"op_http_write_headers",
|
|
|
|
stream,
|
|
|
|
200,
|
|
|
|
[],
|
|
|
|
"Hello World",
|
|
|
|
);
|
|
|
|
Deno.core.close(stream);
|
|
|
|
}
|
|
|
|
})();
|
|
|
|
}
|