add model query logguer

src/index.js

@@ -7,7 +7,7 @@ import { concatValues } from './helpers';
 
 export { concatValues };
 
-export default ({ filename }) => {
+export default ({ filename, queryLogger }) => {
   const dbParams = {
     filename,
     driver: sqlite3.Database
@@ -29,7 +29,7 @@ export default ({ filename }) => {
 
   return {
     connect,
-    model: model(connect),
+    model: model({ connect, log: queryLogger }),
     migrate
   };
 };

src/model/model.js

@@ -2,8 +2,14 @@ import SQL from 'sql-template-strings';
 
 import { concatValues } from '../helpers';
 
-const makeExec = (connect) => (action, query) => connect()
-  .then(db => db[action](query));
+const makeExec = ({ connect, log }) => (action, query) => connect()
+  .then(db => {
+    if (log) {
+      log({ db, action, query });
+    }
+
+    return db[action](query)
+  });
 
 const makeQueries = ({ fields, table }) => {
   const fieldsList = fields.join(', ');
@@ -71,13 +77,13 @@ const makeStore = ({ exec, queries, fields }) => {
  *
  * @return {object}
  */
-const init = (connect) => (config) => {
+const init = ({ connect, log }) => (config) => {
   const {
     fields,
     table,
     primaryKey = 'rowid',
   } = config;
-  const exec = makeExec(connect)
+  const exec = makeExec({ connect, log })
   const queries = makeQueries({ fields, table });
 
   return {

tests/features/model/getter/getter.test.js

@@ -7,6 +7,11 @@ describe('Model->getters', () => {
   beforeAll(async () => {
     vegeData = VegeData({ filename: getTmpDb() });
 
+    model = vegeData.model.init({
+      table: 'characters',
+      fields: ['name', 'type']
+    });
+
     db = await vegeData.connect();
 
     await db.run(`
@@ -26,14 +31,6 @@ describe('Model->getters', () => {
     `);
   });
 
-  beforeEach(async () => {
-
-    model = vegeData.model.init({
-      table: 'characters',
-      fields: ['name', 'type']
-    });
-  });
-
   describe('all', () => {
     it('should return all elements in db', async () => {
       return Promise.all([