2.4.0

It's now possible to limit the models rest routes are created for. This
is done via a `models` option that can be simple to complex. The readme
has been updated to reflect this.

Gruntfile.js

@@ -1,29 +0,0 @@
-module.exports = function(grunt) {
-  grunt.initConfig({
-    babel: {
-      scripts: {
-        files: [{
-          expand: true,
-          cwd: 'src',
-          src: '**/*.js',
-          dest: 'build/'
-        }]
-      }
-    },
-		clean: {
-			files: ['build/**/*.js']
-		},
-    watch: {
-      scripts: {
-        files: ['src/**/*.js', 'server/**/*.js'],
-        tasks: ['babel']
-      }
-    }
-  });
-
-  grunt.loadNpmTasks('grunt-babel');
-	grunt.loadNpmTasks('grunt-contrib-clean');
-  grunt.loadNpmTasks('grunt-contrib-watch');
-
-  grunt.registerTask('default', ['clean', 'babel']);
-};

README.md

@@ -28,11 +28,34 @@ await register({
   register: require('hapi-sequelize-crud'),
   options: {
     prefix: '/v1',
-    defaultConfig: { ... } // passed as `config` to all routes created
+    name: 'db', // the same name you used for configuring `hapi-sequelize` (options.name)
+    defaultConfig: { ... }, // passed as `config` to all routes created
+    models: ['cat', 'dog'] // only the cat and dog models will have routes created
+    // or
+    models: {
+      // possible methods: list, get, scope, create, destroy, destroyAll, destroyScope, update
+      cat: ['get', 'list'], // the cat model only has get and list methods enabled
+      dog: true, // the dog model has all methods enabled
+      bat: {
+        methods: ['list'],
+        config: { ... } // if provided, overrides the default config
+      }
+    }
   }
 });
 ```
 
+### Methods
+* list: get all rows in a table
+* get: get a single row
+* scope: reference a [sequelize scope](http://docs.sequelizejs.com/en/latest/api/model/#scopeoptions-model)
+* create: create a new row
+* destroy: delete a row
+* destroyAll: delete all models in the table
+* destroyScope: use a [sequelize scope](http://docs.sequelizejs.com/en/latest/api/model/#scopeoptions-model) to find rows, then delete them
+* update: update a row
+
+
 Please note that you should register `hapi-sequelize-crud` after defining your
 associations.
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getable/hapi-sequelize-crud",
-  "version": "2.2.0",
+  "version": "2.4.0",
   "description": "Hapi plugin that automatically generates RESTful API for CRUD",
   "main": "build/index.js",
   "config": {
@@ -30,7 +30,7 @@
     "babel-plugin-transform-es2015-modules-commonjs": "^6.10.3",
     "babel-preset-stage-1": "^6.5.0",
     "eslint": "2.10.2",
-    "eslint-config-pichak": "1.0.1",
+    "eslint-config-pichak": "1.1.0",
     "ghooks": "1.0.3",
     "scripty": "^1.6.0"
   },

src/associations/associate.js

@@ -14,15 +14,15 @@ export default (server, a, b, names, options) => {
 
     @error
     async handler(request, reply) {
-      let instanceb = await b.findOne({
+      const instanceb = await b.findOne({
         where: {
-          id: request.params.bid,
+          [b.primaryKeyField]: request.params.bid,
         },
       });
 
-      let instancea = await a.findOne({
+      const instancea = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primaryKeyField]: request.params.aid,
         },
       });
 

src/associations/one-to-many.js

@@ -28,18 +28,23 @@ export const get = (server, a, b, names) => {
     async handler(request, reply) {
       const include = parseInclude(request);
 
-      const base = a.findOne({
+      const base = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primaryKeyField]: request.params.aid,
         },
       });
 
       const method = getMethod(base, names.b);
+
       const list = await method({ where: {
-        id: request.params.bid,
+        [b.primaryKeyField]: request.params.bid,
       }, include });
 
-      reply(list);
+      if (Array.isArray(list)) {
+        reply(list[0]);
+      } else {
+        reply(list);
+      }
     },
 
     config: defaultConfig,
@@ -58,7 +63,7 @@ export const list = (server, a, b, names) => {
 
       const base = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primaryKeyField]: request.params.aid,
         },
       });
 
@@ -73,7 +78,7 @@ export const list = (server, a, b, names) => {
 };
 
 export const scope = (server, a, b, names) => {
-  let scopes = Object.keys(b.options.scopes);
+  const scopes = Object.keys(b.options.scopes);
 
   server.route({
     method: 'GET',
@@ -86,7 +91,7 @@ export const scope = (server, a, b, names) => {
 
       const base = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primaryKeyField]: request.params.aid,
         },
       });
 
@@ -112,7 +117,7 @@ export const scope = (server, a, b, names) => {
 };
 
 export const scopeScope = (server, a, b, names) => {
-  let scopes = {
+  const scopes = {
     a: Object.keys(a.options.scopes),
     b: Object.keys(b.options.scopes),
   };
@@ -126,7 +131,7 @@ export const scopeScope = (server, a, b, names) => {
       const include = parseInclude(request);
       const where = parseWhere(request);
 
-      let list = await b.scope(request.params.scopeb).findAll({
+      const list = await b.scope(request.params.scopeb).findAll({
         where,
         include: include.concat({
           model: a.scope(request.params.scopea),
@@ -159,7 +164,7 @@ export const destroy = (server, a, b, names) => {
 
       const base = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primaryKeyField]: request.params.aid,
         },
       });
 
@@ -175,7 +180,7 @@ export const destroy = (server, a, b, names) => {
 };
 
 export const destroyScope = (server, a, b, names) => {
-  let scopes = Object.keys(b.options.scopes);
+  const scopes = Object.keys(b.options.scopes);
 
   server.route({
     method: 'DELETE',
@@ -188,7 +193,7 @@ export const destroyScope = (server, a, b, names) => {
 
       const base = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primarykeyField]: request.params.aid,
         },
       });
 
@@ -228,7 +233,7 @@ export const update = (server, a, b, names) => {
 
       const base = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primaryKeyField]: request.params.aid,
         },
       });
 

src/associations/one-to-one.js

@@ -26,7 +26,7 @@ export const get = (server, a, b, names) => {
 
       const base = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primaryKeyField]: request.params.aid,
         },
       });
       const method = getMethod(base, names.b, false);
@@ -53,7 +53,7 @@ export const create = (server, a, b, names) => {
     async handler(request, reply) {
       const base = await a.findOne({
         where: {
-          id: request.params.id,
+          [a.primaryKeyField]: request.params.id,
         },
       });
 
@@ -79,10 +79,12 @@ export const destroy = (server, a, b, names) => {
 
       const base = await a.findOne({
         where: {
-          id: request.params.aid,
+          [a.primaryKeyField]: request.params.aid,
         },
       });
 
+      where[b.primaryKeyField] = request.params.bid;
+
       const method = getMethod(base, names.b, false, 'get');
       const instance = await method({ where, include });
       await instance.destroy();
@@ -110,6 +112,8 @@ export const update = (server, a, b, names) => {
         },
       });
 
+      where[b.primaryKeyField] = request.params.bid;
+
       const method = getMethod(base, names.b, false);
 
       const instance = await method({ where, include });

src/crud.js

@@ -4,24 +4,66 @@ import _ from 'lodash';
 import { parseInclude, parseWhere } from './utils';
 import { notFound } from 'boom';
 
-let prefix;
+const createAll = ({server, model, prefix, config}) => {
-let defaultConfig;
+  Object.keys(methods).forEach((method) => {
-
+    methods[method]({server, model, prefix, config});
-export default (server, model, options) => {
+  });
-  prefix = options.prefix;
-  defaultConfig = options.defaultConfig;
-
-  list(server, model);
-  get(server, model);
-  scope(server, model);
-  create(server, model);
-  destroy(server, model);
-  destroyAll(server, model);
-  destroyScope(server, model);
-  update(server, model);
 };
 
-export const list = (server, model) => {
+/*
+The `models` option, becomes `permissions`, and can look like:
+
+```
+models: ['cat', 'dog']
+```
+
+or
+
+```
+models: {
+  cat: ['list', 'get']
+  , dog: true // all
+}
+```
+
+*/
+
+export default (server, model, {prefix, defaultConfig: config, models: permissions}) => {
+  const modelName = model._singular;
+
+  if (!permissions) {
+    createAll({server, model, prefix, config});
+  }
+  else if (Array.isArray(permissions) && permissions.includes(modelName)) {
+    createAll({server, model, prefix, config});
+  }
+  else if (_.isPlainObject(permissions)) {
+    const permittedModels = Object.keys(permissions);
+
+    if (permissions[modelName] === true) {
+      createAll({server, model, prefix, config});
+    }
+    else if (permittedModels.includes(modelName)) {
+      if (Array.isArray(permissions[modelName])) {
+        permissions[modelName].forEach((method) => {
+          methods[method]({server, model, prefix, config});
+        });
+      }
+      else if (_.isPlainObject(permissions[modelName])) {
+        permissions[modelName].methods.forEach((method) => {
+          methods[method]({
+            server,
+            model,
+            prefix,
+            config: permissions[modelName].config || config,
+          });
+        });
+      }
+    }
+  }
+};
+
+export const list = ({server, model, prefix, config}) => {
   server.route({
     method: 'GET',
     path: `${prefix}/${model._plural}`,
@@ -40,11 +82,11 @@ export const list = (server, model) => {
       reply(list);
     },
 
-    config: defaultConfig,
+    config,
   });
 };
 
-export const get = (server, model) => {
+export const get = ({server, model, prefix, config}) => {
   server.route({
     method: 'GET',
     path: `${prefix}/${model._singular}/{id?}`,
@@ -53,8 +95,8 @@ export const get = (server, model) => {
     async handler(request, reply) {
       const include = parseInclude(request);
       const where = parseWhere(request);
-      const {id} = request.params;
+      const { id } = request.params;
-      if (id) where.id = id;
+      if (id) where[model.primaryKeyField] = id;
 
       const instance = await model.findOne({ where, include });
 
@@ -68,12 +110,12 @@ export const get = (server, model) => {
           id: joi.any(),
         }),
       },
-    }, defaultConfig),
+    }, config),
   });
 };
 
-export const scope = (server, model) => {
+export const scope = ({server, model, prefix, config}) => {
-  let scopes = Object.keys(model.options.scopes);
+  const scopes = Object.keys(model.options.scopes);
 
   server.route({
     method: 'GET',
@@ -94,11 +136,11 @@ export const scope = (server, model) => {
           scope: joi.string().valid(...scopes),
         }),
       },
-    }, defaultConfig),
+    }, config),
   });
 };
 
-export const create = (server, model) => {
+export const create = ({server, model, prefix, config}) => {
   server.route({
     method: 'POST',
     path: `${prefix}/${model._singular}`,
@@ -110,11 +152,11 @@ export const create = (server, model) => {
       reply(instance);
     },
 
-    config: defaultConfig,
+    config,
   });
 };
 
-export const destroy = (server, model) => {
+export const destroy = ({server, model, prefix, config}) => {
   server.route({
     method: 'DELETE',
     path: `${prefix}/${model._singular}/{id?}`,
@@ -122,7 +164,7 @@ export const destroy = (server, model) => {
     @error
     async handler(request, reply) {
       const where = parseWhere(request);
-      if (request.params.id) where.id = request.params.id;
+      if (request.params.id) where[model.primaryKeyField] = request.params.id;
 
       const list = await model.findAll({ where });
 
@@ -131,11 +173,11 @@ export const destroy = (server, model) => {
       reply(list.length === 1 ? list[0] : list);
     },
 
-    config: defaultConfig,
+    config,
   });
 };
 
-export const destroyAll = (server, model) => {
+export const destroyAll = ({server, model, prefix, config}) => {
   server.route({
     method: 'DELETE',
     path: `${prefix}/${model._plural}`,
@@ -151,12 +193,12 @@ export const destroyAll = (server, model) => {
       reply(list.length === 1 ? list[0] : list);
     },
 
-    config: defaultConfig,
+    config,
   });
 };
 
-export const destroyScope = (server, model) => {
+export const destroyScope = ({server, model, prefix, config}) => {
-  let scopes = Object.keys(model.options.scopes);
+  const scopes = Object.keys(model.options.scopes);
 
   server.route({
     method: 'DELETE',
@@ -167,7 +209,7 @@ export const destroyScope = (server, model) => {
       const include = parseInclude(request);
       const where = parseWhere(request);
 
-      let list = await model.scope(request.params.scope).findAll({ include, where });
+      const list = await model.scope(request.params.scope).findAll({ include, where });
 
       await Promise.all(list.map(instance => instance.destroy()));
 
@@ -179,18 +221,18 @@ export const destroyScope = (server, model) => {
           scope: joi.string().valid(...scopes),
         }),
       },
-    }, defaultConfig),
+    }, config),
   });
 };
 
-export const update = (server, model) => {
+export const update = ({server, model, prefix, config}) => {
   server.route({
     method: 'PUT',
     path: `${prefix}/${model._singular}/{id}`,
 
     @error
     async handler(request, reply) {
-      const {id} = request.params;
+      const { id } = request.params;
       const instance = await model.findOne({
         where: {
           id,
@@ -208,9 +250,13 @@ export const update = (server, model) => {
       validate: {
         payload: joi.object().required(),
       },
-    }, defaultConfig),
+    }, config),
   });
 };
 
 import * as associations from './associations/index';
 export { associations };
+
+const methods = {
+  list, get, scope, create, destroy, destroyAll, destroyScope, update,
+};

src/error.js

@@ -1,10 +1,10 @@
 export default (target, key, descriptor) => {
-  let fn = descriptor.value;
+  const fn = descriptor.value;
 
   descriptor.value = async (request, reply) => {
     try {
       await fn(request, reply);
-    } catch(e) {
+    } catch (e) {
       console.error(e);
       reply(e);
     }

src/index.js

@@ -8,9 +8,10 @@ import qs from 'qs';
 
 const register = (server, options = {}, next) => {
   options.prefix = options.prefix || '';
+  options.name = options.name || 'db';
 
-	let db = server.plugins['hapi-sequelize'].db;
+  const db = server.plugins['hapi-sequelize'][options.name];
-	let models = db.sequelize.models;
+  const models = db.sequelize.models;
 
   const onRequest = function (request, reply) {
     const uri = request.raw.req.url;
@@ -26,9 +27,9 @@ const register = (server, options = {}, next) => {
     method: onRequest,
   });
 
-  for (let modelName of Object.keys(models)) {
+  for (const modelName of Object.keys(models)) {
-    let model = models[modelName];
+    const model = models[modelName];
-    let { plural, singular } = model.options.name;
+    const { plural, singular } = model.options.name;
     model._plural = plural.toLowerCase();
     model._singular = singular.toLowerCase();
 
@@ -37,29 +38,30 @@ const register = (server, options = {}, next) => {
 
     crud(server, model, options);
 
-    for (let key of Object.keys(model.associations)) {
+    for (const key of Object.keys(model.associations)) {
-      let association = model.associations[key];
+      const association = model.associations[key];
-      let { source, target } = association;
+      const { source, target } = association;
 
-      let sourceName = source.options.name;
+      const sourceName = source.options.name;
 
       const names = (rev) => {
         const arr =  [{
-            plural: sourceName.plural.toLowerCase(),
+          plural: sourceName.plural.toLowerCase(),
-            singular: sourceName.singular.toLowerCase(),
+          singular: sourceName.singular.toLowerCase(),
-            original: sourceName,
+          original: sourceName,
-          }, {
+        }, {
-            plural: association.options.name.plural.toLowerCase(),
+          plural: association.options.name.plural.toLowerCase(),
-            singular: association.options.name.singular.toLowerCase(),
+          singular: association.options.name.singular.toLowerCase(),
-            original: association.options.name,
+          original: association.options.name,
-          }];
+        }];
 
         return rev ? { b: arr[0], a: arr[1] } : { a: arr[0], b: arr[1] };
       };
 
-      let targetAssociations = target.associations[sourceName.plural] || target.associations[sourceName.singular];
+      const targetAssociations = target.associations[sourceName.plural]
-      let sourceType = association.associationType,
+                               || target.associations[sourceName.singular];
-          targetType = (targetAssociations || {}).associationType;
+      const sourceType = association.associationType,
+        targetType = (targetAssociations || {}).associationType;
 
       try {
         if (sourceType === 'BelongsTo' && (targetType === 'BelongsTo' || !targetType)) {
@@ -83,7 +85,7 @@ const register = (server, options = {}, next) => {
 
         associations.associate(server, source, target, names(), options);
         associations.associate(server, target, source, names(1), options);
-      } catch(e) {
+      } catch (e) {
         // There might be conflicts in case of models associated with themselves and some other
         // rare cases.
       }

src/utils.js

@@ -5,16 +5,14 @@ export const parseInclude = request => {
                                                        : [request.query.include];
 
   const noGetDb = typeof request.getDb !== 'function';
-  const noRequestModels = request.models;
+  const noRequestModels = !request.models;
 
   if (noGetDb && noRequestModels) {
-    return new Error('`request.getDb` or `request.models` are not defined. Be sure to load hapi-sequelize before hapi-sequelize-crud.');
+    return new Error('`request.getDb` or `request.models` are not defined.'
+                   + 'Be sure to load hapi-sequelize before hapi-sequelize-crud.');
   }
 
-  const {models} = !noGetDb
+  const { models } = noGetDb ? request : request.getDb();
-    ? request.getDb()
-    : request
-    ;
 
   return include.map(a => {
     if (typeof a === 'string') return models[a];