.init({}, fn) for initializing db schema

package.json

@@ -57,6 +57,7 @@
     "lib": "lib"
   },
   "dependencies": {
+    "debug": "^2.6.8",
     "feathers-errors": "^2.0.1",
     "feathers-query-filters": "^2.0.0",
     "is-plain-object": "^2.0.1",

src/index.js

@@ -4,6 +4,8 @@ import isPlainObject from 'is-plain-object';
 import { errors } from 'feathers-errors';
 import errorHandler from './error-handler';
 
+const debug = require('debug')('feathers-knex');
+
 const METHODS = {
   $or: 'orWhere',
   $ne: 'whereNot',
@@ -51,6 +53,17 @@ class Service {
     return Proto.extend(obj, this);
   }
 
+  init (opts = {}, cb) {
+    let k = this.knex;
+    let table = this.table;
+
+    return k.schema.dropTableIfExists(table)
+      .then(function () {
+        debug(`dropped ${table} table`);
+        return k.schema.createTable(table, cb);
+      });
+  }
+
   knexify (query, params, parentKey) {
     Object.keys(params || {}).forEach(key => {
       const value = params[key];

test/index.test.js

@@ -14,37 +14,44 @@ const db = knex({
   }
 });
 
+const people = service({
+  Model: db,
+  name: 'people',
+  events: [ 'testing' ]
+});
+
+const peopleId = service({
+  Model: db,
+  id: 'customid',
+  name: 'people-customid',
+  events: [ 'testing' ]
+});
+
 function clean () {
-  return db.schema.dropTableIfExists('people')
-    .then(() => db.schema.dropTableIfExists('people-customid'))
-    .then(() =>
-      db.schema.createTable('people', table => {
-        table.increments('id');
-        table.string('name');
-        table.integer('age');
-        table.integer('time');
-        table.boolean('created');
-      }).then(() => db.schema.createTable('people-customid', table => {
-        table.increments('customid');
-        table.string('name');
-        table.integer('age');
-        table.integer('time');
-        table.boolean('created');
-      }))
-  );
+  return people.init({}, (table) => {
+    table.increments('id');
+    table.string('name');
+    table.integer('age');
+    table.integer('time');
+    table.boolean('created');
+    return table;
+  })
+  .then(() => {
+    return peopleId.init({}, (table) => {
+      table.increments('customid');
+      table.string('name');
+      table.integer('age');
+      table.integer('time');
+      table.boolean('created');
+      return table;
+    });
+  });
 }
 
 describe('Feathers Knex Service', () => {
-  const app = feathers().use('/people', service({
-    Model: db,
-    name: 'people',
-    events: [ 'testing' ]
-  })).use('/people-customid', service({
-    Model: db,
-    id: 'customid',
-    name: 'people-customid',
-    events: [ 'testing' ]
-  }));
+  const app = feathers()
+    .use('/people', people)
+    .use('people-customid', peopleId);
 
   before(clean);
   after(clean);