1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
// @ts-check
import { Status, STATUS_TEXT } from "std/http/http_status.ts";import { contentType } from "std/media_types/mod.ts";import { extname } from "std/path/mod.ts";import { readableStreamFromReader } from "std/streams/conversion.ts";
/** * Creates a response for a public file request. * @param {Request} request Request. * @param {URL} publicDir Public directory file URL. * @param {( *   request: Request, *   responseInit: import("./serve.mjs").ResponseInit * ) => import("./serve.mjs").ResponseInit *   | Promise<import("./serve.mjs").ResponseInit * >} [customizeResponseInit] Customizes the response init. * @returns {Promise<Response>} Response that streams the public file. */export default async function publicFileResponse(  request,  publicDir,  customizeResponseInit,) {  if (!(request instanceof Request)) {    throw new TypeError("Argument 1 `request` must be a `Request` instance.");  }
  if (!(publicDir instanceof URL)) {    throw new TypeError("Argument 2 `publicDir` must be a `URL` instance.");  }
  if (!publicDir.href.endsWith("/")) {    throw new TypeError(      "Argument 2 `publicDir` must be a URL ending with `/`.",    );  }
  if (    customizeResponseInit !== undefined &&    typeof customizeResponseInit !== "function"  ) {    throw new TypeError(      "Argument 3 `customizeResponseInit` must be a function.",    );  }
  const requestUrl = new URL(request.url);  const fileUrl = new URL("." + requestUrl.pathname, publicDir);  const file = await Deno.open(fileUrl);
  try {    const { isFile } = await file.stat();
    if (!isFile) throw new Deno.errors.NotFound();
    const body = readableStreamFromReader(file);
    /** @type {import("./serve.mjs").ResponseInit} */    let responseInit = {      status: Status.OK,      statusText: STATUS_TEXT[Status.OK],      headers: new Headers(),    };
    const fileExtension = extname(fileUrl.pathname);
    if (fileExtension) {      const contentTypeHeader = contentType(fileExtension);
      if (contentTypeHeader) {        responseInit.headers.set("content-type", contentTypeHeader);      }    }
    if (typeof customizeResponseInit === "function") {      responseInit = await customizeResponseInit(request, responseInit);    }
    return new Response(body, responseInit);  } catch (error) {    // Avoid closing an already closed file, see:    // https://github.com/denoland/deno/issues/14210    if (file.rid in Deno.resources()) Deno.close(file.rid);
    throw error;  }}