From 26378c2d2ad1f8cb3f20c7070be3be9a4f0a0ad6 Mon Sep 17 00:00:00 2001 From: nsfisis Date: Thu, 8 Aug 2024 01:28:43 +0900 Subject: refactor(backend): add Queue.Enqueue*() variants --- backend/game/hub.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) (limited to 'backend/game/hub.go') 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) } -- cgit v1.2.3-70-g09d2