Versions in this module Expand all Collapse all v0 v0.1.2 Oct 31, 2024 v0.1.1 Oct 31, 2024 v0.1.0 Oct 31, 2024 Changes in this version + const AUTOEXEC_KEY + const CONSENT_EXPIRATION + const CREATE_SERVER_COOLDOWN + const DEMO_KEY + const DEMO_TTL + const DuelPhaseBattle + const DuelPhaseDone + const DuelPhaseOvertime + const DuelPhaseWarmup + const INITIAL_SCRIPT + const RUN_WAIT_TIMEOUT + const TUNNEL_MODE + const UserStatusConnected + const UserStatusConnecting + const UserStatusDisconnected + var DEMO_PATH_REGEX = regexp.MustCompile(`^/api/demo/([\w-]+)$`) + var PURGATORY []byte + func Compress(data []byte) ([]byte, error) + func EncodeDemo(startTime time.Time, messages []RecordedPacket) ([]byte, error) + func EncodeSession(startTime time.Time, messages []RecordedPacket) ([]byte, error) + func RecordSession(ctx context.Context, redis *redis.Client, shouldSave bool, user *User) error + func WriteFile(path string, data []byte) error + type Cluster struct + Users *UserOrchestrator + func NewCluster(ctx context.Context, serverManager *servers.ServerManager, ...) *Cluster + func (c *Cluster) AnnounceInServer(ctx context.Context, server *servers.GameServer, message string) + func (c *Cluster) DoAuthChallenge(ctx context.Context, user *User, id string) (*state.User, error) + func (c *Cluster) GetDemo(ctx context.Context, id string) ([]byte, error) + func (c *Cluster) GoHome(ctx context.Context, user *User) error + func (c *Cluster) HandleDesktopLogin(ctx context.Context, user *User) error + func (c *Cluster) HandleTeleport(ctx context.Context, user *User, source int32) + func (c *Cluster) NotifyNameChange(ctx context.Context, user *User, name string) + func (c *Cluster) PollFromMessages(ctx context.Context, user *User) + func (c *Cluster) PollToMessages(ctx context.Context, user *User) + func (c *Cluster) PollUser(ctx context.Context, user *User) + func (c *Cluster) SendMap(ctx context.Context, user *User, name string) error + func (c *Cluster) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (s *Cluster) HandleCommand(ctx context.Context, user *User, command string) + func (server *Cluster) CreateGame(ctx context.Context, params *CreateParams, user *User) error + func (server *Cluster) ForwardGlobalChat(ctx context.Context, sender *User, message string) + func (server *Cluster) GetClientInfo() []*servers.ClientExtInfo + func (server *Cluster) GetServerInfo() *servers.ServerInfo + func (server *Cluster) GetTeamInfo() *servers.TeamInfo + func (server *Cluster) GetUptime() int + func (server *Cluster) GivePrivateMatchHelp(ctx context.Context, user *User, gameServer *servers.GameServer) + func (server *Cluster) GreetClient(ctx context.Context, user *User) + func (server *Cluster) NotifyClientChange(ctx context.Context, user *User, joined bool) + func (server *Cluster) PollDuels(ctx context.Context) + func (server *Cluster) PollServers(ctx context.Context) + func (server *Cluster) PollUsers(ctx context.Context, newConnections chan ingress.Connection) + func (server *Cluster) Shutdown() + func (server *Cluster) StartServers(ctx context.Context) + type ConnectionEvent struct + Server *servers.GameServer + type CreateParams struct + Map opt.Option[string] + Mode opt.Option[int] + Preset opt.Option[string] + type Duel struct + A *User + B *User + Finished chan DuelDone + Manager *servers.ServerManager + Mutex sync.Mutex + Phase DuelPhase + Type config.DuelType + func (d *Duel) Cleanup() + func (d *Duel) Logger() zerolog.Logger + func (d *Duel) MonitorClient(ctx context.Context, user *User, oldServer *servers.GameServer, ...) + func (d *Duel) PollDeaths(ctx context.Context) + func (d *Duel) Respawn(ctx context.Context, user *User) + func (d *Duel) Run(ctx context.Context) + type DuelDone struct + Duel *Duel + Result DuelResult + type DuelPhase byte + type DuelQueue struct + Type string + User *User + type DuelResult struct + Disconnected bool + IsDraw bool + Loser *User + Type string + Winner *User + type ELO struct + Draws uint + Losses uint + Rating uint + Wins uint + func LoadELOState(ctx context.Context, db *gorm.DB, user *state.User, matchType string) (*ELO, error) + func NewELO() *ELO + func (e *ELO) SaveState(ctx context.Context, db *gorm.DB, user *state.User, matchType string) error + type ELOState struct + Mutex sync.Mutex + Ratings map[string]*ELO + func NewELOState(duels []config.DuelType) *ELOState + type Matchmaker struct + func NewMatchmaker(manager *servers.ServerManager, duelTypes []config.DuelType) *Matchmaker + func (m *Matchmaker) Dequeue(user *User) + func (m *Matchmaker) FindDuelType(name string) opt.Option[config.DuelType] + func (m *Matchmaker) NotifyProgress(queued *QueuedClient) + func (m *Matchmaker) Poll(ctx context.Context) + func (m *Matchmaker) Queue(user *User, typeName string) error + func (m *Matchmaker) ReceiveQueues() <-chan DuelQueue + func (m *Matchmaker) ReceiveResults() <-chan DuelResult + type QueuedClient struct + Cancel context.CancelFunc + Context context.Context + JoinTime time.Time + Type string + User *User + type RecordedPacket struct + From bool + Packet io.RawPacket + Time time.Time + func NewPacket(from bool, packet io.RawPacket) RecordedPacket + type TrackedPacket struct + Error chan error + Packet P.Packet + type User struct + Auth *state.User + Authentication chan *state.User + Connection ingress.Connection + ELO *ELOState + From *P.MessageProxy + Id ingress.ClientID + Mutex deadlock.RWMutex + Name string + RawFrom *utils.Topic[io.RawPacket] + RawTo *utils.Topic[io.RawPacket] + Server *servers.GameServer + ServerClient *server.Client + ServerSession utils.Session + Space *verse.SpaceInstance + Status UserStatus + To *P.MessageProxy + func (c *User) DelayMessages() + func (c *User) GetStatus() UserStatus + func (c *User) ReceiveAuthentication() <-chan *state.User + func (c *User) ReceiveConnections() <-chan ConnectionEvent + func (c *User) ReceiveToMessages() <-chan TrackedPacket + func (c *User) RestoreMessages() + func (c *User) Send(messages ...P.Message) <-chan error + func (c *User) SendChannel(channel uint8, messages ...P.Message) <-chan error + func (c *User) SendChannelSync(channel uint8, messages ...P.Message) error + func (c *User) SendSync(messages ...P.Message) error + func (u *User) AnnounceELO() + func (u *User) Connect(server *servers.GameServer) (<-chan bool, error) + func (u *User) ConnectToServer(server *servers.GameServer, target string, shouldCopy bool, isSpace bool) (<-chan bool, error) + func (u *User) ConnectToSpace(server *servers.GameServer, id string) (<-chan bool, error) + func (u *User) DisconnectFromServer() error + func (u *User) GetAuth() *state.User + func (u *User) GetAutoexecKey() string + func (u *User) GetClientNum() int + func (u *User) GetFormattedName() string + func (u *User) GetFormattedReference() string + func (u *User) GetHomeSpace(ctx context.Context) (*state.Space, error) + func (u *User) GetID() string + func (u *User) GetName() string + func (u *User) GetServer() *servers.GameServer + func (u *User) GetServerInfo() P.ServerInfo + func (u *User) GetServerName() string + func (u *User) GetSessionID() string + func (u *User) GetSpace() *verse.SpaceInstance + func (u *User) GetSpaceEntity(ctx context.Context) (*state.Space, error) + func (u *User) HandleAuthentication(ctx context.Context, auth *state.User) error + func (u *User) HasCubeScript() bool + func (u *User) IsAtHome(ctx context.Context) (bool, error) + func (u *User) IsInSpace() bool + func (u *User) IsLoggedIn() bool + func (u *User) IsOwner(ctx context.Context) (bool, error) + func (u *User) LogVisit(ctx context.Context) error + func (u *User) Logger() zerolog.Logger + func (u *User) Message(message string) + func (u *User) RawMessage(message string) + func (u *User) Reference() string + func (u *User) Response(ctx context.Context, code P.MessageCode, messages ...P.Message) (P.Message, error) + func (u *User) ResponseTimeout(ctx context.Context, timeout time.Duration, code P.MessageCode, ...) (P.Message, error) + func (u *User) RunCubeScript(ctx context.Context, code string) error + func (u *User) ServerSessionContext() context.Context + func (u *User) SetName(ctx context.Context, name string) error + type UserOrchestrator struct + Duels []config.DuelType + Mutex deadlock.RWMutex + Servers map[*servers.GameServer][]*User + Users []*User + func NewUserOrchestrator(duels []config.DuelType) *UserOrchestrator + func (u *UserOrchestrator) AddUser(ctx context.Context, connection ingress.Connection) (*User, error) + func (u *UserOrchestrator) FindUser(id ingress.ClientID) *User + func (u *UserOrchestrator) PollUser(ctx context.Context, user *User) + func (u *UserOrchestrator) RemoveUser(user *User) + type UserStatus uint8
Go to main page