aboutsummaryrefslogtreecommitdiffhomepage
path: root/backend/game/hub.go
diff options
context:
space:
mode:
authornsfisis <nsfisis@gmail.com>2024-08-05 04:39:51 +0900
committernsfisis <nsfisis@gmail.com>2024-08-05 05:14:30 +0900
commit1325626397703567828a903a82fc1ed8626dbad4 (patch)
treed667f50894676a7bb208c03a7e96812ef0d029b9 /backend/game/hub.go
parent940fc430a5c8fa7a1454cc84586eaca2722ac757 (diff)
downloadphperkaigi-2025-albatross-1325626397703567828a903a82fc1ed8626dbad4.tar.gz
phperkaigi-2025-albatross-1325626397703567828a903a82fc1ed8626dbad4.tar.zst
phperkaigi-2025-albatross-1325626397703567828a903a82fc1ed8626dbad4.zip
feat(backend): enqueue exec task when players submit their code
Diffstat (limited to 'backend/game/hub.go')
-rw-r--r--backend/game/hub.go8
1 files changed, 6 insertions, 2 deletions
diff --git a/backend/game/hub.go b/backend/game/hub.go
index a44bce0..0b12ce9 100644
--- a/backend/game/hub.go
+++ b/backend/game/hub.go
@@ -176,8 +176,12 @@ func (hub *gameHub) run() {
case *playerMessageC2SSubmit:
// TODO: assert game state is gaming
log.Printf("submit: %v", message.message)
- // code := msg.Data.Code
- // TODO
+ code := msg.Data.Code
+ task, err := taskqueue.NewExecTask(hub.game.gameID, message.client.playerID, code)
+ if err != nil {
+ log.Fatalf("failed to create task: %v", err)
+ }
+ hub.taskQueue.Enqueue(task)
default:
log.Printf("unexpected message type: %T", message.message)
}