op

May 16, 2024

Changes in this version

+ type CurrentMovie struct

+ ID string

+ IsLive bool

type Movie

+ func (m *Movie) Close() error

+ func (m *Movie) SubPath() string

type Room

+ func (r *Room) ClearMoviesByParentID(parentID string) error

+ func (r *Room) IsParentOf(movieID, parentID string) (bool, error)

+ func (r *Room) LoadCurrentMovie() (*Movie, error)

type User

+ func (u *User) ClearRoomMoviesByParentID(room *Room, parentID string) error

Apr 22, 2024

Changes in this version

+ var ErrNoCurrentMovie = errors.New("no current movie")

type Client

+ func (c *Client) SendChatMessage(message string) error

+ func (c *Client) SetSeekRate(seek float64, rate float64, timeDiff float64) (*Status, error)

+ func (c *Client) SetStatus(playing bool, seek float64, rate float64, timeDiff float64) (*Status, error)

type Current

+ IsLive bool

+ MovieID string

type Hub

+ func (h *Hub) IsOnline(userID string) bool

+ func (h *Hub) KickUser(userID string) error

+ func (h *Hub) OnlineCount(userID string) int

type Room

+ func (r *Room) AddAdminPermissions(userID string, permissions model.RoomAdminPermission) error

+ func (r *Room) AddMemberPermissions(userID string, permissions model.RoomMemberPermission) error

+ func (r *Room) ApprovePendingMember(userID string) error

+ func (r *Room) BanMember(userID string) error

+ func (r *Room) CurrentMovieID() string

+ func (r *Room) DeleteMoviesByID(ids []string) error

+ func (r *Room) HasAdminPermission(userID string, permission model.RoomAdminPermission) bool

+ func (r *Room) IsAdmin(userID string) bool

+ func (r *Room) IsCreator(userID string) bool

+ func (r *Room) IsGuest(userID string) bool

+ func (r *Room) KickUser(userID string) error

+ func (r *Room) LoadMemberStatus(userID string) (model.RoomMemberStatus, error)

+ func (r *Room) LoadOrCreateMemberStatus(userID string) (model.RoomMemberStatus, error)

+ func (r *Room) LoadOrCreateRoomMember(userID string) (*model.RoomMember, error)

+ func (r *Room) LoadRoomAdminPermission(userID string) (model.RoomAdminPermission, error)

+ func (r *Room) LoadRoomMember(userID string) (*model.RoomMember, error)

+ func (r *Room) LoadRoomMemberPermission(userID string) (model.RoomMemberPermission, error)

+ func (r *Room) RemoveAdminPermissions(userID string, permissions model.RoomAdminPermission) error

+ func (r *Room) RemoveMemberPermissions(userID string, permissions model.RoomMemberPermission) error

+ func (r *Room) ResetAdminPermissions(userID string) error

+ func (r *Room) ResetMemberPermissions(userID string) error

+ func (r *Room) SetAdmin(userID string, permissions model.RoomAdminPermission) error

+ func (r *Room) SetAdminPermissions(userID string, permissions model.RoomAdminPermission) error

+ func (r *Room) SetCurrentSeekRate(seek float64, rate float64, timeDiff float64) *Status

+ func (r *Room) SetCurrentStatus(playing bool, seek float64, rate float64, timeDiff float64) *Status

+ func (r *Room) SetMember(userID string, permissions model.RoomMemberPermission) error

+ func (r *Room) SetMemberPermissions(userID string, permissions model.RoomMemberPermission) error

+ func (r *Room) UnbanMember(userID string) error

+ func (r *Room) UpdateSettings(settings map[string]any) error

+ func (r *Room) UserIsOnline(userID string) bool

+ func (r *Room) UserOnlineCount(userID string) int

+ func (r *Room) UserRole(userID string) (model.RoomMemberRole, error)

type User

+ func (u *User) AddMemberPermissions(room *Room, userID string, permissions model.RoomMemberPermission) error

+ func (u *User) AddRoomAdminPermissions(room *Room, userID string, permissions model.RoomAdminPermission) error

