require(__dirname+'/test-helper'); test('Parser on single messages', function() { var authenticationOkBuffer = Buffer([0x52, 00, 00, 00, 08, 00, 00, 00, 00]); var firstString = [0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x65, 0x6e, 0x63, 0x6f, 0x64, 0x69, 0x6e, 0x67, 0]; var secondString = [0x55, 0x54, 0x46, 0x38, 0]; var bytes = [0x53, 0, 0, 0, 0x19].concat(firstString).concat(secondString); var parameterStatusBuffer = Buffer(bytes); var backendKeyDataBuffer = Buffer([0x4b, 0, 0, 0, 0x0c, 0, 0, 0, 1, 0, 0, 0, 2]); var readyForQueryBuffer = Buffer([0x5a, 0, 0, 0, 5, 'I'.charCodeAt(0)]) test('parses AuthenticationOk message', function() { var result = new Parser(authenticationOkBuffer).parse(); assert.same(result, { name: 'AuthenticationOk', id: 'R', length: 8 }); }); test('parses ParameterStatus message', function() { var result = new Parser(parameterStatusBuffer).parse(); assert.same(result, { name: 'ParameterStatus', id: 'S', length: 25, parameterName: 'client_encoding', parameterValue: 'UTF8' }); }); test('parses BackendKeyData message', function() { var result = new Parser(backendKeyDataBuffer).parse(); assert.same(result, { name: 'BackendKeyData', id: 'K', processID: 1, secretKey: 2 }); }); test('parses ReadyForQuery message', function() { var result = new Parser(readyForQueryBuffer).parse(); assert.same(result, { name: 'ReadyForQuery', id: 'Z', length: 5, status: 'I' }); }); test('parses normal CString', function() { var result = new Parser(Buffer([33,0])).parseCString(); assert.equal(result,"!"); }); test('parses empty CString', function() { var result = new Parser(Buffer([0])).parseCString(); assert.equal(result, ''); }); test('parses length', function() { var parser = new Parser(Buffer([0,0,0,3])); var result = parser.parseLength(); assert.equal(result, 3); assert.equal(parser.offset, 4); }); test('parsing empty buffer returns false', function() { var parser = new Parser(Buffer(0)); assert.equal(parser.parse(), false); }); });