From d9ef1f915f68aa63e6096045c02f714d927e544e Mon Sep 17 00:00:00 2001
From: wujunzhuo <wujunzhuo@hotmail.com>
Date: Thu, 16 Jun 2022 15:11:42 +0800
Subject: [PATCH] fix: encode metadata (#341)

---
 core/frame/meta_frame.go | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/core/frame/meta_frame.go b/core/frame/meta_frame.go
index 1d54a21b0..712c00976 100644
--- a/core/frame/meta_frame.go
+++ b/core/frame/meta_frame.go
@@ -62,11 +62,19 @@ func (m *MetaFrame) Encode() []byte {
 	transactionID := y3.NewPrimitivePacketEncoder(byte(TagOfTransactionID))
 	transactionID.SetStringValue(m.tid)
 	meta.AddPrimitivePacket(transactionID)
+
 	// source ID
 	sourceID := y3.NewPrimitivePacketEncoder(byte(TagOfSourceID))
 	sourceID.SetStringValue(m.sourceID)
 	meta.AddPrimitivePacket(sourceID)
 
+	// metadata
+	if m.metadata != nil {
+		metadata := y3.NewPrimitivePacketEncoder(byte(TagOfMetadata))
+		metadata.SetBytesValue(m.metadata)
+		meta.AddPrimitivePacket(metadata)
+	}
+
 	return meta.Encode()
 }