Super lo-fi pub/sub

gistfile1.txt

-- In publisher:
Name: notify_trigger(); Type: FUNCTION; Schema: public; Owner: -

CREATE FUNCTION notify_trigger() RETURNS trigger
    LANGUAGE plpgsql
    AS $$
DECLARE
BEGIN
  PERFORM pg_notify('orders', TG_TABLE_NAME || ',id,' || row_to_json(NEW)::text );
  RETURN new;
END;
$$;

CREATE TRIGGER watched_table_trigger AFTER INSERT ON orders FOR EACH ROW EXECUTE PROCEDURE notify_trigger();

--- In subscriber:

var pg = require ('pg');

var pgConString = process.env.COMMERCE_HOST

pg.connect(pgConString, function(err, client) {
  if(err) {
    console.log(err);
  }
  client.on('notification', function(msg) {
    console.log(msg);
  });
  var query = client.query("LISTEN orders");
});