+ func (u *User) AddRoomMovie(room *Room, movie *model.BaseMovie) error

+ func (u *User) AddRoomMovies(room *Room, movies []*model.BaseMovie) error

+ func (u *User) ApproveRoomPendingMember(room *Room, userID string) error

+ func (u *User) Ban() error

+ func (u *User) BanRoomMember(room *Room, userID string) error

+ func (u *User) ClearRoomMovies(room *Room) error

+ func (u *User) DeleteRoomMovieByID(room *Room, movieID string) error

+ func (u *User) DeleteRoomMoviesByID(room *Room, movieIDs []string) error

+ func (u *User) GetRoomMoviesWithPage(room *Room, page, pageSize int) ([]*Movie, int)

+ func (u *User) HasRoomAdminPermission(room *Room, permission model.RoomAdminPermission) bool

+ func (u *User) IsGuest() bool

+ func (u *User) IsRoomAdmin(room *Room) bool

+ func (u *User) IsRoomCreator(room *Room) bool

+ func (u *User) RemoveMemberPermissions(room *Room, userID string, permissions model.RoomMemberPermission) error

+ func (u *User) RemoveRoomAdminPermissions(room *Room, userID string, permissions model.RoomAdminPermission) error

+ func (u *User) ResetMemberPermissions(room *Room, userID string) error

+ func (u *User) ResetRoomAdminPermissions(room *Room, userID string) error

+ func (u *User) SetAdminRole() error

+ func (u *User) SetMemberPermissions(room *Room, userID string, permissions model.RoomMemberPermission) error

+ func (u *User) SetRoomAdmin(room *Room, userID string, permissions model.RoomAdminPermission) error

+ func (u *User) SetRoomAdminPermissions(room *Room, userID string, permissions model.RoomAdminPermission) error

+ func (u *User) SetRoomCurrentMovie(room *Room, movieID string, play bool) error

+ func (u *User) SetRoomCurrentSeekRate(room *Room, seek, rate, timeDiff float64) (*Status, error)

+ func (u *User) SetRoomCurrentStatus(room *Room, playing bool, seek, rate, timeDiff float64) (*Status, error)

+ func (u *User) SetRoomMember(room *Room, userID string, permissions model.RoomMemberPermission) error

+ func (u *User) SetRoomSettings(room *Room, setting *model.RoomSettings) error

+ func (u *User) SetRootRole() error

+ func (u *User) SetUserRole() error

+ func (u *User) SwapRoomMoviePositions(room *Room, id1, id2 string) error

+ func (u *User) Unban() error

+ func (u *User) UnbanRoomMember(room *Room, userID string) error

+ func (u *User) UpdateRoomMovie(room *Room, movieID string, movie *model.BaseMovie) error

+ func (u *User) UpdateRoomSettings(room *Room, settings map[string]interface{}) error

Apr 10, 2024

Changes in this version

+ var ErrEmailUnbound = errors.New("email unbound")

type User

+ func (u *User) BindEmail(e string) error

+ func (u *User) SendBindCaptchaEmail(e string) error

+ func (u *User) SendRetrievePasswordCaptchaEmail(host string) error

+ func (u *User) SendTestEmail() error

+ func (u *User) UnbindEmail() error

+ func (u *User) VerifyBindCaptchaEmail(e, captcha string) (bool, error)

+ func (u *User) VerifyRetrievePasswordCaptchaEmail(e, captcha string) (bool, error)

type UserEntry

+ func CreateOrLoadUserWithEmail(username, password, email string, conf ...db.CreateUserConfig) (*UserEntry, error)

+ func CreateUserWithEmail(username, password, email string, conf ...db.CreateUserConfig) (*UserEntry, error)

+ func LoadOrInitUserByEmail(email string) (*UserEntry, error)

Jan 30, 2024

Changes in this version

type Current

+ func (c *Current) UpdateStatus() Status

Jan 29, 2024

Changes in this version

type Movie

+ func (m *Movie) CheckExpired(expireId uint64) bool

