init

Author: paulserraino

.editorconfig

@@ -0,0 +1,9 @@
+root = true
+
+[*]
+end_of_line = lf
+insert_final_newline = true
+indent_style = space
+indent_size = 2
+charset = utf-8
+trim_trailing_whitespace = true

.gitignore

@@ -0,0 +1,2 @@
+.DS_Store
+node_modules

LICENSE

@@ -0,0 +1,21 @@
+The MIT License (MIT)
+
+Copyright (c) 2015 Paul Serraino
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

index.js

@@ -0,0 +1,33 @@
+var pg = require('pg')
+//PGEvents = require('pg-events')
+
+pg.connect('postgres://paulserraino@localhost/test', function (err, client, done) {
+	if (err) throw err;
+	console.log('connected');
+	//var events = PGEvents(client);
+
+	//events.listen('users')
+	//events.on('users:update', fn);
+	//events.on('users:insert', fn);
+	//events.on('users:delete', fn);
+
+
+});
+
+var EventEmitter = require('events').EventEmitter;
+var inherits = require('inherits');
+
+function PGEvents (client) {
+	if (!(this instanceof PGEvents)) return new PGEvents(client);
+	var self = this;
+
+	this.client = client;
+	this.events = {};
+};
+
+inherits(pgEvents, EventEmitter);
+
+pgEvents.prototype.listen = function (table) {};
+pgEvents.prototype.notify = function (table) {};
+pgEvents.prototype.unlisten = function (table) {};
+

install.sql

@@ -0,0 +1,50 @@
+CREATE OR REPLACE FUNCTION notify_trigger() RETURNS trigger AS $$
+DECLARE
+	_json_ text := '{}';
+BEGIN
+	IF TG_OP = 'INSERT' THEN
+		_json_ := '{"table": "' || TG_TABLE_NAME || '",
+  		"operation": "insert",
+		  "timestamp": "' || CURRENT_TIMESTAMP || '",
+		  "data": ' || row_to_json(NEW) || '}';
+
+  ELSIF TG_OP = 'UPDATE' THEN
+    _json_ := '{"table:" "' || TG_TABLE_NAME || '",
+      "operation": "update",
+      "timestamp": "' || CURRENT_TIMESTAMP || '",
+      "old_data": "' || row_to_json(OLD) || ',
+      "data": ' || row_to_json(NEW) || '}';
+
+  ELSIF TG_OP = 'DELETE' THEN
+    _json_ := '{"table": "' || TG_TABLE_NAME || '",
+      "operation": "delete",
+      "timestamp": "' || CURRENT_TIMESTAMP || '",
+      "data": ' || row_to_json(OLD) || '}';
+  END IF;
+
+  PERFORM pg_notify(TG_TABLE_NAME::text, _json_);
+
+  RETURN NULL;
+END;
+$$ LANGUAGE plpgsql;
+
+CREATE OR REPLACE FUNCTION add_notify_trigger_to_table(table_name text) 
+RETURNS VOID as $$
+BEGIN
+  EXECUTE 'DROP TRIGGER IF EXISTS notify_trigger_event ON ' || table_name::regclass;
+
+  EXECUTE '
+    CREATE TRIGGER notify_trigger_event
+      AFTER INSERT OR UPDATE OR DELETE
+      ON ' || table_name::regclass || ' 
+      FOR EACH ROW 
+      EXECUTE PROCEDURE notify_trigger()';
+END;
+$$ LANGUAGE plpgsql;
+
+CREATE OR REPLACE FUNCTION remove_notify_trigger_from_table(table_name text)
+RETURNS VOID AS $$
+BEGIN
+  EXECUTE 'DROP TRIGGER IF EXISTS notify_trigger_event ON ' || table_name::regclass;
+END;
+$$ LANGUAGE plpgsql;

package.json

@@ -0,0 +1,30 @@
+{
+  "name": "pg-events",
+  "version": "0.0.0",
+  "description": "postgreSQL listen/notify events",
+  "main": "index.js",
+  "scripts": {
+    "test": "./node_modules/mocha/bin/mocha tests/"
+  },
+  "keywords": [
+    "pg",
+    "listen",
+    "notify",
+    "events"
+  ],
+  "author": {
+    "name": "Paul Serraino",
+    "url": "http://paulserraino.com"
+  },
+  "license": "MIT",
+  "dependencies": {
+    "inherits": "~2.0.1"
+  },
+  "devDependencies": {
+    "mocha": "~2.1.0",
+    "pg": "~4.2.0"
+  },
+  "engines": {
+    "node": "0.10.x"
+  }
+}

readme.md

@@ -0,0 +1,10 @@
+
+```
+npm install pg-events
+```
+```
+psql -h localhost -d mydb < install.sql
+```
+
+#License
+MIT