fix: encode metadata (#341)

yomorun · Jun 16, 2022 · d9ef1f9 · d9ef1f9
1 parent 2e4f65b
commit d9ef1f9
Showing 1 changed file with 8 additions and 0 deletions.
diff --git 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()
 }