+ func (m *Movie) ClearCache()

+ func (m *Movie) ExpireId() uint64

type Room

+ func (r *Room) CheckCurrentExpired(expireId uint64) (bool, error)

+ func (r *Room) CurrentMovie() (*Movie, error)

Jan 6, 2024

Changes in this version

+ var ErrRoomCreatorBanned = errors.New("room creator banned")

+ var ErrorRoomCreatorPending = errors.New("room creator pending, please wait for admin to approve")

+ func SetRoomStatusByID(roomID string, status model.RoomStatus) error

+ type RoomEntry = synccache.Entry[*Room]

+ type UserEntry = synccache.Entry[*User]

Dec 26, 2023

Changes in this version

+ func PeopleNum(roomID string) int64

+ func RangeRoomCache(f func(key string, value *synccache.Entry[*Room]) bool)

type BroadcastConf

+ func WithIgnoreClient(cli ...*Client) BroadcastConf

type Hub

+ func (h *Hub) PeopleNum() int64

type Movie

+ func (m *Movie) AlistCache() *cache.AlistMovieCache

+ func (m *Movie) BilibiliCache() *cache.BilibiliMovieCache

+ func (m *Movie) EmbyCache() *cache.EmbyMovieCache

type Room

+ func (r *Room) NewClient(user *User, conn *websocket.Conn) (*Client, error)

+ func (r *Room) PeopleNum() int64

type User

+ func (u *User) AlistCache() *cache.AlistUserCache

+ func (u *User) BilibiliCache() *cache.BilibiliUserCache

+ func (u *User) EmbyCache() *cache.EmbyUserCache

Nov 28, 2023

Changes in this version

+ var ErrAlreadyClosed = fmt.Errorf("already closed")

+ var ErrRoomBanned = errors.New("room banned")

+ var ErrRoomPending = errors.New("room pending, please wait for admin to approve")

+ var ErrUserBanned = errors.New("user banned")

+ var ErrUserPending = errors.New("user pending, please wait for admin to approve")

+ func ClientNum(roomID string) int64

+ func CloseRoomById(roomID string) error

+ func CloseUserById(id string) error

+ func CompareAndCloseRoom(room *Room) error

+ func CompareAndCloseRoomEntry(id string, room *synccache.Entry[*Room]) error

+ func CompareAndCloseUser(user *User) error

+ func CompareAndDeleteRoom(room *Room) error

+ func CompareAndDeleteUser(user *User) error

+ func DeleteRoomByID(roomID string) error

+ func DeleteUserByID(id string) error

+ func GetUserName(userID string) string

+ func HasRoom(roomID string) bool

+ func HasRoomByName(name string) bool

+ func Init(size int) error

+ func SetRoleByID(userID string, role model.Role) error

+ func SetRoomStatus(roomID string, status model.RoomStatus) error

+ type BaseCache struct

+ func (b *BaseCache) Clear()

+ func (b *BaseCache) InitOrLoadMPDCache(id string, refreshFunc func() (*MPDCache, error), maxAge time.Duration) (*refreshcache.RefreshCache[*MPDCache], error)

+ func (b *BaseCache) InitOrLoadURLCache(id string, refreshFunc func() (string, error), maxAge time.Duration) (*refreshcache.RefreshCache[string], error)

+ type BroadcastConf func(*broadcastMessage)

+ func WithIgnoreId(id ...string) BroadcastConf

+ func WithSendToSelf() BroadcastConf

+ func WithSender(sender string) BroadcastConf

+ type Client struct

+ func (c *Client) Broadcast(msg Message, conf ...BroadcastConf) error

+ func (c *Client) Close() error

+ func (c *Client) Closed() bool

+ func (c *Client) GetReadChan() <-chan Message

+ func (c *Client) NextReader() (int, io.Reader, error)

+ func (c *Client) NextWriter(messageType int) (io.WriteCloser, error)

+ func (c *Client) Room() *Room

+ func (c *Client) Send(msg Message) error

+ func (c *Client) User() *User

+ type Current struct

