diff options
| -rw-r--r-- | backend/game/hub.go | 25 |
1 files changed, 5 insertions, 20 deletions
diff --git a/backend/game/hub.go b/backend/game/hub.go index bb82170..719b216 100644 --- a/backend/game/hub.go +++ b/backend/game/hub.go @@ -7,7 +7,6 @@ import ( "time" "github.com/jackc/pgx/v5/pgtype" - "github.com/oapi-codegen/nullable" "github.com/nsfisis/iosdc-japan-2024-albatross/backend/api" "github.com/nsfisis/iosdc-japan-2024-albatross/backend/db" @@ -149,14 +148,6 @@ func (hub *gameHub) run() { // TODO: assert game state is gaming log.Printf("code: %v", message.message) code := msg.Data.Code - score := len(code) - message.client.s2cMessages <- &playerMessageS2CExecResult{ - Type: playerMessageTypeS2CExecResult, - Data: playerMessageS2CExecResultPayload{ - Score: nullable.NewNullableWithValue(score), - Status: api.GamePlayerMessageS2CExecResultPayloadStatusSuccess, - }, - } for watcher := range hub.watchers { watcher.s2cMessages <- &watcherMessageS2CCode{ Type: watcherMessageTypeS2CCode, @@ -165,15 +156,6 @@ func (hub *gameHub) run() { Code: code, }, } - watcher.s2cMessages <- &watcherMessageS2CExecResult{ - Type: watcherMessageTypeS2CExecResult, - Data: watcherMessageS2CExecResultPayload{ - PlayerID: message.client.playerID, - Score: nullable.NewNullableWithValue(score), - Stdout: "", - Stderr: "", - }, - } } case *playerMessageC2SSubmit: // TODO: assert game state is gaming @@ -188,6 +170,7 @@ func (hub *gameHub) run() { log.Printf("unexpected message type: %T", message.message) } case executionStatus := <-hub.testcaseExecution: + _ = executionStatus for player := range hub.players { player.s2cMessages <- &playerMessageS2CExecResult{ Type: playerMessageTypeS2CExecResult, @@ -197,6 +180,7 @@ func (hub *gameHub) run() { }, } } + // broadcast to watchers case <-ticker.C: if hub.game.state == gameStateStarting { if time.Now().After(*hub.game.startedAt) { @@ -220,8 +204,8 @@ func (hub *gameHub) run() { } hub.game.state = gameStateFinished hub.close() + return } - return } } } @@ -291,6 +275,7 @@ func NewGameHubs(q *db.Queries, taskQueue *taskqueue.Queue) *GameHubs { } func (hubs *GameHubs) Close() { + log.Println("closing all game hubs") for _, hub := range hubs.hubs { hub.close() } @@ -358,5 +343,5 @@ func (hubs *GameHubs) StartGame(gameID int) error { } func (hubs *GameHubs) C() chan string { - return hubs.hubs[4].testcaseExecution + return hubs.hubs[7].testcaseExecution } |