First iteration of simple validation

Author: megoth

lib/handlers/validate.js

@@ -0,0 +1,28 @@
+module.exports = handler
+
+const bodyParser = require('body-parser')
+const error = require('../http-error')
+const LDP = require('../ldp')
+const $rdf = require('rdflib')
+const debug = require('../debug')
+
+function handler (req, res, next) {
+  bodyParser.text({ type: () => true })(req, res, () => validate(req, res, next))
+}
+
+function validate (req, res, next) {
+  const contentType = req.get('content-type')
+  if (!LDP.mimetypeIsRdf(contentType)) {
+    return next()
+  }
+
+  const resourceGraph = $rdf.graph()
+  const requestUri = `${req.protocol}//${req.get('host')}${req.originalUrl}`
+  try {
+    $rdf.parse(req.body, resourceGraph, requestUri, contentType)
+  } catch (err) {
+    debug.handlers('VALIDATE -- Error parsing data: ' + err)
+    return next(error(400, 'Unable to parse the body of request'))
+  }
+  next()
+}

lib/ldp-middleware.js

@@ -10,6 +10,7 @@ const del = require('./handlers/delete')
 const patch = require('./handlers/patch')
 const index = require('./handlers/index')
 const copy = require('./handlers/copy')
+const validate = require('./handlers/validate')
 
 function LdpMiddleware (corsSettings) {
   const router = express.Router('/')
@@ -23,9 +24,9 @@ function LdpMiddleware (corsSettings) {
 
   router.copy('/*', allow('Write'), copy)
   router.get('/*', index, allow('Read'), header.addPermissions, get)
-  router.post('/*', allow('Append'), post)
-  router.patch('/*', allow('Append'), patch)
-  router.put('/*', allow('Write'), put)
+  router.post('/*', allow('Append'), validate, post)
+  router.patch('/*', allow('Append'), validate, patch)
+  router.put('/*', allow('Write'), validate, put)
   router.delete('/*', allow('Write'), del)
 
   return router