+ Movie Movie

+ Status Status

+ func (c *Current) Proto() *pb.Current

+ func (c *Current) SetSeek(seek, timeDiff float64) Status

+ func (c *Current) SetSeekRate(seek, rate, timeDiff float64) Status

+ func (c *Current) SetStatus(playing bool, seek, rate, timeDiff float64) Status

+ func (c *Current) UpdateSeek()

+ type ElementJsonMessage struct

+ BeforeSendFunc func(sendTo *User) error

+ func (em *ElementJsonMessage) BeforeSend(sendTo *User) error

+ func (em *ElementJsonMessage) Encode(w io.Writer) error

+ func (em *ElementJsonMessage) MessageType() int

+ func (em *ElementJsonMessage) String() string

+ type ElementMessage struct

+ BeforeSendFunc func(sendTo *User) error

+ func (em *ElementMessage) BeforeSend(sendTo *User) error

+ func (em *ElementMessage) Encode(w io.Writer) error

+ func (em *ElementMessage) MessageType() int

+ func (em *ElementMessage) String() string

+ type Hub struct

+ func (h *Hub) Broadcast(data Message, conf ...BroadcastConf) error

+ func (h *Hub) ClientNum() int64

+ func (h *Hub) Close() error

+ func (h *Hub) Closed() bool

+ func (h *Hub) RegClient(cli *Client) (*Client, error)

+ func (h *Hub) SendToUser(userID string, data Message) error

+ func (h *Hub) Start() error

+ func (h *Hub) UnRegClient(user *User) error

+ type MPDCache struct

+ MPDFile string

+ URLs []string

+ type Message interface

+ BeforeSend func(sendTo *User) error

+ Encode func(w io.Writer) error

+ MessageType func() int

+ String func() string

+ type Movie struct

+ Movie model.Movie

+ func (m *Movie) Cache() *BaseCache

+ func (m *Movie) Channel() (*rtmps.Channel, error)

+ func (m *Movie) Terminate()

+ func (m *Movie) Update(movie *model.BaseMovie) error

+ func (movie *Movie) Validate() error

+ type PingMessage struct

+ func (pm *PingMessage) BeforeSend(sendTo *User) error

+ func (pm *PingMessage) Encode(w io.Writer) error

+ func (pm *PingMessage) MessageType() int

+ func (pm *PingMessage) String() string

+ type Room struct

+ func CreateRoom(name, password string, maxCount int64, conf ...db.CreateRoomConfig) (*Room, error)

+ func GetAllRoomsInCacheWithNoNeedPassword() []*Room

+ func GetAllRoomsInCacheWithoutHidden() []*Room

+ func LoadOrInitRoom(room *model.Room) (*Room, error)

+ func LoadOrInitRoomByID(id string) (*Room, error)

+ func LoadRoomByID(id string) (*Room, error)

+ func (r *Room) AddMovie(m *model.Movie) error

+ func (r *Room) AddMovies(movies []*model.Movie) error

+ func (r *Room) AddUserPermission(userID string, permission model.RoomUserPermission) error

+ func (r *Room) Broadcast(data Message, conf ...BroadcastConf) error

+ func (r *Room) CheckVersion(version uint32) bool

+ func (r *Room) ClearMovies() error

+ func (r *Room) ClientNum() int64

+ func (r *Room) Current() *Current

+ func (r *Room) DeleteMovieByID(id string) error

+ func (r *Room) GetChannel(channelName string) (*rtmps.Channel, error)

+ func (r *Room) GetMovieByID(id string) (*Movie, error)

+ func (r *Room) GetMoviesCount() int

+ func (r *Room) GetMoviesWithPage(page, pageSize int) []*Movie

+ func (r *Room) GetRoomUserRelation(userID string) (model.RoomUserPermission, error)

+ func (r *Room) HasPermission(userID string, permission model.RoomUserPermission) bool

+ func (r *Room) LoadOrCreateRoomUserRelation(userID string) (*model.RoomUserRelation, error)

+ func (r *Room) NeedPassword() bool

