db transaction overlay

db.js

import knex from 'knex';
import userQueries from './user';

function DB(qb) {
    this.qb = qb;
}


DB.prototype.startTransaction = function(fn) {
    this.knex.transaction(trx => {
        return fn(new DB(trx));
    });
};

Object.keys(userQueries).map(queryName => {
    DB.prototype[queryName] = function(...args) {
        return userQueries[queryName](this.qb)(...args);
    };
})


export default function createDB() {
    return new DB(knex({
        connectionInfos
    }));
}

index.js

import createDB from 'db';

const db = createDB();

db.startTransaction(trx => {
   return trx.saveUser(user);
});

user.js

const saveUser = qb => user {
    return qb.insert(user)
        .into('vamos_user');
}

export default {
    saveUser
}