Chapter 20 - Directory creation

Author: schaable

chapter-20/directory-creation.js

@@ -0,0 +1,16 @@
+import { mkdir } from 'fs/promises';
+import { urlPath } from './file-server.js';
+
+// Run file-server.js with node for testing
+const mkcolHandler = async (request) => {
+  const path = urlPath(request.url);
+  try {
+    await mkdir(path, { recursive: true });
+    return { status: 201 };
+  } catch (error) {
+    if (error.code != 'EEXIST') throw error;
+    else return { status: 400, body: 'Not a directory' };
+  }
+};
+
+export default mkcolHandler;

chapter-20/file-server.js

@@ -0,0 +1,89 @@
+import { createServer } from 'http';
+import { parse } from 'url';
+import { resolve, sep } from 'path';
+import { createReadStream, createWriteStream } from 'fs';
+import { stat, readdir, rmdir, unlink } from 'fs/promises';
+import mime from 'mime';
+
+import mkcolHandler from './directory-creation.js';
+
+const methods = Object.create(null);
+
+createServer((request, response) => {
+  let handler = methods[request.method] || notAllowed;
+  handler(request)
+    .catch((error) => {
+      if (error.status != null) return error;
+      return { body: String(error), status: 500 };
+    })
+    .then(({ body, status = 200, type = 'text/plain' }) => {
+      response.writeHead(status, { 'Content-Type': type });
+      if (body && body.pipe) body.pipe(response);
+      else response.end(body);
+    });
+}).listen(8000);
+
+async function notAllowed(request) {
+  return {
+    status: 405,
+    body: `Method ${request.method} not allowed.`,
+  };
+}
+
+var baseDirectory = process.cwd() + sep + 'test-files';
+
+export function urlPath(url) {
+  let { pathname } = parse(url);
+  let path = resolve('test-files' + sep + decodeURIComponent(pathname).slice(1));
+  if (path != baseDirectory && !path.startsWith(baseDirectory + sep)) {
+    throw { status: 403, body: 'Forbidden' };
+  }
+  return path;
+}
+
+methods.GET = async function (request) {
+  let path = urlPath(request.url);
+  let stats;
+  try {
+    stats = await stat(path);
+  } catch (error) {
+    if (error.code != 'ENOENT') throw error;
+    else return { status: 404, body: 'File not found' };
+  }
+  if (stats.isDirectory()) {
+    return { body: (await readdir(path)).join('\n') };
+  } else {
+    return { body: createReadStream(path), type: mime.getType(path) };
+  }
+};
+
+methods.DELETE = async function (request) {
+  let path = urlPath(request.url);
+  let stats;
+  try {
+    stats = await stat(path);
+  } catch (error) {
+    if (error.code != 'ENOENT') throw error;
+    else return { status: 204 };
+  }
+  if (stats.isDirectory()) await rmdir(path);
+  else await unlink(path);
+  return { status: 204 };
+};
+
+function pipeStream(from, to) {
+  return new Promise((resolve, reject) => {
+    from.on('error', reject);
+    to.on('error', reject);
+    to.on('finish', resolve);
+    from.pipe(to);
+  });
+}
+
+methods.PUT = async function (request) {
+  let path = urlPath(request.url);
+  await pipeStream(request, createWriteStream(path));
+  return { status: 204 };
+};
+
+methods.MKCOL = mkcolHandler;

chapter-20/package-lock.json

@@ -0,0 +1,15 @@
+{
+  "name": "file-server",
+  "version": "1.0.0",
+  "description": "",
+  "main": "file-server.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "mime": "^3.0.0"
+  },
+  "type": "module"
+}