Documentation
¶
Overview ¶
Package rooms is a generated GoMock package.
Index ¶
- Variables
- func InitEventsSocket(conn *websocket.Conn, roomsServer *RoomsServer)
- func NewRoomsServer(router *mux.Router, roomsService RoomServicer, userService UserServicer, ...) http.Handler
- func ToSkipCheerIfSeng(cheer *cheers.Cheer) bool
- type AddCheerRequest
- type Callback
- type CheerAddedMessage
- type CheerImage
- type CheerItem
- type CheerUser
- type EventCallbacks
- type EventType
- type EventsCallbacksManager
- type JoinRoomRequest
- type LeaderboardResponseUser
- type MockRoomServicer
- func (m *MockRoomServicer) AddCheer(room *Room, cheer *cheers.Cheer, user User) error
- func (m *MockRoomServicer) AddCheerAddedListener(room *Room, user User, clientId string, callback Callback) error
- func (m *MockRoomServicer) AddCheerImage(ctx context.Context, roomId string, user User, url string) error
- func (m *MockRoomServicer) AllowAllCheers(roomId string)
- func (m *MockRoomServicer) DeleteAllUsers(id string)
- func (m *MockRoomServicer) DisallowSeng(roomId string)
- func (m *MockRoomServicer) EXPECT() *MockRoomServicerMockRecorder
- func (m *MockRoomServicer) GetCheerImages(ctx context.Context, roomId string, user User) ([]*CheerImage, error)
- func (m *MockRoomServicer) GetLeaderboard(roomId string) []*UserInfo
- func (m *MockRoomServicer) GetOrCreateRoom(name string) *Room
- func (m *MockRoomServicer) GetRoom(name string) *Room
- func (m *MockRoomServicer) GetUsers(roomId string) []*UserInfo
- func (m *MockRoomServicer) RemoveOutdatedCheers()
- func (m *MockRoomServicer) RemoveUserFromRoom(userId, roomId string)
- func (m *MockRoomServicer) ResetPoints(roomId string)
- func (m *MockRoomServicer) StopListeningCheers(room *Room, clientId string)
- func (m *MockRoomServicer) UploadCheerImage(ctx context.Context, roomId string, user User, data []byte) (*CheerImage, error)
- func (m *MockRoomServicer) UserJoinsRoom(ctx context.Context, room *Room, user User) error
- type MockRoomServicerMockRecorder
- func (mr *MockRoomServicerMockRecorder) AddCheer(room, cheer, user interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) AddCheerAddedListener(room, user, clientId, callback interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) AddCheerImage(ctx, roomId, user, url interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) AllowAllCheers(roomId interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) DeleteAllUsers(id interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) DisallowSeng(roomId interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) GetCheerImages(ctx, roomId, user interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) GetLeaderboard(roomId interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) GetOrCreateRoom(name interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) GetRoom(name interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) GetUsers(roomId interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) RemoveOutdatedCheers() *gomock.Call
- func (mr *MockRoomServicerMockRecorder) RemoveUserFromRoom(userId, roomId interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) ResetPoints(roomId interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) StopListeningCheers(room, clientId interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) UploadCheerImage(ctx, roomId, user, data interface{}) *gomock.Call
- func (mr *MockRoomServicerMockRecorder) UserJoinsRoom(ctx, room, user interface{}) *gomock.Call
- type ResponseUser
- type Room
- func (room *Room) AddCheer(cheer *cheers.Cheer) error
- func (room *Room) AddCheerImage(user User, cheerImage *CheerImage) error
- func (room *Room) AddUserIfNotPresent(user User) (bool, error)
- func (room *Room) ClearSkipCheerRule()
- func (room *Room) DeleteAllUsers()
- func (room *Room) GetCheerImages(user User) ([]*CheerImage, error)
- func (room *Room) GetUserInfo(user User) (*UserInfo, error)
- func (room *Room) GetUsers() []*UserInfo
- func (room *Room) HasSkipCheerRule() bool
- func (room *Room) Intensity(filterCheer func(cheer cheers.Cheer) bool) float32
- func (room *Room) ResetPoints()
- func (room *Room) SkipAddCheerIfSeng()
- type RoomConnectedMessage
- type RoomEvents
- type RoomIntensityMessage
- type RoomServicer
- type RoomsServer
- type RoomsServerOpts
- type User
- type UserInfo
- type UserInfoHeap
- type UserServicer
Constants ¶
This section is empty.
Variables ¶
var ( EVENT_CHEER_ADDED = EventType{ "EVENT_CHEER_ADDED", } EVENT_ROOM_CONNECTED = EventType{ "EVENT_ROOM_CONNECTED", } EVENT_ROOM_INTENSITY = EventType{ "EVENT_INTENSITY", } )
var (
ERROR_NO_USER_INFO = errors.New("ERROR_NO_USER_INFO")
)
var (
ERROR_RETRIEVING_USER = errors.New("ERROR_RETRIEVING_USER")
)
var (
ERROR_ROOM_NOT_FOUND = errors.New("ERROR_ROOM_NOT_FOUND")
)
Functions ¶
func InitEventsSocket ¶
func InitEventsSocket(conn *websocket.Conn, roomsServer *RoomsServer)
func NewRoomsServer ¶
func NewRoomsServer(router *mux.Router, roomsService RoomServicer, userService UserServicer, opts RoomsServerOpts) http.Handler
func ToSkipCheerIfSeng ¶
Types ¶
type AddCheerRequest ¶
type AddCheerRequest struct {
Url string `json:"url"`
}
type CheerAddedMessage ¶
type CheerAddedMessage struct { Cheer cheers.Cheer `json:"cheer"` EventName string `json:"event_name"` }
func NewCheerAddedMessage ¶
func NewCheerAddedMessage(cheer cheers.Cheer) (*CheerAddedMessage, error)
type CheerImage ¶
type EventCallbacks ¶
type EventCallbacks struct {
// contains filtered or unexported fields
}
type EventsCallbacksManager ¶
type EventsCallbacksManager struct {
// contains filtered or unexported fields
}
type JoinRoomRequest ¶
type LeaderboardResponseUser ¶
type MockRoomServicer ¶
type MockRoomServicer struct {
// contains filtered or unexported fields
}
MockRoomServicer is a mock of RoomServicer interface.
func NewMockRoomServicer ¶
func NewMockRoomServicer(ctrl *gomock.Controller) *MockRoomServicer
NewMockRoomServicer creates a new mock instance.
func (*MockRoomServicer) AddCheerAddedListener ¶
func (m *MockRoomServicer) AddCheerAddedListener(room *Room, user User, clientId string, callback Callback) error
AddCheerAddedListener mocks base method.
func (*MockRoomServicer) AddCheerImage ¶
func (m *MockRoomServicer) AddCheerImage(ctx context.Context, roomId string, user User, url string) error
AddCheerImage mocks base method.
func (*MockRoomServicer) AllowAllCheers ¶
func (m *MockRoomServicer) AllowAllCheers(roomId string)
AllowAllCheers mocks base method.
func (*MockRoomServicer) DeleteAllUsers ¶
func (m *MockRoomServicer) DeleteAllUsers(id string)
DeleteAllUsers mocks base method.
func (*MockRoomServicer) DisallowSeng ¶
func (m *MockRoomServicer) DisallowSeng(roomId string)
DisallowSeng mocks base method.
func (*MockRoomServicer) EXPECT ¶
func (m *MockRoomServicer) EXPECT() *MockRoomServicerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRoomServicer) GetCheerImages ¶
func (m *MockRoomServicer) GetCheerImages(ctx context.Context, roomId string, user User) ([]*CheerImage, error)
GetCheerImages mocks base method.
func (*MockRoomServicer) GetLeaderboard ¶
func (m *MockRoomServicer) GetLeaderboard(roomId string) []*UserInfo
GetLeaderboard mocks base method.
func (*MockRoomServicer) GetOrCreateRoom ¶
func (m *MockRoomServicer) GetOrCreateRoom(name string) *Room
GetOrCreateRoom mocks base method.
func (*MockRoomServicer) GetRoom ¶
func (m *MockRoomServicer) GetRoom(name string) *Room
GetRoom mocks base method.
func (*MockRoomServicer) GetUsers ¶
func (m *MockRoomServicer) GetUsers(roomId string) []*UserInfo
GetUsers mocks base method.
func (*MockRoomServicer) RemoveOutdatedCheers ¶
func (m *MockRoomServicer) RemoveOutdatedCheers()
RemoveOutdatedCheers mocks base method.
func (*MockRoomServicer) RemoveUserFromRoom ¶
func (m *MockRoomServicer) RemoveUserFromRoom(userId, roomId string)
RemoveUserFromRoom mocks base method.
func (*MockRoomServicer) ResetPoints ¶
func (m *MockRoomServicer) ResetPoints(roomId string)
ResetPoints mocks base method.
func (*MockRoomServicer) StopListeningCheers ¶
func (m *MockRoomServicer) StopListeningCheers(room *Room, clientId string)
StopListeningCheers mocks base method.
func (*MockRoomServicer) UploadCheerImage ¶
func (m *MockRoomServicer) UploadCheerImage(ctx context.Context, roomId string, user User, data []byte) (*CheerImage, error)
UploadCheerImage mocks base method.
func (*MockRoomServicer) UserJoinsRoom ¶
UserJoinsRoom mocks base method.
type MockRoomServicerMockRecorder ¶
type MockRoomServicerMockRecorder struct {
// contains filtered or unexported fields
}
MockRoomServicerMockRecorder is the mock recorder for MockRoomServicer.
func (*MockRoomServicerMockRecorder) AddCheer ¶
func (mr *MockRoomServicerMockRecorder) AddCheer(room, cheer, user interface{}) *gomock.Call
AddCheer indicates an expected call of AddCheer.
func (*MockRoomServicerMockRecorder) AddCheerAddedListener ¶
func (mr *MockRoomServicerMockRecorder) AddCheerAddedListener(room, user, clientId, callback interface{}) *gomock.Call
AddCheerAddedListener indicates an expected call of AddCheerAddedListener.
func (*MockRoomServicerMockRecorder) AddCheerImage ¶
func (mr *MockRoomServicerMockRecorder) AddCheerImage(ctx, roomId, user, url interface{}) *gomock.Call
AddCheerImage indicates an expected call of AddCheerImage.
func (*MockRoomServicerMockRecorder) AllowAllCheers ¶
func (mr *MockRoomServicerMockRecorder) AllowAllCheers(roomId interface{}) *gomock.Call
AllowAllCheers indicates an expected call of AllowAllCheers.
func (*MockRoomServicerMockRecorder) DeleteAllUsers ¶
func (mr *MockRoomServicerMockRecorder) DeleteAllUsers(id interface{}) *gomock.Call
DeleteAllUsers indicates an expected call of DeleteAllUsers.
func (*MockRoomServicerMockRecorder) DisallowSeng ¶
func (mr *MockRoomServicerMockRecorder) DisallowSeng(roomId interface{}) *gomock.Call
DisallowSeng indicates an expected call of DisallowSeng.
func (*MockRoomServicerMockRecorder) GetCheerImages ¶
func (mr *MockRoomServicerMockRecorder) GetCheerImages(ctx, roomId, user interface{}) *gomock.Call
GetCheerImages indicates an expected call of GetCheerImages.
func (*MockRoomServicerMockRecorder) GetLeaderboard ¶
func (mr *MockRoomServicerMockRecorder) GetLeaderboard(roomId interface{}) *gomock.Call
GetLeaderboard indicates an expected call of GetLeaderboard.
func (*MockRoomServicerMockRecorder) GetOrCreateRoom ¶
func (mr *MockRoomServicerMockRecorder) GetOrCreateRoom(name interface{}) *gomock.Call
GetOrCreateRoom indicates an expected call of GetOrCreateRoom.
func (*MockRoomServicerMockRecorder) GetRoom ¶
func (mr *MockRoomServicerMockRecorder) GetRoom(name interface{}) *gomock.Call
GetRoom indicates an expected call of GetRoom.
func (*MockRoomServicerMockRecorder) GetUsers ¶
func (mr *MockRoomServicerMockRecorder) GetUsers(roomId interface{}) *gomock.Call
GetUsers indicates an expected call of GetUsers.
func (*MockRoomServicerMockRecorder) RemoveOutdatedCheers ¶
func (mr *MockRoomServicerMockRecorder) RemoveOutdatedCheers() *gomock.Call
RemoveOutdatedCheers indicates an expected call of RemoveOutdatedCheers.
func (*MockRoomServicerMockRecorder) RemoveUserFromRoom ¶
func (mr *MockRoomServicerMockRecorder) RemoveUserFromRoom(userId, roomId interface{}) *gomock.Call
RemoveUserFromRoom indicates an expected call of RemoveUserFromRoom.
func (*MockRoomServicerMockRecorder) ResetPoints ¶
func (mr *MockRoomServicerMockRecorder) ResetPoints(roomId interface{}) *gomock.Call
ResetPoints indicates an expected call of ResetPoints.
func (*MockRoomServicerMockRecorder) StopListeningCheers ¶
func (mr *MockRoomServicerMockRecorder) StopListeningCheers(room, clientId interface{}) *gomock.Call
StopListeningCheers indicates an expected call of StopListeningCheers.
func (*MockRoomServicerMockRecorder) UploadCheerImage ¶
func (mr *MockRoomServicerMockRecorder) UploadCheerImage(ctx, roomId, user, data interface{}) *gomock.Call
UploadCheerImage indicates an expected call of UploadCheerImage.
func (*MockRoomServicerMockRecorder) UserJoinsRoom ¶
func (mr *MockRoomServicerMockRecorder) UserJoinsRoom(ctx, room, user interface{}) *gomock.Call
UserJoinsRoom indicates an expected call of UserJoinsRoom.
type ResponseUser ¶
type Room ¶
type Room struct { Cheers []*cheers.Cheer Name string Users map[string]*UserInfo // contains filtered or unexported fields }
func (*Room) AddCheerImage ¶
func (room *Room) AddCheerImage(user User, cheerImage *CheerImage) error
func (*Room) ClearSkipCheerRule ¶
func (room *Room) ClearSkipCheerRule()
func (*Room) DeleteAllUsers ¶
func (room *Room) DeleteAllUsers()
func (*Room) GetCheerImages ¶
func (room *Room) GetCheerImages(user User) ([]*CheerImage, error)
func (*Room) HasSkipCheerRule ¶
func (*Room) ResetPoints ¶
func (room *Room) ResetPoints()
func (*Room) SkipAddCheerIfSeng ¶
func (room *Room) SkipAddCheerIfSeng()
type RoomConnectedMessage ¶
type RoomConnectedMessage struct { EventName string `json:"event_name"` UserId string `json:"user_id"` RoomName string `json:"room_name"` }
func NewRoomConnectedMessage ¶
func NewRoomConnectedMessage(room *Room, user User) (*RoomConnectedMessage, error)
type RoomEvents ¶
type RoomEvents struct {
// contains filtered or unexported fields
}
func NewRoomEvents ¶
func NewRoomEvents() *RoomEvents
func (*RoomEvents) PublishCheerAdded ¶
func (roomEvents *RoomEvents) PublishCheerAdded(room *Room, cheer cheers.Cheer)
func (*RoomEvents) SubscribeCheerAdded ¶
func (roomEvents *RoomEvents) SubscribeCheerAdded(room *Room, clientId string, cb Callback)
func (*RoomEvents) UnsubscribeCheerAdded ¶
func (roomEvents *RoomEvents) UnsubscribeCheerAdded(room *Room, clientId string)
type RoomIntensityMessage ¶
type RoomIntensityMessage struct { Intensity float32 `json:"intensity"` EventName string `json:"event_name"` }
func NewRoomIntensityMessage ¶
func NewRoomIntensityMessage(intensity float32) (*RoomIntensityMessage, error)
type RoomServicer ¶
type RoomServicer interface { AddCheerImage(ctx context.Context, roomId string, user User, url string) error UploadCheerImage(ctx context.Context, roomId string, user User, data []byte) (*CheerImage, error) GetCheerImages(ctx context.Context, roomId string, user User) ([]*CheerImage, error) UserJoinsRoom(ctx context.Context, room *Room, user User) error AddCheer(room *Room, cheer *cheers.Cheer, user User) error AddCheerAddedListener(room *Room, user User, clientId string, callback Callback) error StopListeningCheers(room *Room, clientId string) GetOrCreateRoom(name string) *Room GetRoom(name string) *Room GetUsers(roomId string) []*UserInfo RemoveUserFromRoom(userId string, roomId string) GetLeaderboard(roomId string) []*UserInfo //todo remove this issue-1.md RemoveOutdatedCheers() ResetPoints(roomId string) DeleteAllUsers(id string) //todo remove hardcode AllowAllCheers(roomId string) DisallowSeng(roomId string) }
mockgen -source=service.go -destination service_mockgen.go -package rooms
func NewRoomsService ¶
func NewRoomsService(storage objectstorage.Storage) RoomServicer
type RoomsServer ¶
type RoomsServer struct { http.Handler RoomServicer UserService UserServicer RoomsServerOpts }
type RoomsServerOpts ¶
type UserInfo ¶
type UserInfo struct { CheerImages []*CheerImage `json:"cheer_images"` User User `json:"user"` Points int `json:"points"` }
func NewUserAndInfo ¶
type UserInfoHeap ¶
type UserInfoHeap []*UserInfo
func (UserInfoHeap) Len ¶
func (h UserInfoHeap) Len() int
func (UserInfoHeap) Less ¶
func (h UserInfoHeap) Less(i, j int) bool
func (*UserInfoHeap) Pop ¶
func (h *UserInfoHeap) Pop() interface{}
func (*UserInfoHeap) Push ¶
func (h *UserInfoHeap) Push(x interface{})
func (UserInfoHeap) Swap ¶
func (h UserInfoHeap) Swap(i, j int)