Skip to content

Commit e61ec5d

Browse files
committed
unit test for portal suspended
1 parent 6585f85 commit e61ec5d

File tree

3 files changed

+15
-0
lines changed

3 files changed

+15
-0
lines changed

lib/connection.js

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -283,6 +283,10 @@ p.parseMessage = function() {
283283
msg.name = 'emptyQuery';
284284
return msg;
285285

286+
case 0x73: //s
287+
msg.name = 'portalSuspended';
288+
return msg;
289+
286290
default:
287291
throw new Error("Unrecognized message code " + id);
288292
}

test/test-buffers.js

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -117,4 +117,8 @@ buffers.emptyQuery = function() {
117117
return new BufferList().join(true, 'I');
118118
};
119119

120+
buffers.portalSuspended = function() {
121+
return new BufferList().join(true, 's');
122+
};
123+
120124
module.exports = buffers;

test/unit/connection/inbound-parser-tests.js

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ var backendKeyDataBuffer = buffers.backendKeyData(1,2);
1111
var commandCompleteBuffer = buffers.commandComplete("SELECT 3");
1212
var parseCompleteBuffer = buffers.parseComplete();
1313
var bindCompleteBuffer = buffers.bindComplete();
14+
var portalSuspendedBuffer = buffers.portalSuspended();
1415

1516
var addRow = function(bufferList, name, offset) {
1617
return bufferList.addCString(name) //field name
@@ -339,6 +340,12 @@ test('Connection', function() {
339340
name: 'bindComplete'
340341
});
341342
});
343+
344+
test('parses portal suspended message', function() {
345+
testForMessage(portalSuspendedBuffer, {
346+
name: 'portalSuspended'
347+
});
348+
});
342349
});
343350

344351
//since the data message on a stream can randomly divide the incomming

0 commit comments

Comments
 (0)