From e61ec5dfeddaa6487a2a348ab4f45beaa59884e5 Mon Sep 17 00:00:00 2001
From: Brian Carlson <brian.m.carlson@gmail.com>
Date: Sun, 14 Nov 2010 17:44:36 -0600
Subject: [PATCH] unit test for portal suspended

---
 lib/connection.js                            | 4 ++++
 test/test-buffers.js                         | 4 ++++
 test/unit/connection/inbound-parser-tests.js | 7 +++++++
 3 files changed, 15 insertions(+)

diff --git a/lib/connection.js b/lib/connection.js
index 9788e9b8..46be8636 100644
--- a/lib/connection.js
+++ b/lib/connection.js
@@ -283,6 +283,10 @@ p.parseMessage =  function() {
     msg.name = 'emptyQuery';
     return msg;
 
+  case 0x73: //s
+    msg.name = 'portalSuspended';
+    return msg;
+
   default:
     throw new Error("Unrecognized message code " + id);
   }
diff --git a/test/test-buffers.js b/test/test-buffers.js
index afef19c9..ddb6ba63 100644
--- a/test/test-buffers.js
+++ b/test/test-buffers.js
@@ -117,4 +117,8 @@ buffers.emptyQuery = function() {
   return new BufferList().join(true, 'I');
 };
 
+buffers.portalSuspended = function() {
+  return new BufferList().join(true, 's');
+};
+
 module.exports = buffers;
diff --git a/test/unit/connection/inbound-parser-tests.js b/test/unit/connection/inbound-parser-tests.js
index 1d12f22d..440f8b46 100644
--- a/test/unit/connection/inbound-parser-tests.js
+++ b/test/unit/connection/inbound-parser-tests.js
@@ -11,6 +11,7 @@ var backendKeyDataBuffer = buffers.backendKeyData(1,2);
 var commandCompleteBuffer = buffers.commandComplete("SELECT 3");
 var parseCompleteBuffer = buffers.parseComplete();
 var bindCompleteBuffer = buffers.bindComplete();
+var portalSuspendedBuffer = buffers.portalSuspended();
 
 var addRow = function(bufferList, name, offset) {
   return bufferList.addCString(name) //field name
@@ -339,6 +340,12 @@ test('Connection', function() {
       name: 'bindComplete'
     });
   });
+
+  test('parses portal suspended message', function() {
+    testForMessage(portalSuspendedBuffer, {
+      name: 'portalSuspended'
+    });
+  });
 });
 
 //since the data message on a stream can randomly divide the incomming