plugin.js

async function withAuthenticatedPgClient(
  { pgPool, needTransaction, sqlSettingsQuery },
  fn
) {
  const provideClient = async pgClient => {
    if (sqlSettingsQuery) {
      await pgClient.query(sqlSettingsQuery)
    }
    return await fn(pgClient)
  }

  return pgPool.task(pgClient =>
    needTransaction ? pgClient.tx(provideClient) : provideClient(pgClient)
  )
}