Redis AdaptiveStream (#631)

* Redis AdaptiveStream

* Fix adaptive stream while tarnsferring from start session
This commit is contained in:
Raja Subramanian
2022-04-20 10:48:32 +05:30
committed by GitHub
parent 282e2aed49
commit 8535f3d5b9
3 changed files with 16 additions and 14 deletions
+13 -11
View File
@@ -169,11 +169,12 @@ func (r *RedisRouter) StartParticipantSignal(ctx context.Context, roomName livek
Identity: string(pi.Identity),
Name: string(pi.Name),
// connection id is to allow the RTC node to identify where to route the message back to
ConnectionId: string(connectionID),
Reconnect: pi.Reconnect,
AutoSubscribe: pi.AutoSubscribe,
Client: pi.Client,
GrantsJson: string(claims),
ConnectionId: string(connectionID),
Reconnect: pi.Reconnect,
AutoSubscribe: pi.AutoSubscribe,
Client: pi.Client,
GrantsJson: string(claims),
AdaptiveStream: pi.AdaptiveStream,
})
if err != nil {
return
@@ -258,12 +259,13 @@ func (r *RedisRouter) startParticipantRTC(ss *livekit.StartSession, participantK
}
pi := ParticipantInit{
Identity: livekit.ParticipantIdentity(ss.Identity),
Name: livekit.ParticipantName(ss.Name),
Reconnect: ss.Reconnect,
Client: ss.Client,
AutoSubscribe: ss.AutoSubscribe,
Grants: claims,
Identity: livekit.ParticipantIdentity(ss.Identity),
Name: livekit.ParticipantName(ss.Name),
Reconnect: ss.Reconnect,
Client: ss.Client,
AutoSubscribe: ss.AutoSubscribe,
Grants: claims,
AdaptiveStream: ss.AdaptiveStream,
}
reqChan := r.getOrCreateMessageChannel(r.requestChannels, string(participantKey))