Postgres transaction clean up

postgres-transaction-api-clean-up.js

const db = require('../../database/db.js');

// The following would be library code, touched barely ever
const _executeTransaction = async(transaction) => {
  try {
    return await db.tx(transaction);
  } catch (e) {
    console.log(e);
    // Handle DB error
  }
};

const _buildTransaction = ( queries = [] ) =>
  ( t ) => {

    // TODO: Handle logic of the queries object structure
    const preparedQueries = queries.map( ({ method, query, args }) =>
      t[method || 'any'](query, args || [])
    );

    return t.batch(preparedQueries);
  };

const doBoth = (queries) => {
  const temp = _buildTransaction(queries);
  return _executeTransaction(temp);
};


// The following is how the code would be consumed...
executeTransaction([{
  query: 'SELECT * FROM oauth_code'
}, {
  query: 'SELECT * FROM oauth_code'
}])
  .then( (data) => {
    console.log(data);
  });