From 3307715a8d8bdeac1b2d7df66ec2abb6e503ba9a Mon Sep 17 00:00:00 2001
From: Runxi Yu
Date: Fri, 6 Mar 2026 13:01:12 +0800
Subject: format/pktline: Add pktline

---
 format/pktline/append.go | 39 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)
 create mode 100644 format/pktline/append.go

(limited to 'format/pktline/append.go')

diff --git a/format/pktline/append.go b/format/pktline/append.go
new file mode 100644
index 00000000..9425e58e
--- /dev/null
+++ b/format/pktline/append.go
@@ -0,0 +1,39 @@
+package pktline
+
+import "fmt"
+
+// AppendData appends one data frame to dst.
+//
+// Empty payload is encoded as 0004.
+func AppendData(dst, payload []byte) ([]byte, error) {
+	if len(payload) > LargePacketDataMax {
+		return dst, fmt.Errorf("%w: %d > %d", ErrTooLarge, len(payload), LargePacketDataMax)
+	}
+
+	var hdr [4]byte
+
+	err := EncodeLengthHeader(&hdr, len(payload)+4)
+	if err != nil {
+		return dst, err
+	}
+
+	dst = append(dst, hdr[:]...)
+	dst = append(dst, payload...)
+
+	return dst, nil
+}
+
+// AppendFlushPkt appends control frame 0000 (flush-pkt).
+func AppendFlushPkt(dst []byte) []byte {
+	return append(dst, '0', '0', '0', '0')
+}
+
+// AppendDelimPkt appends control frame 0001 (delim-pkt).
+func AppendDelimPkt(dst []byte) []byte {
+	return append(dst, '0', '0', '0', '1')
+}
+
+// AppendResponseEndPkt appends control frame 0002 (response-end-pkt).
+func AppendResponseEndPkt(dst []byte) []byte {
+	return append(dst, '0', '0', '0', '2')
+}
-- 
cgit v1.3.1-10-gc9f91