update: Add buffer test files and optimize code to improve readability.

zishang520 · Oct 21, 2023 · e0e0b7a · e0e0b7a
1 parent c282647
commit e0e0b7a
Show file tree

Hide file tree

Showing 3 changed files with 746 additions and 14 deletions.
diff --git a/packet/type.go b/packet/type.go
@@ -6,7 +6,20 @@ import (
 	"github.com/zishang520/engine.io-go-parser/types"
 )
 
-type Type string
+type (
+	Type string
+
+	Options struct {
+		Compress bool `json:"compress" mapstructure:"compress" msgpack:"compress"`
+	}
+
+	Packet struct {
+		Type         Type                  `json:"type" mapstructure:"type" msgpack:"type"`
+		Data         io.Reader             `json:"data,omitempty" mapstructure:"data,omitempty" msgpack:"data,omitempty"`
+		Options      *Options              `json:"options,omitempty" mapstructure:"options,omitempty" msgpack:"options,omitempty"`
+		WsPreEncoded types.BufferInterface `json:"wsPreEncoded,omitempty" mapstructure:"wsPreEncoded,omitempty" msgpack:"wsPreEncoded,omitempty"`
+	}
+)
 
 // Packet types.
 const (
@@ -19,14 +32,3 @@ const (
 	NOOP    Type = "noop"
 	ERROR   Type = "error"
 )
-
-type Options struct {
-	Compress bool `json:"compress" mapstructure:"compress" msgpack:"compress"`
-}
-
-type Packet struct {
-	Type         Type                  `json:"type" mapstructure:"type" msgpack:"type"`
-	Data         io.Reader             `json:"data,omitempty" mapstructure:"data,omitempty" msgpack:"data,omitempty"`
-	Options      *Options              `json:"options,omitempty" mapstructure:"options,omitempty" msgpack:"options,omitempty"`
-	WsPreEncoded types.BufferInterface `json:"wsPreEncoded,omitempty" mapstructure:"wsPreEncoded,omitempty" msgpack:"wsPreEncoded,omitempty"`
-}
diff --git a/parser/type.go b/parser/type.go
@@ -13,6 +13,8 @@ type Parser interface {
 	DecodePayload(types.BufferInterface) ([]*packet.Packet, error)
 }
 
+const SEPARATOR byte = 0x1E
+
 // Packet types.
 var (
 	PACKET_TYPES map[packet.Type]byte = map[packet.Type]byte{
@@ -38,5 +40,3 @@ var (
 	// Premade error packet.
 	ERROR_PACKET = &packet.Packet{Type: packet.ERROR, Data: types.NewStringBufferString(`parser error`)}
 )
-
-const SEPARATOR = byte(0x1E)