rooms

package
v0.0.0-...-3943c12 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 22, 2022 License: GPL-3.0 Imports: 25 Imported by: 0

Documentation

Overview

Package rooms is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	EVENT_CHEER_ADDED = EventType{
		"EVENT_CHEER_ADDED",
	}
	EVENT_ROOM_CONNECTED = EventType{
		"EVENT_ROOM_CONNECTED",
	}
	EVENT_ROOM_INTENSITY = EventType{
		"EVENT_INTENSITY",
	}
)
View Source 
var (
	ERROR_NO_USER_INFO = errors.New("ERROR_NO_USER_INFO")
)
View Source 
var (
	ERROR_RETRIEVING_USER = errors.New("ERROR_RETRIEVING_USER")
)
View Source 
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 

func ToSkipCheerIfSeng(cheer *cheers.Cheer) bool

Types

type AddCheerRequest 

type AddCheerRequest struct {
	Url string `json:"url"`
}

type Callback 

type Callback func(args ...interface{})

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 CheerImage struct {
	Url      string `json:"url"`
	ObjectId string `json:"object_id"`
}

type CheerItem 

type CheerItem struct {
	*cheers.Cheer
}

func (CheerItem) GetTime 

func (item CheerItem) GetTime() time.Time

type CheerUser 

type CheerUser struct {
	*cheers.Cheer
}

func (CheerUser) GetId 

func (c CheerUser) GetId() string

type EventCallbacks 

type EventCallbacks struct {
	// contains filtered or unexported fields
}

type EventType 

type EventType struct {
	// contains filtered or unexported fields
}

func (*EventType) GetName 

func (eventType *EventType) GetName() string

type EventsCallbacksManager 

type EventsCallbacksManager struct {
	// contains filtered or unexported fields
}

type JoinRoomRequest 

type JoinRoomRequest struct {
	UserId   string `json:"user_id"`
	RoomName string `json:"room_name"`
}

type LeaderboardResponseUser 

type LeaderboardResponseUser struct {
	UserId string `json:"user_id"`
	Points int    `json:"points"`
}

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) AddCheer 

func (m *MockRoomServicer) AddCheer(room *Room, cheer *cheers.Cheer, user User) error

AddCheer mocks base method.

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 

func (m *MockRoomServicer) UserJoinsRoom(ctx context.Context, room *Room, user User) error

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 ResponseUser struct {
	UserId string `json:"user_id"`
	Points int    `json:"points"`
}

type Room 

type Room struct {
	Cheers []*cheers.Cheer
	Name   string

	Users map[string]*UserInfo
	// contains filtered or unexported fields
}

func NewRoom 

func NewRoom(name string) *Room

func (*Room) AddCheer 

func (room *Room) AddCheer(cheer *cheers.Cheer) error

func (*Room) AddCheerImage 

func (room *Room) AddCheerImage(user User, cheerImage *CheerImage) error

func (*Room) AddUserIfNotPresent 

func (room *Room) AddUserIfNotPresent(user User) (bool, 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) GetUserInfo 

func (room *Room) GetUserInfo(user User) (*UserInfo, error)

func (*Room) GetUsers 

func (room *Room) GetUsers() []*UserInfo

func (*Room) HasSkipCheerRule 

func (room *Room) HasSkipCheerRule() bool

func (*Room) Intensity 

func (room *Room) Intensity(filterCheer func(cheer cheers.Cheer) bool) float32

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 RoomsServerOpts struct {
	AllowOriginFunc func(r *http.Request) bool
}

type User 

type User interface {
	GetId() string
}

type UserInfo 

type UserInfo struct {
	CheerImages []*CheerImage `json:"cheer_images"`
	User        User          `json:"user"`
	Points      int           `json:"points"`
}

func NewUserAndInfo 

func NewUserAndInfo(user User) *UserInfo

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)

type UserServicer 

type UserServicer interface {
	GetUser(string) (User, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.