-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
159490c
commit d2c5c2b
Showing
13 changed files
with
273 additions
and
242 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -113,6 +113,8 @@ func (b *Board) newGame() error { | |
|
|
||
| b.lastStatus = status | ||
|
|
||
| b.drawInit(true) | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,136 @@ | ||
| package gamegrp | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "sync" | ||
| ) | ||
|
|
||
| // These types exist for documentation purposes. The API will | ||
| // will accept a string. | ||
| type ( | ||
| gameID string | ||
| playerID string | ||
| ) | ||
|
|
||
| // evts maintains the set player channels for sending messages over | ||
| // the players web socket. | ||
| var evts = newEvents() | ||
|
|
||
| // events maintains a mapping of unique id and channels so goroutines | ||
| // can register and receive events. | ||
| type events struct { | ||
| players map[playerID]chan string | ||
| games map[gameID]map[playerID]struct{} | ||
| mu sync.RWMutex | ||
| } | ||
|
|
||
| func newEvents() *events { | ||
| return &events{ | ||
| players: make(map[playerID]chan string), | ||
| games: make(map[gameID]map[playerID]struct{}), | ||
| } | ||
| } | ||
|
|
||
| func (evt *events) acquire(pID string) chan string { | ||
| evt.mu.Lock() | ||
| defer evt.mu.Unlock() | ||
|
|
||
| // Since a message will be dropped if the websocket receiver is | ||
| // not ready to receive, this arbitrary buffer should give the receiver | ||
| // enough time to not lose a message. Websocket send could take long. | ||
| const messageBuffer = 100 | ||
|
|
||
| playID := playerID(pID) | ||
|
|
||
| ch, exists := evt.players[playID] | ||
| if !exists { | ||
| ch = make(chan string, messageBuffer) | ||
| evt.players[playID] = ch | ||
| } | ||
|
|
||
| return ch | ||
| } | ||
|
|
||
| func (evt *events) release(pID string) error { | ||
| evt.mu.Lock() | ||
| defer evt.mu.Unlock() | ||
|
|
||
| playID := playerID(pID) | ||
|
|
||
| ch, exists := evt.players[playID] | ||
| if !exists { | ||
| return fmt.Errorf("player id %q does not exist", pID) | ||
| } | ||
|
|
||
| delete(evt.players, playID) | ||
| close(ch) | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func (evt *events) addPlayerToGame(gID string, pID string) error { | ||
| evt.mu.Lock() | ||
| defer evt.mu.Unlock() | ||
|
|
||
| gameID := gameID(gID) | ||
| playID := playerID(pID) | ||
|
|
||
| if _, exists := evt.players[playID]; !exists { | ||
| return fmt.Errorf("player id %q does not exist", pID) | ||
| } | ||
|
|
||
| playerMap, exists := evt.games[gameID] | ||
| if !exists { | ||
| playerMap = make(map[playerID]struct{}) | ||
| evt.games[gameID] = playerMap | ||
| } | ||
|
|
||
| playerMap[playID] = struct{}{} | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func (evt *events) removePlayersFromGame(gID string) error { | ||
| evt.mu.Lock() | ||
| defer evt.mu.Unlock() | ||
|
|
||
| gameID := gameID(gID) | ||
|
|
||
| playerMap, exists := evt.games[gameID] | ||
| if !exists { | ||
| return nil | ||
| } | ||
|
|
||
| for playID := range playerMap { | ||
| delete(playerMap, playID) | ||
| } | ||
| delete(evt.games, gameID) | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // send signals a message to every registered channel for the specified | ||
| // game. Send will not block waiting for a receiver on any given channel. | ||
| func (evt *events) send(gID string, s string) { | ||
| evt.mu.RLock() | ||
| defer evt.mu.RUnlock() | ||
|
|
||
| gameID := gameID(gID) | ||
|
|
||
| playerMap, exists := evt.games[gameID] | ||
| if !exists { | ||
| return | ||
| } | ||
|
|
||
| for playID := range playerMap { | ||
| ch, exists := evt.players[playID] | ||
| if !exists { | ||
| continue | ||
| } | ||
|
|
||
| select { | ||
| case ch <- s: | ||
| default: | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.