Function TestDecoderInvalidSkip

decoder_test.go:1191–1240

(t *testing.T)

}

func TestDecoderInvalidSkip(t *testing.T) {
	var data = []byte{
		// 1 (varint): 42
		0x8, 0x2A,
	}
	var skipErr *csproto.DecoderSkipError

	dec := csproto.NewDecoder(data)
	// skip with incorrect tag
	_, err := dec.Skip(2, csproto.WireTypeVarint)
	assert.ErrorAs(t, err, &skipErr)
	// skip with incorrect wire types
	for _, wt := range []csproto.WireType{csproto.WireTypeFixed64, csproto.WireTypeLengthDelimited, csproto.WireTypeFixed32} {
		_, err := dec.Skip(1, wt)
		assert.ErrorAs(t, err, &skipErr)
	}

	t.Run("corrupt messages", func(t *testing.T) {
		t.Run("truncated data", func(t *testing.T) {
			// length-delimited field value with a length of 3 but only 2 bytes
			data := []byte{0x0A, 0x3, 0x42, 0x11}
			dec := csproto.NewDecoder(data)

			tag, wt, _ := dec.DecodeTag()
			got, err := dec.Skip(tag, wt)
			assert.Error(t, err)
			assert.Nil(t, got)
		})
		t.Run("negative length", func(t *testing.T) {
			// length-delimited field value with a length of -50
			data := []byte{0x0A, 0xCE, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0x01, 0x3, 0x42, 0x11, 0x38}
			dec := csproto.NewDecoder(data)

			tag, wt, _ := dec.DecodeTag()
			got, err := dec.Skip(tag, wt)
			assert.Error(t, err)
			assert.Nil(t, got)
		})
		t.Run("length overflow", func(t *testing.T) {
			// length-delimited field with length greater than 2GB
			data := []byte{0x0A, 0x80, 0x80, 0x80, 0x80, 0x08}
			dec := csproto.NewDecoder(data)

			tag, wt, _ := dec.DecodeTag()
			got, err := dec.Skip(tag, wt)
			assert.Error(t, err)
			assert.Nil(t, got)
		})
	})
}

func TestDecodePastEndOfBuffer(t *testing.T) {
	var data = []byte{