Update to latest jsonapi-server with parsed filter.

Update to support latest version of jsonapi-server, check that we have a
minimum version that provides the `processedFilter` property and make
use of that in order to avoid duplicated processing and be able to use
filter values cast from strings to the correct attribute type.

Author: pmcnr-hx

lib/sqlHandler.js

@@ -5,13 +5,17 @@ var async = require("async");
 var crypto = require("crypto");
 var debug = require("debug")("jsonApi:store:relationaldb");
 var Joi = require("joi");
+var semver = require("semver");
 var _ = {
   pick: require("lodash.pick"),
   assign: require("lodash.assign"),
   omit: require("lodash.omit")
 };
 
+var MIN_SERVER_VERSION = "1.10.0";
+
 var SqlStore = module.exports = function SqlStore(config) {
+  SqlStore._checkMinServerVersion();
   this.config = config;
 };
 
@@ -22,6 +26,14 @@ SqlStore._sequelizeInstances = Object.create(null);
  */
 SqlStore.prototype.ready = false;
 
+SqlStore._checkMinServerVersion = function() {
+  var serverVersion = require('jsonapi-server')._version;
+  if (!serverVersion) return;
+  if (semver.lt(serverVersion, MIN_SERVER_VERSION)) {
+    throw new Error("This version of jsonapi-store-mongodb requires jsonapi-server>=" + MIN_SERVER_VERSION + ".");
+  }
+};
+
 /**
   initialise gets invoked once for each resource that uses this hander.
   In this instance, we're instantiating a Sequelize instance and building models.
@@ -252,35 +264,42 @@ SqlStore.prototype._filterInclude = function(relationships) {
 SqlStore.prototype._generateSearchBlock = function(request) {
   var self = this;
 
-  var attributesToFilter = _.omit(request.params.filter, Object.keys(self.relations));
-  var searchBlock = self._recurseOverSearchBlock(attributesToFilter);
+  var attributesToFilter = _.omit(request.params.processedFilter, Object.keys(self.relations));
+  var searchBlock = SqlStore._getSearchBlock(attributesToFilter);
   return searchBlock;
 };
 
-SqlStore.prototype._recurseOverSearchBlock = function(obj) {
-  var self = this;
-  if (!obj) return { };
+SqlStore._scalarFilterElementToWhereObj = function(element) {
+  var value = element.value;
+  if (!element.operator) return value;
+  var whereObj = {
+    ">": { $gt: value },
+    "<": { $lt: value },
+    "~": { $like: value },
+    ":": { $like: "%" + value + "%" }
+  }[element.operator];
+  return whereObj;
+};
+
+SqlStore._filterElementToSearchBlock = function(filterElement) {
+  if (!filterElement) return { };
+  var whereObjs = filterElement.map(function(scalarFilterElement) {
+    return SqlStore._scalarFilterElementToWhereObj(scalarFilterElement);
+  });
+  if (!whereObjs.length) return { };
+  if (filterElement.length === 1) {
+    return whereObjs[0];
+  }
+  return { $or: whereObjs };
+};
+
+SqlStore._getSearchBlock = function(filter) {
+  if (!filter) return { };
   var searchBlock = { };
 
-  Object.keys(obj).forEach(function(attributeName) {
-    var textToMatch = obj[attributeName];
-    if (textToMatch instanceof Array) {
-      searchBlock[attributeName] = { $or: textToMatch.map(function(i) {
-        return self._recurseOverSearchBlock({ i: i }).i;
-      }) };
-    } else if (textToMatch instanceof Object) {
-      // Do nothing, its a nested filter
-    } else if (textToMatch[0] === ">") {
-      searchBlock[attributeName] = { $gt: textToMatch.substring(1) };
-    } else if (textToMatch[0] === "<") {
-      searchBlock[attributeName] = { $lt: textToMatch.substring(1) };
-    } else if (textToMatch[0] === "~") {
-      searchBlock[attributeName] = { $like: textToMatch.substring(1) };
-    } else if (textToMatch[0] === ":") {
-      searchBlock[attributeName] = { $like: "%" + textToMatch.substring(1) + "%" };
-    } else {
-      searchBlock[attributeName] = textToMatch;
-    }
+  Object.keys(filter).forEach(function(attributeName) {
+    var filterElement = filter[attributeName];
+    searchBlock[attributeName] = SqlStore._filterElementToSearchBlock(filterElement);
   });
 
   return searchBlock;

package.json

@@ -28,13 +28,14 @@
     "lodash.assign": "^4.0.9",
     "lodash.omit": "^4.3.0",
     "lodash.pick": "^4.2.1",
+    "semver": "^5.1.0",
     "sequelize": "^3.23.3"
   },
   "devDependencies": {
     "blanket": "1.1.9",
     "coveralls": "^2.11.9",
     "eslint": "^2.11.0",
-    "jsonapi-server": "1.2.0",
+    "jsonapi-server": "holidayextras/jsonapi-server#2ba05c6",
     "mocha": "^2.5.3",
     "mocha-lcov-reporter": "^1.2.0",
     "mocha-performance": "^0.1.1",