From 296aa3f8a145a8fbc08db9f5b1d45fe6f72a38a4 Mon Sep 17 00:00:00 2001
From: nsfisis <nsfisis@gmail.com>
Date: Mon, 5 Aug 2024 03:57:21 +0900
Subject: feat: implement task queue

---
 backend/taskqueue/tasks.go | 32 ++++++++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)
 create mode 100644 backend/taskqueue/tasks.go

(limited to 'backend/taskqueue/tasks.go')

diff --git a/backend/taskqueue/tasks.go b/backend/taskqueue/tasks.go
new file mode 100644
index 0000000..2891a36
--- /dev/null
+++ b/backend/taskqueue/tasks.go
@@ -0,0 +1,32 @@
+package taskqueue
+
+import (
+	"encoding/json"
+
+	"github.com/hibiken/asynq"
+)
+
+const (
+	TaskTypeExec = "exec"
+)
+
+type Testcase struct {
+	Stdin  string
+	Stdout string
+}
+
+type TaskExecPlayload struct {
+	Code      string
+	Testcases []*Testcase
+}
+
+func NewExecTask(code string, testcases []*Testcase) (*asynq.Task, error) {
+	payload, err := json.Marshal(TaskExecPlayload{
+		Code:      code,
+		Testcases: testcases,
+	})
+	if err != nil {
+		return nil, err
+	}
+	return asynq.NewTask(TaskTypeExec, payload), nil
+}
-- 
cgit v1.2.3-70-g09d2


From 1325626397703567828a903a82fc1ed8626dbad4 Mon Sep 17 00:00:00 2001
From: nsfisis <nsfisis@gmail.com>
Date: Mon, 5 Aug 2024 04:39:51 +0900
Subject: feat(backend): enqueue exec task when players submit their code

---
 backend/game/hub.go        |  8 ++++++--
 backend/taskqueue/tasks.go | 17 +++++++----------
 2 files changed, 13 insertions(+), 12 deletions(-)

(limited to 'backend/taskqueue/tasks.go')

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)
 			}
diff --git a/backend/taskqueue/tasks.go b/backend/taskqueue/tasks.go
index 2891a36..cd67948 100644
--- a/backend/taskqueue/tasks.go
+++ b/backend/taskqueue/tasks.go
@@ -10,20 +10,17 @@ const (
 	TaskTypeExec = "exec"
 )
 
-type Testcase struct {
-	Stdin  string
-	Stdout string
-}
-
 type TaskExecPlayload struct {
-	Code      string
-	Testcases []*Testcase
+	GameID int
+	UserID int
+	Code   string
 }
 
-func NewExecTask(code string, testcases []*Testcase) (*asynq.Task, error) {
+func NewExecTask(gameID, userID int, code string) (*asynq.Task, error) {
 	payload, err := json.Marshal(TaskExecPlayload{
-		Code:      code,
-		Testcases: testcases,
+		GameID: gameID,
+		UserID: userID,
+		Code:   code,
 	})
 	if err != nil {
 		return nil, err
-- 
cgit v1.2.3-70-g09d2