FilesExpand file tree

 master

/

pgsql.js

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

29 lines (22 loc) · 657 Bytes

 master

/

pgsql.js

Copy path

Top

File metadata and controls

• Code
• Blame

29 lines (22 loc) · 657 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

var pg = require ('pg');

var events = require('events');

var eventEmitter = new events.EventEmitter();

var pgConString = 'postgres://<user>:<password>@<host>/<server>';

var clientConnected;

pg.connect(pgConString, function(err, client) {

if (err) return console.log(err);

clientConnected = client;

client.on('notification', function(msg) {

var data = JSON.parse(msg.payload);

eventEmitter.emit(data.table, data.row);

});

client.query('LISTEN watchers', function () {

console.log('Connected on postgresql');

});

});

module.exports = {

getConnection: function () {

return clientConnected;

},

events: eventEmitter

}