Database service

database.js

import R from 'ramda';
import knex from 'knex';

export const connect = knex;

export const disconnect = async client => {
  return await client.destroy();
};

export const withClient = R.curry(async (config, cb) => {
  const client = connect(config);
  try {
    return await cb(client);
  } finally {
    await disconnect(client);
  }
});

export const withTransaction = R.curry(async (client, cb) => {
  return await client.transaction(cb);
});

export const execute = R.curry(async (client, { sql, values }) => {
  return await client.raw(sql, values);
});

export const query = R.curry(async (client, { sql, values }) => {
  const { rows } = await client.raw(sql, values);
  return rows;
});

export const queryOne = R.curry(async (client, { sql, values }) => {
  const { rows: [row = null] } = await client.raw(sql, values);
  return row;
});