mirror of
https://github.com/livekit/livekit.git
synced 2026-04-26 19:35:24 +00:00
David Colburn
69c1d4c295
* create interface * move room manager to interface * interfaces * updates * fix loop * fix fakes * remove node types
45 lines
1.4 KiB
Go
45 lines
1.4 KiB
Go
package service
|
|
|
|
import (
|
|
"time"
|
|
|
|
livekit "github.com/livekit/protocol/proto"
|
|
|
|
"github.com/livekit/livekit-server/pkg/routing"
|
|
"github.com/livekit/livekit-server/pkg/rtc"
|
|
)
|
|
|
|
//go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 -generate
|
|
|
|
// encapsulates CRUD operations for room settings
|
|
// look up participant
|
|
//counterfeiter:generate . RoomStore
|
|
type RoomStore interface {
|
|
StoreRoom(room *livekit.Room) error
|
|
LoadRoom(idOrName string) (*livekit.Room, error)
|
|
ListRooms() ([]*livekit.Room, error)
|
|
DeleteRoom(idOrName string) error
|
|
|
|
// enable locking on a specific room to prevent race
|
|
// returns a (lock uuid, error)
|
|
LockRoom(name string, duration time.Duration) (string, error)
|
|
UnlockRoom(name string, uid string) error
|
|
|
|
StoreParticipant(roomName string, participant *livekit.ParticipantInfo) error
|
|
LoadParticipant(roomName, identity string) (*livekit.ParticipantInfo, error)
|
|
ListParticipants(roomName string) ([]*livekit.ParticipantInfo, error)
|
|
DeleteParticipant(roomName, identity string) error
|
|
}
|
|
|
|
type RoomManager interface {
|
|
RoomStore
|
|
|
|
CreateRoom(req *livekit.CreateRoomRequest) (*livekit.Room, error)
|
|
GetRoom(roomName string) *rtc.Room
|
|
DeleteRoom(roomName string) error
|
|
CleanupRooms() error
|
|
CloseIdleRooms()
|
|
Stop()
|
|
StartSession(roomName string, pi routing.ParticipantInit, requestSource routing.MessageSource, responseSink routing.MessageSink)
|
|
}
|