Add support for form submissions

package.json

@@ -86,6 +86,7 @@
     "configstore": "^5.0.0",
     "cookie": "^0.4.0",
     "copy-template-dir": "^1.4.0",
+    "csv-writer": "^1.6.0",
     "debug": "^4.1.1",
     "dot-prop": "^5.1.0",
     "dotenv": "^8.2.0",
@@ -119,6 +120,7 @@
     "log-symbols": "^2.2.0",
     "make-dir": "^3.0.0",
     "minimist": "^1.2.0",
+    "mkdirp": "^1.0.3",
     "netlify": "^4.0.0",
     "netlify-redirect-parser": "^2.3.0",
     "netlify-redirector": "^0.1.0",
@@ -168,7 +170,6 @@
     "husky": "^3.0.3",
     "lint-staged": "^9.2.1",
     "markdown-magic": "^0.1.25",
-    "mkdirp": "^0.5.1",
     "mocha": "^6.2.0",
     "nock": "^10.0.6",
     "npm-run-all": "^4.1.5",

src/commands/dev/index.js

@@ -11,11 +11,14 @@ const getPort = require('get-port')
 const chokidar = require('chokidar')
 const proxyMiddleware = require('http-proxy-middleware')
 const cookie = require('cookie')
+const mkdirp = require('mkdirp')
+const csvWriterPkg = require('csv-writer')
 const get = require('lodash.get')
 const isEmpty = require('lodash.isempty')
 const { serveFunctions } = require('../../utils/serve-functions')
 const { serverSettings } = require('../../utils/detect-server')
 const { detectFunctionsBuilder } = require('../../utils/detect-functions-builder')
+const { collectRequestBody } = require('../../utils/forms')
 const Command = require('../../utils/command')
 const chalk = require('chalk')
 const jwtDecode = require('jwt-decode')
@@ -172,7 +175,25 @@ async function startProxy(settings, addonUrls, configPath, projectDir) {
     configPath,
   })
 
+  mkdirp.sync(path.resolve(projectDir, '.netlify'))
+
+  const formSubmissionsFile = path.resolve(projectDir, '.netlify', 'form-submissions.csv')
+  const csvWriter = csvWriterPkg.createArrayCsvWriter({
+    alwaysQuote: true,
+    header: ['timestamp', 'path', 'body'],
+    path: formSubmissionsFile,
+    append: true,
+  })
+
   const server = http.createServer(function(req, res) {
+    if (req.method === 'POST') {
+      collectRequestBody(req, async body => {
+        await csvWriter.writeRecords([[new Date().toISOString(), req.url, body]])
+        res.end(body)
+      })
+      return
+    }
+
     if (isFunction(settings.functionsPort, req)) {
       return proxy.web(req, res, { target: functionsServer })
     }

src/utils/forms.js

@@ -0,0 +1,17 @@
+const FORM_URLENCODED = 'application/x-www-form-urlencoded'
+
+function collectRequestBody(request, callback) {
+    let body = ''
+
+    request.on('data', chunk => body += chunk)
+
+    if(request.headers['content-type'] === FORM_URLENCODED) {
+        request.on('end', () => callback(body))
+    }  else {
+        callback(body)
+    }
+}
+
+module.exports = {
+    collectRequestBody,
+}