import { join as posixJoin } from "../path/posix/join.ts";import { normalize as posixNormalize } from "../path/posix/normalize.ts";import { extname } from "../path/extname.ts";import { join } from "../path/join.ts";import { relative } from "../path/relative.ts";import { resolve } from "../path/resolve.ts";import { SEPARATOR_PATTERN } from "../path/constants.ts";import { contentType } from "../media_types/content_type.ts";import { calculate, ifNoneMatch } from "./etag.ts";import { isRedirectStatus, STATUS_CODE, STATUS_TEXT, type StatusCode,} from "./status.ts";import { ByteSliceStream } from "../streams/byte_slice_stream.ts";import { parseArgs } from "../cli/parse_args.ts";import { red } from "../fmt/colors.ts";import { VERSION } from "../version.ts";import { format as formatBytes } from "../fmt/bytes.ts";
interface EntryInfo { mode: string; size: string; url: string; name: string;}
const ENV_PERM_STATUS = Deno.permissions.querySync?.({ name: "env", variable: "DENO_DEPLOYMENT_ID" }) .state ?? "granted"; const DENO_DEPLOYMENT_ID = ENV_PERM_STATUS === "granted" ? Deno.env.get("DENO_DEPLOYMENT_ID") : undefined;const HASHED_DENO_DEPLOYMENT_ID = DENO_DEPLOYMENT_ID ? calculate(DENO_DEPLOYMENT_ID, { weak: true }) : undefined;
function modeToString(isDir: boolean, maybeMode: number | null): string { const modeMap = ["---", "--x", "-w-", "-wx", "r--", "r-x", "rw-", "rwx"];
if (maybeMode === null) { return "(unknown mode)"; } const mode = maybeMode.toString(8); if (mode.length < 3) { return "(unknown mode)"; } let output = ""; mode .split("") .reverse() .slice(0, 3) .forEach((v) => { output = `${modeMap[+v]} ${output}`; }); output = `${isDir ? "d" : "-"} ${output}`; return output;}
function createStandardResponse(status: StatusCode, init?: ResponseInit) { const statusText = STATUS_TEXT[status]; return new Response(statusText, { status, statusText, ...init });}
function parseRangeHeader(rangeValue: string, fileSize: number) { const rangeRegex = /bytes=(?<start>\d+)?-(?<end>\d+)?$/u; const parsed = rangeValue.match(rangeRegex);
if (!parsed || !parsed.groups) { return null; }
const { start, end } = parsed.groups; if (start !== undefined) { if (end !== undefined) { return { start: +start, end: +end }; } else { return { start: +start, end: fileSize - 1 }; } } else { if (end !== undefined) { return { start: fileSize - +end, end: fileSize - 1 }; } else { return null; } }}
export interface ServeFileOptions { etagAlgorithm?: AlgorithmIdentifier; fileInfo?: Deno.FileInfo;}
export async function serveFile( req: Request, filePath: string, { etagAlgorithm: algorithm, fileInfo }: ServeFileOptions = {},): Promise<Response> { try { fileInfo ??= await Deno.stat(filePath); } catch (error) { if (error instanceof Deno.errors.NotFound) { await req.body?.cancel(); return createStandardResponse(STATUS_CODE.NotFound); } else { throw error; } }
if (fileInfo.isDirectory) { await req.body?.cancel(); return createStandardResponse(STATUS_CODE.NotFound); }
const headers = createBaseHeaders();
if (fileInfo.atime) { headers.set("date", fileInfo.atime.toUTCString()); }
const etag = fileInfo.mtime ? await calculate(fileInfo, { algorithm }) : await HASHED_DENO_DEPLOYMENT_ID;
if (fileInfo.mtime) { headers.set("last-modified", fileInfo.mtime.toUTCString()); } if (etag) { headers.set("etag", etag); }
if (etag || fileInfo.mtime) { const ifNoneMatchValue = req.headers.get("if-none-match"); const ifModifiedSinceValue = req.headers.get("if-modified-since"); if ( (!ifNoneMatch(ifNoneMatchValue, etag)) || (ifNoneMatchValue === null && fileInfo.mtime && ifModifiedSinceValue && fileInfo.mtime.getTime() < new Date(ifModifiedSinceValue).getTime() + 1000) ) { const status = STATUS_CODE.NotModified; return new Response(null, { status, statusText: STATUS_TEXT[status], headers, }); } }
const contentTypeValue = contentType(extname(filePath)); if (contentTypeValue) { headers.set("content-type", contentTypeValue); }
const fileSize = fileInfo.size;
const rangeValue = req.headers.get("range");
if (rangeValue && 0 < fileSize) { const parsed = parseRangeHeader(rangeValue, fileSize);
if (!parsed) { headers.set("content-length", `${fileSize}`);
const file = await Deno.open(filePath); const status = STATUS_CODE.OK; return new Response(file.readable, { status, statusText: STATUS_TEXT[status], headers, }); }
if ( parsed.end < 0 || parsed.end < parsed.start || fileSize <= parsed.start ) { headers.set("content-range", `bytes */${fileSize}`);
return createStandardResponse( STATUS_CODE.RangeNotSatisfiable, { headers }, ); }
const start = Math.max(0, parsed.start); const end = Math.min(parsed.end, fileSize - 1);
headers.set("content-range", `bytes ${start}-${end}/${fileSize}`);
const contentLength = end - start + 1; headers.set("content-length", `${contentLength}`);
const file = await Deno.open(filePath); await file.seek(start, Deno.SeekMode.Start); const sliced = file.readable .pipeThrough(new ByteSliceStream(0, contentLength - 1)); const status = STATUS_CODE.PartialContent; return new Response(sliced, { status, statusText: STATUS_TEXT[status], headers, }); }
headers.set("content-length", `${fileSize}`);
const file = await Deno.open(filePath); const status = STATUS_CODE.OK; return new Response(file.readable, { status, statusText: STATUS_TEXT[status], headers, });}
async function serveDirIndex( dirPath: string, options: { showDotfiles: boolean; target: string; urlRoot: string | undefined; quiet: boolean | undefined; },): Promise<Response> { const { showDotfiles } = options; const urlRoot = options.urlRoot ? "/" + options.urlRoot : ""; const dirUrl = `/${ relative(options.target, dirPath).replaceAll( new RegExp(SEPARATOR_PATTERN, "g"), "/", ) }`; const listEntryPromise: Promise<EntryInfo>[] = [];
if (dirUrl !== "/") { const prevPath = join(dirPath, ".."); const entryInfo = Deno.stat(prevPath).then((fileInfo): EntryInfo => ({ mode: modeToString(true, fileInfo.mode), size: "", name: "../", url: `${urlRoot}${posixJoin(dirUrl, "..")}`, })); listEntryPromise.push(entryInfo); }
for await (const entry of Deno.readDir(dirPath)) { if (!showDotfiles && entry.name[0] === ".") { continue; } const filePath = join(dirPath, entry.name); const fileUrl = encodeURIComponent(posixJoin(dirUrl, entry.name)) .replaceAll("%2F", "/");
listEntryPromise.push((async () => { try { const fileInfo = await Deno.stat(filePath); return { mode: modeToString(entry.isDirectory, fileInfo.mode), size: entry.isFile ? formatBytes(fileInfo.size ?? 0) : "", name: `${entry.name}${entry.isDirectory ? "/" : ""}`, url: `${urlRoot}${fileUrl}${entry.isDirectory ? "/" : ""}`, }; } catch (error) { if (!options.quiet) logError(error); return { mode: "(unknown mode)", size: "", name: `${entry.name}${entry.isDirectory ? "/" : ""}`, url: `${urlRoot}${fileUrl}${entry.isDirectory ? "/" : ""}`, }; } })()); }
const listEntry = await Promise.all(listEntryPromise); listEntry.sort((a, b) => a.name.toLowerCase() > b.name.toLowerCase() ? 1 : -1 ); const formattedDirUrl = `${dirUrl.replace(/\/$/, "")}/`; const page = dirViewerTemplate(formattedDirUrl, listEntry);
const headers = createBaseHeaders(); headers.set("content-type", "text/html; charset=UTF-8");
const status = STATUS_CODE.OK; return new Response(page, { status, statusText: STATUS_TEXT[status], headers, });}
function serveFallback(maybeError: unknown): Response { if (maybeError instanceof URIError) { return createStandardResponse(STATUS_CODE.BadRequest); }
if (maybeError instanceof Deno.errors.NotFound) { return createStandardResponse(STATUS_CODE.NotFound); }
return createStandardResponse(STATUS_CODE.InternalServerError);}
function serverLog(req: Request, status: number) { const d = new Date().toISOString(); const dateFmt = `[${d.slice(0, 10)} ${d.slice(11, 19)}]`; const url = new URL(req.url); const s = `${dateFmt} [${req.method}] ${url.pathname}${url.search} ${status}`; console.debug(s);}
function createBaseHeaders(): Headers { return new Headers({ server: "deno", "accept-ranges": "bytes", });}
function dirViewerTemplate(dirname: string, entries: EntryInfo[]): string { const paths = dirname.split("/");
return ` <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8" /> <meta name="viewport" content="width=device-width, initial-scale=1.0" /> <meta http-equiv="X-UA-Compatible" content="ie=edge" /> <title>Deno File Server</title> <style> :root { --background-color: #fafafa; --color: rgba(0, 0, 0, 0.87); } @media (prefers-color-scheme: dark) { :root { --background-color: #292929; --color: #fff; } thead { color: #7f7f7f; } } @media (min-width: 960px) { main { max-width: 960px; } body { padding-left: 32px; padding-right: 32px; } } @media (min-width: 600px) { main { padding-left: 24px; padding-right: 24px; } } body { background: var(--background-color); color: var(--color); font-family: "Roboto", "Helvetica", "Arial", sans-serif; font-weight: 400; line-height: 1.43; font-size: 0.875rem; } a { color: #2196f3; text-decoration: none; } a:hover { text-decoration: underline; } thead { text-align: left; } thead th { padding-bottom: 12px; } table td { padding: 6px 36px 6px 0px; } .size { text-align: right; padding: 6px 12px 6px 24px; } .mode { font-family: monospace, monospace; } </style> </head> <body> <main> <h1>Index of <a href="/">home</a>${ paths .map((path, index, array) => { if (path === "") return ""; const link = array.slice(0, index + 1).join("/"); return `<a href="${link}">${path}</a>`; }) .join("/") } </h1> <table> <thead> <tr> <th>Mode</th> <th>Size</th> <th>Name</th> </tr> </thead> ${ entries .map( (entry) => ` <tr> <td class="mode"> ${entry.mode} </td> <td class="size"> ${entry.size} </td> <td> <a href="${entry.url}">${entry.name}</a> </td> </tr> `, ) .join("") } </table> </main> </body> </html> `;}
export interface ServeDirOptions { fsRoot?: string; urlRoot?: string; showDirListing?: boolean; showDotfiles?: boolean; showIndex?: boolean; enableCors?: boolean; quiet?: boolean; etagAlgorithm?: AlgorithmIdentifier; headers?: string[];}
export async function serveDir( req: Request, opts: ServeDirOptions = {},): Promise<Response> { let response: Response; try { response = await createServeDirResponse(req, opts); } catch (error) { if (!opts.quiet) logError(error); response = serveFallback(error); }
const isRedirectResponse = isRedirectStatus(response.status);
if (opts.enableCors && !isRedirectResponse) { response.headers.append("access-control-allow-origin", "*"); response.headers.append( "access-control-allow-headers", "Origin, X-Requested-With, Content-Type, Accept, Range", ); }
if (!opts.quiet) serverLog(req, response.status);
if (opts.headers && !isRedirectResponse) { for (const header of opts.headers) { const headerSplit = header.split(":"); const name = headerSplit[0]!; const value = headerSplit.slice(1).join(":"); response.headers.append(name, value); } }
return response;}
async function createServeDirResponse( req: Request, opts: ServeDirOptions,) { const target = opts.fsRoot || "."; const urlRoot = opts.urlRoot; const showIndex = opts.showIndex ?? true; const showDotfiles = opts.showDotfiles || false; const { etagAlgorithm, showDirListing, quiet } = opts;
const url = new URL(req.url); const decodedUrl = decodeURIComponent(url.pathname); let normalizedPath = posixNormalize(decodedUrl);
if (urlRoot && !normalizedPath.startsWith("/" + urlRoot)) { return createStandardResponse(STATUS_CODE.NotFound); }
if (normalizedPath !== decodedUrl) { url.pathname = normalizedPath; return Response.redirect(url, 301); }
if (urlRoot) { normalizedPath = normalizedPath.replace(urlRoot, ""); }
if (normalizedPath.endsWith("/")) { normalizedPath = normalizedPath.slice(0, -1); }
const fsPath = join(target, normalizedPath); const fileInfo = await Deno.stat(fsPath);
if (fileInfo.isFile && url.pathname.endsWith("/")) { url.pathname = url.pathname.slice(0, -1); return Response.redirect(url, 301); } if (fileInfo.isDirectory && !url.pathname.endsWith("/")) { url.pathname += "/"; return Response.redirect(url, 301); }
if (!fileInfo.isDirectory) { return serveFile(req, fsPath, { etagAlgorithm, fileInfo, }); }
if (showIndex) { const indexPath = join(fsPath, "index.html");
let indexFileInfo: Deno.FileInfo | undefined; try { indexFileInfo = await Deno.lstat(indexPath); } catch (error) { if (!(error instanceof Deno.errors.NotFound)) { throw error; } }
if (indexFileInfo?.isFile) { return serveFile(req, indexPath, { etagAlgorithm, fileInfo: indexFileInfo, }); } }
if (showDirListing) { return serveDirIndex(fsPath, { urlRoot, showDotfiles, target, quiet }); }
return createStandardResponse(STATUS_CODE.NotFound);}
function logError(error: unknown) { console.error(red(error instanceof Error ? error.message : `${error}`));}
function main() { const serverArgs = parseArgs(Deno.args, { string: ["port", "host", "cert", "key", "header"], boolean: ["help", "dir-listing", "dotfiles", "cors", "verbose", "version"], negatable: ["dir-listing", "dotfiles", "cors"], collect: ["header"], default: { "dir-listing": true, dotfiles: true, cors: true, verbose: false, version: false, host: "0.0.0.0", port: "4507", cert: "", key: "", }, alias: { p: "port", c: "cert", k: "key", h: "help", v: "verbose", V: "version", H: "header", }, }); const port = Number(serverArgs.port); const headers = serverArgs.header || []; const host = serverArgs.host; const certFile = serverArgs.cert; const keyFile = serverArgs.key;
if (serverArgs.help) { printUsage(); Deno.exit(); }
if (serverArgs.version) { console.log(`Deno File Server ${VERSION}`); Deno.exit(); }
if (keyFile || certFile) { if (keyFile === "" || certFile === "") { console.log("--key and --cert are required for TLS"); printUsage(); Deno.exit(1); } }
const wild = serverArgs._ as string[]; const target = resolve(wild[0] ?? "");
const handler = (req: Request): Promise<Response> => { return serveDir(req, { fsRoot: target, showDirListing: serverArgs["dir-listing"], showDotfiles: serverArgs.dotfiles, enableCors: serverArgs.cors, quiet: !serverArgs.verbose, headers, }); };
const useTls = !!(keyFile && certFile);
if (useTls) { Deno.serve({ port, hostname: host, cert: Deno.readTextFileSync(certFile), key: Deno.readTextFileSync(keyFile), }, handler); } else { Deno.serve({ port, hostname: host, }, handler); }}
function printUsage() { console.log(`Deno File Server ${VERSION} Serves a local directory in HTTP.
INSTALL: deno install --allow-net --allow-read https://deno.land/std/http/file_server.ts
USAGE: file_server [path] [options]
OPTIONS: -h, --help Prints help information -p, --port <PORT> Set port --cors Enable CORS via the "Access-Control-Allow-Origin" header --host <HOST> Hostname (default is 0.0.0.0) -c, --cert <FILE> TLS certificate file (enables TLS) -k, --key <FILE> TLS key file (enables TLS) -H, --header <HEADER> Sets a header on every request. (e.g. --header "Cache-Control: no-cache") This option can be specified multiple times. --no-dir-listing Disable directory listing --no-dotfiles Do not show dotfiles --no-cors Disable cross-origin resource sharing -v, --verbose Print request level logs -V, --version Print version information
All TLS options are required when one is provided.`);}
if (import.meta.main) { main();}