add adapter loopback (#4)

.travis.yml

@@ -1,6 +1,5 @@
 language: node_js
 node_js:
-  - '4.0.0'
-  - '5.0.0'
+  - '6.0.0'
 services:
   - mongodb

lib/adapters/loopback.js

@@ -0,0 +1,20 @@
+'use strict'
+
+const collections = [];
+let context = null;
+
+exports.setContext = function (val) {
+  context = val;
+};
+
+exports.put = function (coll, docs, cb) {
+  return context.models[coll].create(docs, cb);
+};
+
+exports.del = function (coll, cb) {
+  return context.models[coll].destroyAll(cb);
+};
+
+exports.close = function (cb) {
+  // TODO
+};

lib/adapters/mongo.js

@@ -1,4 +1,4 @@
-"use strict"
+'use strict'
 
 const typifyJSON = require('typify-json');
 const exec = require('child_process').execSync;
@@ -50,7 +50,7 @@ exports.put = function (coll, docs, cb) {
   }
 };
 
-exports.del = function (cb) {
+exports.del = function (coll, cb) {
   if (typeof cb !== 'function') {
     exec(`mongo ${dburl} --eval "db.dropDatabase()"`);
   } else {

lib/index.js

@@ -1,4 +1,4 @@
-"use strict"
+'use strict'
 
 const path = require('path');
 const once = require('once');
@@ -11,7 +11,13 @@ const fixturesDir = process.cwd() + '/test/fixtures';
 const dirs = new Map();
 var currentDir;
 
-exports.use = function (name, cb) {
+exports.use = function (name, context, cb) {
+  // normalize the arguments
+  if (typeof arguments[1] === 'function' && 
+    arguments.length === 2) {
+    cb = arguments[1];
+    context = false;
+  }
   var files;
   if (!dirs.has(name)) {
     debug(`${name} does not have caches, parsing a new one`);
@@ -24,6 +30,9 @@ exports.use = function (name, cb) {
         meta.name = path.basename(p, pmatch[1]);
         if (typeof meta.adapter === 'string') {
           meta.adapter = require('./adapters/' + meta.adapter);
+          if (typeof meta.adapter.setContext === 'function' && context) {
+            meta.adapter.setContext(context);
+          }
           adapters.push(meta.adapter);
         }
         return meta;
@@ -51,9 +60,13 @@ exports.use = function (name, cb) {
     debug('async mode');
     // delete documents tasks from adapters
     let deleteTasks = function () {
-      return Promise.race(
+      return Promise.all(
         files.adapters.map(function (adapter) {
-          return promisify(adapter.del)();
+          return Promise.all(
+            files.map(function (meta) {
+              return promisify(adapter.del)(meta.name);
+            })
+          );
         })
       );
     };
@@ -87,6 +100,7 @@ exports.use = function (name, cb) {
       debug('closing connections');
       return closeTasks();
     }).catch(function (err) {
+      console.error(err);
       cb(err);
     });
   }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "fibula",
-  "version": "1.3.4",
+  "version": "1.4.0",
   "description": "A **fixtures** framework for Node.js",
   "main": "lib/index.js",
   "scripts": {