const Pool      = require('pg').Pool;
const LiveQuery = require('pg-live-query');
 
const pool = new Pool(); // Or however you set up pg
 
pool.connect((error, client, done) => {
    const lq = new LiveQuery(client);
 
    const sql = `
        SELECT
            *
        FROM
            users u JOIN
            logins l ON
                l.user_id = u.id
        WHERE
            l.date > '2016-01-01'
    `;
 
    // To get 'insert', 'update', 'delete', and 'changes' events
    const handle = lq.watch(sql);
    // To get the above plus an additional 'rows' event with the full rowset
    // This consumes more memory as it has to maintain the current state of the rowset
    const handle = lq.query(sql);
 
    // The "update" event looks the same as "insert"
    // They contain the id, row data (as an array), and column names
    handle.on('insert', (id, row, cols) => {
        const out = {};
 
        cols.forEach((col, i) => {
            out[col] = row[i] || null;
        });
 
        console.log('row inserted', id, row);
    });
 
    // The "delete" event only contains the id
    handle.on('delete', (id) => {
        console.log('row deleted', id);
    });
 
    // The "changes" event contains several changes batched together
    handle.on('changes', (changes) => {
        changes.forEach(({ id, rn, data }) => {
            if(data) {
                console.log(`upsert: ${id} at row ${rn}`, data);
            }
            else {
                console.log(`delete: ${id}`);
            }
        });
    });
 
    // The "rows" event contains an array of objects
    // that represent the entire current result set
    handle.on('rows', (rows) => {
        console.log('all rows', rows);
    });
});