dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-09-01 20:09:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

revert recording apis

Browse Source
This commit is contained in:
David Colburn
2021-08-03 00:19:19 -07:00
parent 24494e96fd
commit a53deecb82
3 changed files with 3 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/service/roomservice.go
-30
View File
@@ -220,36 +220,6 @@ func (s *RoomService) UpdateSubscriptions(ctx context.Context, req *livekit.Upda
return &livekit.UpdateSubscriptionsResponse{}, nil
}
func (s *RoomService) RecordRoom(ctx context.Context, req *livekit.RecordRoomRequest) (*livekit.RecordingResponse, error) {
if s.recorder == nil {
return nil, errors.New("recording not configured (redis required)")
}
id, err := s.recorder.ReserveRecorder(ctx, req)
if err != nil {
return nil, err
}
err = s.recorder.StartRecording(ctx, id)
if err != nil {
return nil, err
}
return &livekit.RecordingResponse{RecordingId: id}, nil
}
func (s *RoomService) EndRoomRecording(ctx context.Context, req *livekit.EndRecordingRequest) (*livekit.RecordingResponse, error) {
if s.recorder == nil {
return nil, errors.New("recording not configured (redis required)")
}
err := s.recorder.EndRecording(ctx, req.RecordingId)
if err != nil {
return nil, err
}
return &livekit.RecordingResponse{RecordingId: req.RecordingId}, nil
}
func (s *RoomService) createRTCSink(ctx context.Context, room, identity string) (routing.MessageSink, error) {
if err := EnsureAdminPermission(ctx, room); err != nil {
return nil, twirpAuthError(err)