feat(associations): many-to-many associations

fix(associations): fix association queries, must use `include` instead of ForeignKey
fix(error): error decorator was missing await, which prevented it from catching errors
fix(error): console.error the error
refactor(crud): don't use `request.models[name]`, use the model directly
chore: README added

src/associations/one-to-many.js

@@ -18,11 +18,17 @@ export const list = (server, a, b) => {
 
     @error
     async handler(request, reply) {
-      let list = await request.models[b.name].findAll({
+      let list = await b.findAll({
         where: {
           ...request.query,
-          [a.name + 'Id']: request.params.aid
-        }
+        },
+
+        include: [{
+          model: a,
+          where: {
+            id: request.params.aid
+          }
+        }]
       });
 
       reply(list);
@@ -37,11 +43,17 @@ export const destroy = (server, a, b) => {
 
     @error
     async handler(request, reply) {
-      let list = await request.models[b.name].findAll({
+      let list = await b.findAll({
         where: {
-          ...request.query,
-          [a.name + 'Id']: request.params.aid
-        }
+          ...request.query
+        },
+
+        include: [{
+          model: a,
+          where: {
+            id: request.params.aid
+          }
+        }]
       });
 
       await* list.map(instance => instance.destroy());
@@ -58,11 +70,17 @@ export const update = (server, a, b) => {
 
     @error
     async handler(request, reply) {
-      let list = await request.models[b.name].findOne({
+      let list = await b.findOne({
         where: {
-          ...request.query,
-          [a.name + 'Id']: request.params.aid
-        }
+          ...request.query
+        },
+
+        include: [{
+          model: a,
+          where: {
+            id: request.params.aid
+          }
+        }]
       });
 
       await* list.map(instance => instance.update(request.payload));

src/associations/one-to-one.js

@@ -19,11 +19,17 @@ export const get = (server, a, b) => {
 
     @error
     async handler(request, reply) {
-      let instance = await request.models[b.name].findOne({
+      let instance = await b.findOne({
         where: {
-          id: request.params.bid,
-          [a.name + 'Id']: request.params.aid
-        }
+          id: request.params.bid
+        },
+
+        include: [{
+          model: a,
+          where: {
+            id: request.params.aid
+          }
+        }]
       });
 
       reply(instance);
@@ -53,11 +59,17 @@ export const destroy = (server, a, b) => {
 
     @error
     async handler(request, reply) {
-      let instance = await request.models[b.name].findOne({
+      let instance = await b.findOne({
         where: {
-          id: request.params.bid,
-          [a.name + 'Id']: request.params.aid
-        }
+          id: request.params.bid
+        },
+
+        include: [{
+          model: a,
+          where: {
+            id: request.params.aid
+          }
+        }]
       });
 
       await instance.destroy();
@@ -74,11 +86,17 @@ export const update = (server, a, b) => {
 
     @error
     async handler(request, reply) {
-      let instance = await request.models[b.name].findOne({
+      let instance = await b.findOne({
         where: {
-          id: request.params.bid,
-          [a.name + 'Id']: request.params.aid
-        }
+          id: request.params.bid
+        },
+
+        include: [{
+          model: a,
+          where: {
+            id: request.params.aid
+          }
+        }]
       });
 
       await instance.update(request.payload);

src/crud.js

@@ -21,8 +21,7 @@ export const list = (server, model) => {
 
     @error
     async handler(request, reply) {
-      console.log(request.models[model.name], request.query);
-      let list = await request.models[model.name].findAll({
+      let list = await model.findAll({
         where: request.query
       });
 
@@ -40,7 +39,7 @@ export const get = (server, model) => {
     async handler(request, reply) {
       let where = request.params.id ? { id : request.params.id } : request.query;
 
-      let instance = await request.models[model.name].findOne({ where });
+      let instance = await model.findOne({ where });
 
       reply(instance);
     },
@@ -63,7 +62,7 @@ export const scope = (server, model) => {
 
     @error
     async handler(request, reply) {
-      let list = await request.models[model.name].scope(request.params.scope).findAll();
+      let list = await model.scope(request.params.scope).findAll();
 
       reply(list);
     },
@@ -84,7 +83,7 @@ export const create = (server, model) => {
 
     @error
     async handler(request, reply) {
-      let instance = await request.models[model.name].create(request.payload);
+      let instance = await model.create(request.payload);
 
       reply(instance);
     }
@@ -100,7 +99,7 @@ export const destroy = (server, model) => {
     async handler(request, reply) {
       let where = request.params.id ? { id : request.params.id } : request.query;
 
-      let list = await request.models[model.name].findAll({ where });
+      let list = await model.findAll({ where });
 
       await* list.map(instance => instance.destroy());
 
@@ -116,7 +115,7 @@ export const update = (server, model) => {
 
     @error
     async handler(request, reply) {
-      let instance = await request.models[model.name].findOne({
+      let instance = await model.findOne({
         where: {
           id: request.params.id
         }

src/error.js

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

src/index.js

@@ -37,16 +37,23 @@ const register = (server, options = {}, next) => {
           associations.oneToOne(server, target, source, options);
         }
 
-        if (sourceType === 'BelongsTo' && (targetType === 'HasMany')) {
+        if (sourceType === 'BelongsTo' && targetType === 'HasMany') {
           associations.oneToOne(server, source, target, options);
           associations.oneToOne(server, target, source, options);
           associations.oneToMany(server, target, source, options);
         }
+
+        if (sourceType === 'BelongsToMany' && targetType === 'BelongsToMany') {
+          associations.oneToOne(server, source, target, options);
+          associations.oneToOne(server, target, source, options);
+
+          associations.oneToMany(server, source, target, options);
+          associations.oneToMany(server, target, source, options);
+        }
       } catch(e) {
         // There might be conflicts in case of models associated with themselves and some other
         // rare cases.
       }
-      console.log(sourceName.singular, sourceType, targetName.singular, ' & ', targetName.singular, targetType, sourceName.singular);
     }
   }