mirror of
https://github.com/denoland/deno.git
synced 2024-11-30 16:40:57 -05:00
Simple file server (#11)
This commit is contained in:
parent
0e82a4249e
commit
c8e5d98900
2 changed files with 42 additions and 8 deletions
42
file_server.ts
Normal file → Executable file
42
file_server.ts
Normal file → Executable file
|
@ -1,18 +1,44 @@
|
|||
#!/usr/bin/env deno --allow-net
|
||||
|
||||
// This program serves files in the current directory over HTTP.
|
||||
// TODO Supply the directory to serve as a CLI argument.
|
||||
// TODO Stream responses instead of reading them into memory.
|
||||
// TODO Add tests like these:
|
||||
// https://github.com/indexzero/http-server/blob/master/test/http-server-test.js
|
||||
|
||||
import { listenAndServe } from "./http.ts";
|
||||
import { open, cwd } from "deno";
|
||||
import { cwd, readFile, DenoError, ErrorKind } from "deno";
|
||||
|
||||
const addr = "0.0.0.0:4500";
|
||||
const d = cwd();
|
||||
const currentDir = cwd();
|
||||
|
||||
const encoder = new TextEncoder();
|
||||
|
||||
listenAndServe(addr, async req => {
|
||||
const fileName = req.url.replace(/\/$/, '/index.html');
|
||||
const filePath = currentDir + fileName;
|
||||
let file;
|
||||
|
||||
listenAndServe(addr, async req => {
|
||||
const filename = d + "/" + req.url;
|
||||
let res;
|
||||
try {
|
||||
res = { status: 200, body: open(filename) };
|
||||
file = await readFile(filePath);
|
||||
} catch (e) {
|
||||
res = { status: 500, body: "bad" };
|
||||
if (e instanceof DenoError && e.kind === ErrorKind.NotFound) {
|
||||
await req.respond({ status: 404, body: encoder.encode("Not found") });
|
||||
} else {
|
||||
await req.response({ status: 500, body: encoder.encode("Internal server error") });
|
||||
}
|
||||
return;
|
||||
}
|
||||
req.respond(res);
|
||||
|
||||
const headers = new Headers();
|
||||
headers.set('content-type', 'octet-stream');
|
||||
|
||||
const res = {
|
||||
status: 200,
|
||||
body: file,
|
||||
headers,
|
||||
}
|
||||
await req.respond(res);
|
||||
});
|
||||
|
||||
console.log(`HTTP server listening on http://${addr}/`);
|
||||
|
|
8
http.ts
8
http.ts
|
@ -82,6 +82,14 @@ export async function* serve(addr: string) {
|
|||
listener.close();
|
||||
}
|
||||
|
||||
export async function listenAndServe(addr: string, handler: (ServerRequest) => void) {
|
||||
const server = serve(addr);
|
||||
|
||||
for await (const request of server) {
|
||||
await handler(request);
|
||||
}
|
||||
}
|
||||
|
||||
interface Response {
|
||||
status?: number;
|
||||
headers?: Headers;
|
||||
|
|
Loading…
Reference in a new issue