aboutsummaryrefslogtreecommitdiffhomepage
path: root/backend/game/hub.go
diff options
context:
space:
mode:
Diffstat (limited to 'backend/game/hub.go')
-rw-r--r--backend/game/hub.go9
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)
}