Wrap for query using Knex

User.js

const knex = require('../../config/db')
const baseUsers = knex('users')

const tryCatch = fn => {
  try {
    return Promise.resolve(fn())
  } catch (e) {
    return Promise.reject(e)
  }
}

const sendCommit = (txt) => {
  return txt.commit
}

const sendRollback = (txt) => {
  return txt.rollback
}

const tryCommit = (txt, callback) => {
  return tryCatch(callback)
    .then(sendCommit)
    .catch(sendRollback)
}

const insert = (txt, user) => {
  return baseUsers
    .transacting(txt)
    .insert(user)
}

const handler = (callback, untilGetResult) => {
  console.log(' handler ' + callback, untilGetResult)
  return knex.transaction(txt => tryCommit(txt, callback(txt, untilGetResult)))
}

const beginTransaction = (callback, untilGetResult) => {
  console.log(' beginTransaction callback ' + JSON.stringify(callback))
  console.log(' beginTransaction untilGetResult ' + JSON.stringify(untilGetResult))
  return tryCatch(handler)
}

const insertUser = (user) => {
  console.log(' insertuser ' + JSON.stringify(user))
  return beginTransaction(insert, user)
}

module.exports = insertUser