dumbserver/app/dumbserver.js

//
// Dependencies
//
let http = require("http");
let fs = require("fs");

//
// Constants
//
let DATA_LOCATION = "dataDir/data"; // both the url root and the location of data file
let DATA_LOCATION_LEN = DATA_LOCATION.length;
let DATA_FILE = __dirname + "/" + DATA_LOCATION;
let PORT = 1280;

//
// Load store file
//
let store = {}; // deafult empty object
let json = "";
try {
  let json = fs.readFileSync(DATA_FILE);
  store = JSON.parse(json);
  console.log("Read store file");
} catch (e) {
  // lazy error handling
  console.log("Could not load store file.  Using empty array.");
}

//
// Flush to store file on exit
//
let flush = function () {
  console.log("Flushing data to file [" + DATA_FILE + "]\n");
  fs.writeFileSync(DATA_FILE, JSON.stringify(store));
};

let handleInterrupt = function () {
  flush();
  process.exit();
};

process.on("SIGINT", handleInterrupt);
process.on("SIGTERM", handleInterrupt);
process.on("SIGHUP", flush); // HUP flushes to file but keeps the server running

//
// If request URI is prefixed with the value of DATA_LOCATION, we treat incoming request as a REST request
// Otherwise we serve the file referenced by the URI
//
let serveFile = function (loc, req, resp) {
  let fullPath = __dirname + "/" + loc;
  console.log("Trying to serve file at [" + fullPath + "]");

  if (req.method !== "GET") {
    // read only!
    resp.writeHead(405);
    resp.write("Unsupported method\n");
    resp.end();
  } else if (fs.existsSync(fullPath)) {
    resp.writeHead(200);
    fs.createReadStream(fullPath).pipe(resp);
  } else {
    resp.writeHead(404);
    resp.write("Not Found\n");
    resp.end();
  }
};

let serveRestData = function (urlPath, req, resp) {
  console.log(req.method + " request for path [" + urlPath + "]");

  switch (req.method) {
    case "GET":
      let exactMatch = !urlPath.endsWith("/");
      let matchFound = false;

      if (exactMatch) {
        // assumes that only a single resource has this ID.
        console.log("  - Exact Match.");
        if (store.hasOwnProperty(urlPath)) {
          resp.writeHead(200, { "Content-Type": "application/json" });
          resp.write(JSON.stringify(store[urlPath]) + "\n");
          matchFound = true;
        }
      } else {
        console.log("  - All Matches.");
        let matches = [];
        Object.keys(store).forEach((theKey) => {
          if (theKey.startsWith(urlPath)) {
            matches.push(store[theKey]);
            matchFound = true;
          }
        });

        if (matchFound) {
          resp.writeHead(200, { "Content-Type": "application/json" });
          resp.write(JSON.stringify(matches));
        }
      }

      if (!matchFound) {
        console.log("  - Match NOT found.");
        resp.writeHead(404, { "Content-Type": "application/json" });
        resp.write('{"success":false, "error":"Not Found"}');
      } else {
        console.log("  - Match found.");
      }
      resp.end();
      break;

    case "PUT":
      json = "";
      req.on("data", function (chunk) {
        json += chunk;
      });
      req.on("end", function () {
        try {
          let data = JSON.parse(json);
          store[urlPath] = data;
          resp.writeHead(201, { "Content-Type": "application/json" });
          resp.write('{"success":true}');
        } catch (e) {
          resp.writeHead(400, { "Content-Type": "application/json" });
          resp.write('{"success":false, "error":"Invalid JSON"}');
        }
        resp.end();
        flush();
      });
      break;

    case "POST":
      json = "";
      req.on("data", function (chunk) {
        json += chunk;
      });
      req.on("end", function () {
        try {
          let data = JSON.parse(json);
          if (data.ID === undefined) {
            resp.writeHead(400, { "Content-Type": "application/json" });
            resp.write('{"success":false, "error":"The ID Field needs to be given"}');
          } else {
            // make sure the ID from the data is used as the final resource Identifier,
            // even if the URL has none or says different.
            let re = new RegExp("/[^/]*$");
            urlPath = urlPath.replace(re, "");
            urlPath = urlPath + "/" + data.ID;
            console.log("  - storing with resource key: [" + urlPath + "]");

            store[urlPath] = data;

            resp.writeHead(201, { "Content-Type": "application/json" });
            resp.write(JSON.stringify(store[urlPath]));
          }
        } catch (e) {
          resp.writeHead(400, { "Content-Type": "application/json" });
          resp.write('{"success":false, "error":"Invalid JSON"}');
        }
        resp.end();
        flush();
      });
      break;

    case "PATCH":
      json = "";
      req.on("data", function (chunk) {
        json += chunk;
      });
      req.on("end", function () {
        try {
          let data = JSON.parse(json);
          Object.keys(data).forEach((theKey) => {
            store[urlPath][theKey] = data[theKey];
          });

          resp.writeHead(201, { "Content-Type": "application/json" });
          resp.write('{"success":true}');
        } catch (e) {
          resp.writeHead(400, { "Content-Type": "application/json" });
          resp.write('{"success":false, "error":"Invalid JSON"}');
        }
        resp.end();
        flush();
      });
      break;

    case "OPTIONS":
      resp.end();
      break;

    case "DELETE":
      if (store.hasOwnProperty(urlPath)) {
        delete store[urlPath];
        resp.writeHead(204, { "Content-Type": "application/json" });
        resp.write('{"success":true}');
      } else {
        resp.writeHead(404, { "Content-Type": "application/json" });
        resp.write('{"success":false, "error":"Not Found"}');
      }
      resp.end();
      flush();
      break;

    default:
      resp.writeHead(405, { "Content-Type": "application/json" });
      resp.write('{"success":false, "error":"Unsupported method"}');
      resp.end();
  }
};

//
// Listen for connections
//
http
  .createServer(function (req, resp) {
    // CORS headers
    resp.setHeader("Access-Control-Allow-Origin", "*");
    resp.setHeader("Access-Control-Allow-Headers", "X-Request-With, content-type");
    resp.setHeader("Vary", "Origin");

    resp.setHeader("Access-Control-Allow-Methods", "GET, PATCH, POST, PUT, DELETE, OPTIONS");

    console.log("Serving [" + req.url + "]");

    if (req.url === "/") {
      // server index file
      serveFile("index.html", req, resp);
    } else {
      // rest request
      serveRestData(req.url, req, resp);
    }
  })
  .listen(PORT);