Skip to content

Commit 08c3abc

Browse files
authored
Add attachedStreamIds as text stream metadata (#1805)
1 parent 014346e commit 08c3abc

File tree

4 files changed

+11
-2
lines changed

4 files changed

+11
-2
lines changed

.changeset/spotty-tigers-sort.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
'livekit-client': patch
3+
---
4+
5+
Add attachedStreamIds as text stream metadata

src/room/data-stream/incoming/IncomingDataStreamManager.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -191,6 +191,7 @@ export default class IncomingDataStreamManager {
191191
timestamp: Number(streamHeader.timestamp),
192192
attributes: streamHeader.attributes,
193193
encryptionType,
194+
attachedStreamIds: streamHeader.contentHeader.value.attachedStreamIds,
194195
};
195196

196197
const stream = new ReadableStream<DataStream_Chunk>({

src/room/data-stream/outgoing/OutgoingDataStreamManager.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,7 @@ export default class OutgoingDataStreamManager {
107107
encryptionType: this.engine.e2eeManager?.isDataChannelEncryptionEnabled
108108
? Encryption_Type.GCM
109109
: Encryption_Type.NONE,
110+
attachedStreamIds: options?.attachedStreamIds,
110111
};
111112
const header = new DataStream_Header({
112113
streamId,
@@ -119,7 +120,7 @@ export default class OutgoingDataStreamManager {
119120
case: 'textHeader',
120121
value: new DataStream_TextHeader({
121122
version: options?.version,
122-
attachedStreamIds: options?.attachedStreamIds,
123+
attachedStreamIds: info.attachedStreamIds,
123124
replyToStreamId: options?.replyToStreamId,
124125
operationType:
125126
options?.type === 'update'

src/room/types.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,4 +142,6 @@ export interface ByteStreamInfo extends BaseStreamInfo {
142142
name: string;
143143
}
144144

145-
export interface TextStreamInfo extends BaseStreamInfo {}
145+
export interface TextStreamInfo extends BaseStreamInfo {
146+
attachedStreamIds?: Array<string>;
147+
}

0 commit comments

Comments
 (0)