Initial commit

paulbellamy · paulbellamy · commit 783e01a80d8d · 2012-02-09T14:50:11.000Z
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,3 @@
+*.sw?
+npm-debug.log
+node_modules
diff --git a/ReadMe.md b/ReadMe.md
@@ -0,0 +1 @@
+# Unreleased, please come back later.
diff --git a/bin/postgres b/bin/postgres
@@ -0,0 +1,18 @@
+#!/usr/bin/env node
+
+var PostgresHook = require('../lib/postgres').PostgresHook;
+
+var postgres = new PostgresHook({ 
+  "name": "the-postgres-hook",
+  "debug": true,
+  "host": '127.0.0.1',
+  "port": 5672,
+  "vhost": '/',
+  "login": 'guest',
+  "password": 'guest',
+  "ssl": false,
+  "exchange": 'events',
+  "topics": ['#']
+});
+
+postgres.start();
diff --git a/config.json.template b/config.json.template
@@ -0,0 +1,3 @@
+{
+  "database": "pg://brian:1234@localhost/postgres"
+}
diff --git a/lib/postgres.js b/lib/postgres.js
@@ -0,0 +1,65 @@
+/*
+
+   hook.io hook for interfacing with postgres
+
+*/
+
+
+var Hook = require('hook.io').Hook,
+    pg = require('pg'),
+    util = require('util');
+
+var PostgresHook = exports.PostgresHook = function(options){
+  var self = this;
+
+  Hook.call(this, options);
+
+  self.options = options;
+
+  self.on('hook::ready', function(){
+    self._start();
+  });
+
+  self.on('*::postgres::query', function(sql, callback) {
+    self._query(sql, callback);
+  });
+};
+
+// Postgres inherits from Hook
+util.inherits(PostgresHook, Hook);
+
+PostgresHook.prototype._start = function() {
+  var self = this;
+
+  self.client = new pg.Client(self.options.database);
+  self.client.connect();
+
+  self.client.on('error', function(err) {
+    console.dir(err);
+    self._error(err);
+  });
+};
+
+PostgresHook.prototype._query = function(sql, callback) {
+  var self = this;
+
+  var query = self.client.apply(sql); // handle strings, arrays, or objects with apply
+  var rows = [];
+
+  query.on('row', function(row) {
+    rows.push(row);
+  });
+
+  query.on('end', function() {
+    callback(null, rows);
+  });
+
+  query.on('error', function(err) {
+    callback(err, null);
+  });
+};
+
+PostgresHook.prototype._error = function(err) {
+  var self = this;
+  self.emit('postgres::error', err);
+};
diff --git a/package.json b/package.json
@@ -0,0 +1,26 @@
+{
+  "authors": [
+    "Paul Bellamy <paul.a.bellamy@gmail.com>"
+  ],
+  "name": "hookio-postgres",
+  "description": "hook.io hook to interface with a postgres database",
+  "version": "0.1.0",
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/paulbellamy/hookio-postgres.git"
+  },
+  "bin": {
+     "hookio-postgres": "./bin/postgres"
+  },
+  "main" : "lib/postgres",
+  "engines": {
+    "node": ">= v0.4.7"
+  },
+  "dependencies": {
+    "hook.io": "0.8.x",
+    "colors": "0.5.x",
+    "async": "0.1.x",
+    "pg": "0.6.x"
+  },
+  "devDependencies": {}
+}

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+*.sw?`
	`2`	`+npm-debug.log`
	`3`	`+node_modules`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+{`
	`2`	`+ "database": "pg://brian:1234@localhost/postgres"`
	`3`	`+}`