PostCSVServer.js

/**
 * Server that only accepts POST requests and appends request body
 * to a local CSV file. Can be used in conjunction with PostCSV.
 */
/* global process */
import { promises as Fs } from "fs";

import Cors from "cors";
import Express from "express";
import BasicAuth from "express-basic-auth";
import bodyParser from "body-parser";
import Getopt from "posix-getopt";

const DESCRIPTION = [
  "DESCRIPTION\nServer giving GET/POST access to static files and database, and AJAX requests for reading sensors attached to host Raspberry Pi.",
  "", "OPTIONS",
  "\t-h, --help - Show this help",
  `\t-p, --port=ARG - port to listen on (default 80))`,
  "\t-f, --file - .csv file to append post data to",
  "\t-u, --user - user and password for basic auth e.g. `brain:freeze` for user `brain` password `freeze`",
  "\tYou can give s many --user options as you want.",
  "", "\tThe server supports the following routes:",
  "\tPOST /uploadCSV - POST csv data to append to file"
].join("\n");

const go_parser = new Getopt.BasicParser(
  "p:(port)h(help)f:(file)u:(user)w:", process.argv);

let port = 80, csvFile = "dives.csv", users = [], pause = 0;
let option;
while ((option = go_parser.getopt())) {
  let up;
  switch (option.option) {
  case "p": port = option.optarg; break;
  case "u":
    up = option.optarg.split(":");
    users[up[0]] = up[1];
    break;
  case 'f': csvFile = option.optarg; break;
    // Undocumented wait before response, for debugging
  case 'w': pause = parseInt(option.optarg); break;
  case "h": console.log(DESCRIPTION); process.exit(); break;
  default: throw Error(`Unknown option -${option.option}\n${DESCRIPTION}`);
  }
}

const server = new Express();

server.use(Cors());

if (Object.keys(users).length > 0) {
  console.debug("BasicAuth enabled");
  server.use(BasicAuth({
    users: users,
    challenge: true,
    realm: "PostCSV Server",
    unauthorizedResponse: req => {
      return req.auth
      ? ('Credentials ' + req.auth.user + ':' + req.auth.password + ' rejected')
      : 'No credentials provided';
    }
  }));
}

server.use(bodyParser.text({ type: '*/*' }));
server.post("/upload", (req, res) => {
  const data = req.body;
  console.debug("Upload", typeof data, data);
  return Fs.readFile(csvFile)
  .then(old => Fs.writeFile(csvFile, old.toString() + data)
        .catch(e => {
          console.debug(e);
          return Fs.writeFile(csvFile, data);
        }))
  .then(() => new Promise(resolve => setTimeout(resolve, pause)))
  .then(() => res.status(200).send("Uploaded"))
  .catch(e => {
    console.debug("POST failed", e);
    res.status(400).send("POST failed");
  });
});

console.debug(`Started server on port ${port}`);
//HTTP.Server(server).listen(port);
server.listen(port);