Accept InsertMessage with zero-column tuples

message.go

@@ -438,8 +438,8 @@ type InsertMessage struct {
 
 // Decode decodes to message from src.
 func (m *InsertMessage) Decode(src []byte) error {
-	if len(src) < 8 {
-		return m.lengthError("InsertMessage", 8, len(src))
+	if len(src) < 7 {
+		return m.lengthError("InsertMessage", 7, len(src))
 	}
 
 	var low, used int

messageV2.go

@@ -237,8 +237,8 @@ func (m *InsertMessageV2) DecodeV2(src []byte, inStream bool) (err error) {
 		return m.InsertMessage.Decode(src)
 	}
 
-	if len(src) < 12 {
-		return m.lengthError("InsertMessageV2", 12, len(src))
+	if len(src) < 11 {
+		return m.lengthError("InsertMessageV2", 11, len(src))
 	}
 
 	src = readXidAndAdvance(src, &m.InStreamMessageV2WithXid, inStream)

messageV2_test.go

@@ -271,6 +271,29 @@ func (s *insertMessageV2Suite) TestNoStream() {
 	s.Equal(expected, &insertMsg.InsertMessage)
 }
 
+func (s *insertMessageV2Suite) TestNoColumns() {
+	msg, expected := s.createInsertTestDataNoColumns()
+	msgV2, xid := s.insertXid(msg)
+
+	m, err := ParseV2(msgV2, true)
+	s.NoError(err)
+	insertMsg, ok := m.(*InsertMessageV2)
+	s.True(ok)
+	s.Equal(xid, insertMsg.Xid)
+	s.Equal(expected, &insertMsg.InsertMessage)
+}
+
+func (s *insertMessageV2Suite) TestNoColumnsNoStream() {
+	msg, expected := s.createInsertTestDataNoColumns()
+
+	m, err := ParseV2(msg, false)
+	s.NoError(err)
+	insertMsg, ok := m.(*InsertMessageV2)
+	s.True(ok)
+	s.Equal(uint32(0), insertMsg.Xid)
+	s.Equal(expected, &insertMsg.InsertMessage)
+}
+
 func TestUpdateMessageV2Suite(t *testing.T) {
 	suite.Run(t, new(updateMessageV2Suite))
 }

message_test.go

@@ -285,6 +285,24 @@ func (s *messageSuite) createInsertTestData() ([]byte, *InsertMessage) {
 	return msg, expected
 }
 
+func (s *messageSuite) createInsertTestDataNoColumns() ([]byte, *InsertMessage) {
+	relationID := s.newRelationID()
+
+	msg := make([]byte, 1+4+1+2)
+	msg[0] = 'I'
+	bigEndian.PutUint32(msg[1:], relationID)
+	msg[5] = 'N'
+	bigEndian.PutUint16(msg[6:], 0)
+
+	expected := &InsertMessage{
+		RelationID: relationID,
+		Tuple:      &TupleData{},
+	}
+	expected.msgType = 'I'
+
+	return msg, expected
+}
+
 func (s *messageSuite) createUpdateTestDataTypeK() ([]byte, *UpdateMessage) {
 	relationID := s.newRelationID()
 
@@ -736,6 +754,17 @@ func (s *insertMessageSuite) Test() {
 	s.Equal(expected, insertMsg)
 }
 
+func (s *insertMessageSuite) TestNoColumns() {
+	msg, expected := s.createInsertTestDataNoColumns()
+
+	m, err := Parse(msg)
+	s.NoError(err)
+	insertMsg, ok := m.(*InsertMessage)
+	s.True(ok)
+
+	s.Equal(expected, insertMsg)
+}
+
 func TestUpdateMessageSuite(t *testing.T) {
 	suite.Run(t, new(updateMessageSuite))
 }