+ func (r *Room) RegClient(user *User, conn *websocket.Conn) (*Client, error)

+ func (r *Room) RemoveUserPermission(userID string, permission model.RoomUserPermission) error

+ func (r *Room) SendToUser(user *User, data Message) error

+ func (r *Room) SetCurrentMovie(movie *Movie, play bool)

+ func (r *Room) SetCurrentMovieByID(id string, play bool) error

+ func (r *Room) SetPassword(password string) error

+ func (r *Room) SetRoomStatus(status model.RoomStatus) error

+ func (r *Room) SetSeekRate(seek float64, rate float64, timeDiff float64) Status

+ func (r *Room) SetSettings(settings model.RoomSettings) error

+ func (r *Room) SetStatus(playing bool, seek float64, rate float64, timeDiff float64) Status

+ func (r *Room) SetUserPermission(userID string, permission model.RoomUserPermission) error

+ func (r *Room) SetUserStatus(userID string, status model.RoomUserStatus) error

+ func (r *Room) SwapMoviePositions(id1, id2 string) error

+ func (r *Room) UnregisterClient(user *User) error

+ func (r *Room) UpdateMovie(movieId string, movie *model.BaseMovie) error

+ func (r *Room) Version() uint32

+ type RoomInfo struct

+ CreatedAt int64

+ Creator string

+ CreatorID string

+ NeedPassword bool

+ PeopleNum int64

+ RoomId string

+ RoomName string

+ Status model.RoomStatus

+ func GetRoomHeapInCacheWithoutHidden() []*RoomInfo

+ type Status struct

+ Playing bool

+ Rate float64

+ Seek float64

+ type User struct

+ func CreateOrLoadUser(username string, password string, conf ...db.CreateUserConfig) (*User, error)

+ func CreateOrLoadUserWithProvider(username, password string, p provider.OAuth2Provider, pid string, ...) (*User, error)

+ func CreateUser(username string, password string, conf ...db.CreateUserConfig) (*User, error)

+ func GetUserByProvider(p provider.OAuth2Provider, pid string) (*User, error)

+ func LoadOrInitUser(u *model.User) (*User, error)

+ func LoadOrInitUserByID(id string) (*User, error)

+ func LoadUserByUsername(username string) (*User, error)

+ func (u *User) AddMovieToRoom(room *Room, movie *model.BaseMovie) error

+ func (u *User) AddMoviesToRoom(room *Room, movies []*model.BaseMovie) error

+ func (u *User) BindProvider(p provider.OAuth2Provider, pid string) error

+ func (u *User) CheckVersion(version uint32) bool

+ func (u *User) ClearMovies(room *Room) error

+ func (u *User) CreateRoom(name, password string, conf ...db.CreateRoomConfig) (*Room, error)

+ func (u *User) DeleteMovieByID(room *Room, movieID string) error

+ func (u *User) DeleteMoviesByID(room *Room, movieIDs []string) error

+ func (u *User) DeleteRoom(room *Room) error

+ func (u *User) HasRoomPermission(room *Room, permission model.RoomUserPermission) bool

+ func (u *User) IsAdmin() bool

+ func (u *User) IsBanned() bool

+ func (u *User) IsPending() bool

+ func (u *User) IsRoot() bool

+ func (u *User) NewMovie(movie *model.BaseMovie) *model.Movie

+ func (u *User) NewMovies(movies []*model.BaseMovie) []*model.Movie

+ func (u *User) SetCurrentMovie(room *Room, movie *Movie, play bool) error

+ func (u *User) SetCurrentMovieByID(room *Room, movieID string, play bool) error

+ func (u *User) SetPassword(password string) error

+ func (u *User) SetRole(role model.Role) error

+ func (u *User) SetRoomPassword(room *Room, password string) error

+ func (u *User) SetRoomSetting(room *Room, setting model.RoomSettings) error

+ func (u *User) SetUsername(username string) error

+ func (u *User) UpdateMovie(room *Room, movieID string, movie *model.BaseMovie) error

+ func (u *User) Version() uint32