diff options
| author | nsfisis <nsfisis@gmail.com> | 2024-08-08 01:28:43 +0900 |
|---|---|---|
| committer | nsfisis <nsfisis@gmail.com> | 2024-08-08 04:02:37 +0900 |
| commit | 26378c2d2ad1f8cb3f20c7070be3be9a4f0a0ad6 (patch) | |
| tree | 56f9359013760b67abaaf598de5acbc62b89c9a3 /backend/game/hub.go | |
| parent | d936d587df9d96f373cf8ec35f0c6c6882083f32 (diff) | |
| download | phperkaigi-2025-albatross-26378c2d2ad1f8cb3f20c7070be3be9a4f0a0ad6.tar.gz phperkaigi-2025-albatross-26378c2d2ad1f8cb3f20c7070be3be9a4f0a0ad6.tar.zst phperkaigi-2025-albatross-26378c2d2ad1f8cb3f20c7070be3be9a4f0a0ad6.zip | |
refactor(backend): add Queue.Enqueue*() variants
Diffstat (limited to 'backend/game/hub.go')
| -rw-r--r-- | backend/game/hub.go | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/backend/game/hub.go b/backend/game/hub.go index 58eb180..b51d977 100644 --- a/backend/game/hub.go +++ b/backend/game/hub.go @@ -162,16 +162,15 @@ func (hub *gameHub) run() { log.Printf("submit: %v", message.message) code := msg.Data.Code codeSize := len(code) // TODO: exclude whitespaces. - task, err := taskqueue.NewTaskCreateSubmissionRecord( + if err := hub.taskQueue.EnqueueTaskCreateSubmissionRecord( hub.game.gameID, message.client.playerID, code, codeSize, - ) - if err != nil { - log.Fatalf("failed to create task: %v", err) + ); err != nil { + // TODO: notify failure to player + log.Fatalf("failed to enqueue task: %v", err) } - hub.taskQueue.Enqueue(task) default: log.Printf("unexpected message type: %T", message.message) } |