Implementation

Author: hiroshihorie

lib/src/core/room.dart

@@ -1329,6 +1329,19 @@ extension DataStreamRoomMethods on Room {
         topic: streamHeader.topic,
         timestamp: streamHeader.timestamp.toInt(),
         attributes: streamHeader.attributes,
+        replyToStreamId: streamHeader.textHeader.hasReplyToStreamId()
+            ? streamHeader.textHeader.replyToStreamId
+            : null,
+        attachedStreamIds: streamHeader.textHeader.attachedStreamIds.toList(),
+        version: streamHeader.textHeader.hasVersion()
+            ? streamHeader.textHeader.version
+            : null,
+        generated: streamHeader.textHeader.hasGenerated()
+            ? streamHeader.textHeader.generated
+            : false,
+        operationType: streamHeader.textHeader.hasOperationType()
+            ? streamHeader.textHeader.operationType.name
+            : null,
       );
 
       final streamController = DataStreamController<lk_models.DataStream_Chunk>(

lib/src/participant/local.dart

@@ -1239,6 +1239,11 @@ extension DataStreamParticipantMethods on LocalParticipant {
       timestamp: DateTime.timestamp().millisecondsSinceEpoch,
       topic: options?.topic ?? '',
       size: options?.totalSize ?? 0,
+      replyToStreamId: options?.replyToStreamId,
+      attachedStreamIds: options?.attachedStreamIds ?? [],
+      version: options?.version,
+      generated: options?.generated ?? false,
+      operationType: options?.type,
     );
 
     final header = lk_models.DataStream_Header(

lib/src/types/data_stream.dart

@@ -166,13 +166,33 @@ class ByteStreamInfo extends BaseStreamInfo {
 }
 
 class TextStreamInfo extends BaseStreamInfo {
+  /// The stream ID this message is replying to, if any
+  final String? replyToStreamId;
+
+  /// List of stream IDs that are attached to this stream
+  final List<String> attachedStreamIds;
+
+  /// Version of the stream
+  final int? version;
+
+  /// Whether this text was generated by an agent
+  final bool generated;
+
+  /// Operation type for the stream
+  final String? operationType;
+
   TextStreamInfo({
     required String id,
     required String mimeType,
     required String topic,
     required int timestamp,
     required int size,
     Map<String, String> attributes = const {},
+    this.replyToStreamId,
+    this.attachedStreamIds = const [],
+    this.version,
+    this.generated = false,
+    this.operationType,
   }) : super(
           id: id,
           mimeType: mimeType,

test/core/data_stream_test.dart

@@ -219,6 +219,11 @@ void main() {
         final text = await reader.readAll();
         print('received reply message: ${text}');
         expect(text, 'This is a reply to the original message');
+
+        // Verify that reply metadata is accessible
+        expect(reader.info?.replyToStreamId, originalStreamId);
+        expect(reader.info?.version, 1);
+        expect(reader.info?.operationType, 'CREATE');
       });
 
       // Send a reply to an existing stream