Rx'ified node-postgres (pg)


Rough implementation of rxified wrapper of node-postgres lib.

Getting started

Installation
``
$ npm i pg @rough/rx-pg
`

A simple query
`js
const { finalize } = require('rxjs/operators');
const { Pool } = require('pg');
const RxPg = require('@rough/rx-pg');

const pool = new Pool({
host: 'localhost',
user: 'root',
password: 'root',
database: 'myproject',
max: 50,
idleTimeoutMillis: 30000,
connectionTimeoutMillis: 2000
});

const rxpg = new RxPg(pool);

rxpg
.query('select * from users')
.pipe(finalize(_ => pool.end()))
.subscribe(result => console.log(result));
`

A simple transaction
`js
rxpg
.transaction(
(rxpg, prevResult) => rxpg.query('select * from users where id = ? for update', 42),
(rxpg, prevResult) => rxpg.query('delete from deals where user_scope_id = ?', prevResult[0].user_scope_id),
(rxpg, prevResult) => rxpg.query('delete from inventory where user_id = ?', 42),
)
.pipe(finalize(_ => pool.end()))
.subscribe(result => console.log(result));
``