test zero-length packet

Author: fanweixiao

Makefile

@@ -21,7 +21,7 @@ cover:
 	$(GO) test github.com/yomorun/y3-codec-golang/pkg -coverprofile=prof.out && $(GO) tool cover -html=prof.out && rm prof.out
 
 test:
-	$(GO) test -v api.go api_test.go
+	$(GO) test -v api.go api_test.go stream_api.go stream_api_test.go
 
 test-spec:
 	$(GO) test -v github.com/yomorun/y3-codec-golang/pkg/spec

stream_api.go

@@ -8,6 +8,7 @@ import (
 	"github.com/yomorun/y3-codec-golang/pkg/spec"
 )
 
+// StreamDecoder decode Y3 Packet from a io.Reader
 type StreamDecoder struct {
 	errState bool
 	tagbuf   []byte

stream_api_test.go

@@ -2,7 +2,6 @@ package y3
 
 import (
 	"bytes"
-	"log"
 	"testing"
 
 	"github.com/yomorun/y3-codec-golang/pkg/spec"
@@ -105,30 +104,37 @@ func TestStreamDecode4(t *testing.T) {
 }
 
 func TestStreamDecode5(t *testing.T) {
-	data := []byte{0x01, 0x01, 0x01, 0x02, 0x02, 0x01, 0x02, 0x03, 0x03, 0x01, 0x02, 0x03}
+	data := []byte{0x01, 0x01, 0x01, 0x02, 0x02, 0x01, 0x02, 0x03, 0x00, 0x04, 0x03, 0x01, 0x02, 0x03}
 
 	// as reader
 	r := bytes.NewReader(data)
 	// create steam decoder
 	pr := NewStreamDecoder(r)
 
-	times := 0
+	times := 1
 
 	// handler
 	pr.OnPacket(func(p *spec.Packet) {
-		log.Printf("==>OnPacket: %v", p)
-		if times == 0 {
+		if times == 1 {
 			compareBytes(t, p.GetTagBuffer(), []byte{0x01}, "T")
 			compareBytes(t, p.GetLengthBuffer(), []byte{0x01}, "L")
 			compareBytes(t, p.GetValueBuffer(), []byte{0x01}, "V")
 		}
-		if times == 1 {
+		if times == 2 {
 			compareBytes(t, p.GetTagBuffer(), []byte{0x02}, "T")
 			compareBytes(t, p.GetLengthBuffer(), []byte{0x02}, "L")
 			compareBytes(t, p.GetValueBuffer(), []byte{0x01, 0x02}, "V")
 		}
-		if times == 2 {
+		if times == 3 {
 			compareBytes(t, p.GetTagBuffer(), []byte{0x03}, "T")
+			compareBytes(t, p.GetLengthBuffer(), []byte{0x00}, "L")
+			compareBytes(t, p.GetValueBuffer(), []byte{}, "V")
+			if p.Length != 0 {
+				t.Errorf("Packet:Tag=[% X] Length should be 0, actual=%d", p.GetTagBuffer(), p.Length)
+			}
+		}
+		if times == 4 {
+			compareBytes(t, p.GetTagBuffer(), []byte{0x04}, "T")
 			compareBytes(t, p.GetLengthBuffer(), []byte{0x03}, "L")
 			compareBytes(t, p.GetValueBuffer(), []byte{0x01, 0x02, 0x03}, "V")
 		}