server

package

v1.0.3 Latest Latest Go to latest Published: Mar 20, 2024 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/xescugc/maze-wars

Links

Open Source Insights

Documentation ¶

Index ¶

func New(ad *ActionDispatcher, s *Store, opt Options) error
type ActionDispatcher
- func NewActionDispatcher(d *flux.Dispatcher, l *slog.Logger, s *Store, ws WSConnector) *ActionDispatcher
- func (ac *ActionDispatcher) Dispatch(a *action.Action)
- func (ac *ActionDispatcher) IncomeTick(rooms *RoomsStore)
- func (ac *ActionDispatcher) SyncState(rooms *RoomsStore)
- func (ac *ActionDispatcher) SyncUsers(users *UsersStore)
- func (ac *ActionDispatcher) SyncWaitingRoom(rooms *RoomsStore)
- func (ac *ActionDispatcher) UserSignIn(un, ra string, ws *websocket.Conn)
- func (ac *ActionDispatcher) UserSignOut(un string)
- func (ac *ActionDispatcher) UserSignUp(un string)
- func (ac *ActionDispatcher) WaitRoomCountdownTick()
type Game
- func NewGame(d *flux.Dispatcher, l *slog.Logger) *Game
type Options
type PlayerConn
type Room
type RoomsState
type RoomsStore
- func NewRoomsStore(d *flux.Dispatcher, s *Store, l *slog.Logger) *RoomsStore
- func (rs *RoomsStore) FindCurrentWaitingRoom() *Room
- func (rs *RoomsStore) GetNextID(room string) int
- func (rs *RoomsStore) List() []*Room
- func (rs *RoomsStore) Reduce(state, a interface{}) interface{}
type Store
- func NewStore(d *flux.Dispatcher, l *slog.Logger) *Store
type User
type UsersState
type UsersStore
- func NewUsersStore(d *flux.Dispatcher, s *Store) *UsersStore
- func (us *UsersStore) FindByRemoteAddress(ra string) (User, bool)
- func (us *UsersStore) FindByUsername(un string) (User, bool)
- func (us *UsersStore) List() []*User
- func (us *UsersStore) Reduce(state, a interface{}) interface{}
type WS
- func NewWS() *WS
- func (ws *WS) Read(ctx context.Context, conn *websocket.Conn, d interface{}) error
- func (ws *WS) Write(ctx context.Context, conn *websocket.Conn, d interface{}) error
type WSConnector

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(ad *ActionDispatcher, s *Store, opt Options) error

Types ¶

type ActionDispatcher ¶

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

ActionDispatcher is in charge of dispatching actions to the application dispatcher

func NewActionDispatcher ¶

func NewActionDispatcher(d *flux.Dispatcher, l *slog.Logger, s *Store, ws WSConnector) *ActionDispatcher

NewActionDispatcher initializes the action dispatcher with the give dispatcher

func (*ActionDispatcher) Dispatch ¶

func (ac *ActionDispatcher) Dispatch(a *action.Action)

Dispatch is a helper to access to the internal dispatch directly with an action. This should only be used from the WS Handler to forward server actions directly

func (*ActionDispatcher) IncomeTick ¶

func (ac *ActionDispatcher) IncomeTick(rooms *RoomsStore)

func (*ActionDispatcher) SyncState ¶

func (ac *ActionDispatcher) SyncState(rooms *RoomsStore)

func (*ActionDispatcher) SyncUsers ¶

func (ac *ActionDispatcher) SyncUsers(users *UsersStore)

func (*ActionDispatcher) SyncWaitingRoom ¶

func (ac *ActionDispatcher) SyncWaitingRoom(rooms *RoomsStore)

func (*ActionDispatcher) UserSignIn ¶

func (ac *ActionDispatcher) UserSignIn(un, ra string, ws *websocket.Conn)

func (*ActionDispatcher) UserSignOut ¶

func (ac *ActionDispatcher) UserSignOut(un string)

func (*ActionDispatcher) UserSignUp ¶

func (ac *ActionDispatcher) UserSignUp(un string)

func (*ActionDispatcher) WaitRoomCountdownTick ¶

func (ac *ActionDispatcher) WaitRoomCountdownTick()

type Game ¶

type Game struct {
	*store.Store
}

func NewGame ¶

func NewGame(d *flux.Dispatcher, l *slog.Logger) *Game

type Options ¶

type Options struct {
	Port    string
	Verbose bool
}

type PlayerConn ¶

type PlayerConn struct {
	Conn       *websocket.Conn
	RemoteAddr string
}

type Room ¶

type Room struct {
	Name string

	Players map[string]PlayerConn

	Connections map[string]string

	Size      int
	Countdown int

	Game *Game
}

type RoomsState ¶

type RoomsState struct {
	Rooms              map[string]*Room
	CurrentWaitingRoom string
}

type RoomsStore ¶

type RoomsStore struct {
	*flux.ReduceStore

	Store *Store
	// contains filtered or unexported fields
}

func NewRoomsStore ¶

func NewRoomsStore(d *flux.Dispatcher, s *Store, l *slog.Logger) *RoomsStore

func (*RoomsStore) FindCurrentWaitingRoom ¶

func (rs *RoomsStore) FindCurrentWaitingRoom() *Room

func (*RoomsStore) GetNextID ¶

func (rs *RoomsStore) GetNextID(room string) int

func (*RoomsStore) List ¶

func (rs *RoomsStore) List() []*Room

func (*RoomsStore) Reduce ¶

func (rs *RoomsStore) Reduce(state, a interface{}) interface{}

type Store ¶

type Store struct {
	Rooms *RoomsStore
	Users *UsersStore
}

func NewStore ¶ added in v1.0.3

func NewStore(d *flux.Dispatcher, l *slog.Logger) *Store

type User ¶

type User struct {
	ID       string
	Username string

	Conn       *websocket.Conn
	RemoteAddr string

	CurrentRoomID string
}

type UsersState ¶

type UsersState struct {
	Users map[string]*User
}

type UsersStore ¶

type UsersStore struct {
	*flux.ReduceStore

	Store *Store
	// contains filtered or unexported fields
}

func NewUsersStore ¶

func NewUsersStore(d *flux.Dispatcher, s *Store) *UsersStore

func (*UsersStore) FindByRemoteAddress ¶

func (us *UsersStore) FindByRemoteAddress(ra string) (User, bool)

func (*UsersStore) FindByUsername ¶

func (us *UsersStore) FindByUsername(un string) (User, bool)

func (*UsersStore) List ¶

func (us *UsersStore) List() []*User

func (*UsersStore) Reduce ¶

func (us *UsersStore) Reduce(state, a interface{}) interface{}

type WS ¶ added in v1.0.3

type WS struct{}

func NewWS ¶ added in v1.0.3

func NewWS() *WS

func (*WS) Read ¶ added in v1.0.3

func (ws *WS) Read(ctx context.Context, conn *websocket.Conn, d interface{}) error

func (*WS) Write ¶ added in v1.0.3

func (ws *WS) Write(ctx context.Context, conn *websocket.Conn, d interface{}) error

type WSConnector ¶ added in v1.0.3

type WSConnector interface {
	Write(context.Context, *websocket.Conn, interface{}) error
	Read(context.Context, *websocket.Conn, interface{}) error
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
assets
mock Package mock is a generated GoMock package.	Package mock is a generated GoMock package.
templates

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL