Merge pull request #80 from doug-martin/master

v0.2.8

History.md

@@ -1,3 +1,8 @@
+# 0.2.8
+
+* Updated listener to strip generated quotes.
+
+
 # 0.2.7
 
 * Fixed issue with quoted channel names

docs/History.html

@@ -360,6 +360,10 @@
 
 
 
+<h1>0.2.8</h1>
+<ul>
+<li>Updated listener to strip generated quotes.</li>
+</ul>
 <h1>0.2.7</h1>
 <ul>
 <li>Fixed issue with quoted channel names</li>

lib/adapters/postgres.js

@@ -480,11 +480,15 @@ var DB = define(Database, {
         listen: function (channel, cb, opts) {
             opts = opts || {};
             channel = this.__quoteSchemaTable(channel);
+            var listeningChannel = channel.toLowerCase();
             var timeout = opts.timeout || 30000,
                 loop = opts.loop || false,
                 ret = new Promise(),
                 connected = true;
             var self = this;
+            if (this.quoteIdentifiers) {
+                listeningChannel = listeningChannel.replace(/^"|"$/g, "");
+            }
             var connectionTimeout = setTimeout(function () {
                 if (!connected) {
                     ret.errback(new Error("Listen: Unable to connect to " + channel));
@@ -493,8 +497,10 @@ var DB = define(Database, {
             this._getConnection().chain(function (conn) {
                 connected = true;
                 clearTimeout(connectionTimeout);
+
+
                 function __listener(message) {
-                    if (message.channel === channel.toLowerCase()) {
+                    if (message.channel === listeningChannel) {
                         cb(JSON.parse(message.payload));
                     }
                 }

package.json

@@ -1,7 +1,7 @@
 {
     "name": "patio",
     "description": "Patio query engine and ORM",
-    "version": "0.2.7",
+    "version": "0.2.8",
     "keywords": [
         "ORM",
         "object relation mapper",